[jira] [Commented] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453172#comment-17453172 ] Matthias commented on FLINK-24261: -- Timeout in topic deletion: https://dev.azure.com/m

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453171#comment-17453171 ] Matthias commented on FLINK-24341: -- A backport to 1.13 also caused this issue: [right a

[jira] [Updated] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24506: - Release Note: FLINK-19463 introduced a change in Flink 1.13+ where the configuration passed in through t

[jira] [Updated] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24506: - Release Note: FLINK-19463 introduced a change in Flink 1.13+ where the configuration passed in through t

[jira] [Updated] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24506: - Release Note: FLINK-19463 introduced a change in Flink 1.13+ where the configuration passed in through t

[jira] [Updated] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24341: - Description: I experienced a timeout in [this PR build|https://dev.azure.com/mapohl/flink/_build/result

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452810#comment-17452810 ] Matthias commented on FLINK-24341: -- And another build failure right after {{test_data_s

[jira] [Comment Edited] (FLINK-23152) Flink - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

[ https://issues.apache.org/jira/browse/FLINK-23152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369252#comment-17369252 ] Matthias edited comment on FLINK-23152 at 12/1/21, 12:34 PM: -

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451775#comment-17451775 ] Matthias commented on FLINK-24341: -- I checked the other build failures. The last tests

[jira] [Comment Edited] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451769#comment-17451769 ] Matthias edited comment on FLINK-24341 at 12/1/21, 12:26 PM: -

[jira] [Commented] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451769#comment-17451769 ] Matthias commented on FLINK-24341: -- https://dev.azure.com/mapohl/flink/_build/results?b

[jira] [Commented] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451622#comment-17451622 ] Matthias commented on FLINK-24506: -- Both, {{StreamPlanEnvironment}} and {{StreamContext

[jira] [Assigned] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-24506: Assignee: Matthias > checkpoint directory is not configurable through the Flink configuration >

[jira] [Updated] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-24506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24506: - Description: FLINK-19463 introduced the separation of {{StateBackend}} and {{{}CheckpointStorage{}}}. B

[jira] [Updated] (FLINK-25096) Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-25096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25096: - Fix Version/s: 1.15.0 1.14.1 1.13.4 > Issue in exceptions API(/job

[jira] [Assigned] (FLINK-25096) Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-25096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-25096: Assignee: Matthias > Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2 > -

[jira] [Updated] (FLINK-25096) Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-25096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25096: - Affects Version/s: 1.13.3 > Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2 > -

[jira] [Updated] (FLINK-25096) Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-25096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25096: - Affects Version/s: 1.14.0 > Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2 > -

[jira] [Updated] (FLINK-25096) Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2

[ https://issues.apache.org/jira/browse/FLINK-25096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25096: - Component/s: Runtime / Coordination > Issue in exceptions API(/jobs/:jobid/exceptions) in flink 1.13.2 >

[jira] [Updated] (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:all-tabpanel ] Matthias updated FLINK-25107: - Description: [GlueSchemaRegistryAvroKinesisITCase|https://github.com/apache/flink/blob/master/flink-end-

[jira] [Commented] (FLINK-23389) AWS Glue Schema Registry JSON support for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-23389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450945#comment-17450945 ] Matthias commented on FLINK-23389: -- I created FLINK-25107 to cover the test failure fix

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

Matthias created FLINK-25107: Summary: GlueSchemaRegistryAvroKinesisITCase and  GlueSchemaRegistryJsonKinesisITCase are skipped on AzureCI but fail when enabled Key: FLINK-25107 URL: https://issues.apache.org/jira/brow

[jira] [Comment Edited] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449678#comment-17449678 ] Matthias edited comment on FLINK-24573 at 11/26/21, 10:23 PM:

[jira] [Comment Edited] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449678#comment-17449678 ] Matthias edited comment on FLINK-24573 at 11/26/21, 10:20 PM:

[jira] [Updated] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24573: - Attachment: logs-ci_build-test_ci_build_core-1637952435.zip > ZooKeeperJobGraphsStoreITCase crashes JVM

[jira] [Commented] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449678#comment-17449678 ] Matthias commented on FLINK-24573: -- We experienced the same odd behavior on our Flink f

[jira] [Assigned] (FLINK-25080) FutureUtils is located in flink-core whereas the corresponding test is still located in flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-25080: Assignee: Matthias > FutureUtils is located in flink-core whereas the corresponding test is still

[jira] [Commented] (FLINK-25080) FutureUtils is located in flink-core whereas the corresponding test is still located in flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449539#comment-17449539 ] Matthias commented on FLINK-25080: -- FLINK-23085 moved {{FutureUtils}} into {{{}flink-co

[jira] [Created] (FLINK-25080) FutureUtils is located in flink-core whereas the corresponding test is still located in flink-runtime

Matthias created FLINK-25080: Summary: FutureUtils is located in flink-core whereas the corresponding test is still located in flink-runtime Key: FLINK-25080 URL: https://issues.apache.org/jira/browse/FLINK-25080

[jira] [Commented] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus

[ https://issues.apache.org/jira/browse/FLINK-11813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449015#comment-17449015 ] Matthias commented on FLINK-11813: -- FYI: [FLIP-194|https://cwiki.apache.org/confluence

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Release Note: 1.14.0 introduced a new dropdown menu to browse through concurrently failed Executions. Th

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Release Note: 1.14.0 introduced a new dropdown menu to browse through concurrently failed Executions in

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Release Note: 1.14.0 introduced a new dropdown menu to browse through concurrently failed {{Executions}}

[jira] [Comment Edited] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448986#comment-17448986 ] Matthias edited comment on FLINK-24261 at 11/25/21, 7:38 AM: -

[jira] [Updated] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24261: - Affects Version/s: 1.14.0 > KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic" > --

[jira] [Updated] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24261: - Attachment: mvn-1.FLINK-24261-vvp-flink-1.14-stream.log.gz > KafkaSourceITCase.testMultipleSplits fails

[jira] [Commented] (FLINK-24261) KafkaSourceITCase.testMultipleSplits fails due to "Cannot create topic"

[ https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448986#comment-17448986 ] Matthias commented on FLINK-24261: -- We experienced the same issue in our Flink Fork for

[jira] [Commented] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits

[ https://issues.apache.org/jira/browse/FLINK-25030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448437#comment-17448437 ] Matthias commented on FLINK-25030: -- FLINK-24261 and FLINK-25030 are related in a way th

[jira] [Updated] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits

[ https://issues.apache.org/jira/browse/FLINK-25030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25030: - Attachment: logs-ci_build-test_ci_build_kafka_gelly-1637699602.zip > Unexpected record in KafkaSourceITC

[jira] [Updated] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits

[ https://issues.apache.org/jira/browse/FLINK-25030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25030: - Description: We experienced a test failure in {{KafkaSourceITCase$IntegrationTests.testMultipleSplits}}

[jira] [Updated] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits

[ https://issues.apache.org/jira/browse/FLINK-25030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25030: - Description: We experienced a test failure in {{KafkaSourceITCase$IntegrationTests.testMultipleSplits}}

[jira] [Updated] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits

[ https://issues.apache.org/jira/browse/FLINK-25030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-25030: - Labels: test-stability (was: ) > Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSp

[jira] [Created] (FLINK-25030) Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits

Matthias created FLINK-25030: Summary: Unexpected record in KafkaSourceITCase$IntegrationTests.testMultipleSplits Key: FLINK-25030 URL: https://issues.apache.org/jira/browse/FLINK-25030 Project: Flink

[jira] [Comment Edited] (FLINK-24978) Upgrade ASM to 9.2

[ https://issues.apache.org/jira/browse/FLINK-24978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448018#comment-17448018 ] Matthias edited comment on FLINK-24978 at 11/23/21, 1:49 PM: -

[jira] [Commented] (FLINK-24978) Upgrade ASM to 9.2

[ https://issues.apache.org/jira/browse/FLINK-24978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448018#comment-17448018 ] Matthias commented on FLINK-24978: -- Doesn't the PR detection work on the {{apache/flink

[jira] [Updated] (FLINK-24934) Python CI job fails with exit code 143

[ https://issues.apache.org/jira/browse/FLINK-24934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24934: - Labels: test-stability (was: ) > Python CI job fails with exit code 143 > -

[jira] [Created] (FLINK-24934) Python CI job fails with exit code 143

Matthias created FLINK-24934: Summary: Python CI job fails with exit code 143 Key: FLINK-24934 URL: https://issues.apache.org/jira/browse/FLINK-24934 Project: Flink Issue Type: Bug Comp

[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444391#comment-17444391 ] Matthias commented on FLINK-24801: -- I'm linking FLINK-24433 and FLINK-24801 because the

[jira] [Comment Edited] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442637#comment-17442637 ] Matthias edited comment on FLINK-24348 at 11/12/21, 9:46 AM: -

[jira] [Updated] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24348: - Summary: Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed" (wa

[jira] [Commented] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442637#comment-17442637 ] Matthias commented on FLINK-24348: -- Failure of {{FlinkKafkaInternalProducerITCase}} cau

[jira] [Updated] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24348: - Affects Version/s: 1.15.0 > KafkaTableITCase fail with "ContainerLaunch Container startup failed" >

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Release Note: This fixes an issue where the dropdown menu for concurrent failures in the exception histo

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Description: FLINK-21867 introduced a new dropdown menu to browse through concurrently failed {{Executi

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Affects Version/s: (was: 1.15.0) > Dropdown menu is not properly shown in UI > -

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Description: FLINK-21867 introduced a new dropdown menu to browse through concurrently failed {{Executi

[jira] [Updated] (FLINK-24874) Dropdown menu is not properly shown in UI

[ https://issues.apache.org/jira/browse/FLINK-24874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24874: - Description: FLINK-21867 introduced a new dropdown menu to browse through concurrently failed {{Executi

[jira] [Created] (FLINK-24874) Dropdown menu is not properly shown in UI

Matthias created FLINK-24874: Summary: Dropdown menu is not properly shown in UI Key: FLINK-24874 URL: https://issues.apache.org/jira/browse/FLINK-24874 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already

[ https://issues.apache.org/jira/browse/FLINK-24789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24789: - Attachment: logs-ci_build-test_ci_build_finegrained_resource_management-1635785399.zip > IllegalStateEx

[jira] [Created] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already

Matthias created FLINK-24789: Summary: IllegalStateException with CheckpointCleaner being closed already Key: FLINK-24789 URL: https://issues.apache.org/jira/browse/FLINK-24789 Project: Flink Is

[jira] [Updated] (FLINK-24618) FlinkChillPackageRegistrar and PriorityQueueSerializer are located in wrong package

[ https://issues.apache.org/jira/browse/FLINK-24618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24618: - Description: We accidentally moved some Java classes into the wrong sub-directory as Alexey validly poi

[jira] [Created] (FLINK-24618) FlinkChillPackageRegistrar and PriorityQueueSerializer are located in wrong package

Matthias created FLINK-24618: Summary: FlinkChillPackageRegistrar and PriorityQueueSerializer are located in wrong package Key: FLINK-24618 URL: https://issues.apache.org/jira/browse/FLINK-24618 Project:

[jira] [Commented] (FLINK-24348) KafkaTableITCase fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17429217#comment-17429217 ] Matthias commented on FLINK-24348: -- Same issue was observed on VVP's Flink 1.14 fork:

[jira] [Assigned] (FLINK-24509) FlinkKafkaProducer example is not compiling due to incorrect constructer signature used

[ https://issues.apache.org/jira/browse/FLINK-24509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-24509: Assignee: Ali Bahadir Zeybek > FlinkKafkaProducer example is not compiling due to incorrect const

[jira] [Created] (FLINK-24506) checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment

Matthias created FLINK-24506: Summary: checkpoint directory is not configurable through the Flink configuration passed into the StreamExecutionEnvironment Key: FLINK-24506 URL: https://issues.apache.org/jira/browse/FL

[jira] [Updated] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest

[ https://issues.apache.org/jira/browse/FLINK-24505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24505: - Labels: test-stability (was: ) > org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnec

[jira] [Updated] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest

[ https://issues.apache.org/jira/browse/FLINK-24505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24505: - Affects Version/s: 1.14.0 > org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHa

[jira] [Comment Edited] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest

[ https://issues.apache.org/jira/browse/FLINK-24505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427058#comment-17427058 ] Matthias edited comment on FLINK-24505 at 10/11/21, 10:44 AM:

[jira] [Commented] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest

[ https://issues.apache.org/jira/browse/FLINK-24505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427058#comment-17427058 ] Matthias commented on FLINK-24505: -- Other tests have the same issue. > org.apache.flin

[jira] [Updated] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest

[ https://issues.apache.org/jira/browse/FLINK-24505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24505: - Attachment: logs-ci_build-test_ci_build_core-1632221898.zip > org.apache.flink.runtime.leaderelection.Zo

[jira] [Created] (FLINK-24505) org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest

Matthias created FLINK-24505: Summary: org.apache.flink.runtime.leaderelection.ZooKeeperLeaderRetrievalConnectionHandlingTest Key: FLINK-24505 URL: https://issues.apache.org/jira/browse/FLINK-24505 Projec

[jira] [Commented] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException

[ https://issues.apache.org/jira/browse/FLINK-23405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427057#comment-17427057 ] Matthias commented on FLINK-23405: -- This is a duplicate of FLINK-22821. I'm going to cl

[jira] [Closed] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException

[ https://issues.apache.org/jira/browse/FLINK-23405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-23405. Resolution: Duplicate > FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to > BindEx

[jira] [Comment Edited] (FLINK-20523) OffsetsInitializerTest test failed with "java.net.BindException: Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-20523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427054#comment-17427054 ] Matthias edited comment on FLINK-20523 at 10/11/21, 10:36 AM:

[jira] [Commented] (FLINK-20523) OffsetsInitializerTest test failed with "java.net.BindException: Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-20523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427054#comment-17427054 ] Matthias commented on FLINK-20523: -- All issues, FLINK-22821, FLINK-23405 and FLINK-2052

[jira] [Updated] (FLINK-24331) PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;"

[ https://issues.apache.org/jira/browse/FLINK-24331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24331: - Affects Version/s: 1.14.0 > PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx

[jira] [Updated] (FLINK-24331) PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;"

[ https://issues.apache.org/jira/browse/FLINK-24331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24331: - Attachment: logs-ci_build-test_ci_build_finegrained_resource_management-1633890853.zip > PartiallyFinis

[jira] [Commented] (FLINK-24331) PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;"

[ https://issues.apache.org/jira/browse/FLINK-24331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427043#comment-17427043 ] Matthias commented on FLINK-24331: -- We're experiencing this issue also on the VVP Flink

[jira] [Commented] (FLINK-24444) OperatorCoordinatorSchedulerTest#testGlobalFailoverDoesNotNotifyLocalRestore fails with IllegalState

[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427040#comment-17427040 ] Matthias commented on FLINK-2: -- We observed the same issue in the VVP fork of Flink

[jira] [Updated] (FLINK-24444) OperatorCoordinatorSchedulerTest#testGlobalFailoverDoesNotNotifyLocalRestore fails with IllegalState

[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-2: - Summary: OperatorCoordinatorSchedulerTest#testGlobalFailoverDoesNotNotifyLocalRestore fails with Illega

[jira] [Comment Edited] (FLINK-24444) OperatorCoordinatorSchedulerTest#testGlobalFailoverDoesNotNotifyLocalRestore fails with IllegalState

[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427039#comment-17427039 ] Matthias edited comment on FLINK-2 at 10/11/21, 9:42 AM: -

[jira] [Commented] (FLINK-24444) OperatorCoordinatorSchedulerTest#shutdownScheduler fails with IllegalState

[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427039#comment-17427039 ] Matthias commented on FLINK-2: -- The link to the build failure in the ticket descrip

[jira] [Commented] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427028#comment-17427028 ] Matthias commented on FLINK-24482: -- All build failures were observed under `release-1.1

[jira] [Comment Edited] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427027#comment-17427027 ] Matthias edited comment on FLINK-24482 at 10/11/21, 9:16 AM: -

[jira] [Updated] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24482: - Attachment: logs-ci_build-test_ci_build_kafka_gelly-1633289435.zip > KafkaShuffleTestBase.testMetrics fa

[jira] [Commented] (FLINK-24482) KafkaShuffleTestBase.testMetrics fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427027#comment-17427027 ] Matthias commented on FLINK-24482: -- This seems to be caused by failing to elect a leade

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417573#comment-17417573 ] Matthias commented on FLINK-15493: -- https://dev.azure.com/mapohl/flink/_build/results?b

[jira] [Updated] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24341: - Description: I experienced a timeout in [this PR build|https://dev.azure.com/mapohl/flink/_build/result

[jira] [Updated] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24341: - Description: I experienced a timeout in [this PR build|https://dev.azure.com/mapohl/flink/_build/result

[jira] [Updated] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24341: - Description: I experienced a timeout in [this PR build|https://dev.azure.com/mapohl/flink/_build/result

[jira] [Updated] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24341: - Description: I experienced a timeout in [this PR build|https://dev.azure.com/mapohl/flink/_build/result

[jira] [Created] (FLINK-24341) PyFlink Table test module timeout

Matthias created FLINK-24341: Summary: PyFlink Table test module timeout Key: FLINK-24341 URL: https://issues.apache.org/jira/browse/FLINK-24341 Project: Flink Issue Type: Bug Component

[jira] [Updated] (FLINK-24129) TopicRangeTest.rangeCreationHaveALimitedScope fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-24129: - Fix Version/s: 1.15.0 > TopicRangeTest.rangeCreationHaveALimitedScope fails on Azure > -

[jira] [Commented] (FLINK-24169) Flaky local YARN tests relying on log files

[ https://issues.apache.org/jira/browse/FLINK-24169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414153#comment-17414153 ] Matthias commented on FLINK-24169: -- [~mgergely] since it's related to FLINK-23611, I ju

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

[ https://issues.apache.org/jira/browse/FLINK-23611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414150#comment-17414150 ] Matthias commented on FLINK-23611: -- [~mgergely] Are these kind of rarer test instabilit

[jira] [Comment Edited] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlo

[ https://issues.apache.org/jira/browse/FLINK-23611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411793#comment-17411793 ] Matthias edited comment on FLINK-23611 at 9/8/21, 8:42 AM: --- I'

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

[ https://issues.apache.org/jira/browse/FLINK-23611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411793#comment-17411793 ] Matthias commented on FLINK-23611: -- I'm unassigning myself. Let's see whether we can ge

[jira] [Assigned] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots han

[ https://issues.apache.org/jira/browse/FLINK-23611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-23611: Assignee: (was: Matthias) > YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJo

[jira] [Commented] (FLINK-24147) HDFS lease issues on Flink retry

[ https://issues.apache.org/jira/browse/FLINK-24147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411055#comment-17411055 ] Matthias commented on FLINK-24147: -- Just for documentation purposes since the communica

[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=17410954#comment-17410954 ] Matthias commented on FLINK-23047: -- CassandraConnectorITCase.createTable https://dev.az

  1   2   3   4   5   6   7   8   9   10   >