基于Flinkx写入Iceberg,问下,中间是有用Kafka吗?还是Flinkx裸写?怎么解决小文件问题?
匿名用户
发布于 2022-01-24 09:57
最新回复 2022-01-24 10:01 来自于
群内解答
605
1
1条回答
-
回复于 2022-01-24 10:01
-
问题解答来源于群友:shihe
ClassCastException: org.apache.flink.table.data.GenericRowData cannot be cast to com.dtstack.flinkx.element.ColumnRowData
Http connector
这里改成rowData就可以了
0
0