issues  

Messages by Thread

• • Re: [PR] [FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
  • Re: [PR] [FLINK-34427][tests] Wait for slot manager close() in runTest [flink] via GitHub
• [jira] [Updated] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Martijn Visser (Jira)
• [jira] [Updated] (FLINK-35284) Streaming File Sink end-to-end test times out Martijn Visser (Jira)
• [jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
• [jira] [Updated] (FLINK-36299) AdaptiveSchedulerTest.testStatusMetrics times out Martijn Visser (Jira)
• [jira] [Updated] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira)
• [jira] [Updated] (FLINK-33595) StreamDependencyTests.test_set_requirements_with_cached_directory failed with ModuleNotFoundError Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• [jira] [Updated] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• Re: [PR] [FLINK-40378] add GROUP BY ALL support [flink] via GitHub
• [jira] [Closed] (FLINK-39254) FLIP-565: Improve ProcessTableFunctions for late data handling and state access Timo Walther (Jira)
• [jira] [Updated] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40585) KafkaSinkITCase.rescaleListing fails intermittently after scale-up-then-down: restored transactions fenced on commit, only a subset of records readable Martijn Visser (Jira)
• [jira] [Commented] (FLINK-33595) StreamDependencyTests.test_set_requirements_with_cached_directory failed with ModuleNotFoundError Martijn Visser (Jira)
• [jira] [Commented] (FLINK-26177) PulsarSourceITCase.testScaleDown fails with timeout Martijn Visser (Jira)
• [jira] [Assigned] (FLINK-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40132) MixedKubernetesServerExtension teardown flaky with RejectedExecutionException from Fabric8 Vert.x mock server shutdown Mika Naylor (Jira)
• [jira] [Commented] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Gunjan Aggarwal (Jira)
• [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34523) Some jar couldn't be downloaded from google-maven-central Martijn Visser (Jira)
• [jira] [Commented] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail Martijn Visser (Jira)
• [jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown Martijn Visser (Jira)
• [jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• [jira] [Commented] (FLINK-38614) SinkV2ITCase.writerAndCommitterExecuteInStreamingModeWithScaling failed in test_cron_adaptive_scheduler tests Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• [jira] [Commented] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40961) Support NOTIFY_STATEFUL_SETS Timo Walther (Jira)
• [PR] [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins [flink] via GitHub
  • Re: [PR] [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins [flink] via GitHub
  • Re: [PR] [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins [flink] via GitHub
  • Re: [PR] [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins [flink] via GitHub
  • Re: [PR] [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins [flink] via GitHub
• [jira] [Updated] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Mika Naylor (Jira)
  • [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Rakesh kumar (Jira)
  • [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Rakesh kumar (Jira)
• [jira] [Created] (FLINK-41044) CommonDataStreamTests.test_logging_msg fails with external log debug-level msg not found Martijn Visser (Jira)
• [jira] [Commented] (FLINK-26563) HadoopS3RecoverableWriterITCase hang on azure Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)
• [jira] [Commented] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code Martijn Visser (Jira)
• [jira] [Commented] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• [jira] [Created] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
• [jira] [Created] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Martijn Visser (Jira)
• [jira] [Created] (FLINK-41046) HBaseConnectorITCase.testTableSinkDisabledBufferFlush expected [+I[1, 6]] but was [+I[1, 1]] Martijn Visser (Jira)
• [jira] [Created] (FLINK-41045) unning Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register Martijn Visser (Jira)
• [jira] [Created] (FLINK-41042) TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails in teardown with Boxed InterruptedException Martijn Visser (Jira)
• [jira] [Created] (FLINK-41041) Maven waits until the time budget after a JDK 8 surefire fork crashes with SIGSEGV in libjvm.so Martijn Visser (Jira)
• Re: [PR] [FLINK-40916][runtime] Add option to create checkpoint directories on first checkpoint [flink] via GitHub
  • Re: [PR] [FLINK-40916][runtime] Add option to create checkpoint directories on first checkpoint [flink] via GitHub
• [jira] [Assigned] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Gyula Fora (Jira)
• [jira] [Commented] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40584) Bound RocksDB prefix iterators to avoid scanning unrelated tombstones Yuepeng Pan (Jira)
• [I] [Bug][docs][api][java][python] MCP server example from YAML API is not runnable [flink-agents] via GitHub
  • Re: [I] [Bug][docs][api][java][python] MCP server example from YAML API is not runnable [flink-agents] via GitHub
• [PR] [FLINK-41040][state-processor-api] Fix binary row conversion [flink] via GitHub
  • Re: [PR] [FLINK-41040][state-processor-api] Fix binary row conversion [flink] via GitHub
  • Re: [PR] [FLINK-41040][state-processor-api] Fix binary row conversion [flink] via GitHub
  • Re: [PR] [FLINK-41040][state-processor-api] Fix binary row conversion [flink] via GitHub
• [PR] [docs] Fix non-runnable shared chat model example in the YAML API page [flink-agents] via GitHub
  • Re: [PR] [docs] Fix non-runnable shared chat model example in the YAML API page [flink-agents] via GitHub
• [jira] [Commented] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Muhammad (Jira)
  • [jira] [Commented] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Muhammad (Jira)
• Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink] via GitHub
  • Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink] via GitHub
  • Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink] via GitHub
  • Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink] via GitHub
  • Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink] via GitHub
  • Re: [PR] [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory [flink] via GitHub
• [PR] [release][dist] Build release artifacts with JDK 21 and keep JDK 21 classes in thin JARs [flink-agents] via GitHub
  • Re: [PR] [release][dist] Build release artifacts with JDK 21 and keep JDK 21 classes in thin JARs [flink-agents] via GitHub
  • Re: [PR] [release][dist] Build release artifacts with JDK 21 and keep JDK 21 classes in thin JARs [flink-agents] via GitHub
  • Re: [PR] [release][dist] Build release artifacts with JDK 21 and keep JDK 21 classes in thin JARs [flink-agents] via GitHub
• [jira] [Commented] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Manish (Jira)
  • [jira] [Commented] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Yaoxuan Wu (Jira)
• Re: [PR] [FLINK-40338][table-runtime] ELT() throws ClassCastException when index is not INT [flink] via GitHub
• [I] [Bug][runtime][java] Cancellation logs an uncaught IllegalStateException from ParallelExecutionLock [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][java] Cancellation logs an uncaught IllegalStateException from ParallelExecutionLock [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][java] Cancellation logs an uncaught IllegalStateException from ParallelExecutionLock [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][java] Cancellation logs an uncaught IllegalStateException from ParallelExecutionLock [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][java] Cancellation logs an uncaught IllegalStateException from ParallelExecutionLock [flink-agents] via GitHub
• [PR] [hotfix][plan] Upgrade tree-sitter to 0.26.6 [flink-agents] via GitHub
  • Re: [PR] [hotfix][plan] Upgrade tree-sitter to 0.26.6 [flink-agents] via GitHub
• [PR] [FLINK-37751][autoscaler] Add vertex name to the autoscaler scaling metrics [flink-kubernetes-operator] via GitHub
• Re: [PR] [FLINK-39844][postgres] Filter snapshot table columns by schema name to fix LIKE-wildcard cross-schema column leakage [flink-cdc] via GitHub
  • Re: [PR] [FLINK-39844][postgres] Filter snapshot table columns by schema name to fix LIKE-wildcard cross-schema column leakage [flink-cdc] via GitHub
• [I] [Bug][runtime][release] JDK 17 release builds omit the continuation runtime that Java ctx.chat needs on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][release] JDK 17 release builds omit the continuation runtime that Java ctx.chat needs on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][release] JDK 17 release builds omit the continuation runtime that Java ctx.chat needs on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][release] JDK 17 release builds omit the continuation runtime that Java ctx.chat needs on JDK 21 [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][release] JDK 17 release builds omit the continuation runtime that Java ctx.chat needs on JDK 21 [flink-agents] via GitHub
• Re: [I] [Tech Debt][Umbrella] Review and refine Flink Agents APIs for 0.4 [flink-agents] via GitHub
• [I] [runtime][python] Support TaskManager reuse across Flink Agents jobs [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40837) SavepointWriter#changeOperatorIdentifier drops the operator coordinator state Manish (Jira)
• Re: [PR] [FLINK-39899] Fix Flink SQL rowtime attributes after Window TVF [flink] via GitHub
• [I] [Bug][plan][java] The bash parser stays unusable after an interrupt during tree-sitter's first native library load [flink-agents] via GitHub
  • Re: [I] [Bug][plan][java] The bash parser stays unusable after an interrupt during tree-sitter's first native library load [flink-agents] via GitHub
  • Re: [I] [Bug][plan][java] The bash parser stays unusable after an interrupt during tree-sitter's first native library load [flink-agents] via GitHub
  • Re: [I] [Bug][plan][java] The bash parser stays unusable after an interrupt during tree-sitter's first native library load [flink-agents] via GitHub
