[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) > ZooKeeperLeaderElectionIT

[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&focusedCommentId=17477055#comment-17477055 ] Till Rohrmann commented on FLINK-25500: --- The test has not been disabled for {{1.13

[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&focusedCommentId=17477054#comment-17477054 ] Till Rohrmann commented on FLINK-23946: --- Yes, it is missing backports to {{1.13}}

[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 Is

[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&focusedCommentId=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) > CassandraConnectorITCase.

[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&focusedCommentId=17477046#comment-17477046 ] Till Rohrmann commented on FLINK-25674: --- [~echauchot], there seems to be another C

[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&focusedCommentId=17477042#comment-17477042 ] Till Rohrmann commented on FLINK-25224: --- Once we have dropped the lower Hadoop ver

[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&focusedCommentId=17477041#comment-17477041 ] Till Rohrmann commented on FLINK-24119: --- Another instance for the {{KafkaITCase.te

[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) > AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSav

[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&focusedCommentId=17477021#comment-17477021 ] Till Rohrmann commented on FLINK-25648: --- If it is easy to fix and improves the dep

[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 99a101ca0916d4dc90dcaebce16bf68b3895e54

[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) > LogicalRelDataT

[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&focusedCommentId=17476095#comment-17476095 ] Till Rohrmann commented on FLINK-24038: --- I've finalized the PR. It is ready for re

[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) > DispatcherResou

[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, ma

[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&focusedCommentId=17475999#comment-17475999 ] Till Rohrmann edited comment on FLINK-25649 at 1/14/22, 7:30 AM: -

[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&focusedCommentId=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: Fixe

[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 du

[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: Fixe

[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 fail

[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&focusedCommentId=17475284#comment-17475284 ] Till Rohrmann commented on FLINK-23047: --- Great news [~echauchot]! Thanks a lot for

[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. > CassandraConnectorITCase.testCassandraBatchTupleForm

[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 fai

[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&focusedCommentId=17475179#comment-17475179 ] Till Rohrmann commented on FLINK-25566: --- Are you sure that you are using Flink 1.1

[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 Type

[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 fine-g

[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&focusedCommentId=17474561#comment-17474561 ] Till Rohrmann commented on FLINK-25566: --- Are you sure that it fails in the {{onFat

[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&focusedCommentId=17474558#comment-17474558 ] Till Rohrmann commented on FLINK-23843: --- Sure [~echauchot]. You are now assigned.

[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 "SplitEnumeratorCon

[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&focusedCommentId=17474555#comment-17474555 ] Till Rohrmann commented on FLINK-25053: --- Great, thanks a lot [~wanglijie95]! > Do

[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&focusedCommentId=17474380#comment-17474380 ] Till Rohrmann commented on FLINK-25053: --- [~wanglijie95] are you still working on t

[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&focusedCommentId=17472791#comment-17472791 ] Till Rohrmann commented on FLINK-25566: --- Hi [~Jiangang], for this specific {{Class

[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&focusedCommentId=17472599#comment-17472599 ] Till Rohrmann commented on FLINK-23843: --- Could we start by saying that an exceptio

[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&focusedCommentId=17472584#comment-17472584 ] Till Rohrmann commented on FLINK-25427: --- What are the TMs doing that should provid

[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&focusedCommentId=17472582#comment-17472582 ] Till Rohrmann commented on FLINK-25374: --- What is our plan for moving forward? Wait

[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 > BatchArrowPythonGroupWind

[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&focusedCommentId=17472580#comment-17472580 ] Till Rohrmann commented on FLINK-25025: --- Ok, then let's close this ticket as canno

[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&focusedCommentId=17472528#comment-17472528 ] Till Rohrmann commented on FLINK-25584: --- cc [~MartijnVisser], [~chesnay] > Azure

[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&focusedCommentId=17472318#comment-17472318 ] Till Rohrmann commented on FLINK-24946: --- Any updates [~fpaul]? > KafkaSourceLegac

[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&focusedCommentId=17472312#comment-17472312 ] Till Rohrmann commented on FLINK-25181: --- Did you have a chance to take a look at t

[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&focusedCommentId=17472310#comment-17472310 ] Till Rohrmann commented on FLINK-23956: --- Any update on this ticket [~fpaul]? > Ka

[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&focusedCommentId=17472308#comment-17472308 ] Till Rohrmann commented on FLINK-23391: --- Any updates on this ticket [~renqs]? > K

[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&focusedCommentId=17472307#comment-17472307 ] Till Rohrmann commented on FLINK-25427: --- [~akalashnikov] do you have an update for

[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&focusedCommentId=17472303#comment-17472303 ] Till Rohrmann commented on FLINK-25107: --- [~dannycranmer] do you think that you can

[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&focusedCommentId=17472304#comment-17472304 ] Till Rohrmann commented on FLINK-25025: --- What's the state of this ticket [~hxbks2k

[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&focusedCommentId=17472302#comment-17472302 ] Till Rohrmann commented on FLINK-25374: --- Any updates on this ticket [~MartijnVisse

[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&focusedCommentId=17472301#comment-17472301 ] Till Rohrmann commented on FLINK-25209: --- What is the state of this ticket [~lzljs3

[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&focusedCommentId=17471795#comment-17471795 ] Till Rohrmann commented on FLINK-22602: --- Should we upgrade to 1.12.2? cc [~Martij

[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&focusedCommentId=17471791#comment-17471791 ] Till Rohrmann commented on FLINK-25564: --- I didn't try to reproduce it yet. Maybe a

[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&focusedCommentId=17470433#comment-17470433 ] Till Rohrmann commented on FLINK-25307: --- https://dev.azure.com/apache-flink/apache

[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: https:/

[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&focusedCommentId=17470430#comment-17470430 ] Till Rohrmann commented on FLINK-25307: --- https://dev.azure.com/apache-flink/apache

[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 change

[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&focusedCommentId=17470429#comment-17470429 ] Till Rohrmann commented on FLINK-25307: --- It looks to me that we broke something wr

[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&focusedCommentId=17470427#comment-17470427 ] Till Rohrmann commented on FLINK-25307: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17470424#comment-17470424 ] Till Rohrmann commented on FLINK-23944: --- Another instance: https://dev.azure.com/

[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&focusedCommentId=17470426#comment-17470426 ] Till Rohrmann commented on FLINK-23944: --- [~syhily] can you take another look at th

[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&focusedCommentId=17470422#comment-17470422 ] Till Rohrmann commented on FLINK-25307: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17470419#comment-17470419 ] Till Rohrmann commented on FLINK-25307: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17470421#comment-17470421 ] Till Rohrmann commented on FLINK-25307: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17470418#comment-17470418 ] Till Rohrmann commented on FLINK-25181: --- cc [~fpaul] > KafkaSourceITCase.testValu

[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&focusedCommentId=17470417#comment-17470417 ] Till Rohrmann commented on FLINK-25181: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17470415#comment-17470415 ] Till Rohrmann commented on FLINK-25307: --- Another instance: https://dev.azure.com/

[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 Savepoint

[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 Project:

[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&focusedCommentId=17469766#comment-17469766 ] Till Rohrmann commented on FLINK-18356: --- Another instance: https://dev.azure.com/

[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 Pro

[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 le

[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&focusedCommentId=17469226#comment-17469226 ] Till Rohrmann edited comment on FLINK-25486 at 1/5/22, 11:38 AM: -

[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 rec

[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) > Perj

[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 > Perjob

[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&focusedCommentId=17469226#comment-17469226 ] Till Rohrmann commented on FLINK-25486: --- Hi [~Jiangang], thanks for reporting this

[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 leade

[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&focusedCommentId=17469119#comment-17469119 ] Till Rohrmann commented on FLINK-25523: --- cc [~fpaul] > KafkaSourceITCase$KafkaSpe

[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&focusedCommentId=17469118#comment-17469118 ] Till Rohrmann commented on FLINK-25464: --- Another instance: https://dev.azure.com/

[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&focusedCommentId=17469117#comment-17469117 ] Till Rohrmann commented on FLINK-25464: --- Thanks for the updates [~hxbks2ks]. Hopef

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

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

[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 @Experi

[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) > YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectl

[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 > YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobMana

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

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

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