[jira] [Comment Edited] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411461#comment-17411461 ] Arvid Heise edited comment on FLINK-24182 at 9/7/21, 8:19 PM:

[jira] [Issue Comment Deleted] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24182: Comment: was deleted (was: I'm not entirely sure if it's directly connected, but when spinning the

[jira] [Commented] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411477#comment-17411477 ] Arvid Heise commented on FLINK-24131: - Again wrong ticket, probably FLINK-22056 or e

[jira] [Commented] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411711#comment-17411711 ] Arvid Heise commented on FLINK-24182: - I also saw another source of interrupts. Not

[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=17411900#comment-17411900 ] Arvid Heise commented on FLINK-23391: - cc [~renqs] > KafkaSourceReaderTest.testKafk

[jira] [Resolved] (FLINK-24126) Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-24126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24126. - Resolution: Fixed Merged into 1.14 as b434f0acd65d1cb654f080bf091f6585eeba7e16. > Use increment

[jira] [Resolved] (FLINK-23807) Use RestClient to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23807. - Resolution: Fixed Merged into master as ef082c9d091846a1659277aa313b1cc6f79eba94. Merged into 1.

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

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

[jira] [Assigned] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-18634: --- Assignee: Arvid Heise > FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed wit

[jira] [Resolved] (FLINK-23462) Translate the abfs documentation to chinese

[ https://issues.apache.org/jira/browse/FLINK-23462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23462. - Fix Version/s: 1.15.0 1.14.0 Resolution: Fixed Merged into master as 1

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412425#comment-17412425 ] Arvid Heise commented on FLINK-23969: - The documentation PR will receive one more re

[jira] [Assigned] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24206: --- Assignee: Yufan Sheng > PulsarSourceITCase fails with "Consumer not found" > --

[jira] [Created] (FLINK-24250) Add De/Serialization API to tear-down user code

Arvid Heise created FLINK-24250: --- Summary: Add De/Serialization API to tear-down user code Key: FLINK-24250 URL: https://issues.apache.org/jira/browse/FLINK-24250 Project: Flink Issue Type: Imp

[jira] [Assigned] (FLINK-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24246: --- Assignee: Yufan Sheng > Bump Pulsar to 2.8.1 > > > Key

[jira] [Commented] (FLINK-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413166#comment-17413166 ] Arvid Heise commented on FLINK-24246: - Let's target 1.14.1. It's fully functional as

[jira] [Updated] (FLINK-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24246: Fix Version/s: 1.14.1 > Bump Pulsar to 2.8.1 > > > Key: FLINK

[jira] [Resolved] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23864. - Resolution: Fixed > The document for Pulsar Source > -- > >

[jira] [Commented] (FLINK-23864) The document for Pulsar Source

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

[jira] [Updated] (FLINK-24055) Deprecate FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24055: Release Note: `FlinkKafkaConsumer` has been deprecated in favor of `KafkaSource`. To upgrade to t

[jira] [Updated] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: KafkaSink supersedes FlinkKafkaProducer and provides efficient exactly-once and at-l

[jira] [Resolved] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22902. - Resolution: Fixed > Port KafkaSink to new Unified Sink API (FLIP-143) >

[jira] [Updated] (FLINK-24055) Deprecate FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24055: Release Note: `FlinkKafkaConsumer` has been deprecated in favor of `KafkaSource`. To upgrade to th

[jira] [Updated] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: KafkaSink supersedes FlinkKafkaProducer and provides efficient exactly-once and at-l

[jira] [Updated] (FLINK-22902) Port KafkaSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Release Note: `KafkaSink` supersedes `FlinkKafkaProducer` and provides efficient exactly-once and

[jira] [Updated] (FLINK-23639) Migrate Table API to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23639: Release Note: Table API/SQL write to Kafka with the new `KafkaSink`. To run in exactly-once proces

[jira] [Updated] (FLINK-23639) Migrate Table API to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23639: Release Note: Table API/SQL write to Kafka with the new `KafkaSink`. When migrating from a query w

[jira] [Created] (FLINK-24252) HybridSource should return TypeInformation

Arvid Heise created FLINK-24252: --- Summary: HybridSource should return TypeInformation Key: FLINK-24252 URL: https://issues.apache.org/jira/browse/FLINK-24252 Project: Flink Issue Type: Improvem

[jira] [Assigned] (FLINK-24252) HybridSource should return TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-24252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24252: --- Assignee: Arvid Heise > HybridSource should return TypeInformation > --

[jira] [Comment Edited] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420492#comment-17420492 ] Arvid Heise edited comment on FLINK-24207 at 9/27/21, 6:06 AM: ---

[jira] [Commented] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420492#comment-17420492 ] Arvid Heise commented on FLINK-24207: - I'm a bit torn on this one. It sounds like a

[jira] [Commented] (FLINK-24207) Add support of KeyedState in TwoPhaseCommitSinkFunction

[ https://issues.apache.org/jira/browse/FLINK-24207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420493#comment-17420493 ] Arvid Heise commented on FLINK-24207: - I double checked and the new {{SinkOperator}}

[jira] [Resolved] (FLINK-24371) Support SinkWriter preCommit without the need of a committer

[ https://issues.apache.org/jira/browse/FLINK-24371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24371. - Resolution: Fixed Merged into master as 44bbd1df377e40f715cca529e5c2ab675c43ff36..4fe9f525a9231

[jira] [Updated] (FLINK-24371) Support SinkWriter preCommit without the need of a committer

[ https://issues.apache.org/jira/browse/FLINK-24371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24371: Fix Version/s: 1.14.1 1.15.0 > Support SinkWriter preCommit without the need of

[jira] [Updated] (FLINK-23652) Implement FLIP-179: Expose Standardized Operator Metrics

[ https://issues.apache.org/jira/browse/FLINK-23652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23652: Release Note: Connectors using unified Source and Sink interface expose certain standardized metri

[jira] [Created] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState

Arvid Heise created FLINK-23759: --- Summary: notifyCheckpointComplete without corresponding snapshotState Key: FLINK-23759 URL: https://issues.apache.org/jira/browse/FLINK-23759 Project: Flink I

[jira] [Updated] (FLINK-23759) notifyCheckpointComplete without corresponding snapshotState

[ https://issues.apache.org/jira/browse/FLINK-23759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23759: Description: In a private run on AZP, I found a run where {{notifyCheckpointComplete}} was invoke

[jira] [Created] (FLINK-23767) FLIP-180: Adjust StreamStatus and Idleness definition

Arvid Heise created FLINK-23767: --- Summary: FLIP-180: Adjust StreamStatus and Idleness definition Key: FLINK-23767 URL: https://issues.apache.org/jira/browse/FLINK-23767 Project: Flink Issue Typ

[jira] [Updated] (FLINK-23767) FLIP-180: Adjust StreamStatus and Idleness definition

[ https://issues.apache.org/jira/browse/FLINK-23767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23767: Issue Type: Improvement (was: Bug) > FLIP-180: Adjust StreamStatus and Idleness definition >

[jira] [Resolved] (FLINK-23639) Migrate Table API to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23639. - Fix Version/s: 1.14.0 Release Note: Table API/SQL write to Kafka with the new KafkaSink.

[jira] [Resolved] (FLINK-19554) Unified testing framework for connectors

[ https://issues.apache.org/jira/browse/FLINK-19554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19554. - Assignee: Qingsheng Ren Resolution: Fixed Merged into master as 4fd33234407e07d99647e4958

[jira] [Comment Edited] (FLINK-23639) Migrate Table API to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17398757#comment-17398757 ] Arvid Heise edited comment on FLINK-23639 at 8/13/21, 6:19 PM: ---

[jira] [Resolved] (FLINK-23735) Migrate BufferedUpsertSinkFunction to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-23735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23735. - Fix Version/s: 1.14.0 Resolution: Fixed Merged into master as 134f388323f0c2b625504fc58e

[jira] [Resolved] (FLINK-23652) Implement FLIP-179: Expose Standardized Operator Metrics

[ https://issues.apache.org/jira/browse/FLINK-23652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23652. - Release Note: Connectors using unified Source and Sink interface expose certain standardized met

[jira] [Assigned] (FLINK-23785) SinkITCase.testMetrics fails with ConcurrentModification on Azure

[ https://issues.apache.org/jira/browse/FLINK-23785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23785: --- Assignee: Arvid Heise > SinkITCase.testMetrics fails with ConcurrentModification on Azure >

[jira] [Commented] (FLINK-23785) SinkITCase.testMetrics fails with ConcurrentModification on Azure

[ https://issues.apache.org/jira/browse/FLINK-23785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399385#comment-17399385 ] Arvid Heise commented on FLINK-23785: - Synchronizing access to the reporter unfortun

[jira] [Commented] (FLINK-23776) Performance regression on 14.08.2021 in FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-23776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399522#comment-17399522 ] Arvid Heise commented on FLINK-23776: - Thanks for the report. I will investigate.

[jira] [Closed] (FLINK-23793) SinkITCase.writerAndCommitterAndGlobalCommitterExecuteInStreamingMode fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-23793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-23793. --- Resolution: Duplicate This is a duplicate of FLINK-23785, fix available for review. > SinkITCase.wr

[jira] [Commented] (FLINK-23795) JoinITCase.testFullJoinWithEqualPkNonEqui fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-23795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399526#comment-17399526 ] Arvid Heise commented on FLINK-23795: - Probably a duplicate of FLINK-23759. > JoinI

[jira] [Created] (FLINK-23803) Improve instantiation of InMemoryReporter

Arvid Heise created FLINK-23803: --- Summary: Improve instantiation of InMemoryReporter Key: FLINK-23803 URL: https://issues.apache.org/jira/browse/FLINK-23803 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-23807) Use metrics to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

Arvid Heise created FLINK-23807: --- Summary: Use metrics to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover Key: FLINK-23807 URL: https://issues.apache.org/jira/browse/FLINK-23807

[jira] [Updated] (FLINK-23807) Use metrics to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23807: Description: {{MiniClusterTestEnvironment#triggerTaskManagerFailover}} checks the job status to d

[jira] [Resolved] (FLINK-23785) SinkITCase.testMetrics fails with ConcurrentModification on Azure

[ https://issues.apache.org/jira/browse/FLINK-23785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23785. - Resolution: Fixed Merged into master as 236bd652c9f2080c490935e3e0f2381fb7850b4a..cab4a9875b9ab

[jira] [Commented] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399754#comment-17399754 ] Arvid Heise commented on FLINK-23797: - [~trohrm...@apache.org] could that be connect

[jira] [Resolved] (FLINK-23767) FLIP-180: Adjust StreamStatus and Idleness definition

[ https://issues.apache.org/jira/browse/FLINK-23767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23767. - Fix Version/s: 1.14.0 Assignee: Arvid Heise Resolution: Fixed Merged into master

[jira] [Updated] (FLINK-23814) Test FLIP-143 KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23814: Labels: release-testing (was: ) > Test FLIP-143 KafkaSink > --- > >

[jira] [Updated] (FLINK-22790) HybridSource end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22790: Priority: Blocker (was: Major) > HybridSource end-to-end test > > >

[jira] [Updated] (FLINK-22790) HybridSource end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22790: Labels: release-testing (was: ) > HybridSource end-to-end test > > >

[jira] [Updated] (FLINK-22790) HybridSource end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22790: Fix Version/s: 1.14.0 > HybridSource end-to-end test > > >

[jira] [Created] (FLINK-23816) Test new (Kafka) metrics in cluster

Arvid Heise created FLINK-23816: --- Summary: Test new (Kafka) metrics in cluster Key: FLINK-23816 URL: https://issues.apache.org/jira/browse/FLINK-23816 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399936#comment-17399936 ] Arvid Heise commented on FLINK-23647: - > I think it's still a bit fragile: > 1. It a

[jira] [Created] (FLINK-23817) Write documentation for standardized operator metrics

Arvid Heise created FLINK-23817: --- Summary: Write documentation for standardized operator metrics Key: FLINK-23817 URL: https://issues.apache.org/jira/browse/FLINK-23817 Project: Flink Issue Typ

[jira] [Resolved] (FLINK-20731) Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20731. - Fix Version/s: 1.14.0 Release Note: Flink now directly provides a way to read data from Puls

[jira] [Resolved] (FLINK-23710) Move sink to org.apache.kafka.conntor.kafka.sink package

[ https://issues.apache.org/jira/browse/FLINK-23710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23710. - Fix Version/s: 1.14.0 Resolution: Fixed Merged into master as 94da2b587c133621bbdf39d36d

[jira] [Comment Edited] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception

[ https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400072#comment-17400072 ] Arvid Heise edited comment on FLINK-23674 at 8/17/21, 5:30 AM: ---

[jira] [Comment Edited] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception

[ https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400072#comment-17400072 ] Arvid Heise edited comment on FLINK-23674 at 8/17/21, 5:31 AM: ---

[jira] [Commented] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception

[ https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400147#comment-17400147 ] Arvid Heise commented on FLINK-23674: - This seems to be a duplicate of FLINK-23509.

[jira] [Resolved] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception

[ https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23674. - Resolution: Duplicate > flink restart with checkpoint ,kafka producer throw exception > ---

[jira] [Created] (FLINK-23858) Clarify StreamRecord#timestamp.

Arvid Heise created FLINK-23858: --- Summary: Clarify StreamRecord#timestamp. Key: FLINK-23858 URL: https://issues.apache.org/jira/browse/FLINK-23858 Project: Flink Issue Type: Technical Debt

[jira] [Updated] (FLINK-23858) Clarify StreamRecord#timestamp.

[ https://issues.apache.org/jira/browse/FLINK-23858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23858: Description: The new Source apparently changed the way we specify records without timestamps. Pre

[jira] [Commented] (FLINK-20731) Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401025#comment-17401025 ] Arvid Heise commented on FLINK-20731: - [~syhily] just to clarify: It would be awesom

[jira] [Assigned] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23528: --- Assignee: Arvid Heise > stop-with-savepoint can fail with FlinkKinesisConsumer > --

[jira] [Updated] (FLINK-23854) KafkaSink error when restart from the checkpoint with a lower parallelism by exactly-once guarantee

[ https://issues.apache.org/jira/browse/FLINK-23854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23854: Description: The KafkaSink throws the exception when restarted with a lower parallelism and the e

[jira] [Updated] (FLINK-23854) KafkaSink error when restart from the checkpoint with a lower parallelism by exactly-once guarantee

[ https://issues.apache.org/jira/browse/FLINK-23854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23854: Description: The KafkaSink throws the exception when restarted with a lower parallelism and the e

[jira] [Resolved] (FLINK-23776) Performance regression on 14.08.2021 in FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-23776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23776. - Resolution: Fixed Merged into master as 976026b63175e63009749936416fc9581a0bf56b. > Performance

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401588#comment-17401588 ] Arvid Heise commented on FLINK-23796: - I have merged FLINK-23776, let's check back i

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401591#comment-17401591 ] Arvid Heise commented on FLINK-23796: - On a related note, shouldn't Flink more grace

[jira] [Assigned] (FLINK-23854) KafkaSink error when restart from the checkpoint with a lower parallelism by exactly-once guarantee

[ https://issues.apache.org/jira/browse/FLINK-23854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23854: --- Assignee: Arvid Heise > KafkaSink error when restart from the checkpoint with a lower paral

[jira] [Commented] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer

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

[jira] [Resolved] (FLINK-23838) Add FLIP-33 metrics to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23838. - Resolution: Fixed Merged into master as 8e8a60a7afaba21272aaf2c2e12e1abfc2b12375..545fd7a9e306b

[jira] [Assigned] (FLINK-23773) KafkaPartitionSplitReader should remove empty splits from fetcher

[ https://issues.apache.org/jira/browse/FLINK-23773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23773: --- Assignee: Qingsheng Ren > KafkaPartitionSplitReader should remove empty splits from fetcher

[jira] [Commented] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

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

[jira] [Resolved] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23801. - Resolution: Fixed > Add FLIP-33 metrics to KafkaSource > -- > >

[jira] [Assigned] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23801: --- Assignee: Qingsheng Ren > Add FLIP-33 metrics to KafkaSource >

[jira] [Commented] (FLINK-23640) Create a KafkaRecordSerializationSchemas valueOnly helper

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

[jira] [Resolved] (FLINK-23640) Create a KafkaRecordSerializationSchemas valueOnly helper

[ https://issues.apache.org/jira/browse/FLINK-23640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23640. - Fix Version/s: 1.14.0 Resolution: Fixed > Create a KafkaRecordSerializationSchemas valueO

[jira] [Commented] (FLINK-23879) Benchmarks are not compiling

[ https://issues.apache.org/jira/browse/FLINK-23879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402542#comment-17402542 ] Arvid Heise commented on FLINK-23879: - Thanks for fixing [~chesnay]! Sorry for creat

[jira] [Commented] (FLINK-23794) JdbcExactlyOnceSinkE2eTest JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403204#comment-17403204 ] Arvid Heise commented on FLINK-23794: - Wow thanks for the in-depth analysis. I think

[jira] [Assigned] (FLINK-23794) JdbcExactlyOnceSinkE2eTest JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23794: --- Assignee: Arvid Heise (was: Roman Khachatryan) > JdbcExactlyOnceSinkE2eTest JVM crash on A

[jira] [Assigned] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22889: --- Assignee: Arvid Heise (was: Roman Khachatryan) > JdbcExactlyOnceSinkE2eTest.testInsert han

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404034#comment-17404034 ] Arvid Heise commented on FLINK-23796: - I haven't seen any new reports. There is stil

[jira] [Resolved] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23796. - Resolution: Fixed > UnalignedCheckpointRescaleITCase JVM crash on Azure > --

[jira] [Commented] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

[ https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404035#comment-17404035 ] Arvid Heise commented on FLINK-23913: - This is probably caused by FLINK-23794. > Un

[jira] [Comment Edited] (FLINK-23913) UnalignedCheckpointITCase fails with exit code 137 (kernel oom) on Azure VMs

[ https://issues.apache.org/jira/browse/FLINK-23913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404035#comment-17404035 ] Arvid Heise edited comment on FLINK-23913 at 8/24/21, 8:16 PM: ---

[jira] [Assigned] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23647: --- Assignee: Arvid Heise > UnalignedCheckpointStressITCase crashed on azure >

[jira] [Commented] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

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

[jira] [Updated] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

[ https://issues.apache.org/jira/browse/FLINK-24488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24488: Fix Version/s: 1.15.0 > KafkaRecordSerializationSchemaBuilder does not forward timestamp > ---

[jira] [Resolved] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception

[ https://issues.apache.org/jira/browse/FLINK-24647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24647. - Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed Merged into master as d

[jira] [Commented] (FLINK-23914) Make connector testing framework more verbose on test failure

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

[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=17435192#comment-17435192 ] Arvid Heise commented on FLINK-23391: - Merged into master as c461338d0009a164d9c236a

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

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23391. - Fix Version/s: 1.14.1 1.15.0 Assignee: Qingsheng Ren Resolutio

<    4   5   6   7   8   9   10   11   12   13   >