[jira] [Resolved] (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 resolved FLINK-23621. - Fix Version/s: 1.14.0 Resolution: Fixed Merged into master as

[jira] [Resolved] (FLINK-22902) Port KafkaSink to 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 Merged into master as

[jira] [Updated] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Affects Version/s: 1.14.0 > Port KafkaSink to FLIP-143 > -- > >

[jira] [Updated] (FLINK-22902) Port KafkaSink to 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] [Reopened] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reopened FLINK-22902: - > Port KafkaSink to FLIP-143 > -- > > Key: FLINK-22902 >

[jira] [Resolved] (FLINK-23123) Implement at-least-once Kafka Sink

[ https://issues.apache.org/jira/browse/FLINK-23123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23123. - Fix Version/s: 1.14.0 Resolution: Fixed > Implement at-least-once Kafka Sink >

[jira] [Issue Comment Deleted] (FLINK-22902) Port KafkaSink to FLIP-143

[ https://issues.apache.org/jira/browse/FLINK-22902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22902: Comment: was deleted (was: Merged into master as

[jira] [Resolved] (FLINK-23124) Implement exactly-once Kafka Sink

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

[jira] [Commented] (FLINK-23124) Implement exactly-once Kafka Sink

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

[jira] [Commented] (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.

[ https://issues.apache.org/jira/browse/FLINK-23722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397370#comment-17397370 ] Arvid Heise commented on FLINK-23722: - Downgrading to 3.3.0 yields HADOOP-17337. 3.2.2 looks good

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

[ https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397830#comment-17397830 ] Arvid Heise commented on FLINK-23678: - The new errors are related to FLINK-23408. We do not see a

[jira] [Updated] (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 updated FLINK-23678: Attachment: extracted.log > KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails

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

[ https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397832#comment-17397832 ] Arvid Heise commented on FLINK-23678: - Ignoring test in ac42bb3d146 on master. >

[jira] [Resolved] (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 resolved FLINK-23678. - Resolution: Fixed Merged into master as 58ff344e5e5fdd397e0f9276561b746ddabbadea. >

[jira] [Updated] (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 updated FLINK-23678: Priority: Major (was: Blocker) > KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee

[jira] [Updated] (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 updated FLINK-23678: Priority: Critical (was: Major) >

[jira] [Comment Edited] (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 regio

[ https://issues.apache.org/jira/browse/FLINK-23722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397606#comment-17397606 ] Arvid Heise edited comment on FLINK-23722 at 8/11/21, 8:13 PM: --- Merged

[jira] [Resolved] (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.

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

[jira] [Assigned] (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 reassigned FLINK-21407: --- Assignee: Etienne Chauchot > Clarify which sources and APIs support which formats >

[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=17428617#comment-17428617 ] Arvid Heise commented on FLINK-20928: - Merged into 1.14 as 7578758fa8c84314b8b3206629b3afa9ff41b636.

[jira] [Assigned] (FLINK-24530) GlobalCommitter might not commit all records on drain

[ https://issues.apache.org/jira/browse/FLINK-24530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24530: --- Assignee: Arvid Heise > GlobalCommitter might not commit all records on drain >

[jira] [Created] (FLINK-24574) Allow metrics to be removed in UDFs

Arvid Heise created FLINK-24574: --- Summary: Allow metrics to be removed in UDFs Key: FLINK-24574 URL: https://issues.apache.org/jira/browse/FLINK-24574 Project: Flink Issue Type: Improvement

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

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

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

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

[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=17430052#comment-17430052 ] Arvid Heise commented on FLINK-20928: - Merged into 1.13 as e75111dffc6a7bf05ade246cc5485d50cad8162f.

[jira] [Commented] (FLINK-24459) Performance improvement of file sink on Nexmark

[ https://issues.apache.org/jira/browse/FLINK-24459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429260#comment-17429260 ] Arvid Heise commented on FLINK-24459: - [~ykt836] shouldn't we also have backports for the change? >

[jira] [Commented] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing

[ https://issues.apache.org/jira/browse/FLINK-24493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429245#comment-17429245 ] Arvid Heise commented on FLINK-24493: - Hi Rion, unfortunately documentation is still lacking. Have

[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

[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

[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

[jira] [Assigned] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20443: --- Assignee: liwei li > ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[jira] [Updated] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20443: Priority: Major (was: Not a Priority) > ContinuousProcessingTimeTrigger doesn't fire at the end

[jira] [Closed] (FLINK-15845) Add java-based StreamingFileSink test using s3

[ https://issues.apache.org/jira/browse/FLINK-15845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-15845. --- Resolution: Fixed We are currentlying phasing out StreamingFileSink and replace it with FileSink.

[jira] [Resolved] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

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

[jira] [Commented] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

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

[jira] [Resolved] (FLINK-24324) Create ElasticSearch 7 Sink

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

[jira] [Resolved] (FLINK-24382) RecordsOut metric for sinks is inaccurate

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

[jira] [Commented] (FLINK-24382) RecordsOut metric for sinks is inaccurate

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

[jira] [Commented] (FLINK-24382) RecordsOut metric for sinks is inaccurate

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

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

[jira] [Commented] (FLINK-24405) KafkaWriterITCase.testLingeringTransaction fails on azure

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

[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=17420492#comment-17420492 ] Arvid Heise edited comment on FLINK-24207 at 9/27/21, 6:06 AM: --- I'm a bit

[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=17420492#comment-17420492 ] Arvid Heise commented on FLINK-24207: - I'm a bit torn on this one. It sounds like a reasonable idea.

[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=17420493#comment-17420493 ] Arvid Heise commented on FLINK-24207: - I double checked and the new {{SinkOperator}} actually also

[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] [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] [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-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-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-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-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-18450) FLIP-182: Support watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-18450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447831#comment-17447831 ] Arvid Heise commented on FLINK-18450: - Yes, we still aim for 1.15.0. > FLIP-182: Support watermark

[jira] [Commented] (FLINK-24905) KDS implementation of Async Sink Table API

[ https://issues.apache.org/jira/browse/FLINK-24905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448010#comment-17448010 ] Arvid Heise commented on FLINK-24905: - Table API is not giving a strong guarantee for state upgrades

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

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

[jira] [Resolved] (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 resolved FLINK-23696. - Resolution: Fixed > RMQSourceTest.testRedeliveredSessionIDsAck fails on azure >

[jira] [Commented] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441664#comment-17441664 ] Arvid Heise commented on FLINK-24851: - Done > KafkaSourceBuilder: auto.offset.reset is ignored >

[jira] [Assigned] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24851: --- Assignee: liwei li > KafkaSourceBuilder: auto.offset.reset is ignored >

[jira] [Assigned] (FLINK-24839) CsvFilesystemStreamSinkITCase.testPart times out on AZP

[ https://issues.apache.org/jira/browse/FLINK-24839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24839: --- Assignee: Jingsong Lee > CsvFilesystemStreamSinkITCase.testPart times out on AZP >

[jira] [Commented] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server do

[ https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442833#comment-17442833 ] Arvid Heise commented on FLINK-24744: - Let's check if the Kafka version bump to 2.8.1 fixes things.

[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=17442802#comment-17442802 ] Arvid Heise commented on FLINK-24821: - This seems to be caused by the use of

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442840#comment-17442840 ] Arvid Heise commented on FLINK-24763: - Please stop pinging me. Blame shows that [~lzljs3620320] is

[jira] [Resolved] (FLINK-24773) KafkaCommitter should fail on unknown Exception

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

[jira] [Commented] (FLINK-24867) E2e tests take longer than the maximum 310 minutes on AZP

[ https://issues.apache.org/jira/browse/FLINK-24867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442786#comment-17442786 ] Arvid Heise commented on FLINK-24867: - In particular, it seems that a slow download of

[jira] [Comment Edited] (FLINK-24867) E2e tests take longer than the maximum 310 minutes on AZP

[ https://issues.apache.org/jira/browse/FLINK-24867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442786#comment-17442786 ] Arvid Heise edited comment on FLINK-24867 at 11/12/21, 2:57 PM: In

[jira] [Commented] (FLINK-24795) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool times out on AZP

[ https://issues.apache.org/jira/browse/FLINK-24795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442832#comment-17442832 ] Arvid Heise commented on FLINK-24795: - Let's check if the Kafka version bump to 2.8.1 fixes things.

[jira] [Assigned] (FLINK-24583) ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-24583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24583: --- Assignee: Alexander Preuss > ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444082#comment-17444082 ] Arvid Heise commented on FLINK-24763: - For me, it still not clear why the reader is closed at all.

[jira] [Assigned] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-24916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24916: --- Assignee: Arvid Heise > AvroExternalJarProgramITCase JVM crash on Azure >

[jira] [Commented] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

[ https://issues.apache.org/jira/browse/FLINK-22775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444384#comment-17444384 ] Arvid Heise commented on FLINK-22775: - [~echauchot] could you PTAL when you have time? >

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

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444320#comment-17444320 ] Arvid Heise commented on FLINK-21214: - On master, we bumped Kafka to 2.8.1 but we can't backport it

[jira] [Closed] (FLINK-17379) testScaleDownBeforeFirstCheckpoint Error reading field 'api_versions': Error reading field 'max_version':

[ https://issues.apache.org/jira/browse/FLINK-17379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-17379. --- Resolution: Cannot Reproduce No new report since half a year and cannot reproduce locally. Please

[jira] [Commented] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-24916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444378#comment-17444378 ] Arvid Heise commented on FLINK-24916: - This seems to be an e2e test and should be setup as such. >

[jira] [Commented] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

[ https://issues.apache.org/jira/browse/FLINK-24112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444399#comment-17444399 ] Arvid Heise commented on FLINK-24112: - This test passes on Linux. We should move the test to

[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=17444319#comment-17444319 ] Arvid Heise commented on FLINK-18634: - This seems to prevail even after we bumped Kafka to 2.8.1. >

[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: Fabian Paul (was: Arvid Heise) >

[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444388#comment-17444388 ] Arvid Heise commented on FLINK-24844: - [~echauchot] one more cassandra issue. Can you PTAL? >

[jira] [Assigned] (FLINK-21117) KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable failure threshold."

[ https://issues.apache.org/jira/browse/FLINK-21117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21117: --- Assignee: Qingsheng Ren > KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint

[jira] [Assigned] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

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

[jira] [Closed] (FLINK-24811) KafkaSourceITCase#testRedundantParallelism and testBasicRead failed on azure

[ https://issues.apache.org/jira/browse/FLINK-24811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-24811. --- Resolution: Duplicate > KafkaSourceITCase#testRedundantParallelism and testBasicRead failed on

[jira] [Commented] (FLINK-24811) KafkaSourceITCase#testRedundantParallelism and testBasicRead failed on azure

[ https://issues.apache.org/jira/browse/FLINK-24811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444380#comment-17444380 ] Arvid Heise commented on FLINK-24811: - If the solution can be easily backported to 1.13 then please

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

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

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444316#comment-17444316 ] Arvid Heise commented on FLINK-20950: - I can also take a look. >

[jira] [Assigned] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20950: --- Assignee: Arvid Heise > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test

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

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

[jira] [Updated] (FLINK-21539) 'SQL Client end-to-end test (Blink planner) Elasticsearch (v6.3.1)' fails during download

[ https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21539: Component/s: (was: Connectors / ElasticSearch) > 'SQL Client end-to-end test (Blink planner)

[jira] [Closed] (FLINK-19202) HadoopS3FileSystemITCase.testSimpleFileWriteAndRead failed with "FileNotFoundException: No such file or directory: s3://***/temp/tests-7ebc11df-9160-4403-85a7-c484da44f33

[ https://issues.apache.org/jira/browse/FLINK-19202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19202. --- Resolution: Cannot Reproduce Problem is not reappearing and can only be seen on CI, so closing it

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

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443278#comment-17443278 ] Arvid Heise commented on FLINK-6573: I have assigned the ticket to you. Please note that we are

[jira] [Comment Edited] (FLINK-6573) Flink MongoDB Connector

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443278#comment-17443278 ] Arvid Heise edited comment on FLINK-6573 at 11/14/21, 9:49 AM: --- I have

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

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-6573: -- Assignee: ZhuoYu Chen > Flink MongoDB Connector > --- > >

[jira] [Assigned] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

[ https://issues.apache.org/jira/browse/FLINK-22775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22775: --- Assignee: Etienne Chauchot > CassandraConnectorITCase.testCassandraTableSink Fail >

[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=1772#comment-1772 ] Arvid Heise commented on FLINK-24921: - I think they added the parameter to support Hive and non-Hive

[jira] [Commented] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

[ https://issues.apache.org/jira/browse/FLINK-22775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1768#comment-1768 ] Arvid Heise commented on FLINK-22775: - Thank you, I assigned you. >

[jira] [Commented] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1766#comment-1766 ] Arvid Heise commented on FLINK-24844: - Ideally, you should be able to execute the test locally.

[jira] [Assigned] (FLINK-24844) CassandraConnectorITCase.testCassandraBatchPojoFormat fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24844: --- Assignee: Etienne Chauchot > CassandraConnectorITCase.testCassandraBatchPojoFormat fails

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444688#comment-17444688 ] Arvid Heise commented on FLINK-16908: - We bumped Kafka to 2.8.1 in FLINK-24765, hopefully this issue

[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=17442721#comment-17442721 ] Arvid Heise commented on FLINK-24859: - Done thanks for taking care. > Document new File formats >

[jira] [Assigned] (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 reassigned FLINK-24859: --- Assignee: Etienne Chauchot > Document new File formats > - > >

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

<    6   7   8   9   10   11   12   13   >