• [PR] [hotfix][plan][java] Create the bash parser before BashToolTest interrupts its thread [flink-agents] via GitHub
  • Re: [PR] [hotfix][plan][java] Create the bash parser before BashToolTest interrupts its thread [flink-agents] via GitHub
  • Re: [PR] [hotfix][plan][java] Create the bash parser before BashToolTest interrupts its thread [flink-agents] via GitHub
• [PR] [release-0.3][hotfix][ci] Backport the MinIO image fix for Milvus tests [flink-agents] via GitHub
  • Re: [PR] [release-0.3][hotfix][ci] Backport the MinIO image fix for Milvus tests [flink-agents] via GitHub
• [PR] [runtime][python][docs] Fix multi-agent examples and clarify sub-agent usage [flink-agents] via GitHub
  • Re: [PR] [runtime][python][docs] Fix multi-agent examples and clarify sub-agent usage [flink-agents] via GitHub
• [PR] [release-0.3][hotfix][docs] Link example sources to the release branch [flink-agents] via GitHub
  • Re: [PR] [release-0.3][hotfix][docs] Link example sources to the release branch [flink-agents] via GitHub
• [PR] [docs] Fix release-branch source links and the Apple Silicon setup note [flink-agents] via GitHub
  • Re: [PR] [docs] Fix release-branch source links and the Apple Silicon setup note [flink-agents] via GitHub
