[jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Parent: (was: FLINK-20112) Issue Type: Bug (was: Sub-task) > Fix a few

[jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Summary: Fix a few KafkaSource-related bugs (was: Test Kafka Source based on the new Source API 

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18952: Parent: (was: FLINK-18761) Issue Type: Improvement (was: Sub-task) > Add 10 minutes

[jira] [Resolved] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22479. - Resolution: Fixed > [Kinesis][Consumer] Potential lock-up under error condition >

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22479: Fix Version/s: 1.13.1 > [Kinesis][Consumer] Potential lock-up under error condition >

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21693: Fix Version/s: (was: 1.12.4) 1.12.5 > TestStreamEnvironment does not

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21711: Fix Version/s: (was: 1.12.4) 1.12.5 > DataStreamSink doesn't allow setting

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21876: Fix Version/s: (was: 1.12.4) 1.12.5 > Handle it properly when the returned

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20687: Fix Version/s: (was: 1.12.4) 1.12.5 > Missing 'yarn-application' target in

[jira] [Updated] (FLINK-22564) Kubernetes-related ITCases do not fail even in case of failure

[ https://issues.apache.org/jira/browse/FLINK-22564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22564: Fix Version/s: (was: 1.12.4) 1.12.5 > Kubernetes-related ITCases do not

[jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22040: Fix Version/s: (was: 1.12.4) 1.12.5 > Maven: Entry has not been leased

[jira] [Updated] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

[ https://issues.apache.org/jira/browse/FLINK-22434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22434: Fix Version/s: (was: 1.12.4) 1.12.5 > Dispatcher does not store suspended

[jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20777: Fix Version/s: (was: 1.12.4) 1.12.5 > Default value of property

[jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

[ https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21589: Fix Version/s: (was: 1.12.4) 1.12.5 > Document Table/SQL API limitations

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20849: Fix Version/s: (was: 1.12.4) 1.12.5 > Improve JavaDoc and logging of new

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21445: Fix Version/s: (was: 1.12.4) 1.12.5 > Application mode does not set the

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20656: Fix Version/s: (was: 1.12.4) 1.12.5 > Update docs for new KafkaSource

[jira] [Updated] (FLINK-22494) Avoid discarding checkpoints in case of failure

[ https://issues.apache.org/jira/browse/FLINK-22494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22494: Fix Version/s: (was: 1.12.4) 1.12.5 > Avoid discarding checkpoints in case

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20457: Fix Version/s: (was: 1.12.4) 1.12.5 > Fix the handling of timestamp in

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20655: Fix Version/s: (was: 1.12.4) 1.12.5 > Add E2E tests to the new KafkaSource

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22282: Fix Version/s: (was: 1.12.4) 1.12.5 > Move creation of SplitEnumerator to

[jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19925: Fix Version/s: (was: 1.12.4) 1.12.5 > Errors$NativeIoException:

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20576: Fix Version/s: (was: 1.12.4) 1.12.5 > Flink Temporal Join Hive Dim Error >

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20431: Fix Version/s: (was: 1.12.4) 1.12.5 >

[jira] [Updated] (FLINK-19743) Add Source metrics definitions

[ https://issues.apache.org/jira/browse/FLINK-19743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19743: Fix Version/s: (was: 1.12.4) 1.12.5 > Add Source metrics definitions >

[jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20379: Fix Version/s: (was: 1.12.4) 1.12.5 > Update

[jira] [Updated] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently

[ https://issues.apache.org/jira/browse/FLINK-22502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22502: Fix Version/s: (was: 1.12.4) 1.12.5 > DefaultCompletedCheckpointStore

[jira] [Resolved] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-17170. - Fix Version/s: 1.12.4 1.13.1 1.14.0 Resolution:

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341570#comment-17341570 ] Arvid Heise commented on FLINK-17170: - Merged into master as

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340890#comment-17340890 ] Arvid Heise commented on FLINK-17170: - Merged into 1.13 as

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340239#comment-17340239 ] Arvid Heise commented on FLINK-17170: - Merged into 1.12 as 1de3d6345a4132dda4b31f66275fb732afe3ef30.

[jira] [Commented] (FLINK-22566) Running Kerberized YARN application on Docker test (default input) fails with no resources

[ https://issues.apache.org/jira/browse/FLINK-22566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340237#comment-17340237 ] Arvid Heise commented on FLINK-22566: - I disabled the tests in 1.12 with

[jira] [Resolved] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22573. - Resolution: Fixed > AsyncIO can timeout elements after completion >

[jira] [Updated] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22573: Fix Version/s: 1.12.4 1.13.1 1.14.0 > AsyncIO can timeout

[jira] [Commented] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340014#comment-17340014 ] Arvid Heise commented on FLINK-22573: - Merged into 1.12 as 41dc5871d76e913bad9be59d65e2bb26d67fec15

[jira] [Commented] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339861#comment-17339861 ] Arvid Heise commented on FLINK-22573: - Merged the fix into master as

[jira] [Created] (FLINK-22573) AsyncIO can timeout elements after completion

Arvid Heise created FLINK-22573: --- Summary: AsyncIO can timeout elements after completion Key: FLINK-22573 URL: https://issues.apache.org/jira/browse/FLINK-22573 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-17170: --- Assignee: Arvid Heise > Cannot stop streaming job with savepoint which uses kinesis

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337132#comment-17337132 ] Arvid Heise commented on FLINK-17170: - Hi [~dannycranmer] , why do we need to have this{{

[jira] [Resolved] (FLINK-22136) Device application for unaligned checkpoint test on cluster

[ https://issues.apache.org/jira/browse/FLINK-22136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22136. - Fix Version/s: 1.14.0 Resolution: Fixed > Device application for unaligned checkpoint

[jira] [Commented] (FLINK-22136) Device application for unaligned checkpoint test on cluster

[ https://issues.apache.org/jira/browse/FLINK-22136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333024#comment-17333024 ] Arvid Heise commented on FLINK-22136: - Merged into master as

[jira] [Comment Edited] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331824#comment-17331824 ] Arvid Heise edited comment on FLINK-22019 at 4/26/21, 6:59 AM: --- {noformat}

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331824#comment-17331824 ] Arvid Heise commented on FLINK-22019: - Probably a duplicate of FLINK-22368. >

[jira] [Updated] (FLINK-22124) The job finished without any exception if error was thrown during state access

[ https://issues.apache.org/jira/browse/FLINK-22124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22124: Parent: (was: FLINK-22123) Issue Type: Bug (was: Sub-task) > The job finished

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20654: Release Note: (was: Using unaligned checkpoints in Flink 1.12.0 combined with two/multiple

[jira] [Updated] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22014: Fix Version/s: (was: 1.12.3) 1.12.4 > Flink JobManager failed to restart

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21711: Fix Version/s: (was: 1.12.3) 1.12.4 > DataStreamSink doesn't allow setting

[jira] [Updated] (FLINK-22323) JobEdges Typos

[ https://issues.apache.org/jira/browse/FLINK-22323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22323: Fix Version/s: (was: 1.12.3) 1.12.4 > JobEdges Typos > -- > >

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21876: Fix Version/s: (was: 1.12.3) 1.12.4 > Handle it properly when the returned

[jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22040: Fix Version/s: (was: 1.12.3) 1.12.4 > Maven: Entry has not been leased

[jira] [Updated] (FLINK-21666) Consistent documentation and recommendations regarding Stop vs Cancel with savepoint

[ https://issues.apache.org/jira/browse/FLINK-21666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21666: Fix Version/s: (was: 1.12.3) 1.12.4 > Consistent documentation and

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20687: Fix Version/s: (was: 1.12.3) 1.12.4 > Missing 'yarn-application' target in

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21693: Fix Version/s: (was: 1.12.3) 1.12.4 > TestStreamEnvironment does not

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21445: Fix Version/s: (was: 1.12.3) 1.12.4 > Application mode does not set the

[jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

[ https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21589: Fix Version/s: (was: 1.12.3) 1.12.4 > Document Table/SQL API limitations

[jira] [Updated] (FLINK-21116) DefaultDispatcherRunnerITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21116: Fix Version/s: (was: 1.12.3) 1.12.4 > DefaultDispatcherRunnerITCase hangs

[jira] [Updated] (FLINK-21153) yarn-per-job deployment target ignores yarn options

[ https://issues.apache.org/jira/browse/FLINK-21153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21153: Fix Version/s: (was: 1.12.3) 1.12.4 > yarn-per-job deployment target

[jira] [Updated] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20714: Fix Version/s: (was: 1.12.3) 1.12.4 > Hive delegation token is not

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20849: Fix Version/s: (was: 1.12.3) 1.12.4 > Improve JavaDoc and logging of new

[jira] [Updated] (FLINK-21029) Failure of shutdown lead to restart of (connected) pipeline

[ https://issues.apache.org/jira/browse/FLINK-21029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21029: Fix Version/s: (was: 1.12.3) 1.12.4 > Failure of shutdown lead to restart

[jira] [Updated] (FLINK-20884) NullPointerException in create statements with computed columns which the subQuery is SqlNodeList

[ https://issues.apache.org/jira/browse/FLINK-20884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20884: Fix Version/s: (was: 1.12.3) 1.12.4 > NullPointerException in create

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20656: Fix Version/s: (was: 1.12.3) 1.12.4 > Update docs for new KafkaSource

[jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20777: Fix Version/s: (was: 1.12.3) 1.12.4 > Default value of property

[jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19925: Fix Version/s: (was: 1.12.3) 1.12.4 > Errors$NativeIoException:

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20457: Fix Version/s: (was: 1.12.3) 1.12.4 > Fix the handling of timestamp in

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20655: Fix Version/s: (was: 1.12.3) 1.12.4 > Add E2E tests to the new KafkaSource

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20576: Fix Version/s: (was: 1.12.3) 1.12.4 > Flink Temporal Join Hive Dim Error >

[jira] [Updated] (FLINK-19743) Add Source metrics definitions

[ https://issues.apache.org/jira/browse/FLINK-19743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19743: Fix Version/s: (was: 1.12.3) 1.12.4 > Add Source metrics definitions >

[jira] [Updated] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20553: Fix Version/s: (was: 1.12.3) 1.12.4 1.13.1 > Add

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22282: Fix Version/s: (was: 1.12.3) 1.12.4 > Move creation of SplitEnumerator to

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20951: Fix Version/s: (was: 1.12.3) 1.12.4 > IllegalArgumentException when

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20431: Fix Version/s: (was: 1.12.3) 1.12.4 >

[jira] [Updated] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover

[ https://issues.apache.org/jira/browse/FLINK-20465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20465: Fix Version/s: (was: 1.12.3) 1.12.4 > Fail globally when not resuming from

[jira] [Updated] (FLINK-20114) Test Kafka Source based on the new Source API 

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Fix Version/s: (was: 1.12.3) 1.12.4 > Test Kafka Source based on the new

[jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20379: Fix Version/s: (was: 1.12.3) 1.12.4 > Update

[jira] [Updated] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

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

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325658#comment-17325658 ] Arvid Heise commented on FLINK-22368: - All source tasks are finished, but the job is not finishing

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325647#comment-17325647 ] Arvid Heise commented on FLINK-22368: - Okay, it makes sense that it doesn't checkpoint as

[jira] [Comment Edited] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325641#comment-17325641 ] Arvid Heise edited comment on FLINK-22368 at 4/20/21, 9:30 AM: --- The test

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325641#comment-17325641 ] Arvid Heise commented on FLINK-22368: - The test doesn't finish as checkpointing gets stuck in the

[jira] [Updated] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22368: Component/s: Runtime / Checkpointing > UnalignedCheckpointITCase hangs on azure >

[jira] [Commented] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323936#comment-17323936 ] Arvid Heise commented on FLINK-22290: - Merged as

[jira] [Resolved] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22290. - Resolution: Fixed > Add new unaligned checkpiont options to Python API. >

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322118#comment-17322118 ] Arvid Heise commented on FLINK-22019: - Let's wait for FLINK-21346 for more investigation. >

[jira] [Updated] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22290: Affects Version/s: 1.13.0 > Add new unaligned checkpiont options to Python API. >

[jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API.

Arvid Heise created FLINK-22290: --- Summary: Add new unaligned checkpiont options to Python API. Key: FLINK-22290 URL: https://issues.apache.org/jira/browse/FLINK-22290 Project: Flink Issue

[jira] [Resolved] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22173. - Assignee: Arvid Heise Resolution: Cannot Reproduce > UnalignedCheckpointRescaleITCase

[jira] [Commented] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322038#comment-17322038 ] Arvid Heise commented on FLINK-22173: - Given the frequency and the lack of logs, I'm closing it.

[jira] [Closed] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22259. --- Resolution: Duplicate > UnalignedCheckpointITCase fails with "Value too large for header, this >

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322030#comment-17322030 ] Arvid Heise commented on FLINK-22259: - I'd close this issue in hopes that the upcoming fixes for

[jira] [Comment Edited] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise edited comment on FLINK-22259 at 4/15/21, 7:25 AM: --- -I guess

[jira] [Comment Edited] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise edited comment on FLINK-22259 at 4/15/21, 7:08 AM: --- -I guess

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise commented on FLINK-22259: - I guess the test assumes that the enumerator never fails (it

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321280#comment-17321280 ] Arvid Heise commented on FLINK-22259: - It seems as if the {{SyncEvent}} is not sent from the

[jira] [Resolved] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21992. - Resolution: Fixed > Fix availability notification in UnionInputGate >

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321279#comment-17321279 ] Arvid Heise commented on FLINK-21992: - Merged into 1.12 as e2cbfad6a3cdafe3d568bb43a1d048f9533b29ec.

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321208#comment-17321208 ] Arvid Heise commented on FLINK-22259: - Source is not finishing as {{numRestarts}} is out of sync (at

[jira] [Assigned] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22259: --- Assignee: Arvid Heise > UnalignedCheckpointITCase fails with "Value too large for header,

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321096#comment-17321096 ] Arvid Heise commented on FLINK-21992: - Merged into master as

[jira] [Updated] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21992: Fix Version/s: 1.12.3 > Fix availability notification in UnionInputGate >

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