[jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

2024-10-30 Thread Di Wu (Jira)
Di Wu created FLINK-36631: - Summary: Supports reading incremental data from Oracle from a specified SCN Key: FLINK-36631 URL: https://issues.apache.org/jira/browse/FLINK-36631 Project: Flink Issue T

[jira] [Created] (FLINK-36630) kafka-connector random WakeupException after enabling watermark alignment

2024-10-30 Thread Alberto Lago (Jira)
Alberto Lago created FLINK-36630: Summary: kafka-connector random WakeupException after enabling watermark alignment Key: FLINK-36630 URL: https://issues.apache.org/jira/browse/FLINK-36630 Project: Fl

[jira] [Created] (FLINK-36629) Introducing the AdaptiveSkewedJoinOptimizationStrategy

2024-10-30 Thread Lei Yang (Jira)
Lei Yang created FLINK-36629: Summary: Introducing the AdaptiveSkewedJoinOptimizationStrategy Key: FLINK-36629 URL: https://issues.apache.org/jira/browse/FLINK-36629 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-36632) When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data

2024-10-30 Thread MOBIN (Jira)
MOBIN created FLINK-36632: - Summary: When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data Key: FLINK-36632 URL: https://issues.apache.org/jira/browse/FLINK-3

Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)

2024-10-30 Thread Timo Walther
Hi Jim, 3. Multiple output tables > Does the target_table need to be specified in the SELECT clause? No. Similar to reading from a regular table. The filter column must not be part of SELECT part. > It seems like the two target_table could have separate schemas defined. That is true. The SE

Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-30 Thread Leonard Xu
Thanks Yanquan for opening the ticket, let’s track it under the jira ticket. Best, Leonard > 2024年10月30日 下午8:25，Yanquan Lv 写道： > > Thanks ConradJam, Leonard, Hang for your positive feedback, and I haven't > seen any demand for blocks in the community either. > We’ve created a jira[1] to trace

[jira] [Created] (FLINK-36633) Add support for Flink 1.20 in Flink OpenSearch connector

2024-10-30 Thread Andriy Redko (Jira)
Andriy Redko created FLINK-36633: Summary: Add support for Flink 1.20 in Flink OpenSearch connector Key: FLINK-36633 URL: https://issues.apache.org/jira/browse/FLINK-36633 Project: Flink Issu

*TemporarySystemFunction API without ignoreIfExists option

2024-10-30 Thread Venkatakrishnan Sowrirajan
Hi Flink devs, Quick question: Why does *TableEnvironmentImpl#*TemporarySystemFunction* doesn't offer an API with *ignoreIfExists* - basically to support idempotent registration of UDF functions unlike createFunction that offers an API with *ignoreExists?* Want to understand if there is any nuanc

Re: [DISCUSS] FlinkCDC bump version to Flink 1.19

2024-10-30 Thread Yanquan Lv
Thanks ConradJam, Leonard, Hang for your positive feedback, and I haven't seen any demand for blocks in the community either. We’ve created a jira[1] to trace the bump Flink 1.19 plan, and hope to complete this work in FlinkCDC 3.3. [1] https://issues.apache.org/jira/browse/FLINK-36586 > 2024年

Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-30 Thread Shengkai Fang
Hi, Ron! > I noticed that you say this FLIP focuses on supporting deploy sql scripts to the application cluster, does it mean that it only supports non-interactive gateway mode? Yes. This FLIP only supports to deploy a script in non-interactive mode. > Whether all SQL commands such as DDL & DML

[jira] [Created] (FLINK-36634) Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime

2024-10-30 Thread xingbe (Jira)
xingbe created FLINK-36634: -- Summary: Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime Key: FLINK-36634 URL: https://issues.apache.org/jira/browse/FLINK-36634 Proj

Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-30 Thread Ron Liu
Hi, Shengkai Thanks for your quick response. It looks good to me. Best Ron Shengkai Fang 于2024年10月31日周四 10:08写道： > Hi, Ron! > > > I noticed that you say this FLIP focuses on supporting deploy sql > scripts to the application cluster, does it mean that it only supports > non-interactive gatewa

Re: [DISCUSS] FLIP-480: Support to deploy script in application mode

2024-10-30 Thread Shengkai Fang
Hi, Feng! > if only clusterID is available, it may not be very convenient to connect to this application later on. If FLIP-479 is accepted, I think we can just adapt the sql-gateway behaviour to the behaviour that FLIP-479 mentioned. Best, Shengkai

[jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed

2024-10-30 Thread Yi Zhang (Jira)
Yi Zhang created FLINK-36635: Summary: PhysicalSlotRequestBulkImpl is not used and can be removed Key: FLINK-36635 URL: https://issues.apache.org/jira/browse/FLINK-36635 Project: Flink Issue Type