[jira] [Created] (FLINK-32512) SHOW JARS should not show the jars for temporary function

2023-07-02 Thread Fang Yong (Jira)
Fang Yong created FLINK-32512: - Summary: SHOW JARS should not show the jars for temporary function Key: FLINK-32512 URL: https://issues.apache.org/jira/browse/FLINK-32512 Project: Flink Issue Typ

[jira] [Created] (FLINK-32511) Upgrade GCS connector to 2.2.15

2023-07-02 Thread Jayadeep Jayaraman (Jira)
Jayadeep Jayaraman created FLINK-32511: -- Summary: Upgrade GCS connector to 2.2.15 Key: FLINK-32511 URL: https://issues.apache.org/jira/browse/FLINK-32511 Project: Flink Issue Type: Impro

[DISCUSS] FLIP-329: Add operator attribute to specify support for object-reuse

2023-07-02 Thread Xuannan Su
Hi all, Dong(cc'ed) and I are opening this thread to discuss our proposal to add operator attribute to allow operator to specify support for object-reuse [1]. Currently, the default configuration for pipeline.object-reuse is set to false to avoid data corruption, which can result in suboptimal pe

[DISCUSS] FLIP-327: Support stream-batch unified operator to improve job throughput when processing backlog data

2023-07-02 Thread Dong Lin
Hi all, I am opening this thread to discuss FLIP-327: Support stream-batch unified operator to improve job throughput when processing backlog data. The design doc can be found at https://cwiki.apache.org/confluence/display/FLINK/FLIP-327%3A+Support+stream-batch+unified+operator+to+improve+job+thro

[jira] [Created] (FLINK-32510) Reusing the LongHashJoinGenerator and HashJoinFusionCodegenSpec code as soon as possible to avoid too high maintain cost

2023-07-02 Thread dalongliu (Jira)
dalongliu created FLINK-32510: - Summary: Reusing the LongHashJoinGenerator and HashJoinFusionCodegenSpec code as soon as possible to avoid too high maintain cost Key: FLINK-32510 URL: https://issues.apache.org/jira/b