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

[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-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] [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-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] [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-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: Priority: Critical (was: Blocker) > The new CSV source (file system source + CSV format) does

[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] [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] [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] [Resolved] (FLINK-21406) Add AvroParquetFileRecordFormat

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

[jira] [Commented] (FLINK-25223) ElasticsearchWriterITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461253#comment-17461253 ] Arvid Heise commented on FLINK-25223: - [~alexanderpreuss] could you please double-check if we need a

[jira] [Resolved] (FLINK-25223) ElasticsearchWriterITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-25223. - Resolution: Fixed Reactivated tests and provided memory limit in master as

[jira] [Commented] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461250#comment-17461250 ] Arvid Heise commented on FLINK-25167: - I assigned. [~MartijnVisser] could you please keep an eye on

[jira] [Assigned] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25167: --- Assignee: Lsw_aka_laplace > Support user-defined `StreamOperatorFactory` in

[jira] [Resolved] (FLINK-11576) FLIP-33: Standardize connector metrics

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

[jira] [Updated] (FLINK-20160) Implement standard metrics in JDBC connectors.

[ https://issues.apache.org/jira/browse/FLINK-20160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20160: Parent: (was: FLINK-11576) Issue Type: New Feature (was: Sub-task) > Implement

[jira] [Assigned] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25330: --- Assignee: Jing Ge > Flink SQL doesn't retract all versions of Hbase data >

[jira] [Commented] (FLINK-25293) Option to let fail if KafkaSource keeps failing to commit offset

[ https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459844#comment-17459844 ] Arvid Heise commented on FLINK-25293: - [~renqs], could you PTAL? > Option to let fail if

[jira] [Updated] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24489: Release Note: CEP now allows users to configure the cache size used while processing records. >

[jira] [Resolved] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24489. - Fix Version/s: 1.15.0 Assignee: RocMarshal Resolution: Fixed > The size of

[jira] [Commented] (FLINK-25263) KafkaSourceE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458294#comment-17458294 ] Arvid Heise commented on FLINK-25263: - [~renqs] could you PTAL? > KafkaSourceE2ECase is broken >

[jira] [Resolved] (FLINK-9050) Expose operator IO counter metrics

[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-9050. Fix Version/s: 1.14.0 Resolution: Duplicate > Expose operator IO counter metrics >

[jira] [Resolved] (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 resolved FLINK-19743. - Fix Version/s: 1.14.0 (was: 1.12.6) (was: 1.15.0)

[jira] [Updated] (FLINK-11682) Add abstract source and sink metric classes.

[ https://issues.apache.org/jira/browse/FLINK-11682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-11682: Fix Version/s: 1.14.0 > Add abstract source and sink metric classes. >

[jira] [Resolved] (FLINK-11682) Add abstract source and sink metric classes.

[ https://issues.apache.org/jira/browse/FLINK-11682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-11682. - Resolution: Duplicate > Add abstract source and sink metric classes. >

[jira] [Resolved] (FLINK-11683) Implement standard metrics in Kafka connectors.

[ https://issues.apache.org/jira/browse/FLINK-11683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-11683. - Fix Version/s: 1.14.0 Resolution: Fixed > Implement standard metrics in Kafka

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

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

[jira] [Resolved] (FLINK-24077) HBaseConnectorITCase.testTableSink

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

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

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

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

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

[jira] [Commented] (FLINK-24859) Document new File formats

[ https://issues.apache.org/jira/browse/FLINK-24859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17455336#comment-17455336 ] Arvid Heise commented on FLINK-24859: - Renaming was breaking API in 1.14 and master. 1.14 partially

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17455093#comment-17455093 ] Arvid Heise commented on FLINK-20928: - I think the proper solution is to migrate the tests to docker

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454748#comment-17454748 ] Arvid Heise commented on FLINK-20928: - [~renqs], is this test still using the proxy setup of the

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

[ https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454670#comment-17454670 ] Arvid Heise commented on FLINK-24077: - Note that the cluster could also be non-static. We could of

[jira] [Commented] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454500#comment-17454500 ] Arvid Heise commented on FLINK-25167: - Let me include [~pnowojski]. I think he wanted to overhaul

[jira] [Comment Edited] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454500#comment-17454500 ] Arvid Heise edited comment on FLINK-25167 at 12/7/21, 9:23 AM: --- Let me

[jira] [Updated] (FLINK-24859) Document new File formats

[ https://issues.apache.org/jira/browse/FLINK-24859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24859: Fix Version/s: 1.14.1 > Document new File formats > - > >

[jira] [Commented] (FLINK-24859) Document new File formats

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

[jira] [Commented] (FLINK-24821) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454144#comment-17454144 ] Arvid Heise commented on FLINK-24821: - https://github.com/apache/flink/pull/16108 is currently

[jira] [Commented] (FLINK-24686) Make doc clear on AsyncFunction::timeout() overriding

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

[jira] [Updated] (FLINK-24626) Flink JDBC Sink may lose data in left join

[ https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24626: Labels: correctness (was: ) > Flink JDBC Sink may lose data in left join >

[jira] [Resolved] (FLINK-21407) Clarify which sources and APIs support which formats

[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21407. - Fix Version/s: 1.14.1 Resolution: Fixed > Clarify which sources and APIs support which

[jira] [Commented] (FLINK-21407) Clarify which sources and APIs support which formats

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

[jira] [Resolved] (FLINK-24921) FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-24921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24921. - Resolution: Abandoned > FileSourceSplit should not be visible in the user API in >

[jira] [Resolved] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24392. - Resolution: Later > Upgrade presto s3 fs implementation to Trino >= 348 >

[jira] [Commented] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451122#comment-17451122 ] Arvid Heise commented on FLINK-24392: - This is blocked on dropping Java 8 on which the community has

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

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450981#comment-17450981 ] Arvid Heise commented on FLINK-24348: - Please do, since that is a test-only backport I expect little

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

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450930#comment-17450930 ] Arvid Heise commented on FLINK-24348: - Okay the script "testcontainers_start.sh" is generated in

[jira] [Commented] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450921#comment-17450921 ] Arvid Heise commented on FLINK-22300: - Okay I see, so Flink would never evict the data. That is

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

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450912#comment-17450912 ] Arvid Heise commented on FLINK-24348: - I have not found out much yesterday. It is a standard Unix

[jira] [Assigned] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19863: --- Assignee: Martijn Visser (was: Leonard Xu) > SQLClientHBaseITCase.testHBase failed with

[jira] [Commented] (FLINK-24921) FileSourceSplit should not be visible in the user API in ParquetColumnarRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-24921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450534#comment-17450534 ] Arvid Heise commented on FLINK-24921: - Should we close this ticket or do we expect any work on this

[jira] [Commented] (FLINK-22300) Why TimeEvictor of Keyed Windows evictor do not support ProcessingTime of TimeCharacteristic

[ https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450532#comment-17450532 ] Arvid Heise commented on FLINK-22300: - Sorry for not following it up. I have a hard time to

[jira] [Commented] (FLINK-24859) Document new File formats

[ https://issues.apache.org/jira/browse/FLINK-24859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450526#comment-17450526 ] Arvid Heise commented on FLINK-24859: - You are right that they currently cannot be used in

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450523#comment-17450523 ] Arvid Heise commented on FLINK-20928: - [~renqs], [~lindong] could you please take another look? >

[jira] [Commented] (FLINK-21407) Clarify which sources and APIs support which formats

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

[jira] [Resolved] (FLINK-24108) Update kafka documentation in Chinese

[ https://issues.apache.org/jira/browse/FLINK-24108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24108. - Resolution: Duplicate > Update kafka documentation in Chinese >

[jira] [Commented] (FLINK-24108) Update kafka documentation in Chinese

[ https://issues.apache.org/jira/browse/FLINK-24108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450516#comment-17450516 ] Arvid Heise commented on FLINK-24108: - [~liangkw16], [~monster#12] sorry for not noticing your

[jira] [Assigned] (FLINK-24308) Translate KafkaSink docs to chinese

[ https://issues.apache.org/jira/browse/FLINK-24308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24308: --- Assignee: Qingsheng Ren > Translate KafkaSink docs to chinese >

[jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450509#comment-17450509 ] Arvid Heise commented on FLINK-25029: - Just FYI, the HDFS Filesystem lives in a separate class

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450435#comment-17450435 ] Arvid Heise commented on FLINK-21214: - Yes, I wrote the reason for closing O_o. [~fpaul] apparently

[jira] [Resolved] (FLINK-25088) KafkaSinkITCase failed on azure due to Container did not start correctly

[ https://issues.apache.org/jira/browse/FLINK-25088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-25088. - Assignee: Arvid Heise Resolution: Duplicate This is the same issue as. I will continue

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450420#comment-17450420 ] Arvid Heise commented on FLINK-19863: - [~MartijnVisser] you are currently hardening the shell

[jira] [Assigned] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-19863: --- Assignee: Leonard Xu (was: Arvid Heise) > SQLClientHBaseITCase.testHBase failed with

[jira] [Assigned] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22621: --- Assignee: Jing Ge (was: Arvid Heise) > HBaseConnectorITCase.testTableSourceSinkWithDDL

[jira] [Commented] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

[ https://issues.apache.org/jira/browse/FLINK-22621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450414#comment-17450414 ] Arvid Heise commented on FLINK-22621: - [~jingge] is currently investigating, I'll reassign. >

[jira] [Commented] (FLINK-25088) KafkaSinkITCase failed on azure due to Container did not start correctly

[ https://issues.apache.org/jira/browse/FLINK-25088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450367#comment-17450367 ] Arvid Heise commented on FLINK-25088: - I found in the logs {noformat} 03:37:59,944 [

[jira] [Resolved] (FLINK-24325) Create ElasticSearch 6.8 Sink

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

[jira] [Assigned] (FLINK-25044) Add More Unit Test For Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-25044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25044: --- Assignee: Yufei Zhang > Add More Unit Test For Pulsar Source >

[jira] [Resolved] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

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

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17449618#comment-17449618 ] Arvid Heise commented on FLINK-21214: - Merged into 1.14 as 29c288993ce7e24af70063cf7d645f4ff83909d6.

[jira] [Assigned] (FLINK-24703) Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

[ https://issues.apache.org/jira/browse/FLINK-24703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24703: --- Assignee: Alexander Fedulov > Add CSV format support for filesystem based on StreamFormat

[jira] [Assigned] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code

[ https://issues.apache.org/jira/browse/FLINK-25023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25023: --- Assignee: David Morávek > ClassLoader leak on JM/TM through indirectly-started Hadoop

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

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

  1   2   3   4   5   6   7   8   9   10   >