issues  

Messages by Thread

• [PR] Bump @angular/compiler from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Updated] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Bowen Li (Jira)
• [jira] [Created] (FLINK-39940) DynamicKafkaSource should refresh restored cluster properties from KafkaMetadataService Bowen Li (Jira)
• [PR] Bump @angular/common from 20.1.3 to 20.3.22 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @angular/common from 20.1.3 to 20.3.22 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Closed] (FLINK-34921) SystemProcessingTimeServiceTest fails due to missing output Hao Li (Jira)
• [jira] [Closed] (FLINK-39879) CheckpointAcknowledgeFailureITCase.testCheckpointAckFailure never CompletableFuture and hangs on Complete Hao Li (Jira)
• [PR] Bump @angular/core from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
  • Re: [PR] Bump @angular/core from 20.1.3 to 20.3.25 in /flink-runtime-web/web-dashboard [flink] via GitHub
• [jira] [Comment Edited] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error Dennis-Mircea Ciupitu (Jira)
• [jira] [Commented] (FLINK-38116) Flink kubernetes operator RequestWatchProgress Error Dennis-Mircea Ciupitu (Jira)
• [jira] [Commented] (FLINK-38095) Error in Session Job autoscaler when realizing parallelism overrides Dennis-Mircea Ciupitu (Jira)
• Re: [PR] [BP-2.3][hotfix][runtime] Avoid duplicate serialization in adaptive broadcast [flink] via GitHub
• [jira] [Closed] (FLINK-39370) In-place scaling check only inspects K8s resource spec for adaptive scheduler, ignoring JM running configuration Dennis-Mircea Ciupitu (Jira)
• [jira] [Closed] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment Gyula Fora (Jira)
• [jira] [Updated] (FLINK-39935) Allow connectors to override lineage dataset name in TableLineageDatasetImpl Jaskaran Singh Kukreja (Jira)
• [jira] [Comment Edited] (FLINK-39935) Allow connectors to override lineage dataset name in TableLineageDatasetImpl Ketha Aravind (Jira)
• [jira] [Commented] (FLINK-39935) Allow connectors to override lineage dataset name in TableLineageDatasetImpl Ketha Aravind (Jira)
  • [jira] [Commented] (FLINK-39935) Allow connectors to override lineage dataset name in TableLineageDatasetImpl Jaskaran Singh Kukreja (Jira)
• [jira] [Commented] (FLINK-32119) Revise source partition skew logic Dennis-Mircea Ciupitu (Jira)
• [jira] [Assigned] (FLINK-39924) Memory fragmentation from jemalloc misconfiguration Roman Khachatryan (Jira)
• [jira] [Commented] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment Dennis-Mircea Ciupitu (Jira)
• [jira] [Updated] (FLINK-34195) PythonEnvUtils creates python environment instead of python3 ASF GitHub Bot (Jira)
• [PR] [FLINK-34195][python] Use python3 as the default Python executable [flink] via GitHub
  • Re: [PR] [FLINK-34195][python] Use python3 as the default Python executable [flink] via GitHub
• [jira] [Closed] (FLINK-31867) Enforce a minimum number of observations within a metric window Gyula Fora (Jira)
• [jira] [Commented] (FLINK-31867) Enforce a minimum number of observations within a metric window Dennis-Mircea Ciupitu (Jira)
• [PR] [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail [flink] via GitHub
  • Re: [PR] [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail [flink] via GitHub
  • Re: [PR] [FLINK-39929][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail [flink] via GitHub
• [jira] [Created] (FLINK-39939) FLIP-587: Expose per downstream target numRecordsOut metric Dennis-Mircea Ciupitu (Jira)
• [jira] [Created] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Dennis-Mircea Ciupitu (Jira)
• [PR] [FLINK-39679][table-planner] Fix implicit casts for PTF calls [flink] via GitHub
  • Re: [PR] [FLINK-39679][table-planner] Fix implicit casts for PTF calls [flink] via GitHub
  • Re: [PR] [FLINK-39679][table-planner] Fix implicit casts for PTF calls [flink] via GitHub
  • Re: [PR] [FLINK-39679][table-planner] Fix implicit casts for PTF calls [flink] via GitHub
• [jira] [Comment Edited] (FLINK-39923) RocksDB Statistics native memory leaks on state backend rebuild when ticker metrics are enabled Keith Lee (Jira)
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-pulsar] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-pulsar] via GitHub
• [jira] [Closed] (FLINK-39892) Exactly-once kafka sink reports a negative numBytesOut delta after every checkpoint Piotr Nowojski (Jira)
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-shared-utils] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-shared-utils] via GitHub
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-hive] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-hive] via GitHub
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-elasticsearch] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-elasticsearch] via GitHub
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-kafka] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-kafka] via GitHub
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-jdbc] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink-connector-jdbc] via GitHub
• Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink] via GitHub
  • Re: [PR] [INFRA] Set up default rulesets for default and release branches [flink] via GitHub