• [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
  • Re: [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
  • Re: [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
  • Re: [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
  • Re: [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
  • Re: [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
  • Re: [PR] [docs] Improve consistency and configuration guidance [flink-agents] via GitHub
• [I] [Doc][Umbrella] Walk through documentation and validate documented functionality for 0.4 [flink-agents] via GitHub
  • Re: [I] [Doc][Umbrella] Walk through documentation and validate documented functionality for 0.4 [flink-agents] via GitHub
• [jira] [Updated] (FLINK-37751) Add vertex name to autoscaler metrics ASF GitHub Bot (Jira)
• [PR] [hotfix][docs] Fix grammar error in disaggregated state docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix grammar error in disaggregated state docs [flink] via GitHub
  • Re: [PR] [hotfix][docs] Fix grammar error in disaggregated state docs [flink] via GitHub
• [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated [flink] via GitHub
• [jira] [Created] (FLINK-41039) A projection on top of EXCEPT ALL or INTERSECT ALL is pushed into both inputs and changes the result Yaoxuan Wu (Jira)
• [jira] [Updated] (FLINK-41037) DISTINCT over a FULL OUTER JOIN drops a row when the grouping key is NULL (batch mode) Yaoxuan Wu (Jira)
• [PR] [hotfix][runtime-web] Restore metric chart height to 150 [flink] via GitHub
  • Re: [PR] [hotfix][runtime-web] Restore metric chart height to 150 [flink] via GitHub
• [jira] [Created] (FLINK-41038) WHERE CAST(x AS DECIMAL(10, 2)) IS NULL returns NULL for x when the cast overflows Yaoxuan Wu (Jira)
• [jira] [Closed] (FLINK-41023) Build English and Chinese PyFlink docs from one lockfile Dian Fu (Jira)
• [jira] [Created] (FLINK-41037) DISTINCT over a FULL OUTER JOIN drops a row when the grouping key is NULL (batch mode) Yaoxuan Wu (Jira)
• [jira] [Commented] (FLINK-34625) TTL doesn't seem to work in pyflink YifanWu (Jira)
  • [jira] [Commented] (FLINK-34625) TTL doesn't seem to work in pyflink YifanWu (Jira)
  • [jira] [Commented] (FLINK-34625) TTL doesn't seem to work in pyflink Dian Fu (Jira)
• Re: [PR] [FLINK-40942][fs/s3-native] Return directory status for bucket-root paths in NativeS3FileSystem#getFileStatus [flink] via GitHub
• [jira] [Created] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Biao Geng (Jira)
• [PR] [FLINK-41027][format/avro] Add an option to map time-millis and time-micros to INT and BIGINT [flink] via GitHub
  • Re: [PR] [FLINK-41027][format/avro] Add an option to map time-millis and time-micros to INT and BIGINT [flink] via GitHub
  • Re: [PR] [FLINK-41027][format/avro] Add an option to map time-millis and time-micros to INT and BIGINT [flink] via GitHub
• [jira] [Closed] (FLINK-40978) Cast from VARIANT through FromVariantConverter Timo Walther (Jira)
• [jira] [Created] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions Pritam Kumar (Jira)
• [jira] [Updated] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap Mohsen Rezaei (Jira)
  • [jira] [Updated] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-41036) [postgres-cdc] Restoring from a checkpoint taken inside a large transaction runs out of heap Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
• [jira] [Closed] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API Dian Fu (Jira)
• [jira] [Updated] (FLINK-41035) Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-41035) Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false Dennis-Mircea Ciupitu (Jira)
• [jira] [Assigned] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Martijn Visser (Jira)
• [PR] [FLINK-41035] Operator health probe reports "All informers are unhealthy" when a single event source fails with stop-on-informer-error=false [flink-kubernetes-operator] via GitHub
• [jira] [Commented] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Bonnie Varghese (Jira)
• [jira] [Updated] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
  • [jira] [Updated] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-41026) [format/avro] Convert timestamps above precision 3 as microseconds in both directions Gyula Fora (Jira)
• [jira] [Created] (FLINK-41034) Streaming joins store rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• [PR] [docs] Load pemja parent-first for PyFlink jobs on a session cluster [flink-agents] via GitHub
  • Re: [PR] [docs] Document the successive Python job limitation on a session cluster [flink-agents] via GitHub
• [jira] [Resolved] (FLINK-40046) Upgrade @antv/g2 to v5 Martijn Visser (Jira)
• [I] [Bug][runtime][python] Consecutive Python agent jobs fail to start on a session cluster when the dist JAR isn't in lib [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][python] Consecutive Python agent jobs fail to start on a session cluster when the dist JAR isn't in lib [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][python] Consecutive Python agent jobs fail to start on a session cluster when the dist JAR isn't in lib [flink-agents] via GitHub
  • Re: [I] [Bug][runtime][python] Consecutive Python agent jobs fail to start on a session cluster when the dist JAR isn't in lib [flink-agents] via GitHub
• [PR] [FLINK-41031] Close operator-owned resources on shutdown and exit on startup failure [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-41031) Close operator-owned resources on shutdown and exit on startup failure Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-41031) Close operator-owned resources on shutdown and exit on startup failure Dennis-Mircea Ciupitu (Jira)
  • [jira] [Updated] (FLINK-41031) Close operator-owned resources on shutdown and exit on startup failure ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-41022) Update lz4-java to 1.12.0 Martijn Visser (Jira)
• [jira] [Created] (FLINK-41033) Savepoint history cleanup disposes the savepoint referenced by status.jobStatus.upgradeSavepointPath, causing restore failures (FileNotFoundException) Saurabh Kanawade (Jira)
• Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40957][connect/mongodb] Fix MongoDB credential encoding for spaces [flink-cdc] via GitHub
• [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink] via GitHub
  • Re: [PR] [hotfix] [docs] fix links version errors.  hbase,kafka,upsert-kafka versions separated kafka 5.0.0-2.2 [flink] via GitHub
• [jira] [Updated] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-41032) PyFlink Table.to_pandas() loses column dtypes when the result is empty Biao Geng (Jira)
• [PR] [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas [flink] via GitHub
  • Re: [PR] [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas [flink] via GitHub
  • Re: [PR] [FLINK-41032][python] Preserve column dtypes when converting empty tables to pandas [flink] via GitHub
• [jira] [Updated] (FLINK-40957) MongoDB CDC encodes spaces as '+' instead of '%20' in credentials ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40961) Support NOTIFY_STATEFUL_SETS ASF GitHub Bot (Jira)

• Earlier messages
• Later messages