Flink 1.12 Blink planner timestamp类型转换异常

2022-01-11 文章 张健
Hi, all flink1.12 Blink planner有人遇到过这样的问题么: 下面是简化的逻辑 DataStream ds = .map(xxxRichMapFunction); Table table = tableEnv.fromDataStream(ds); tableEnv.toAppendStream(table.select(xxx).keyBy(xxx), Row.class).addSink(xxxRichSinkFunction); xxxRichMapFunction中对某个字段写了row.setField(index,

Flink 1.12 Blink planner timestamp类型转换异常

2022-01-11 文章 张健
Hi, all flink1.12 Blink planner有人遇到过这样的问题么: 下面是简化的逻辑 DataStream ds = .map(xxxRichMapFunction); Table table = tableEnv.fromDataStream(ds); tableEnv.toAppendStream(table.select(xxx).keyBy(xxx), Row.class).addSink(xxxRichSinkFunction); xxxRichMapFunction中对某个字段写了row.setField(index,

Flink 1.12 Blink planner timestamp类型转换异常

2022-01-11 文章 张健
Hi, all flink1.12 Blink planner有人遇到过这样的问题么: 下面是简化的逻辑 DataStream ds = .map(xxxRichMapFunction); Table table = tableEnv.fromDataStream(ds); tableEnv.toAppendStream(table.select(xxx).keyBy(xxx), Row.class).addSink(xxxRichSinkFunction); xxxRichMapFunction中对某个字段写了row.setField(index,