RE: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

2022-09-04 Thread Ryan van Huuksloot
Hi Mason, First off, thanks for putting this FLIP together! Sorry for the delay. Full disclosure Mason and I chatted a little bit at Flink Forward 2022 but I have tried to capture the questions I had for him then. I'll start the conversation with a few questions: 1. The concept of streamIds is n

Re: Flink Table Task question

2022-09-04 Thread Lijie Wang
Hi Emma, As Sergey said, the improvement of naming (FLIP-195) is ready in Flink 1.15. Maybe you can upgrade Flink to 1.15.x. Best, Lijie Sergey Nuyanzin 于2022年9月1日周四 15:33写道: > Hi Emma, > > not sure if I fully understand your question/case > however there is a FLIP-195 [1] about improvement of

[jira] [Created] (FLINK-29188) The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried

2022-09-04 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-29188: - Summary: The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried Key: FLINK-29188 URL: https://issues.apache.org/jira/browse/FLINK-29188

[jira] [Created] (FLINK-29189) Pass KeyValue to MergeFunction

2022-09-04 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29189: Summary: Pass KeyValue to MergeFunction Key: FLINK-29189 URL: https://issues.apache.org/jira/browse/FLINK-29189 Project: Flink Issue Type: Improvement