[jira] [Updated] (FLINK-35901) Setting web.submit.enable to false prevents FlinkSessionJobs from working

[ https://issues.apache.org/jira/browse/FLINK-35901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35901: -- Component/s: Kubernetes Operator > Setting web.submit.enable to false prevents

[jira] [Updated] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35499: -- Component/s: Runtime / Checkpointing > EventTimeWindowCheckpointingITCase times out due to

[jira] [Commented] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17868723#comment-17868723 ] Matthias Pohl commented on FLINK-35499: --- Test failure copied over from FLINK-35672:

[jira] [Closed] (FLINK-35672) testPreAggregatedSlidingTimeWindow failed due to due to checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-35672. - Resolution: Duplicate I'm closing this one as a duplicate of FLINK-35499 >

[jira] [Updated] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35499: -- Attachment: FLINK-35499.AdaptiveScheduler.log > EventTimeWindowCheckpointingITCase times out

[jira] [Commented] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17868721#comment-17868721 ] Matthias Pohl commented on FLINK-35499: --- Looks like FLINK-35672 and FLINK-35499 are related. As

[jira] [Updated] (FLINK-35672) testPreAggregatedSlidingTimeWindow failed due to due to checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35672: -- Attachment: FLINK-35672.log > testPreAggregatedSlidingTimeWindow failed due to due to

[jira] [Commented] (FLINK-35672) testPreAggregatedSlidingTimeWindow failed due to due to checkpoint expired before completing

[ https://issues.apache.org/jira/browse/FLINK-35672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17868720#comment-17868720 ] Matthias Pohl commented on FLINK-35672: --- The actual error seems to be the following stacktrace:

[jira] [Commented] (FLINK-34447) ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCountingAllocationTime still fails on slow machines

[ https://issues.apache.org/jira/browse/FLINK-34447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17866387#comment-17866387 ] Matthias Pohl commented on FLINK-34447: --- [~Weijie Guo] Can you verify my finding in [PR

[jira] [Updated] (FLINK-35828) NullArgumentException when accessing the checkpoint API concurrently

[ https://issues.apache.org/jira/browse/FLINK-35828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35828: -- Description: {code} 2024-07-12 16:53:02,664 TRACE

[jira] [Updated] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34672: -- Fix Version/s: (was: 2.0.0) > HA deadlock between JobMasterServiceLeadershipRunner and >

[jira] [Closed] (FLINK-35787) DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown)

[ https://issues.apache.org/jira/browse/FLINK-35787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-35787. - Resolution: Duplicate This is a duplicate of FLINK-34427. > DefaultSlotStatusSyncer might

[jira] [Resolved] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-35549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-35549. --- Resolution: Fixed > FLIP-461: Synchronize rescaling with checkpoint creation to minimize >

[jira] [Assigned] (FLINK-27355) JobManagerRunnerRegistry.localCleanupAsync does not call the JobManagerRunner.close method repeatedly

[ https://issues.apache.org/jira/browse/FLINK-27355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-27355: - Assignee: Kumar Mallikarjuna > JobManagerRunnerRegistry.localCleanupAsync does not

[jira] [Updated] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-35549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35549: -- Fix Version/s: 2.0.0 > FLIP-461: Synchronize rescaling with checkpoint creation to minimize

[jira] [Updated] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-35549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35549: -- Release Note: FLIP-461 enables the user to synchronize checkpointing and rescaling in the

[jira] [Resolved] (FLINK-35553) Integrate newly added trigger interface with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-35553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-35553. --- Fix Version/s: 2.0.0 Resolution: Fixed * master **

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17862844#comment-17862844 ] Matthias Pohl commented on FLINK-34227: --- {{WindowDeduplicateITCase}}:

[jira] [Resolved] (FLINK-35552) Move CheckpointStatsTracker out of ExecutionGraph into Scheduler

[ https://issues.apache.org/jira/browse/FLINK-35552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-35552. --- Fix Version/s: 2.0.0 Resolution: Fixed * master **

[jira] [Comment Edited] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17862668#comment-17862668 ] Matthias Pohl edited comment on FLINK-33211 at 7/3/24 7:35 AM: --- I revert

[jira] [Updated] (FLINK-35748) DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime with MiniBatch mode and RocksDB backend enabled

[ https://issues.apache.org/jira/browse/FLINK-35748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35748: -- Description:

[jira] [Updated] (FLINK-35748) DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime with MiniBatch mode and RocksDB backend enabled

[ https://issues.apache.org/jira/browse/FLINK-35748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35748: -- Attachment: failure.miniBatchMode.RocksDB.log

[jira] [Created] (FLINK-35748) DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime with MiniBatch mode and RocksDB backend enabled

Matthias Pohl created FLINK-35748: - Summary: DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime with MiniBatch mode and RocksDB backend enabled Key: FLINK-35748 URL:

[jira] [Comment Edited] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17862668#comment-17862668 ] Matthias Pohl edited comment on FLINK-33211 at 7/3/24 6:40 AM: --- I revert

[jira] [Reopened] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-33211: --- I revert

[jira] [Reopened] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-34487: --- Ok, I was wrong with my assumption that we don't need backports. The Python wheels are created

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17862484#comment-17862484 ] Matthias Pohl commented on FLINK-34582: --- The change was missed for the GitHub Actions. That was

[jira] [Resolved] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34487. --- Fix Version/s: 2.0.0 Resolution: Fixed * master:

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861194#comment-17861194 ] Matthias Pohl edited comment on FLINK-35042 at 7/1/24 3:18 PM: ---

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861194#comment-17861194 ] Matthias Pohl edited comment on FLINK-35042 at 7/1/24 3:16 PM: ---

[jira] [Commented] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server

[ https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861196#comment-17861196 ] Matthias Pohl commented on FLINK-34919: --- 2.0:

[jira] [Updated] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server

[ https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34919: -- Affects Version/s: 2.0.0 > WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861194#comment-17861194 ] Matthias Pohl edited comment on FLINK-35042 at 7/1/24 3:11 PM: ---

[jira] [Commented] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17861194#comment-17861194 ] Matthias Pohl commented on FLINK-35042: ---

[jira] [Commented] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

[ https://issues.apache.org/jira/browse/FLINK-35728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860863#comment-17860863 ] Matthias Pohl commented on FLINK-35728: --- Probably related infrastructure issue: FLINK-35727 >

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860862#comment-17860862 ] Matthias Pohl commented on FLINK-35727: --- Probably related infrastructure issue: FLINK-35728 >

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860861#comment-17860861 ] Matthias Pohl commented on FLINK-35727: ---

[jira] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727 ] Matthias Pohl deleted comment on FLINK-35727: --- was (Author: mapohl):

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860859#comment-17860859 ] Matthias Pohl commented on FLINK-35727: ---

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860857#comment-17860857 ] Matthias Pohl commented on FLINK-35727: ---

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860860#comment-17860860 ] Matthias Pohl commented on FLINK-35727: ---

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860856#comment-17860856 ] Matthias Pohl commented on FLINK-35727: ---

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860855#comment-17860855 ] Matthias Pohl commented on FLINK-35727: ---

[jira] [Commented] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

[ https://issues.apache.org/jira/browse/FLINK-35728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860854#comment-17860854 ] Matthias Pohl commented on FLINK-35728: ---

[jira] [Commented] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

[ https://issues.apache.org/jira/browse/FLINK-35728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860853#comment-17860853 ] Matthias Pohl commented on FLINK-35728: ---

[jira] [Commented] (FLINK-35562) WindowTableFunctionProcTimeRestoreTest produced no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-35562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860852#comment-17860852 ] Matthias Pohl commented on FLINK-35562: ---

[jira] [Created] (FLINK-35729) HiveITCase.testReadWriteHive

Matthias Pohl created FLINK-35729: - Summary: HiveITCase.testReadWriteHive Key: FLINK-35729 URL: https://issues.apache.org/jira/browse/FLINK-35729 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

Matthias Pohl created FLINK-35728: - Summary: PyFlink end-to-end test because miniconda couldn't be downloaded Key: FLINK-35728 URL: https://issues.apache.org/jira/browse/FLINK-35728 Project: Flink

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860848#comment-17860848 ] Matthias Pohl commented on FLINK-35727: ---

[jira] [Created] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

Matthias Pohl created FLINK-35727: - Summary: "Run kubernetes pyflink application test" failed due to access denied issue Key: FLINK-35727 URL: https://issues.apache.org/jira/browse/FLINK-35727

[jira] [Commented] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory

[ https://issues.apache.org/jira/browse/FLINK-25453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860817#comment-17860817 ] Matthias Pohl commented on FLINK-25453: --- {code} org.apache.flink.runtime.JobException: Recovery is

[jira] [Commented] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860782#comment-17860782 ] Matthias Pohl commented on FLINK-35722: --- We touched checkpointing as part of FLINK-35552. Only the

[jira] [Updated] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35722: -- Description: A test instability in

[jira] [Updated] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35722: -- Attachment: FLINK-35552.testCheckpoint.log >

[jira] [Updated] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35722: -- Attachment: logs-ci-test_ci_core-1719524892.zip >

[jira] [Created] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

Matthias Pohl created FLINK-35722: - Summary: CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event Key: FLINK-35722 URL:

[jira] [Commented] (FLINK-32312) SSLConnectionSocketFactory produced no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-32312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860731#comment-17860731 ] Matthias Pohl commented on FLINK-32312: ---

[jira] [Resolved] (FLINK-35551) Introduces RescaleManager#onTrigger endpoint

[ https://issues.apache.org/jira/browse/FLINK-35551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-35551. --- Fix Version/s: 2.0.0 Resolution: Fixed * master **

[jira] [Resolved] (FLINK-20398) Migrate test_batch_sql.sh

[ https://issues.apache.org/jira/browse/FLINK-20398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-20398. --- Fix Version/s: 2.0.0 Resolution: Fixed * master **

[jira] [Comment Edited] (FLINK-35550) Introduce new component RescaleManager

[ https://issues.apache.org/jira/browse/FLINK-35550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17860415#comment-17860415 ] Matthias Pohl edited comment on FLINK-35550 at 6/27/24 10:21 AM: - *

[jira] [Resolved] (FLINK-35550) Introduce new component RescaleManager

[ https://issues.apache.org/jira/browse/FLINK-35550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-35550. --- Fix Version/s: 2.0.0 Resolution: Fixed * master **

[jira] [Assigned] (FLINK-35552) Move CheckpointStatsTracker out of ExecutionGraph into Scheduler

[ https://issues.apache.org/jira/browse/FLINK-35552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-35552: - Assignee: Matthias Pohl > Move CheckpointStatsTracker out of ExecutionGraph into

[jira] [Assigned] (FLINK-35551) Introduces RescaleManager#onTrigger endpoint

[ https://issues.apache.org/jira/browse/FLINK-35551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-35551: - Assignee: Matthias Pohl > Introduces RescaleManager#onTrigger endpoint >

[jira] [Assigned] (FLINK-35553) Integrate newly added trigger interface with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-35553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-35553: - Assignee: Matthias Pohl > Integrate newly added trigger interface with checkpointing >

[jira] [Comment Edited] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856230#comment-17856230 ] Matthias Pohl edited comment on FLINK-35639 at 6/19/24 9:53 AM:

[jira] [Updated] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35639: -- Priority: Major (was: Blocker) > upgrade to 1.19 with job in HA state with restart strategy

[jira] [Closed] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-35639. - Resolution: Not A Problem I'm closing the issue and the related PRs because we're actually not

[jira] [Comment Edited] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856230#comment-17856230 ] Matthias Pohl edited comment on FLINK-35639 at 6/19/24 9:47 AM:

[jira] [Commented] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856230#comment-17856230 ] Matthias Pohl commented on FLINK-35639: --- [~chesnay] pointed me to the actual issue because I was

[jira] [Assigned] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-35639: - Assignee: Matthias Pohl > upgrade to 1.19 with job in HA state with restart strategy

[jira] [Comment Edited] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17855979#comment-17855979 ] Matthias Pohl edited comment on FLINK-35639 at 6/18/24 3:42 PM: I guess,

[jira] [Updated] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35639: -- Priority: Blocker (was: Major) > upgrade to 1.19 with job in HA state with restart strategy

[jira] [Updated] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35639: -- Affects Version/s: 1.20.0 > upgrade to 1.19 with job in HA state with restart strategy

[jira] [Commented] (FLINK-35639) upgrade to 1.19 with job in HA state with restart strategy crashes job manager

[ https://issues.apache.org/jira/browse/FLINK-35639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17855979#comment-17855979 ] Matthias Pohl commented on FLINK-35639: --- I guess, you're right. Looks like there was an error

[jira] [Comment Edited] (FLINK-35601) InitOutputPathTest.testErrorOccursUnSynchronized failed due to NoSuchFieldException

[ https://issues.apache.org/jira/browse/FLINK-35601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17855405#comment-17855405 ] Matthias Pohl edited comment on FLINK-35601 at 6/16/24 1:29 PM: This

[jira] [Commented] (FLINK-35601) InitOutputPathTest.testErrorOccursUnSynchronized failed due to NoSuchFieldException

[ https://issues.apache.org/jira/browse/FLINK-35601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17855406#comment-17855406 ] Matthias Pohl commented on FLINK-35601: --- [~gongzhongqiang] can you have a look? >

[jira] [Commented] (FLINK-35601) InitOutputPathTest.testErrorOccursUnSynchronized failed due to NoSuchFieldException

[ https://issues.apache.org/jira/browse/FLINK-35601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17855405#comment-17855405 ] Matthias Pohl commented on FLINK-35601: --- This seems to be caused by recently added [PR

[jira] [Commented] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854944#comment-17854944 ] Matthias Pohl commented on FLINK-35042: --- I noticed that the build failure in the description is

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854944#comment-17854944 ] Matthias Pohl edited comment on FLINK-35042 at 6/14/24 6:37 AM: I

[jira] [Commented] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854800#comment-17854800 ] Matthias Pohl commented on FLINK-35042: --- This is different to what [~Weijie Guo] observed in his

[jira] [Commented] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854801#comment-17854801 ] Matthias Pohl commented on FLINK-35042: --- I'm linking FLINK-34150 because we refactored the test to

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854789#comment-17854789 ] Matthias Pohl edited comment on FLINK-35042 at 6/13/24 4:16 PM:

[jira] [Commented] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17854789#comment-17854789 ] Matthias Pohl commented on FLINK-35042: ---

[jira] [Commented] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-35549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17853218#comment-17853218 ] Matthias Pohl commented on FLINK-35549: --- cc [~fanrui] I added the code change for FLIP-461. ...if

[jira] [Assigned] (FLINK-35550) Introduce new component RescaleManager

[ https://issues.apache.org/jira/browse/FLINK-35550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-35550: - Assignee: Matthias Pohl > Introduce new component RescaleManager >

[jira] [Assigned] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

[ https://issues.apache.org/jira/browse/FLINK-35549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-35549: - Assignee: Matthias Pohl > FLIP-461: Synchronize rescaling with checkpoint creation to

[jira] [Updated] (FLINK-35553) Integrate newly added trigger interface with checkpointing

[ https://issues.apache.org/jira/browse/FLINK-35553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35553: -- Description: This connects the newly introduced trigger logic (FLINK-35551) with the

[jira] [Created] (FLINK-35553) Integrate newly added trigger interface with checkpointing

Matthias Pohl created FLINK-35553: - Summary: Integrate newly added trigger interface with checkpointing Key: FLINK-35553 URL: https://issues.apache.org/jira/browse/FLINK-35553 Project: Flink

[jira] [Created] (FLINK-35552) Move CheckpointStatsTracker out of ExecutionGraph into Scheduler

Matthias Pohl created FLINK-35552: - Summary: Move CheckpointStatsTracker out of ExecutionGraph into Scheduler Key: FLINK-35552 URL: https://issues.apache.org/jira/browse/FLINK-35552 Project: Flink

[jira] [Created] (FLINK-35551) Introduces RescaleManager#onTrigger endpoint

Matthias Pohl created FLINK-35551: - Summary: Introduces RescaleManager#onTrigger endpoint Key: FLINK-35551 URL: https://issues.apache.org/jira/browse/FLINK-35551 Project: Flink Issue Type:

[jira] [Created] (FLINK-35550) Introduce new component RescaleManager

Matthias Pohl created FLINK-35550: - Summary: Introduce new component RescaleManager Key: FLINK-35550 URL: https://issues.apache.org/jira/browse/FLINK-35550 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35551) Introduces RescaleManager#onTrigger endpoint

[ https://issues.apache.org/jira/browse/FLINK-35551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35551: -- Component/s: Runtime / Coordination > Introduces RescaleManager#onTrigger endpoint >

[jira] [Created] (FLINK-35549) FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler

Matthias Pohl created FLINK-35549: - Summary: FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler Key: FLINK-35549 URL:

[jira] [Comment Edited] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode

[ https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852748#comment-17852748 ] Matthias Pohl edited comment on FLINK-35035 at 6/6/24 11:47 AM: Thanks

[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode

[ https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852748#comment-17852748 ] Matthias Pohl commented on FLINK-35035: --- Thanks for the pointer, [~dmvk]. We looked into this

[jira] [Commented] (FLINK-33278) RemotePekkoRpcActorTest.failsRpcResultImmediatelyIfRemoteRpcServiceIsNotAvailable fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-33278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852700#comment-17852700 ] Matthias Pohl commented on FLINK-33278: --- What are you seeing on Flink 1.18.x? Are you referring to

[jira] [Commented] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17852519#comment-17852519 ] Matthias Pohl commented on FLINK-34989: --- Quote from today's Infra roundtable: * The job

[jira] [Commented] (FLINK-35485) JobMaster failed with "the job xx has not been finished"

[ https://issues.apache.org/jira/browse/FLINK-35485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850600#comment-17850600 ] Matthias Pohl commented on FLINK-35485: --- Hi [~xccui], thanks for reporting the issue. Can you

[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17850387#comment-17850387 ] Matthias Pohl commented on FLINK-34513: --- * 1.20 (Java 8):

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849185#comment-17849185 ] Matthias Pohl commented on FLINK-34582: --- You're checking [~hxb]'s fork where the {{master}} branch

  1   2   3   4   5   6   7   8   9   10   >