• [jira] [Commented] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume Roman Khachatryan (Jira)
• [jira] [Assigned] (FLINK-39778) Recoverable writer silently loses the in-flight tail on resume Roman Khachatryan (Jira)
• [PR] [BP-1.20][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-1.20][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
• [PR] [BP-2.0][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.0][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
• [PR] [BP-2.1][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.1][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
• [PR] [BP-2.2][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.2][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
• [PR] [BP-2.3][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-39933][ci] Use flink-ci-docker with jdk25 in ci [flink] via GitHub
• [jira] [Created] (FLINK-39937) Merge jobmanager and taskmanager into the same JVM melin (Jira)
• [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
  • Re: [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
  • Re: [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
  • Re: [PR] [FLINK-39936][dist] Add flink-s3-fs-native to flink-dist pom file [flink] via GitHub
• [jira] [Created] (FLINK-39936) Add flink-s3-fs-native to flink-dist pom file reswqa (Jira)
• [jira] [Updated] (FLINK-39936) Add flink-s3-fs-native to flink-dist pom file reswqa (Jira)
  • [jira] [Updated] (FLINK-39936) Add flink-s3-fs-native to flink-dist pom file reswqa (Jira)
  • [jira] [Updated] (FLINK-39936) Add flink-s3-fs-native to flink-dist pom file ASF GitHub Bot (Jira)
• [jira] [Resolved] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
• [PR] [docs] Fix typo in community page [flink-agents] via GitHub
  • Re: [PR] [docs] Fix typo in community page [flink-agents] via GitHub
• [jira] [Assigned] (FLINK-33653) Introduce a benchmark for balanced tasks scheduling Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed ASF GitHub Bot (Jira)
• [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink] via GitHub
  • Re: [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink] via GitHub
  • Re: [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink] via GitHub
• [jira] [Updated] (FLINK-39587) [Web dashboard] CI lint uses --cache and tolerates prettier drift on master ASF GitHub Bot (Jira)
• [PR] [FLINK-39587][runtime-web] Remove eslint cache from web dashboard lint [flink] via GitHub
  • Re: [PR] [FLINK-39587][runtime-web] Remove eslint cache from web dashboard lint [flink] via GitHub
• [jira] [Commented] (FLINK-39587) [Web dashboard] CI lint uses --cache and tolerates prettier drift on master Qiu Yanjun (Jira)
• [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
  • Re: [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
  • Re: [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
  • Re: [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
  • Re: [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
  • Re: [PR] [FLINK-39219] [table] Allow connectors to override lineage dataset name [flink] via GitHub
• [jira] [Commented] (FLINK-39572) Hide sensitive information when pyflink's beam runner is closed Qiu Yanjun (Jira)
• [jira] [Updated] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter ASF GitHub Bot (Jira)
• [PR] [FLINK-39893][metrics] Respect non-monotonic counters in OpenTelemetry reporter [flink] via GitHub
  • Re: [PR] [FLINK-39893][metrics] Respect non-monotonic counters in OpenTelemetry reporter [flink] via GitHub
• [jira] [Commented] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter Qiu Yanjun (Jira)
  • [jira] [Commented] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter Efrat Levitan (Jira)
  • [jira] [Commented] (FLINK-39893) Respect non-monotonic counter accumulation in openTelemetry reporter Efrat Levitan (Jira)
• [jira] [Created] (FLINK-39935) Allow connectors to override lineage dataset name in TableLineageDatasetImpl Jaskaran Singh Kukreja (Jira)
• [jira] [Updated] (FLINK-39510) Add Chinese translation about AI-assisted contributions ASF GitHub Bot (Jira)
• [PR] [FLINK-39510][docs-zh] Translate AI-assisted contribution guidance [flink-web] via GitHub
• [PR] [tools] Update install.sh Flink versions to current stable releases [flink-agents] via GitHub
  • Re: [PR] [tools] Update install.sh Flink versions to current stable releases [flink-agents] via GitHub
• Re: [PR] [FLINK-39219] [table] Support lineage extraction for DataStreamscan/sink providers [flink] via GitHub
• [jira] [Updated] (FLINK-39676) Add documentation for specifying Query Creators ASF GitHub Bot (Jira)
• [PR] [FLINK-39676][docs] Document HTTP query creator option [flink-connector-http] via GitHub
• [jira] [Assigned] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Yuepeng Pan (Jira)
• [PR] [docs] Refresh get-started overview for 0.3 features [flink-agents] via GitHub
  • Re: [PR] [docs] Refresh get-started overview for 0.3 features [flink-agents] via GitHub
  • Re: [PR] [docs] Refresh get-started overview for 0.3 features [flink-agents] via GitHub
• [jira] [Updated] (FLINK-39934) Postgres pipeline connector reports misleading table format error message ASF GitHub Bot (Jira)
• [PR] [FLINK-39934][postgres] Fix invalid tables format error message [flink-cdc] via GitHub
• [jira] [Created] (FLINK-39934) Postgres pipeline connector reports misleading table format error message Ran Tao (Jira)
• [jira] [Commented] (FLINK-39676) Add documentation for specifying Query Creators Qiu Yanjun (Jira)
• [jira] [Commented] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF Rion Williams (Jira)
• [jira] [Updated] (FLINK-39122) Decimals with incorrect precision lead to null value in PTF ASF GitHub Bot (Jira)
• [PR] [FLINK-39122][table] Reject out-of-range decimal constant arguments [flink] via GitHub
  • Re: [PR] [FLINK-39122][table] Reject out-of-range decimal constant arguments [flink] via GitHub
• [PR] [BP-2.3][hotfix][ci] Bump artifact-upload version [flink] via GitHub
  • Re: [PR] [BP-2.3][hotfix][ci] Bump artifact-upload version [flink] via GitHub
  • Re: [PR] [BP-2.3][hotfix][ci] Bump artifact-upload version [flink] via GitHub
  • Re: [PR] [BP-2.3][hotfix][ci] Bump artifact-upload version [flink] via GitHub
• [jira] [Updated] (FLINK-39933) Use docker with jdk25 in ci ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
  • [jira] [Updated] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
• [PR] [FLINK-39933][ci] Use docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [FLINK-39933][ci] Use docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [FLINK-39933][ci] Use docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [FLINK-39933][ci] Use docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [FLINK-39933][ci] Use docker with jdk25 in ci [flink] via GitHub
  • Re: [PR] [FLINK-39933][ci] Use docker with jdk25 in ci [flink] via GitHub
• [jira] [Resolved] (FLINK-39739) Add java25 to docker image Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-39933) Use docker with jdk25 in ci Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-39739) Add java25 to docker image Sergey Nuyanzin (Jira)
• Re: [I] [Feature] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
  • Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
  • Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
  • Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
  • Re: [PR] Add HTTP Connector 1.0 [flink-web] via GitHub
• Re: [PR] [hotfix] Ignore unused dependancies for snapshots [flink-connector-http] via GitHub
• Re: [PR] [FLINK-39588][flink-table][connector/datagen] Migrate the DataGen table connector off deprecated source APIs [flink] via GitHub
• Re: [PR] [FLINK-37155] [Runtime/Coordination] Implementing FLIP-505 for Flink History Server scalability improvements to decouple local and remote storage [flink] via GitHub
• [PR] [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. [flink] via GitHub
  • Re: [PR] [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. [flink] via GitHub
  • Re: [PR] [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. [flink] via GitHub
• [jira] [Updated] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Chanhae Oh (Jira)
  • [jira] [Updated] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-39921) Fix the flaky test case ExecutionTimeBasedSlowTaskDetectorTest due to unexepected ComponentMainThreadExecutor setting. Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Efrat Levitan (Jira)
  • [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Efrat Levitan (Jira)
  • [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Efrat Levitan (Jira)
• Re: [PR] [FLINK-38821] [metrics] Add TaskManager creation/deletion metrics [flink] via GitHub
• Re: [PR] [DRAFT][FLINK-34637][table] Migrate JoinConditionEqualityTransferRule to java [flink] via GitHub
• [jira] [Assigned] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution Yuepeng Pan (Jira)
• [jira] [Updated] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution Yuepeng Pan (Jira)
  • [jira] [Updated] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution Yuepeng Pan (Jira)
• [PR] [api] Remove dead no-arg getExecutionEnvironment() referencing a non-existent LocalExecutionEnvironment [flink-agents] via GitHub
  • Re: [PR] [api] Remove dead no-arg getExecutionEnvironment() referencing a non-existent LocalExecutionEnvironment [flink-agents] via GitHub
• [jira] [Commented] (FLINK-39932) [flink-datastream] Merging-Window onRecord Callback Receives Wrong Window Context in DataStream V2 Sameer Devgan (Jira)
• [jira] [Updated] (FLINK-39932) [flink-datastream] Merging-Window onRecord Callback Receives Wrong Window Context in DataStream V2 Sameer Devgan (Jira)
• [jira] [Created] (FLINK-39932) [flink-datastream] Merging-Window onRecord Callback Receives Wrong Window Context in DataStream V2 Sameer Devgan (Jira)
• [jira] [Created] (FLINK-39931) Fix flaky AdaptiveBatchSchedulerTest due to unexpected ComponentMainThreadExecutor behavior in async execution Chanhae Oh (Jira)
• [I] [Tech Debt] Java AgentsExecutionEnvironment no-arg getExecutionEnvironment() throws — dead reflective stub for a non-existent LocalExecutionEnvironment [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Java AgentsExecutionEnvironment no-arg getExecutionEnvironment() throws — dead reflective stub for a non-existent LocalExecutionEnvironment [flink-agents] via GitHub
• [PR] [python] Admit bytes in the Python memory value contract [flink-agents] via GitHub
• [jira] [Closed] (FLINK-39927) Update japicmp configuration post 2.1.3 Xintong Song (Jira)
• [jira] [Closed] (FLINK-39926) Update japicmp configuration post 1.20.5 Xintong Song (Jira)
• [jira] [Commented] (FLINK-39922) Fix the flaky test case AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39922) Fix the flaky test case AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Qiu Yanjun (Jira)
• [jira] [Created] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39919) Increase the timeout for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get stable Yuepeng Pan (Jira)
• [jira] [Comment Edited] (FLINK-39919) Increase the timeout for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get stable Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39919) Increase the timeout for SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown to get stable Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39918) KeyedComplexChainTest hangs until the CI watchdog kills the fork: AbstractOperatorRestoreTestBase waits ~2.7h for a job status that can never arrive Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Yuepeng Pan (Jira)
  • [jira] [Commented] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Chanhae Oh (Jira)
  • [jira] [Commented] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Chanhae Oh (Jira)
• [jira] [Created] (FLINK-39929) Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-39917) JobMasterTriggerSavepointITCase.testDoNotCancelJobIfSavepointFails: "Disconnect job manager" log assertion races the async JM->RM disconnect Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-39884) Free up additional disk space for CI runs Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-39914) Fix flaky TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD creation Yuepeng Pan (Jira)

• Earlier messages