Re: [DISCUSS] FLIP-302: Support TRUNCATE TABLE statement

2023-04-06 Thread Jingsong Li
+1 for voting. Best, Jingsong On Thu, Apr 6, 2023 at 4:52 PM yuxia wrote: > > Hi everyone. > > If there are no other questions or concerns for the FLIP[1], I'd like to > start the vote next Monday (4.10). > > [1] >

[jira] [Created] (FLINK-31750) Hash Keys are duplicate when join reorder happens in stream mode

2023-04-06 Thread ZhengYi Weng (Jira)
ZhengYi Weng created FLINK-31750: Summary: Hash Keys are duplicate when join reorder happens in stream mode Key: FLINK-31750 URL: https://issues.apache.org/jira/browse/FLINK-31750 Project: Flink

[jira] [Created] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

2023-04-06 Thread junzhong qin (Jira)
junzhong qin created FLINK-31749: Summary: The Using Hadoop OutputFormats example is not avaliable for DataStream Key: FLINK-31749 URL: https://issues.apache.org/jira/browse/FLINK-31749 Project:

[jira] [Created] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-06 Thread Zili Chen (Jira)
Zili Chen created FLINK-31748: - Summary: Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar Key: FLINK-31748 URL: https://issues.apache.org/jira/browse/FLINK-31748 Project: Flink

[jira] [Created] (FLINK-31747) Externalize debezium from flink-json

2023-04-06 Thread Mason Chen (Jira)
Mason Chen created FLINK-31747: -- Summary: Externalize debezium from flink-json Key: FLINK-31747 URL: https://issues.apache.org/jira/browse/FLINK-31747 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31746) Batch workload output completes while the job client fails

2023-04-06 Thread Haoze Wu (Jira)
Haoze Wu created FLINK-31746: Summary: Batch workload output completes while the job client fails Key: FLINK-31746 URL: https://issues.apache.org/jira/browse/FLINK-31746 Project: Flink Issue

Re: [ANNOUNCE] Kafka Connector Code Removal from apache/flink:main branch and code freezing

2023-04-06 Thread Chesnay Schepler
Do we have to move Debezium _now_? There is no hard dependency between debezium-json and the Kafka connector, nor does the format depend on Kafka afaict. So is this only about the e2e test that uses debezium-json + kafka connector? If so, then I would suggest to put debezium-json issue aside

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

2023-04-06 Thread Yun Tang
Hi Zakelly, Thanks for driving this work! I'm not sure did you ever read the discussion between Stephan, Roman, Piotr, Yuan and I in the design doc [1] in nearly two years ago. From my understanding, your proposal is also a mixed state ownership: some states are owned by the TM while some are

[jira] [Created] (FLINK-31745) Performance regression on serializerHeavyString since April 3rd

2023-04-06 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-31745: -- Summary: Performance regression on serializerHeavyString since April 3rd Key: FLINK-31745 URL: https://issues.apache.org/jira/browse/FLINK-31745 Project: Flink

[jira] [Created] (FLINK-31744) Extend Adaptive Scheduler sparse EG to contain maxParallelism

2023-04-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-31744: Summary: Extend Adaptive Scheduler sparse EG to contain maxParallelism Key: FLINK-31744 URL: https://issues.apache.org/jira/browse/FLINK-31744 Project: Flink

[jira] [Created] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

2023-04-06 Thread jinghaihang (Jira)
jinghaihang created FLINK-31743: --- Summary: Avoid relocating the RocksDB's log failure when filename exceeds 255 characters Key: FLINK-31743 URL: https://issues.apache.org/jira/browse/FLINK-31743

Re: [DISCUSS] FLIP-302: Support TRUNCATE TABLE statement

2023-04-06 Thread yuxia
Hi everyone. If there are no other questions or concerns for the FLIP[1], I'd like to start the vote next Monday (4.10). [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-302%3A+Support+TRUNCATE+TABLE+statement Best regards, Yuxia - 原始邮件 - 发件人: "yuxia" 收件人: "dev" 发送时间:

Re: [DISCUSS] FLIP-306: Unified File Merging Mechanism for Checkpoints

2023-04-06 Thread Zakelly Lan
Hi Piotr, Thanks for all the feedback. (1) Thanks for the reminder. I have just seen the FLINK-24611, the delayed deletion by JM resolves some sync problems between JM and TM, but I'm afraid it is still not feasible for the file sharing in this FLIP. Considering a concurrent checkpoint scenario