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

[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

[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

[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

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

[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

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

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

[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

[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=17402542#comment-17402542 ] Arvid Heise commented on FLINK-23879: - Thanks for fixing [~chesnay]! Sorry for creating the mess - 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=17401591#comment-17401591 ] Arvid Heise commented on FLINK-23796: - On a related note, shouldn't Flink more gracefully exit on

[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

[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=17401588#comment-17401588 ] Arvid Heise commented on FLINK-23796: - I have merged FLINK-23776, let's check back if this issue

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

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

[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] [Commented] (FLINK-20731) Pulsar Source

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

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

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24131: --- Assignee: Arvid Heise > KafkaSinkITCase "Detected producer leak" >

[jira] [Assigned] (FLINK-24151) java.lang.RuntimeException occurs with setMaxConcurrentCheckpoints being enabled

[ https://issues.apache.org/jira/browse/FLINK-24151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24151: --- Assignee: Arvid Heise > java.lang.RuntimeException occurs with setMaxConcurrentCheckpoints

[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=17410495#comment-17410495 ] Arvid Heise commented on FLINK-24131: - The last error is coming from a different test. Neither the

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

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24131: Fix Version/s: (was: 1.13.3) > KafkaSinkITCase "Detected producer leak" >

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

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24131: Affects Version/s: (was: 1.13.2) > KafkaSinkITCase "Detected producer leak" >

[jira] [Commented] (FLINK-23839) Unclear severity of Kafka transaction recommit warning in logs

[ https://issues.apache.org/jira/browse/FLINK-23839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410529#comment-17410529 ] Arvid Heise commented on FLINK-23839: - InvalidTxnStateException never triggers on duplicate commits

[jira] [Commented] (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:comment-tabpanel=17410496#comment-17410496 ] Arvid Heise commented on FLINK-18634: - Another case:

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

[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=17412425#comment-17412425 ] Arvid Heise commented on FLINK-23969: - The documentation PR will receive one more review round, but

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

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

[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

[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] [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=17413166#comment-17413166 ] Arvid Heise commented on FLINK-24246: - Let's target 1.14.1. It's fully functional as is. > Bump

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

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

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

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

[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

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

[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] [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=17411461#comment-17411461 ] Arvid Heise commented on FLINK-24182: - I'm not entirely sure, but when spinning the KinesisITCase a

[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=17411461#comment-17411461 ] Arvid Heise edited comment on FLINK-24182 at 9/7/21, 8:18 PM: -- I'm not

[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=17411461#comment-17411461 ] Arvid Heise edited comment on FLINK-24182 at 9/7/21, 8:19 PM: -- I'm not

[jira] [Commented] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17411380#comment-17411380 ] Arvid Heise commented on FLINK-24179: - Might be resolved through FLINK-24131, where we made sure to

[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

[jira] [Commented] (FLINK-23839) Unclear severity of Kafka transaction recommit warning in logs

[ https://issues.apache.org/jira/browse/FLINK-23839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410670#comment-17410670 ] Arvid Heise commented on FLINK-23839: - Actually the description of the error in the PR made it very

[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=17411711#comment-17411711 ] Arvid Heise commented on FLINK-24182: - I also saw another source of interrupts. Not too sure on this

[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=17411477#comment-17411477 ] Arvid Heise commented on FLINK-24131: - Again wrong ticket, probably FLINK-22056 or even FLINK-18634.

[jira] [Updated] (FLINK-24151) KafkaSink fails with setMaxConcurrentCheckpoints being enabled

[ https://issues.apache.org/jira/browse/FLINK-24151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24151: Summary: KafkaSink fails with setMaxConcurrentCheckpoints being enabled (was:

[jira] [Commented] (FLINK-24151) KafkaSink fails with setMaxConcurrentCheckpoints being enabled

[ https://issues.apache.org/jira/browse/FLINK-24151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410944#comment-17410944 ] Arvid Heise commented on FLINK-24151: - This is a Kafka broker issue, probably the root cause of

[jira] [Resolved] (FLINK-24151) KafkaSink fails with setMaxConcurrentCheckpoints being enabled

[ https://issues.apache.org/jira/browse/FLINK-24151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24151. - Resolution: Done > KafkaSink fails with setMaxConcurrentCheckpoints being enabled >

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

Arvid Heise created FLINK-24182: --- Summary: Tasks canceler should not immediately interrupt Key: FLINK-24182 URL: https://issues.apache.org/jira/browse/FLINK-24182 Project: Flink Issue Type:

[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=17410956#comment-17410956 ] Arvid Heise commented on FLINK-23969: - [~syhily] will provide documentation later today

[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=17411013#comment-17411013 ] Arvid Heise commented on FLINK-24182: - Thank you. Actually {noformat} interrupt shouldn’t be

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

[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

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

[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

[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

[jira] [Updated] (FLINK-21406) Add AvroParquetFileRecordFormat

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

[jira] [Commented] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409285#comment-17409285 ] Arvid Heise commented on FLINK-21406: - Thank you very much. I assigned it to you. > Add

[jira] [Assigned] (FLINK-21406) Add AvroParquetFileRecordFormat

[ https://issues.apache.org/jira/browse/FLINK-21406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21406: --- Assignee: Jing Ge > Add AvroParquetFileRecordFormat > --- > >

[jira] [Commented] (FLINK-23433) Metrics cannot be initialized in format

[ https://issues.apache.org/jira/browse/FLINK-23433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409286#comment-17409286 ] Arvid Heise commented on FLINK-23433: - Maybe this was an issue in 1.11 (now unsupported) or is

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

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

[jira] [Assigned] (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 reassigned FLINK-24126: --- Assignee: Qingsheng Ren > Use increment of bytes-consumed-total for updating numBytesIn in

[jira] [Commented] (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:comment-tabpanel=17411226#comment-17411226 ] Arvid Heise commented on FLINK-24126: - Merged into master as

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17389836#comment-17389836 ] Arvid Heise commented on FLINK-23449: - [~yuchuanchen] could you please check if the solutions that

[jira] [Assigned] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

[ https://issues.apache.org/jira/browse/FLINK-23351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23351: --- Assignee: Arvid Heise > FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails

[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=17395843#comment-17395843 ] Arvid Heise commented on FLINK-23674: - Can you please provide the full log? > flink restart with

[jira] [Assigned] (FLINK-23684) KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with NoSuchElementException

[ https://issues.apache.org/jira/browse/FLINK-23684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23684: --- Assignee: Fabian Paul > KafkaITCase.testAutoOffsetRetrievalAndCommitToKafka fails with >

[jira] [Assigned] (FLINK-23678) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23678: --- Assignee: Fabian Paul > KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee

[jira] [Assigned] (FLINK-23683) KafkaSinkITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-23683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23683: --- Assignee: Fabian Paul > KafkaSinkITCase hangs on azure > -- >

[jira] [Resolved] (FLINK-23255) Add JUnit 5 jupiter and vintage engine

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

[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=17394256#comment-17394256 ] Arvid Heise commented on FLINK-23647: - I'm assuming it's more an implementation issue than a logic

[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: Summary: Implement FLIP-179: Expose Standardized Operator Metrics (was: Implement FLIP-179) >

[jira] [Created] (FLINK-23652) Implement FLIP-179

Arvid Heise created FLINK-23652: --- Summary: Implement FLIP-179 Key: FLINK-23652 URL: https://issues.apache.org/jira/browse/FLINK-23652 Project: Flink Issue Type: Improvement

[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=17394534#comment-17394534 ] Arvid Heise commented on FLINK-23647: - `listFiles` is an atomic operation afaik. The issue in your

[jira] [Resolved] (FLINK-23617) Co-locate sink operators with same parallelism

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

[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=17394670#comment-17394670 ] Arvid Heise commented on FLINK-23647: - Okay let us take the ticket, it takes too long to explain for

[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=17396845#comment-17396845 ] Arvid Heise commented on FLINK-23647: - Yes, it would also avoid ugly hacks like

[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=17396853#comment-17396853 ] Arvid Heise commented on FLINK-23647: - Here is my solution to solve the test instability in code

[jira] [Assigned] (FLINK-23696) RMQSourceTest.testRedeliveredSessionIDsAck fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23696: --- Assignee: Fabian Paul > RMQSourceTest.testRedeliveredSessionIDsAck fails on azure >

[jira] [Resolved] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-18562. - Release Note: Flink now supports reading from Azure Data Lake Store Gen 2 with the

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

[ https://issues.apache.org/jira/browse/FLINK-23462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397220#comment-17397220 ] Arvid Heise commented on FLINK-23462: - This is now good to go. Thanks [~Liebing]! > Translate the

[jira] [Created] (FLINK-23722) S3 Tests fail on AZP: Unable to find a region via the region provider chain. Must provide an explicit region in the builder or setup environment to supply a region.

Arvid Heise created FLINK-23722: --- Summary: S3 Tests fail on AZP: Unable to find a region via the region provider chain. Must provide an explicit region in the builder or setup environment to supply a region. Key: FLINK-23722

[jira] [Resolved] (FLINK-23297) Upgrade Protobuf to 3.17.3

[ https://issues.apache.org/jira/browse/FLINK-23297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23297. - Fix Version/s: 1.14.0 Resolution: Fixed > Upgrade Protobuf to 3.17.3 >

[jira] [Commented] (FLINK-23297) Upgrade Protobuf to 3.17.3

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

[jira] [Assigned] (FLINK-23617) Co-locate sink operators with same parallelism

[ https://issues.apache.org/jira/browse/FLINK-23617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23617: --- Assignee: Arvid Heise > Co-locate sink operators with same parallelism >

[jira] [Created] (FLINK-23617) Co-locate sink operators with same parallelism

Arvid Heise created FLINK-23617: --- Summary: Co-locate sink operators with same parallelism Key: FLINK-23617 URL: https://issues.apache.org/jira/browse/FLINK-23617 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-23183) Lost ACKs for redelivered messages in RMQSource

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

[jira] [Commented] (FLINK-23183) Lost ACKs for redelivered messages in RMQSource

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

[jira] [Commented] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393062#comment-17393062 ] Arvid Heise commented on FLINK-18562: - [~psrinivasulu], I reviewed your PR and it's almost ready to

[jira] [Created] (FLINK-23621) FLIP-177: Extend Sink API

Arvid Heise created FLINK-23621: --- Summary: FLIP-177: Extend Sink API Key: FLINK-23621 URL: https://issues.apache.org/jira/browse/FLINK-23621 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-23621) FLIP-177: Extend Sink API

[ https://issues.apache.org/jira/browse/FLINK-23621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23621: Fix Version/s: (was: 1.14.0) > FLIP-177: Extend Sink API > - > >

<    5   6   7   8   9   10   11   12   13   >