Re: Flink 1.10 es sink exception

Hi, sunfulin Using constant key in `group by` query is not usual and inefficient, you can get around this bug by bubbling up your constant key in `group by` from now. BTW，godfrey is ready to resolve issue. > 在 2020年2月17日，10:15，sunfulin 写道： > > Hi， > WOW，really thankful for the track and

Re: Flink 1.10 es sink exception

Hi, sunfulin I reproduce your case，this should be a bug in extracting unique key from plan and I create an issue[1] to trace this. CC: jark [1]https://issues.apache.org/jira/browse/FLINK-16070 > 在 2020年2月14日，23:39，sunfulin 写道： > > Hi,

Re: Flink 1.10 es sink exception

Hi sunfulin, Is this the real query you submit? AFAIK, insert with column list is not allowed for now, i.e. the `INSERT INTO ES6_ZHANGLE_OUTPUT(aggId, pageId, ts, expoCnt, clkCnt)`. Could you attach the full SQL text, including DDLs of ES6_ZHANGLE_OUTPUT table and kafka_zl_etrack_event_stream t