issues  

Messages by Thread

• [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
  • Re: [PR] [FLINK-40989][table-planner] Compare MAP values by value instead of by reference [flink] via GitHub
• [PR] [FLINK-40994][connect/paimon] Upgrade Paimon SDK to 2.1.0 [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40994][connect/paimon] Upgrade Paimon SDK to 2.1.0 [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40994) Upgrade paimon to 2.1.0 ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40994) Upgrade paimon to 2.1.0 peiyu (Jira)
• [jira] [Assigned] (FLINK-40924) table.exec.sink.upsert-materialize=NONE silently bypasses the require-on-conflict check Mika Naylor (Jira)
• [I] [Feature] Render a flat RowTypeInfo output schema as JSON Schema [flink-agents] via GitHub
• [PR] [FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsorted rows [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsorted rows [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsorted rows [flink] via GitHub
• [PR] [BP-2.3][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsort… [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsort… [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40959][table-runtime] Fix BinaryExternalSorter emitting unsort… [flink] via GitHub
• Re: [PR] [FLINK-40114][runtime] Don't erase leader information while a confirmation is pending [flink] via GitHub
• [I] [Doc] Improve Sub-Agents documentation [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-40959) Batch sort can emit unsorted rows if comparator implementation is long enough to be split Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40440) Add LLM prediction support to DataFrame API ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-40808) Setting up PyPI for AWS Connector Samrat Deb (Jira)
• [PR] [docs] Clarify API and language choices [flink-agents] via GitHub
  • Re: [PR] [docs] Clarify API and language choices [flink-agents] via GitHub
• Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40365][docs] Correct savepoint config requirements [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-40987) Allow overriding a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40987) Allow overriding a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40987) Allow overriding a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40987) Allow overriding a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
  • [jira] [Updated] (FLINK-40987) Allow overriding a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
• [I] [Bug][integrations][java] A Map field in a native schema becomes an empty object on OpenAI, Azure OpenAI and Anthropic [flink-agents] via GitHub
  • Re: [I] [Bug][integrations][java] A Map field in a native schema becomes an empty object on OpenAI, Azure OpenAI and Anthropic [flink-agents] via GitHub
  • Re: [I] [Bug][integrations][java] A Map field in a native schema becomes an empty object on OpenAI, Azure OpenAI and Anthropic [flink-agents] via GitHub
• [I] [Tech Debt][api] Chat model setups handle a blank model differently across providers and languages [flink-agents] via GitHub
• Re: [PR] [FLINK-36512][runtime] Ignore non-rescale-relevant checkpoint failure reasons in adaptive rescale trigger [flink] via GitHub
• Re: [PR] [FLINK-39704][runtime/jobmaster] Preserve globally terminal job result across leadership revocation [flink] via GitHub
• Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes [flink-cdc] via GitHub
• Re: [PR] [FLINK-39566][runtime-web] Add checkpoint duration Gantt view [flink] via GitHub
• [jira] [Updated] (FLINK-40992) Allow spec.job.parallelism to take effect when spec.taskManager.replicas is set, to support standby TaskManagers in standalone mode ASF GitHub Bot (Jira)
• Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
  • Re: [PR] [integrations][bedrock] Apply Bedrock native structured output [flink-agents] via GitHub
• [PR] [doc] Add a structured output user guide [flink-agents] via GitHub
  • Re: [PR] [doc] Add a structured output user guide [flink-agents] via GitHub
  • Re: [PR] [doc] Add a structured output user guide [flink-agents] via GitHub
  • Re: [PR] [doc] Add a structured output user guide [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
• [jira] [Assigned] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-38907) Records lost using filtered autocreate mode Hongshun Wang (Jira)
• [PR] [FLINK-40992][operator] Allow the job parallelism to take effect when TaskManager replicas are set [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Gyula Fora (Jira)
  • [jira] [Commented] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
  • [jira] [Commented] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Gyula Fora (Jira)
• [jira] [Closed] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira)
• [jira] [Comment Edited] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira)
• [jira] [Created] (FLINK-40992) Allow spec.job.parallelism to take effect when spec.taskManager.replicas is set, to support standby TaskManagers in standalone mode Tomoyuki NAKAMURA (Jira)
• [jira] [Updated] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
• [PR] [FLINK-40991] Read the legacy ClusterHealthInfo healthy field [flink-kubernetes-operator] via GitHub
• [jira] [Created] (FLINK-40991) Health info stored by an operator before 1.12 fails to deserialize after upgrading, breaking reconciliation Tomoyuki NAKAMURA (Jira)
• [PR] [fix] Updated documentation based on changes in version 3.7.0. [flink-cdc] via GitHub
  • Re: [PR] [fix] Updated documentation based on changes in version 3.7.0. [flink-cdc] via GitHub
