issues  

Messages by Thread

• • Re: [PR] [BP-1.20][FLINK-38574][checkpoint] Avoid reusing re-uploaded sst files when checkpoint notification is delayed [flink] via GitHub
• [jira] [Created] (FLINK-41072) Test configuration randomization on GitHub Actions always uses the same seed Martijn Visser (Jira)
• [jira] [Created] (FLINK-41071) Upgrade Testcontainers to 1.21.4 in the Cassandra connector to support Docker 29 Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-38485) Cassandra connector weekly CI is failing with NoClassDefFound Martijn Visser (Jira)
• [jira] [Created] (FLINK-41070) Cassandra connector CI fails downloading the Flink 1.19.0 binary Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable sepuri sai krishna (Jira)
  • [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Mika Naylor (Jira)
• Re: [PR] [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT [flink] via GitHub
  • Re: [PR] [FLINK-40919][table-planner] Do not reduce AVG on TINYINT, SMALLINT and INT to SUM / COUNT [flink] via GitHub
• [jira] [Created] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira)
• [jira] [Created] (FLINK-41063) DataStream large-record sorting unnecessarily falls back to Kryo for payload serialization Jira
• [jira] [Commented] (FLINK-40077) CommonExecSinkITCase.testNullEnforcer fails intermittently: lost NoMoreSplitsEvent failover masks the NOT NULL enforcer cause Martijn Visser (Jira)
• [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• [jira] [Created] (FLINK-41066) MultiJoin produces wrong results when an upsert input replaces a record without UPDATE_BEFORE Gustavo de Morais (Jira)
• [PR] [BP-1.20][FLINK-41053][test] Backport MAX_RETAINED_CHECKPOINTS fix to UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-41053][test] Backport MAX_RETAINED_CHECKPOINTS fix to UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-41053][test] Backport MAX_RETAINED_CHECKPOINTS fix to UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• [jira] [Assigned] (FLINK-40964) Streaming Top-N over an updating ROW_NUMBER input never retracts a replaced row (outer Rank uses AppendFastStrategy) Mika Naylor (Jira)
• [jira] [Created] (FLINK-41065) Improve TypeInferenceUtil for built-in PTFs Timo Walther (Jira)
• [jira] [Commented] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Muhammad (Jira)
  • [jira] [Commented] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-40065) flink-connector-aws: update flink-connector-parent to 2.0.0 and flink.version to 2.1. Muhammad (Jira)
• [jira] [Commented] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 Purushottam Sinha (Jira)
• [jira] [Created] (FLINK-41067) Window and interval joins store rows whose join key can never match Rion Williams (Jira)
• [jira] [Commented] (FLINK-41069) Add support for Flink 2.2 to flink-connector-aws Muhammad (Jira)
• [jira] [Created] (FLINK-41068) LATERAL SNAPSHOT join stores build-side rows whose join key can never match Rion Williams (Jira)
• [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• [jira] [Comment Edited] (FLINK-34625) TTL doesn't seem to work in pyflink Dian Fu (Jira)
• [jira] [Resolved] (FLINK-40968) Accept map() as op_mapping in Table API toChangelog() and fromChangelog() Gustavo de Morais (Jira)
• [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40904][FLINK-40780][runtime] Detect FORWARD parallelism mismatch correctly and make the downgrade configurable [flink] via GitHub
• [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
  • Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
  • Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
  • Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
  • Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
  • Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
• Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] Continuation execution ignores max-in-flight-input-records on JDK 21 [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40567) HistoryServerArchiveFetcherTest.testLazyFetchArchiveProactively is flaky on @TempDir cleanup Mika Naylor (Jira)
• [jira] [Commented] (FLINK-38770) pipeline.jobvertex-parallelism-overrides ignored for StreamGraph in Application Mode Mika Naylor (Jira)
• [jira] [Updated] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-41055) StreamingMultiJoinOperator stores rows with a NULL join key in state, even though they can never match Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-41064) 'State TTL Heap backend end-to-end test' fails on a "Trying to access closed classloader" log4j error in the TaskManager .out files Martijn Visser (Jira)
• [I] [Bug][runtime] An input that triggers no Actions can strand the next input queued for the same key [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] An input that triggers no Actions can strand the next input queued for the same key [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] An input that triggers no Actions can strand the next input queued for the same key [flink-agents] via GitHub
• [jira] [Commented] (FLINK-39330) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailove fails Martijn Visser (Jira)
• [jira] [Comment Edited] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41063) DataStream large-record sorting unnecessarily falls back to Kryo for payload serialization ASF GitHub Bot (Jira)
• [PR] [FLINK-41063][runtime] Extract only sorting fields for large byte-key records [flink] via GitHub
  • Re: [PR] [FLINK-41063][runtime] Extract only sorting fields for large byte-key records [flink] via GitHub
