jctanking

kuduSource to kuduSink

2

Kudu output-format writeSingleRecordInternal failed. java.lang.ClassCastException: org.apache.flink.table.data.GenericRowData cannot be cast to com.dtstack.flinkx.element.ColumnRowData at com.dtstack.flinkx.connector.kudu.sink.KuduOutputFormat.writeSingleRecordInternal(KuduOutputFormat.java:77) at com.dtstack.flinkx.sink.format.BaseRichOutputFormat.writeSingleRecord(BaseRichOutputFormat.java:486) at com.dtstack.flinkx.sink.format.BaseRichOutputFormat.writeRecord(BaseRichOutputFormat.java:246) at com.dtstack.flinkx.sink.format.BaseRichOutputFormat.writeRecord(BaseRichOutputFormat.java:85) at com.dtstack.flinkx.sink.DtOutputFormatSinkFunction.invoke(DtOutputFormatSinkFunction.java:117) at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54) com.dtstack.flinkx.connector.kudu.converter.KuduColumnConverter.java 77 line val converter ColumnRowData.

chunjun kudu json filter 过滤条件怎么使用有用例或文档吗？文档中这个链接已经无法访问了。 https://docs.kudu.com/manual/crud/#read-operations