• [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
  • Re: [I] [Doc] Improve Tool Use documentation [flink-agents] via GitHub
• [I] [Doc] Improve Skills usage and source-loading documentation [flink-agents] via GitHub
• [I] [Doc] Improve Chat with Models and message documentation [flink-agents] via GitHub
• [I] [Doc] Improve Chat Models and built-in provider documentation [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Xiqian Yu (Jira)
• Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
  • Re: [I] [Feature] Support making use of the native capabilities of models for structure output. [flink-agents] via GitHub
• [PR] [BP-2.3][FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. [flink] via GitHub
• Re: [PR] [FLINK-39440]support mysql capture-data-with-rate-limit [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39440]support mysql capture-data-with-rate-limit [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee ASF GitHub Bot (Jira)
• [PR] [FLINK-40983][docs][pipeline-connector/kafka] Document sink.delivery-guarantee [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40983][docs][pipeline-connector/kafka] Document sink.delivery-guarantee [flink-cdc] via GitHub
• [jira] [Updated] (FLINK-40153) CREATE TABLE LIKE cannot resolve inherited metadata columns in a derived watermark expression lincoln lee (Jira)
• [jira] [Created] (FLINK-40988) Bump JUnit to 5.14 Martijn Visser (Jira)
• [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
  • Re: [PR] [FLINK-38830][runtime] Handle duplicate AddColumnEvent gracefully to prevent pipeline crashes [flink-cdc] via GitHub
• [PR] [FLINK-40986][python] Make named Row hashing consistent with equality [flink] via GitHub
  • Re: [PR] [FLINK-40986][python] Make named Row hashing consistent with equality [flink] via GitHub
  • Re: [PR] [FLINK-40986][python] Make named Row hashing consistent with equality [flink] via GitHub
• [jira] [Created] (FLINK-40987) Allow overriding or disabling a table's watermark per table reference via OPTIONS hint Gustavo de Morais (Jira)
• Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40710][Connectors/Kafka] Preserve Dynamic Kafka partition ownership during reader recovery [flink-connector-kafka] via GitHub
• [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
  • Re: [PR] [FLINK-33020][ci] OpensearchSinkTest.testAtLeastOnceSink timed out [flink-connector-opensearch] via GitHub
• [PR] [integrations][java] List Jackson enum values in OpenAI, Azure and Anthropic native schemas [flink-agents] via GitHub
  • Re: [PR] [integrations][java] List Jackson enum values in OpenAI, Azure and Anthropic native schemas [flink-agents] via GitHub
• [PR] [FLINK-40988][tests] Bump JUnit to 5.14.4 [flink] via GitHub
  • Re: [PR] [FLINK-40988][tests] Bump JUnit to 5.14.4 [flink] via GitHub
  • Re: [PR] [FLINK-40988][tests] Bump JUnit to 5.14.4 [flink] via GitHub
• [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
  • Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
  • Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
  • Re: [PR] [runtime] Count restored input runs once when tasks identify them first [flink-agents] via GitHub
• [jira] [Created] (FLINK-40990) MySQL CDC source suppresses terminal missing-schema errors and keeps checkpointing without CDC Vinay Sagar Gonabavi (Jira)
• [jira] [Created] (FLINK-40989) MAP equality compares numeric values by reference Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40988) Bump JUnit to 5.14 Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40988) Bump JUnit to 5.14 ASF GitHub Bot (Jira)
• [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
  • Re: [PR] [FLINK-40968][table] Fix Table API map() op_mapping in changelog PTFs [flink] via GitHub
• [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
  • [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
  • [jira] [Commented] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Zakelly Lan (Jira)
• Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
• [jira] [Comment Edited] (FLINK-40931) ForSt restore with object-store in restore mode fails when scaling in Mohsen Rezaei (Jira)
• [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
  • Re: [PR] [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` [flink] via GitHub
• [I] [Bug][integrations][java] OpenAI, Azure OpenAI and Anthropic native schemas list annotated enums by Java name [flink-agents] via GitHub
  • Re: [I] [Bug][integrations][java] OpenAI, Azure OpenAI and Anthropic native schemas list annotated enums by Java name [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode ChenZhuo (Jira)
• [jira] [Closed] (FLINK-39163) Support ML_PREDICT in Flink Python API Dian Fu (Jira)
• [jira] [Closed] (FLINK-40439) Add model provider management to DataFrame API Dian Fu (Jira)
• [jira] [Closed] (FLINK-40425) Add OVER window aggregation support to DataFrame API Dian Fu (Jira)
• [PR] [docs] Restructure documentation navigation and guides for 0.4 [flink-agents] via GitHub
  • Re: [PR] [docs] Restructure documentation navigation and guides for 0.4 [flink-agents] via GitHub
• [jira] [Comment Edited] (FLINK-40962) LAG() unsupported for TIMESTAMP_LTZ arguments in batch mode ChenZhuo (Jira)
• [jira] [Updated] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed ASF GitHub Bot (Jira)
• [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
  • Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
  • Re: [PR] [FLINK-35376][runtime] Avoid duplicate PackagedProgram in REST JAR handlers [flink] via GitHub
• [jira] [Updated] (FLINK-40986) Equal named Rows can have different hash values in PyFlink ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Dian Fu (Jira)
• [I] [Feature] Support decision models in Flink Agents [flink-agents] via GitHub
• [jira] [Created] (FLINK-40986) Equal named Rows can have different hash values in PyFlink Biao Geng (Jira)
• [PR] [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs [flink] via GitHub
  • Re: [PR] [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs [flink] via GitHub
  • Re: [PR] [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs [flink] via GitHub
• [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
  • Re: [PR] [FLINK-39163][python] Support ML_PREDICT in Python API [flink] via GitHub
• [jira] [Created] (FLINK-40985) [Iceberg] Support per-table location override in Iceberg pipeline sink VISHAL B (Jira)
• [jira] [Resolved] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column Fabian Hueske (Jira)
• [jira] [Resolved] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
• Re: [PR] [hotfix][postgres] generateCreateTableEvent result is skipped [flink-cdc] via GitHub
• [jira] [Created] (FLINK-40984) Port the batch aggregate ITCases in flink-table-planner to Java Martijn Visser (Jira)
• Re: [I] [Feature] Add OpenAI embedding model (Java) [flink-agents] via GitHub
• Re: [PR] [FLINK-39928][ci] If there are changes in tests only then skip non related CI jobs in GHA [flink] via GitHub
  • Re: [PR] [FLINK-39928][ci] If there are changes in tests only then skip non related CI jobs in GHA [flink] via GitHub
• Re: [PR] [FLINK-39285][table] Ignore project rel node generated by FlinkFilterJoinRule in JoinToMultiJoinRule [flink] via GitHub
• [jira] [Resolved] (FLINK-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped Sergey Nuyanzin (Jira)
• [PR] [api][plan][runtime] Use generic resource descriptors for sub-agents [flink-agents] via GitHub
  • Re: [PR] [api][plan][runtime] Use generic resource descriptors for sub-agents [flink-agents] via GitHub
  • Re: [PR] [api][plan][runtime] Use generic resource descriptors for sub-agents [flink-agents] via GitHub
  • Re: [PR] [api][plan][runtime] Use generic resource descriptors for sub-agents [flink-agents] via GitHub
• [I] [Tech Debt] Unify sub-agent declarations with generic resource descriptors [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Unify sub-agent declarations with generic resource descriptors [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40977) ForSt JUnit 5 migration is incomplete Purushottam Sinha (Jira)
• Re: [PR] [FLINK-39327][pipeline-connector/dws]add dws sink pipeline connector [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Rango (Jira)
  • [jira] [Commented] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Xiqian Yu (Jira)
• [jira] [Created] (FLINK-40983) [Docs] Kafka pipeline connector option table omits sink.delivery-guarantee Rango (Jira)
• [jira] [Updated] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed ASF GitHub Bot (Jira)
• [PR] [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent [flink-cdc] via GitHub
• [jira] [Created] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed Xiaobing Fang (Jira)
• [jira] [Updated] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API ASF GitHub Bot (Jira)
• [PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink] via GitHub
  • Re: [PR] [FLINK-40471][python] Support per-UDF concurrency and batch size in DataFrame API [flink] via GitHub

• Earlier messages
• Later messages