• [jira] [Assigned] (FLINK-34625) TTL doesn't seem to work in pyflink Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled ASF GitHub Bot (Jira)
• [PR] [FLINK-41016][python] Derive uids for the operators PyFlink adds for key_by and partition_custom [flink] via GitHub
  • Re: [PR] [FLINK-41016][python] Derive uids for the operators PyFlink adds for key_by and partition_custom [flink] via GitHub
• [jira] [Commented] (FLINK-40780) FORWARD edge silently converted to REBALANCE on parallelism mismatch corrupts changelog (upsert/retract) streams Rui Fan (Jira)
• Re: [PR] [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40216][cdc-base] Preserve assignment order of splits across restore to keep meta groups consistent [flink-cdc] via GitHub
• [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
  • Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
  • Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
  • Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
  • Re: [I] [Doc] Walkthrough findings for Setup, multi-Agent Quickstart and Flink integration [flink-agents] via GitHub
• [jira] [Closed] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Gyula Fora (Jira)
• [jira] [Commented] (FLINK-40898) TRY_RESOLVE wrongly rejects non-deterministic filters inside ChangelogNormalize Sergey Paryshev (Jira)
• [jira] [Updated] (FLINK-40898) TRY_RESOLVE wrongly rejects non-deterministic filters inside ChangelogNormalize ASF GitHub Bot (Jira)
• [PR] [FLINK-40898][table-planner] Allow non-deterministic filters in ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-40898][table-planner] Allow non-deterministic filters in ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-40898][table-planner] Allow non-deterministic filters in ChangelogNormalize [flink] via GitHub
  • Re: [PR] [FLINK-40898][table-planner] Allow non-deterministic filters in ChangelogNormalize [flink] via GitHub
