[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17386957#comment-17386957 ] Arvid Heise commented on FLINK-20726: - [~Jianyun Zhao], please use the new interface. Even if we

[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=17386956#comment-17386956 ] Arvid Heise commented on FLINK-18562: - I'll have a peek on Tuesday. > Add Support for Azure Data

[jira] [Assigned] (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 reassigned FLINK-23255: --- Assignee: Qingsheng Ren > Add JUnit 5 jupiter and vintage engine >

[jira] [Updated] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-25256: Issue Type: Bug (was: Improvement) > Savepoints do not work with ExternallyInducedSources >

[jira] [Assigned] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25256: --- Assignee: Arvid Heise > Savepoints do not work with ExternallyInducedSources >

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504787#comment-17504787 ] Arvid Heise commented on FLINK-25256: - I'll have a look. I'd focus on FLIP-27 interfaces. >

[jira] [Commented] (FLINK-26717) Move s3 common utils to flink-core

[ https://issues.apache.org/jira/browse/FLINK-26717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508739#comment-17508739 ] Arvid Heise commented on FLINK-26717: - Common utilities could be placed in flink-core as long as

[jira] [Updated] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-26760: Priority: Critical (was: Blocker) > The new CSV source (file system source + CSV format) does

[jira] [Commented] (FLINK-26701) Relocation of connector-base might break user jars due to changed imports

[ https://issues.apache.org/jira/browse/FLINK-26701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511142#comment-17511142 ] Arvid Heise commented on FLINK-26701: - Merged into 1.15 as 1b04ba84222dd44cce9b3241e7a939275557478a,

[jira] [Resolved] (FLINK-26701) Relocation of connector-base might break user jars due to changed imports

[ https://issues.apache.org/jira/browse/FLINK-26701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-26701. - Assignee: Alexander Fedulov Resolution: Fixed > Relocation of connector-base might break

[jira] [Commented] (FLINK-26790) Description image about Unaligned Checkpointing maybe incorrect.

[ https://issues.apache.org/jira/browse/FLINK-26790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511226#comment-17511226 ] Arvid Heise commented on FLINK-26790: - I guess you understand "end of output buffers" differently

[jira] [Commented] (FLINK-26931) Pulsar sink's producer name should be unique

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

[jira] [Commented] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

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

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516711#comment-17516711 ] Arvid Heise commented on FLINK-26760: - Why are our benchmarks not use UTF-8? I thought that was the

[jira] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516711#comment-17516711 ] Arvid Heise edited comment on FLINK-26760 at 4/4/22 9:25 AM: - Why are our

[jira] [Closed] (FLINK-26751) [FLIP-171] Kafka implementation of AsyncSinkBase

[ https://issues.apache.org/jira/browse/FLINK-26751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-26751. --- Resolution: Won't Fix As stated, with the current async sink design, it's not possible to implement

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517087#comment-17517087 ] Arvid Heise commented on FLINK-25916: - This looks like FLINK-24608 to me except this was fixed in

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510020#comment-17510020 ] Arvid Heise commented on FLINK-26760: - I prioritized to critical since the behavior was already

[jira] [Updated] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-26760: Issue Type: Improvement (was: Bug) > The new CSV source (file system source + CSV format) does

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

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

[jira] [Updated] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-25256: Fix Version/s: 1.15.0 1.14.5 > Savepoints do not work with

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

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

[jira] [Commented] (FLINK-27137) Remove usage of AdminClient from KafkaSource logic

[ https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519674#comment-17519674 ] Arvid Heise commented on FLINK-27137: - Hi [~gyfora], sorry if you perceived my message as unfriendly

[jira] [Commented] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527329#comment-17527329 ] Arvid Heise commented on FLINK-26793: - Just to double-check: Can we optimize anything on Flink side

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527412#comment-17527412 ] Arvid Heise commented on FLINK-27318: - Are you sure your test is realistic? In a production setup,

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527413#comment-17527413 ] Arvid Heise commented on FLINK-27318: - Btw your scenario could also happen if many successive

[jira] [Commented] (FLINK-27137) Remove usage of AdminClient from KafkaSource logic

[ https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519514#comment-17519514 ] Arvid Heise commented on FLINK-27137: - Can you please elaborate on {{In some environments using the

[jira] [Updated] (FLINK-27137) Remove usage of AdminClient from KafkaSource logic

[ https://issues.apache.org/jira/browse/FLINK-27137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-27137: Priority: Major (was: Critical) > Remove usage of AdminClient from KafkaSource logic >

[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=17564343#comment-17564343 ] Arvid Heise commented on FLINK-23528: - As far as I remember, I needed to fix this for the tests to

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

Title: Message Title Arvid Heise

[jira] [Commented] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

[ https://issues.apache.org/jira/browse/FLINK-27318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530623#comment-17530623 ] Arvid Heise commented on FLINK-27318: - This is exactly what I meant: You don't restart a task, you

[jira] [Commented] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

[ https://issues.apache.org/jira/browse/FLINK-26645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529221#comment-17529221 ] Arvid Heise commented on FLINK-26645: - Merged into 1.15 as 5de8016a5dcee8a38d21f54e685633809f800c48.

[jira] [Commented] (FLINK-27405) Refactor SourceCoordinator to abstract BaseCoordinator implementation

[ https://issues.apache.org/jira/browse/FLINK-27405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529957#comment-17529957 ] Arvid Heise commented on FLINK-27405: - Hi [~stevenz3wu], I think this approach looks promising,

[jira] [Updated] (FLINK-26793) Flink Cassandra connector performance issue

[ https://issues.apache.org/jira/browse/FLINK-26793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-26793: Labels: documentation (was: ) > Flink Cassandra connector performance issue >

[jira] [Commented] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528911#comment-17528911 ] Arvid Heise commented on FLINK-27320: - Could you please add which Kafka server version you are

[jira] [Assigned] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-26760: --- Assignee: (was: Arvid Heise) > The new CSV source (file system source + CSV format)

[jira] [Commented] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17606504#comment-17606504 ] Arvid Heise commented on FLINK-6573: [~martijnvisser] [~MartijnVisser] is probably the right person

[jira] [Closed] (FLINK-22137) Execute unaligned checkpoint test on a cluster

[ https://issues.apache.org/jira/browse/FLINK-22137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22137. --- Resolution: Done Thanks for reminding. This has been done eons ago ;) > Execute unaligned

[jira] [Commented] (FLINK-35749) Kafka sink component will lose data when kafka cluster is unavailable for a while

[ https://issues.apache.org/jira/browse/FLINK-35749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17863034#comment-17863034 ] Arvid Heise commented on FLINK-35749: - Hi [~zjmean], I can take this topic over if you like. I was

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17863157#comment-17863157 ] Arvid Heise commented on FLINK-31762: - [~lorenzo.affetti] if you need help, feel free to ping me in

[jira] [Commented] (FLINK-35749) Kafka sink component will lose data when kafka cluster is unavailable for a while

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

<    8   9   10   11   12   13