Skip to content
This repository was archived by the owner on Dec 14, 2022. It is now read-only.

Commit f79d868

Browse files
authored
[484] delete commented code (#490)
1 parent 5410763 commit f79d868

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/formats/atomic/AtomicRowDataDeserializationSchema.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -88,14 +88,6 @@ public boolean isEndOfStream(RowData nextElement) {
8888

8989
@Override
9090
public TypeInformation<RowData> getProducedType() {
91-
/* DataType dataType = TypeConversions.fromClassToDataType(clazz).
92-
orElseThrow(() -> new IllegalStateException(clazz.getCanonicalName() + "cant cast to flink dataType"));
93-
RowType.RowField rowField = new RowType.RowField("value", dataType.getLogicalType());
94-
List<RowType.RowField> fields = Collections.singletonList(rowField);
95-
return (TypeInformation<Row>) TypeConversions.fromDataTypeToLegacyInfo(TypeConversions.fromLogicalToDataType(new RowType(fields)));*/
96-
97-
// return (TypeInformation<Row>) TypeConversions.fromDataTypeToLegacyInfo(dataType);
98-
9991
List<DataTypes.Field> mainSchema = new ArrayList<>();
10092
DataType dataType =
10193
TypeConversions.fromClassToDataType(clazz)

0 commit comments

Comments
 (0)