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,
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,
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,