fix kafka row to table error

Author: todd5167

kafka/kafka-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java

@@ -277,4 +277,9 @@ private Object convert(JsonNode node, TypeInformation<?> info) {
             }
         }
     }
+
+    @Override
+    public TypeInformation<Row> getProducedType() {
+        return typeInfo;
+    }
 }

kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java

@@ -281,6 +281,9 @@ private Object convert(JsonNode node, TypeInformation<?> info) {
         }
     }
 
-
+    @Override
+    public TypeInformation<Row> getProducedType() {
+        return typeInfo;
+    }
 
 }

kafka10/kafka10-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java

@@ -53,7 +53,9 @@
 import java.util.Map;
 import java.util.Set;
 
-import static com.dtstack.flink.sql.metric.MetricConstant.*;
+import static com.dtstack.flink.sql.metric.MetricConstant.DT_PARTITION_GROUP;
+import static com.dtstack.flink.sql.metric.MetricConstant.DT_TOPIC_GROUP;
+import static com.dtstack.flink.sql.metric.MetricConstant.DT_TOPIC_PARTITION_LAG_GAUGE;
 
 /**
  * json string parsing custom
@@ -283,4 +285,10 @@ private Object convert(JsonNode node, TypeInformation<?> info) {
             }
         }
     }
+
+    @Override
+    public TypeInformation<Row> getProducedType() {
+        return typeInfo;
+    }
+
 }