Yangxu1990

Results 3 comments of Yangxu1990

嵌套json 解析后输出的数据为null

sourcedatatype ='json' 问题，改为sourcedatatype ='dt_nest' dt_nest支持解析2级嵌套和数组

最新版本读取kafka数据sink到ES，如果kafka数据是嵌套json，字段值在es中为null

sourcedatatype ='dt_nest' 试下

1.10版本 无法使用WATERMARK ，报空指针。

2020-06-19 14:19:21,873 ERROR com.dtstack.flink.sql.watermarker.CustomerWaterMarkerForLong - java.lang.NullPointerException at com.dtstack.flink.sql.watermarker.AbstractCustomerWaterMarker.getExtractTimestamp(AbstractCustomerWaterMarker.java:105) at com.dtstack.flink.sql.watermarker.CustomerWaterMarkerForLong.extractTimestamp(CustomerWaterMarkerForLong.java:53) at com.dtstack.flink.sql.watermarker.CustomerWaterMarkerForLong.extractTimestamp(CustomerWaterMarkerForLong.java:38) at org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor.extractTimestamp(BoundedOutOfOrdernessTimestampExtractor.java:81) at org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator.processElement(TimestampsAndPeriodicWatermarksOperator.java:64) at org.apache.flink.streaming.runtime.tasks.OperatorChain$ChainingOutput.pushToOperator(OperatorChain.java:550) at org.apache.flink.streaming.runtime.tasks.OperatorChain$ChainingOutput.collect(OperatorChain.java:527) at org.apache.flink.streaming.runtime.tasks.OperatorChain$ChainingOutput.collect(OperatorChain.java:487) at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:730) at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:708) at SinkConversion$3.processElement(Unknown Source) at...