[jira] [Created] (FLINK-37847) [umbrella] Unstable test in FlinkCDC project

Yanquan Lv created FLINK-37847: -- Summary: [umbrella] Unstable test in FlinkCDC project Key: FLINK-37847 URL: https://issues.apache.org/jira/browse/FLINK-37847 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-37845) Remove FlinkRexBuilder#makeIn

Sergey Nuyanzin created FLINK-37845: --- Summary: Remove FlinkRexBuilder#makeIn Key: FLINK-37845 URL: https://issues.apache.org/jira/browse/FLINK-37845 Project: Flink Issue Type: Technical Deb

[jira] [Created] (FLINK-37848) After timestamp mode is enabled, newly added tables will not have all their data synchronized.

Darcy Lin created FLINK-37848: - Summary: After timestamp mode is enabled, newly added tables will not have all their data synchronized. Key: FLINK-37848 URL: https://issues.apache.org/jira/browse/FLINK-37848

[jira] [Created] (FLINK-37849) Model provider factory discover

Hao Li created FLINK-37849: -- Summary: Model provider factory discover Key: FLINK-37849 URL: https://issues.apache.org/jira/browse/FLINK-37849 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator

Gustavo de Morais created FLINK-37844: - Summary: FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator Key: FLINK-37844 URL: https://issues.apache.org/jira/browse/FLINK-37844

[jira] [Created] (FLINK-37846) [Unstable test] MysqlToKafkaE2eITCase.testSyncWholeDatabaseWithDebeziumJson

Yanquan Lv created FLINK-37846: -- Summary: [Unstable test] MysqlToKafkaE2eITCase.testSyncWholeDatabaseWithDebeziumJson Key: FLINK-37846 URL: https://issues.apache.org/jira/browse/FLINK-37846 Project: Flin

Re: [DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project

@Robert, 1. I wasn't aware of the ASF subproject concept. Yes, the intention here is to create a repository, just like flink-cdc, flink-kubernetes-operator. I'll add a clarification in the FLIP. 2. Sorry for the confusion. I think we are just using Kafka as an example here. I'll correct it in the

[jira] [Created] (FLINK-37850) Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException

Sergey Nuyanzin created FLINK-37850: --- Summary: Several Union, Except, Intersect with one wrong column type fail with UnsupportedOperationException Key: FLINK-37850 URL: https://issues.apache.org/jira/browse/FLIN

Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

+1 (non-binding) We currently use a custom async table source and join it using FOR SYSTEM TIME AS OF This approach has some challenges, especially when used after aggregations . Introducing support for an async UDTF would allow us to perform the join using LATERAL TABLE, which would grea

[jira] [Created] (FLINK-37843) FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci

dalongliu created FLINK-37843: - Summary: FlinkFnExecutionTests::test_flink_fn_execution_pb2_synced test failed of azure ci Key: FLINK-37843 URL: https://issues.apache.org/jira/browse/FLINK-37843 Project:

[jira] [Created] (FLINK-37842) BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci

dalongliu created FLINK-37842: - Summary: BlockingShutdownTest#testProcessShutdownBlocking test failed of azure ci Key: FLINK-37842 URL: https://issues.apache.org/jira/browse/FLINK-37842 Project: Flink

Re: Proposal Flip-233: Donate GetInData HTTP Connector to Flink

Hi David, Big +1 from my side — this is great work, I went through the code and the improvements you’ve outlined clearly show the connector has matured significantly. Also, I wanted to bring up a forward-looking idea: do you (and the community) see potential in evolving this into a broader reposi