[jira] [Updated] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25500: -- Affects Version/s: 1.13.5 (was: 1.15.0) >

[jira] [Reopened] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-25500: --- > ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange > failed on azure >

[jira] [Commented] (FLINK-25500) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477055#comment-17477055 ] Till Rohrmann commented on FLINK-25500: --- The test has not been disabled for {{1.13}}. Hence, I

[jira] [Commented] (FLINK-23946) Application mode fails fatally when being shut down

[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477054#comment-17477054 ] Till Rohrmann commented on FLINK-23946: --- Yes, it is missing backports to {{1.13}} and {{1.12}}. >

[jira] [Created] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

Till Rohrmann created FLINK-25675: - Summary: UnalignedCheckpointCompatibilityITCase.test hangs on AZP Key: FLINK-25675 URL: https://issues.apache.org/jira/browse/FLINK-25675 Project: Flink

[jira] [Comment Edited] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477040#comment-17477040 ] Till Rohrmann edited comment on FLINK-25667 at 1/17/22, 9:10 AM: -

[jira] [Updated] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25674: -- Affects Version/s: 1.14.0 (was: 1.15.0) >

[jira] [Created] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

Till Rohrmann created FLINK-25674: - Summary: CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP Key: FLINK-25674 URL: https://issues.apache.org/jira/browse/FLINK-25674

[jira] [Commented] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477046#comment-17477046 ] Till Rohrmann commented on FLINK-25674: --- [~echauchot], there seems to be another Cassandra test

[jira] [Commented] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477042#comment-17477042 ] Till Rohrmann commented on FLINK-25224: --- Once we have dropped the lower Hadoop versions, can we

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477041#comment-17477041 ] Till Rohrmann commented on FLINK-24119: --- Another instance for the {{KafkaITCase.testBigRecordJob}}

[jira] [Updated] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25673: -- Fix Version/s: (was: 1.15.0) >

[jira] [Created] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

Till Rohrmann created FLINK-25673: - Summary: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP Key: FLINK-25673 URL: https://issues.apache.org/jira/browse/FLINK-25673

[jira] [Commented] (FLINK-25648) Redundant to querying deployment when creating task manager pod

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477021#comment-17477021 ] Till Rohrmann commented on FLINK-25648: --- If it is easy to fix and improves the deployment time

[jira] [Closed] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-16478. - Resolution: Won't Do > add restApi to modify loglevel > --- > >

[jira] [Closed] (FLINK-10804) Transfer suppressed exceptions with SerializedThrowable

[ https://issues.apache.org/jira/browse/FLINK-10804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10804. - Fix Version/s: 1.15.0 Resolution: Fixed Fixed via

[jira] [Closed] (FLINK-25533) Preferred AllocationIDs are not respected when fulfilling pending slot requests

[ https://issues.apache.org/jira/browse/FLINK-25533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25533. - Resolution: Fixed Fixed via 4a98a10c931e4ff9750d38da5c260a35a54fb56a > Preferred AllocationIDs

[jira] [Assigned] (FLINK-10804) Transfer suppressed exceptions with SerializedThrowable

[ https://issues.apache.org/jira/browse/FLINK-10804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10804: - Assignee: Kirill Listopad > Transfer suppressed exceptions with SerializedThrowable >

[jira] [Updated] (FLINK-25659) LogicalRelDataTypeConverterTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-25659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25659: -- Affects Version/s: 1.15.0 > LogicalRelDataTypeConverterTest is flaky on Azure >

[jira] [Updated] (FLINK-25659) LogicalRelDataTypeConverterTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-25659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25659: -- Labels: pull-request-available test-stability (was: pull-request-available) >

[jira] [Commented] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476095#comment-17476095 ] Till Rohrmann commented on FLINK-24038: --- I've finalized the PR. It is ready for review now. >

[jira] [Updated] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24038: -- Labels: pull-request-available (was: pull-request-available stale-assigned) >

[jira] [Closed] (FLINK-24886) flink flame args bug, may we need to modify TimeUtils to supports m

[ https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24886. - Resolution: Fixed Fixed via 4cd0e396514a6efd7a180a3aea106124d919ebf4 > flink flame args bug,

[jira] [Assigned] (FLINK-24886) flink flame args bug, may we need to modify TimeUtils to supports m

[ https://issues.apache.org/jira/browse/FLINK-24886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-24886: - Assignee: jackylau > flink flame args bug, may we need to modify TimeUtils to supports

[jira] [Comment Edited] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475999#comment-17475999 ] Till Rohrmann edited comment on FLINK-25649 at 1/14/22, 7:30 AM: - cc

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475999#comment-17475999 ] Till Rohrmann commented on FLINK-25649: --- cc [~dmvk] > Scheduling jobs fails with >

[jira] [Closed] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22739. - Fix Version/s: 1.15.0 1.13.6 1.14.3 Resolution:

[jira] [Assigned] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException

[ https://issues.apache.org/jira/browse/FLINK-22739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-22739: - Assignee: Etienne Chauchot > CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail

[jira] [Closed] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-24844. - Fix Version/s: 1.13.6 1.14.3 Resolution: Fixed Fixed via FLINK-25147.

[jira] [Closed] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25165. - Fix Version/s: 1.15.0 1.13.6 1.14.3 Resolution:

[jira] [Assigned] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25165: - Assignee: Etienne Chauchot > CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink

[jira] [Assigned] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-24844: - Assignee: Etienne Chauchot > CassandraConnectorITCase.testCassandraBatchPojoFormat

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475284#comment-17475284 ] Till Rohrmann commented on FLINK-23047: --- Great news [~echauchot]! Thanks a lot for your help with

[jira] [Closed] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23047. - Resolution: Fixed Fixed via FLINK-25147. >

[jira] [Assigned] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-23047: - Assignee: Etienne Chauchot > CassandraConnectorITCase.testCassandraBatchTupleFormat

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475179#comment-17475179 ] Till Rohrmann commented on FLINK-25566: --- Are you sure that you are using Flink 1.10.0 [~Jiangang]?

[jira] [Created] (FLINK-25633) CPUResourceTest does not work with German Locale

Till Rohrmann created FLINK-25633: - Summary: CPUResourceTest does not work with German Locale Key: FLINK-25633 URL: https://issues.apache.org/jira/browse/FLINK-25633 Project: Flink Issue

[jira] [Updated] (FLINK-21177) Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management

[ https://issues.apache.org/jira/browse/FLINK-21177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21177: -- Fix Version/s: 1.13.0 > Introduce the counterpart of slotmanager.number-of-slots.max in

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474561#comment-17474561 ] Till Rohrmann commented on FLINK-25566: --- Are you sure that it fails in the {{onFatalError}}

[jira] [Commented] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474558#comment-17474558 ] Till Rohrmann commented on FLINK-23843: --- Sure [~echauchot]. You are now assigned. Happy coding :-)

[jira] [Assigned] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-23843: - Assignee: Etienne Chauchot (was: Stephan Ewen) > Exceptions during

[jira] [Commented] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader

[ https://issues.apache.org/jira/browse/FLINK-25053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474555#comment-17474555 ] Till Rohrmann commented on FLINK-25053: --- Great, thanks a lot [~wanglijie95]! > Document how to

[jira] [Commented] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader

[ https://issues.apache.org/jira/browse/FLINK-25053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474380#comment-17474380 ] Till Rohrmann commented on FLINK-25053: --- [~wanglijie95] are you still working on this issue? >

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472791#comment-17472791 ] Till Rohrmann commented on FLINK-25566: --- Hi [~Jiangang], for this specific

[jira] [Commented] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472599#comment-17472599 ] Till Rohrmann commented on FLINK-23843: --- Could we start by saying that an exception causes a job

[jira] [Commented] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472584#comment-17472584 ] Till Rohrmann commented on FLINK-25427: --- What are the TMs doing that should provide the slots? >

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472582#comment-17472582 ] Till Rohrmann commented on FLINK-25374: --- What is our plan for moving forward? Waiting to see how

[jira] [Closed] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25025. - Fix Version/s: (was: 1.14.3) Resolution: Cannot Reproduce >

[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472580#comment-17472580 ] Till Rohrmann commented on FLINK-25025: --- Ok, then let's close this ticket as cannot reproduce. >

[jira] [Commented] (FLINK-25584) Azure failed on install node and npm for Flink : Runtime web

[ https://issues.apache.org/jira/browse/FLINK-25584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472528#comment-17472528 ] Till Rohrmann commented on FLINK-25584: --- cc [~MartijnVisser], [~chesnay] > Azure failed on

[jira] [Commented] (FLINK-24946) KafkaSourceLegacyITCase.testBigRecordJob fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472318#comment-17472318 ] Till Rohrmann commented on FLINK-24946: --- Any updates [~fpaul]? >

[jira] [Commented] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472312#comment-17472312 ] Till Rohrmann commented on FLINK-25181: --- Did you have a chance to take a look at this issue

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472310#comment-17472310 ] Till Rohrmann commented on FLINK-23956: --- Any update on this ticket [~fpaul]? >

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472308#comment-17472308 ] Till Rohrmann commented on FLINK-23391: --- Any updates on this ticket [~renqs]? >

[jira] [Commented] (FLINK-25427) SavepointITCase.testTriggerSavepointAndResumeWithNoClaim fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472307#comment-17472307 ] Till Rohrmann commented on FLINK-25427: --- [~akalashnikov] do you have an update for this ticket? >

[jira] [Commented] (FLINK-25107) GlueSchemaRegistryAvroKinesisITCase and GlueSchemaRegistryJsonKinesisITCase are skipped on AzureCI but fail when enabled

[ https://issues.apache.org/jira/browse/FLINK-25107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472303#comment-17472303 ] Till Rohrmann commented on FLINK-25107: --- [~dannycranmer] do you think that you can finish the open

[jira] [Commented] (FLINK-25025) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-25025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472304#comment-17472304 ] Till Rohrmann commented on FLINK-25025: --- What's the state of this ticket [~hxbks2ks]? >

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

[ https://issues.apache.org/jira/browse/FLINK-25374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472302#comment-17472302 ] Till Rohrmann commented on FLINK-25374: --- Any updates on this ticket [~MartijnVisser]? > Azure

[jira] [Commented] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken

[ https://issues.apache.org/jira/browse/FLINK-25209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17472301#comment-17472301 ] Till Rohrmann commented on FLINK-25209: --- What is the state of this ticket [~lzljs3620320]? >

[jira] [Updated] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

[ https://issues.apache.org/jira/browse/FLINK-22602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22602: -- Priority: Critical (was: Minor) > Upgrade parquet to 1.12.0 due to CVEs >

[jira] [Commented] (FLINK-22602) Upgrade parquet to 1.12.0 due to CVEs

[ https://issues.apache.org/jira/browse/FLINK-22602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471795#comment-17471795 ] Till Rohrmann commented on FLINK-22602: --- Should we upgrade to 1.12.2? cc [~MartijnVisser] and

[jira] [Commented] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471791#comment-17471791 ] Till Rohrmann commented on FLINK-25564: --- I didn't try to reproduce it yet. Maybe a good step could

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470433#comment-17470433 ] Till Rohrmann commented on FLINK-25307: ---

[jira] [Created] (FLINK-25564) TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP

Till Rohrmann created FLINK-25564: - Summary: TaskManagerProcessFailureStreamingRecoveryITCase>AbstractTaskManagerProcessFailureRecoveryTest.testTaskManagerProcessFailure fails on AZP Key: FLINK-25564 URL:

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470430#comment-17470430 ] Till Rohrmann commented on FLINK-25307: ---

[jira] [Updated] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25307: -- Priority: Blocker (was: Critical) > Resuming Savepoint (hashmap, async, no parallelism

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470429#comment-17470429 ] Till Rohrmann commented on FLINK-25307: --- It looks to me that we broke something wrt

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470427#comment-17470427 ] Till Rohrmann commented on FLINK-25307: ---

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470424#comment-17470424 ] Till Rohrmann commented on FLINK-23944: --- Another instance:

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470426#comment-17470426 ] Till Rohrmann commented on FLINK-23944: --- [~syhily] can you take another look at the problem? >

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470422#comment-17470422 ] Till Rohrmann commented on FLINK-25307: ---

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470419#comment-17470419 ] Till Rohrmann commented on FLINK-25307: ---

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470421#comment-17470421 ] Till Rohrmann commented on FLINK-25307: ---

[jira] [Commented] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470418#comment-17470418 ] Till Rohrmann commented on FLINK-25181: --- cc [~fpaul] >

[jira] [Commented] (FLINK-25181) KafkaSourceITCase.testValueOnlyDeserializer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470417#comment-17470417 ] Till Rohrmann commented on FLINK-25181: ---

[jira] [Commented] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470415#comment-17470415 ] Till Rohrmann commented on FLINK-25307: --- Another instance:

[jira] [Updated] (FLINK-25307) Resuming Savepoint (hashmap, async, no parallelism change) end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25307: -- Fix Version/s: 1.15.0 1.13.6 1.14.3 > Resuming

[jira] [Created] (FLINK-25554) DistributedCacheDfsTest.testSubmittingJobViaRestClusterClient fails on AZP

Till Rohrmann created FLINK-25554: - Summary: DistributedCacheDfsTest.testSubmittingJobViaRestClusterClient fails on AZP Key: FLINK-25554 URL: https://issues.apache.org/jira/browse/FLINK-25554

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469766#comment-17469766 ] Till Rohrmann commented on FLINK-18356: --- Another instance:

[jira] [Updated] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18356: -- Fix Version/s: 1.13.6 1.14.3 > Exit code 137 returned from process >

[jira] [Created] (FLINK-25533) Preferred AllocationIDs are not respected when fulfilling pending slot requests

Till Rohrmann created FLINK-25533: - Summary: Preferred AllocationIDs are not respected when fulfilling pending slot requests Key: FLINK-25533 URL: https://issues.apache.org/jira/browse/FLINK-25533

[jira] [Assigned] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-25486: - Assignee: Liu > Perjob can not recover from checkpoint when zookeeper leader changes >

[jira] [Updated] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25486: -- Issue Type: Bug (was: Improvement) > Perjob can not recover from checkpoint when zookeeper

[jira] [Comment Edited] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469226#comment-17469226 ] Till Rohrmann edited comment on FLINK-25486 at 1/5/22, 11:38 AM: - Hi

[jira] [Updated] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25486: -- Fix Version/s: 1.15.0 1.13.6 1.14.3 > Perjob can not

[jira] [Updated] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25486: -- Component/s: Runtime / Coordination (was: Runtime / Checkpointing) >

[jira] [Updated] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25486: -- Affects Version/s: 1.14.2 1.13.5 1.15.0 >

[jira] [Commented] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469226#comment-17469226 ] Till Rohrmann commented on FLINK-25486: --- Hi [~Jiangang], thanks for reporting this issue. I think

[jira] [Updated] (FLINK-25486) Perjob can not recover from checkpoint when zookeeper leader changes

[ https://issues.apache.org/jira/browse/FLINK-25486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25486: -- Priority: Critical (was: Major) > Perjob can not recover from checkpoint when zookeeper

[jira] [Updated] (FLINK-25464) Python tests hangs on install dependencies

[ https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25464: -- Fix Version/s: 1.15.0 > Python tests hangs on install dependencies >

[jira] [Commented] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469119#comment-17469119 ] Till Rohrmann commented on FLINK-25523: --- cc [~fpaul] >

[jira] [Created] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP

Till Rohrmann created FLINK-25523: - Summary: KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP Key: FLINK-25523 URL: https://issues.apache.org/jira/browse/FLINK-25523 Project: Flink

[jira] [Commented] (FLINK-25464) Python tests hangs on install dependencies

[ https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469118#comment-17469118 ] Till Rohrmann commented on FLINK-25464: --- Another instance:

[jira] [Commented] (FLINK-25464) Python tests hangs on install dependencies

[ https://issues.apache.org/jira/browse/FLINK-25464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469117#comment-17469117 ] Till Rohrmann commented on FLINK-25464: --- Thanks for the updates [~hxbks2ks]. Hopefully, you find

[jira] [Commented] (FLINK-25522) KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryProcessingTime

[ https://issues.apache.org/jira/browse/FLINK-25522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469116#comment-17469116 ] Till Rohrmann commented on FLINK-25522: --- cc [~fpaul] >

[jira] [Created] (FLINK-25522) KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryProcessingTime

Till Rohrmann created FLINK-25522: - Summary: KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryProcessingTime Key: FLINK-25522 URL: https://issues.apache.org/jira/browse/FLINK-25522

[jira] [Updated] (FLINK-25519) Promote StreamExecutionEnvironment#fromSource() from @Experimental to next phase

[ https://issues.apache.org/jira/browse/FLINK-25519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25519: -- Priority: Blocker (was: Major) > Promote StreamExecutionEnvironment#fromSource() from

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24960: -- Priority: Critical (was: Major) >

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24960: -- Fix Version/s: 1.15.0 >

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468711#comment-17468711 ] Till Rohrmann commented on FLINK-24960: --- Another instance:

<    1   2   3   4   5   6   7   8   9   10   >