issues  

Messages by Thread

• • Re: [PR] [FLINK-40949][table-runtime] Update UnsliceAssigners NULL window exception message [flink] via GitHub
• [jira] [Commented] (FLINK-41042) TaskExecutorTest.testHeartbeatTimeoutWithJobManager fails in teardown with Boxed InterruptedException Yahya Kisana (Jira)
• Re: [PR] [FLINK-40776][table-runtime] Cache query-parameter pattern in PARSE_URL [flink] via GitHub
• Re: [PR] [FLINK-40962][table-planner] expose LEAD(TIMESTAMP_LTZ)/LAG(TIMESTAMP_LTZ) in batch mode [flink] via GitHub
• Re: [PR] [FLINK-40501][datastream] Keep watermark status ordered with queued watermarks in AsyncWaitOperator [flink] via GitHub
• [jira] [Commented] (FLINK-41047) SqsSinkWriterTest.getNumRecordsOutErrorsCounterRecordsCorrectNumberOfFailures gets a connection acquire timeout instead of Connection refused Yahya Kisana (Jira)
• [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
  • Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
  • Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
  • Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
  • Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
  • Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
  • Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
• [jira] [Updated] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] via GitHub
  • Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] via GitHub
  • Re: [PR] [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON [flink] via GitHub
• [jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_GET` and `TRY_VARIANT_GET ` to extract values from a variant Ramin Gharib (Jira)
• [jira] [Created] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-41051) JDBC Table source and lookup function derive the lineage dataset name by parsing SQL Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40378) Support GROUP BY position, ORDER BY ALL, and GROUP BY ALL in Flink SQL ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check ASF GitHub Bot (Jira)
• [jira] [Commented] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure Martijn Visser (Jira)
• [jira] [Created] (FLINK-41052) Helm chart: recreate the operator pod on ConfigMap changes and support annotations on the operator Deployment Gerk Elznik (Jira)
• [jira] [Assigned] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys Ferenc Csaky (Jira)
• [jira] [Updated] (FLINK-40997) Regular join picks a random state key among equal-length upsert keys Ferenc Csaky (Jira)
• [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
  • Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
  • Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
  • Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
  • Re: [PR] [FLINK-40977][state/forst] Complete JUnit 5 migration of flink-statebackend-forst [flink] via GitHub
• [jira] [Updated] (FLINK-40977) ForSt JUnit 5 migration is incomplete ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40916) Optionally skip eager initialisation of checkpoint locations Martijn Visser (Jira)
• [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Purushottam Sinha (Jira)
  • [jira] [Commented] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Naveen Joseph (Jira)
• [jira] [Created] (FLINK-41055) StreamingMultiJoinOperator stores rows with a NULL join key in state, even though they can never match Rion Williams (Jira)
• Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] via GitHub
  • Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] via GitHub
  • Re: [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] via GitHub
• [jira] [Commented] (FLINK-36299) AdaptiveSchedulerTest.testStatusMetrics times out Martijn Visser (Jira)
• [jira] [Resolved] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
• [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
  • Re: [PR] [FLINK-37987][jdbc] Migrate JdbcDynamicTableSink to Sink V2 [flink-connector-jdbc] via GitHub
• [jira] [Updated] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2 ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-41048) MiniClusterJobEntryPointITCase.restartResumesJobFromLatestCheckpoint fails to bind the REST port on restart ASF GitHub Bot (Jira)
• [jira] [Reopened] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-40596) Closing metric might lead to a number of test failure Martijn Visser (Jira)
• [jira] [Created] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Diljeet Singh (Jira)
• [jira] [Commented] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Diljeet Singh (Jira)
  • [jira] [Commented] (FLINK-41054) Metrics of finished source splits are never removed from the REST API's metric store Diljeet Singh (Jira)
• Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
  • Re: [PR] [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe [flink] via GitHub
• [jira] [Updated] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed Martijn Visser (Jira)
• [jira] [Commented] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
• [PR] [runtime][java] Keep worker lock ownership when an async call leaves the interrupt flag set [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Keep worker lock ownership when an async call leaves the interrupt flag set [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Keep worker lock ownership when an async call leaves the interrupt flag set [flink-agents] via GitHub
  • Re: [PR] [runtime][java] Keep worker lock ownership when an async call leaves the interrupt flag set [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40887) TaskFailureITCase.testJobWithoutObjectReuse fails with "Expecting Optional to contain a value but it was empty" Martijn Visser (Jira)
• [jira] [Reopened] (FLINK-40958) VARIANT might fail with StackOverflow Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40953) Store the native S3 recoverable writer tail under the target directory Samrat Deb (Jira)
• [jira] [Created] (FLINK-41040) State-Processing SQL reader fails to convert BinaryRowData Muhammad (Jira)
• [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• [jira] [Commented] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently sepuri sai krishna (Jira)
• [jira] [Updated] (FLINK-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-40743][jdbc] Fix the Table sink's empty lineage dataset name [flink-connector-jdbc] via GitHub
• Re: [PR] [FLINK-36297][state] Wait for the periodic materialization scheduler to terminate on close [flink] via GitHub
• [PR] [FLINK-40791][metrics] Expect the counter delta in OpenTelemetryMetricReporterITCase.testCounterDelta [flink] via GitHub
  • Re: [PR] [FLINK-40791][metrics] Expect the counter delta in OpenTelemetryMetricReporterITCase.testCounterDelta [flink] via GitHub
• [jira] [Created] (FLINK-41043) NettyShuffleMaster.registerJob fails with "HashMap$Node cannot be cast to HashMap$TreeNode" when jobs start concurrently Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41052) Helm chart: recreate the operator pod on ConfigMap changes and support annotations on the operator Deployment Gerk Elznik (Jira)
• [jira] [Created] (FLINK-41053) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint cannot find chk-1 on restore on release-1.20 Martijn Visser (Jira)
• [jira] [Commented] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• [jira] [Commented] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown. Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown. Martijn Visser (Jira)
• [jira] [Updated] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator ASF GitHub Bot (Jira)
• [PR] [FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-41050] Canary health checks revert canary metadata changes and restart a healthy operator [flink-kubernetes-operator] via GitHub
• [jira] [Resolved] (FLINK-40743) JDBC Table sink reports an empty lineage dataset name Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40743) JDBC Table sink reports an empty lineage dataset name Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40743) JDBC Table sink reports an empty lineage dataset name Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40069) OpenTelemetryMetricReporterProtocolTest fails with "No content to map due to end-of-input" due to OTel collector readiness race Martijn Visser (Jira)
• [jira] [Created] (FLINK-41050) Canary health checks revert canary metadata changes and restart a healthy operator Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-41045) 'Running Kerberized YARN application on Docker test (custom fs plugin)' fails with NoResourceAvailableException because two of three TaskManager containers never register Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Mateusz Barnacki (Jira)
  • [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Mateusz Barnacki (Jira)
  • [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• [jira] [Commented] (FLINK-40325) Support Kafka as a CDC Source Connector in Flink CDC Pipeline Andrew Otto (Jira)
• [jira] [Commented] (FLINK-35284) Streaming File Sink end-to-end test times out Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40596) Closing metric might lead to a number of test failure Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40596) Closing metric might lead to a number of test failure Martijn Visser (Jira)
• [jira] (FLINK-24743) New File Sink end-to-end test fails on Azure Martijn Visser (Jira)
• [jira] [Updated] (FLINK-24743) New File Sink end-to-end test fails on Azure Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-24743) New File Sink end-to-end test fails on Azure Martijn Visser (Jira)
• [jira] [Commented] (FLINK-24743) New File Sink end-to-end test fails on Azure Martijn Visser (Jira)
  • [jira] [Commented] (FLINK-24743) New File Sink end-to-end test fails on Azure Martijn Visser (Jira)
• [jira] [Updated] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Martijn Visser (Jira)
• [jira] [Created] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Martijn Visser (Jira)
• [jira] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Martijn Visser (Jira)
• Re: [PR] [FLINK-34427][runtime] Pending tasks should be canceled if slot manager is closed [flink] via GitHub
  • Re: [PR] [FLINK-34427][runtime] Pending tasks should be canceled if slot manager is closed [flink] via GitHub
  • Re: [PR] [FLINK-34427][runtime] Pending tasks should be canceled if slot manager is closed [flink] via GitHub
• [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
  • 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
  • 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-40958) VARIANT might fail with StackOverflow 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-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 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-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-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-40804) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint fails with "Exceeded checkpoint tolerable failure threshold" Martijn Visser (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-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-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)
• Re: [I] [Doc] Improve consistency, Action State Store, and configuration guidance [flink-agents] via GitHub
• [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] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (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-40793) DefaultSchedulerTest is unstable across many test methods Martijn Visser (Jira)

• Earlier messages
• Later messages