• [jira] [Closed] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support Ramin Gharib (Jira)
• [jira] [Updated] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• [PR] [BP-1.20][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• [PR] [BP-2.2][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• [PR] [BP-2.3][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• [jira] [Assigned] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled Dian Fu (Jira)
• [PR] [docs][memory] Correct memory documentation [flink-agents] via GitHub
  • Re: [PR] [docs] Correct memory documentation [flink-agents] via GitHub
  • Re: [PR] [docs] Correct memory documentation [flink-agents] via GitHub
  • Re: [PR] [docs] Correct memory documentation [flink-agents] via GitHub
• [jira] [Created] (FLINK-41062) PARSE_XML and TRY_PARSE_XML can run out of memory for large documents Moritz Manner (Jira)
• [jira] [Closed] (FLINK-40829) operators hidden by `assign_timestamps_and_watermarks` get no uid, breaking `pipeline.auto-generate-uids: false` Dian Fu (Jira)
• [jira] [Assigned] (FLINK-40829) operators hidden by `assign_timestamps_and_watermarks` get no uid, breaking `pipeline.auto-generate-uids: false` Dian Fu (Jira)
• [jira] [Resolved] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-33163) Support Java 21 (LTS) Damien GOUYETTE (Jira)
• [jira] [Assigned] (FLINK-38562) Support thread mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Resolved] (FLINK-40671) Document why UnknownInputChannel graduation hardcodes needsRecovery=false Rui Fan (Jira)
• [jira] [Commented] (FLINK-40566) Daily benchmark failures for months Han Yin (Jira)
• [jira] [Commented] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Han Yin (Jira)
  • [jira] [Commented] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Han Yin (Jira)
• [jira] [Created] (FLINK-41061) Daily benchmark keeps failing because of excessive runtime of the adaptive partition benchmark Han Yin (Jira)
• [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest#testStatusMetrics [flink] via GitHub
  • Re: [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest.testStatusMetrics [flink] via GitHub
  • Re: [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest.testStatusMetrics [flink] via GitHub
  • Re: [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest.testStatusMetrics [flink] via GitHub
  • Re: [PR] [FLINK-36299][runtime] Start scheduling and offer the slot in one main-thread task in AdaptiveSchedulerTest.testStatusMetrics [flink] via GitHub
• [jira] [Created] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-36299) AdaptiveSchedulerTest.testStatusMetrics times out Martijn Visser (Jira)
• [jira] [Created] (FLINK-41059) FineGrainedSlotManager schedules requirement checks into the main thread after suspend() Martijn Visser (Jira)
• [PR] [runtime] Fix ActionStateStore divergence detection for multi-action replay [flink-agents] via GitHub
  • Re: [PR] [runtime] Fix ActionStateStore divergence detection for multi-action replay [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism Rui Fan (Jira)
• [jira] [Comment Edited] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism Rui Fan (Jira)
• [jira] [Updated] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory Gabor Somogyi (Jira)
• [jira] [Comment Edited] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory Gabor Somogyi (Jira)
• [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41057][iceberg] Fix append-only update and delete handling [flink-cdc] via GitHub
• [PR] [FLINK-XXXXX][pipeline-connector/fluss] Merge schema options with global sink table properties when creating tables. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-41058][pipeline-connector/fluss] Merge schema options with global sink table properties when creating tables. [flink-cdc] via GitHub
• [jira] [Assigned] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules Hongshun Wang (Jira)
• [jira] [Created] (FLINK-41058) Fluss pipeline sink ignores table options defined in transform rules Hongshun Wang (Jira)
• [jira] [Updated] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events Yanquan Lv (Jira)
  • [jira] [Updated] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41057) Iceberg append-only tables incorrectly append before-images from UPDATE and DELETE events Yanquan Lv (Jira)
• [jira] [Comment Edited] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)
• [jira] [Resolved] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed Hongshun Wang (Jira)
• [jira] [Resolved] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset Hongshun Wang (Jira)
• [jira] [Assigned] (FLINK-40982) Fluss pipeline sink fails to recover when an ADD COLUMN event is replayed Hongshun Wang (Jira)
• [jira] [Assigned] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset Hongshun Wang (Jira)
• [PR] [runtime][python][docs] Fix execution guards and observability gaps in Operations guidance [flink-agents] via GitHub
  • Re: [PR] [runtime][python][docs] Fix execution guards and observability gaps in Operations guidance [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset Hongshun Wang (Jira)
  • [jira] [Updated] (FLINK-40853) [postgres] Data loss: LSN commit passes the latest completed checkpoint when the delayed checkpoint has no stream offset Hongshun Wang (Jira)
• [D] Human-in-the-loop approval: pluggable approver (decision model first, human fallback) - design discussion for #1067 [flink-agents] via GitHub
• Re: [I] [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive [flink-agents] via GitHub
  • Re: [I] [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive [flink-agents] via GitHub
  • Re: [I] [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive [flink-agents] via GitHub
• Re: [PR] [FLINK-31769] feat: quantile to aggregated metrcis [flink] via GitHub
  • Re: [PR] [FLINK-31769] feat: quantile to aggregated metrcis [flink] via GitHub
• Re: [PR] [FLINK-40154][formats] Upgrade Parquet to 1.16.0 [flink] via GitHub
• Re: [PR] [FLINK-39531][table-planner] Fix duplicated Python UDF extraction in calc split rule [flink] via GitHub
• [jira] [Updated] (FLINK-40967) Restore test files of OVER_AGGREGATE_TIME_BOUNDED_NON_PARTITIONED_ROWS_WITH_OUT_OF_ORDER_RECORDS cannot be regenerated ASF GitHub Bot (Jira)
• [PR] [FLINK-40967][table] Fix restore test files of non-partitioned out-of-order OVER aggregate [flink] via GitHub
  • Re: [PR] [FLINK-40967][table] Fix restore test files of non-partitioned out-of-order OVER aggregate [flink] via GitHub
• [PR] [api][plan][java][python] Fix MCP server declarations in YAML [flink-agents] via GitHub
  • Re: [PR] [api][plan][java][python] Fix MCP server declarations in YAML [flink-agents] via GitHub
  • Re: [PR] [api][plan][java][python] Fix MCP server declarations in YAML [flink-agents] via GitHub
  • Re: [PR] [api][plan][java][python] Fix MCP server declarations in YAML [flink-agents] via GitHub
• [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found ASF GitHub Bot (Jira)
• [I] [Feature][runtime] Support durable replay for same-key inputs from multiple upstream instances [flink-agents] via GitHub
  • Re: [I] [Feature][runtime] Support durable replay for same-key inputs from multiple upstream instances [flink-agents] via GitHub
• [I] [Bug][runtime] ActionStateStore misclassifies normal multi-Action execution as divergence [flink-agents] via GitHub
  • Re: [I] [Bug][runtime] ActionStateStore misclassifies normal multi-Action execution as divergence [flink-agents] via GitHub
• [jira] [Commented] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Sangkyoon Nam (Jira)
• [PR] [FLINK-41044][python] Let the Python worker flush its logs before closing the logging server [flink] via GitHub
  • Re: [PR] [FLINK-41044][python] Let the Python worker flush its logs before closing the logging server [flink] via GitHub
• [PR] [docs] Add decision model entries to the resource, event, and cross-l… [flink-agents] via GitHub
  • Re: [PR] [docs] Add decision model entries to the resource, event, and cross-language indexes [flink-agents] via GitHub
  • Re: [PR] [docs] Add decision model entries to the resource, event, and cross-language indexes [flink-agents] via GitHub
  • Re: [PR] [docs] Add decision model entries to the resource, event, and cross-language indexes [flink-agents] via GitHub
• [PR] Support subgraph execution on the non-coroutine parallel engine [flink-agents] via GitHub
  • Re: [PR] [runtime] Support subgraph execution on the non-coroutine parallel engine [flink-agents] via GitHub
  • Re: [PR] [runtime] Support subgraph execution on the non-coroutine parallel engine [flink-agents] via GitHub
  • Re: [PR] [runtime] Support subgraph execution on the non-coroutine parallel engine [flink-agents] via GitHub
  • Re: [PR] [runtime] Support subgraph execution on the non-coroutine parallel engine [flink-agents] via GitHub
• Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
  • Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink] via GitHub
• [jira] [Commented] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled Sangkyoon Nam (Jira)
  • [jira] [Commented] (FLINK-41016) Missing uids on the operators PyFlink adds for key_by, partition_custom and KeyedStream can prevent submission with auto-generated UIDs disabled Dian Fu (Jira)
• Re: [PR] [FLINK-35104][pipeline-connector/kafka] Add kafka pipeline data source connector [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Dale Lane (Jira)
• [PR] Flink 41048 [flink] via GitHub
  • Re: [PR] [FLINK-41048][container] Fix MiniClusterJobEntryPointITCase race condition [flink] via GitHub
  • Re: [PR] [FLINK-41048][container] Fix MiniClusterJobEntryPointITCase race condition [flink] via GitHub
  • Re: [PR] [FLINK-41048][container] Fix MiniClusterJobEntryPointITCase race condition [flink] via GitHub
• Re: [PR] [FLINK-40949][table-runtime] Update UnsliceAssigners NULL window exception message [flink] via GitHub

• Earlier messages
• Later messages