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

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

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

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

[jira] [Commented] (FLINK-24612) Kafka test container creates a large amount of logs

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

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

[ https://issues.apache.org/jira/browse/FLINK-23914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23914. - Fix Version/s: 1.14.1 Assignee: Qingsheng Ren Resolution: Fixed > Make connector

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

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

[jira] [Resolved] (FLINK-24327) Integrate Elasticsearch 7 sink with Table API

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

[jira] [Updated] (FLINK-24327) Integrate unified Elasticsearch 7 sink with Table API

[ https://issues.apache.org/jira/browse/FLINK-24327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24327: Summary: Integrate unified Elasticsearch 7 sink with Table API (was: Integrate Elasticsearch 7 si

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17436646#comment-17436646 ] Arvid Heise commented on FLINK-20443: - Merged into master as a7e15262cdf33d9587b2cb

[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: Fix Version/s: 1.15.0 > ContinuousProcessingTimeTrigger doesn't fire at the end of the window > --

[jira] [Commented] (FLINK-24705) Flink blood relationship

[ https://issues.apache.org/jira/browse/FLINK-24705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436651#comment-17436651 ] Arvid Heise commented on FLINK-24705: - I'm assuming you want to have data lineage in

[jira] [Closed] (FLINK-24705) Flink blood relationship

[ https://issues.apache.org/jira/browse/FLINK-24705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-24705. --- Resolution: Won't Do > Flink blood relationship > > > Key:

[jira] [Commented] (FLINK-24702) toUpperCase/toLowerCase calls may cause problems with some system locales

[ https://issues.apache.org/jira/browse/FLINK-24702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436655#comment-17436655 ] Arvid Heise commented on FLINK-24702: - I'm not sure how to solve it. Do we have expl

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

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436857#comment-17436857 ] Arvid Heise commented on FLINK-6573: I'll reassign this ticket. It's fair to assume t

[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: (was: Hai Zhou) > Flink MongoDB Connector > --- > >

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

[ https://issues.apache.org/jira/browse/FLINK-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436860#comment-17436860 ] Arvid Heise commented on FLINK-6573: [~jiabao.sun], [~monster#12] could you please co

[jira] [Assigned] (FLINK-24741) Deprecate FileRecordFormat, use StreamFormat instead

[ https://issues.apache.org/jira/browse/FLINK-24741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24741: --- Assignee: Jing Ge > Deprecate FileRecordFormat, use StreamFormat instead >

[jira] [Commented] (FLINK-24741) Deprecate FileRecordFormat, use StreamFormat instead

[ https://issues.apache.org/jira/browse/FLINK-24741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437773#comment-17437773 ] Arvid Heise commented on FLINK-24741: - While I agree that the {{FileRecordFormat}} i

[jira] [Assigned] (FLINK-24721) Update the based on the Maven official indication

[ https://issues.apache.org/jira/browse/FLINK-24721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24721: --- Assignee: Jing Ge > Update the based on the Maven official indication > --

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17437817#comment-17437817 ] Arvid Heise commented on FLINK-20443: - Merged into 1.14 as 1e1cbc0b9e7c8d29069a4653

[jira] [Updated] (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 updated FLINK-24325: Component/s: Connectors / ElasticSearch > Create ElasticSearch 6.8 Sink >

[jira] [Updated] (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 updated FLINK-24325: Component/s: (was: Table SQL / API) (was: API / DataStream) > Create Elas

[jira] [Resolved] (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 resolved FLINK-20443. - Fix Version/s: 1.13.4 1.14.1 Resolution: Fixed > ContinuousProcessingT

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17439283#comment-17439283 ] Arvid Heise commented on FLINK-20443: - Merged into 1.13 as 9cd7b421e6ec9cbff0995761

[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&focusedCommentId=17389836#comment-17389836 ] Arvid Heise commented on FLINK-23449: - [~yuchuanchen] could you please check if the

[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&focusedCommentId=17390637#comment-17390637 ] Arvid Heise commented on FLINK-23297: - Merged into master as 8628cf976e99b04c5f87349

[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] [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-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&focusedCommentId=17392843#comment-17392843 ] Arvid Heise commented on FLINK-23183: - Merged into master as 900af3e43eb34f8899a4509

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

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

[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&focusedCommentId=17393062#comment-17393062 ] Arvid Heise commented on FLINK-18562: - [~psrinivasulu], I reviewed your PR and it's

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394256#comment-17394256 ] Arvid Heise commented on FLINK-23647: - I'm assuming it's more an implementation issu

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394534#comment-17394534 ] Arvid Heise commented on FLINK-23647: - `listFiles` is an atomic operation afaik. The

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

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

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394670#comment-17394670 ] Arvid Heise commented on FLINK-23647: - Okay let us take the ticket, it takes too lon

[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 801dd688789921277b0a03d76b7cc707dc1010f0..8719481c3b44d

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

[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] [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&focusedCommentId=17394937#comment-17394937 ] Arvid Heise commented on FLINK-23124: - Merged into master as 801dd688789921277b0a03

[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 801dd688789921277b0a03d76b7cc707dc1010f0..871948

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

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

[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] [Commented] (FLINK-23674) flink restart with checkpoint ,kafka producer throw exception

[ https://issues.apache.org/jira/browse/FLINK-23674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17395843#comment-17395843 ] Arvid Heise commented on FLINK-23674: - Can you please provide the full log? > flink

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

[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] [Commented] (FLINK-23647) UnalignedCheckpointStressITCase crashed on azure

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396845#comment-17396845 ] Arvid Heise commented on FLINK-23647: - Yes, it would also avoid ugly hacks like htt

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

[ https://issues.apache.org/jira/browse/FLINK-23647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396853#comment-17396853 ] Arvid Heise commented on FLINK-23647: - Here is my solution to solve the test instabi

[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 flink-azure-f

[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&focusedCommentId=17397220#comment-17397220 ] Arvid Heise commented on FLINK-23462: - This is now good to go. Thanks [~Liebing]! >

[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] [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&focusedCommentId=17397370#comment-17397370 ] Arvid Heise commented on FLINK-23722: - Downgrading to 3.3.0 yields HADOOP-17337. 3.2

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

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

[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) > KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee

[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&focusedCommentId=17397606#comment-17397606 ] Arvid Heise edited comment on FLINK-23722 at 8/11/21, 8:13 PM: ---

[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&focusedCommentId=17397830#comment-17397830 ] Arvid Heise commented on FLINK-23678: - The new errors are related to FLINK-23408. We

[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&focusedCommentId=17397832#comment-17397832 ] Arvid Heise commented on FLINK-23678: - Ignoring test in ac42bb3d146 on master. > Ka

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

[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&focusedCommentId=17452592#comment-17452592 ] Arvid Heise commented on FLINK-21407: - Merged into 1.14 as db8be1d355ebac1cfe552c10

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

[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] [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&focusedCommentId=17454123#comment-17454123 ] Arvid Heise commented on FLINK-24686: - Merged into master as 7166ef1c08e3e3831a2539

[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&focusedCommentId=17454144#comment-17454144 ] Arvid Heise commented on FLINK-24821: - https://github.com/apache/flink/pull/16108 is

[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&focusedCommentId=17454190#comment-17454190 ] Arvid Heise commented on FLINK-24859: - Merged into 1.14 as 3b9aaca3c96a79c241568f44

[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] [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&focusedCommentId=17454500#comment-17454500 ] Arvid Heise edited comment on FLINK-25167 at 12/7/21, 9:23 AM: ---

[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&focusedCommentId=17454500#comment-17454500 ] Arvid Heise commented on FLINK-25167: - Let me include [~pnowojski]. I think he wante

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

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

[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&focusedCommentId=17454748#comment-17454748 ] Arvid Heise commented on FLINK-20928: - [~renqs], is this test still using the proxy

[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&focusedCommentId=17455093#comment-17455093 ] Arvid Heise commented on FLINK-20928: - I think the proper solution is to migrate the

[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&focusedCommentId=17455336#comment-17455336 ] Arvid Heise commented on FLINK-24859: - Renaming was breaking API in 1.14 and master.

[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&focusedCommentId=17456213#comment-17456213 ] Arvid Heise commented on FLINK-24489: - Merged into master as 4d142b3a417c57e4ed8af4c

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

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

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

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

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

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

[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] [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-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] [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] [Commented] (FLINK-25263) KafkaSourceE2ECase is broken

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

[jira] [Commented] (FLINK-23945) can not open dashboard

[ https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404366#comment-17404366 ] Arvid Heise commented on FLINK-23945: - Your syntax is incorrect. s3:/// is always se

[jira] [Comment Edited] (FLINK-23945) can not open dashboard

[ https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404366#comment-17404366 ] Arvid Heise edited comment on FLINK-23945 at 8/25/21, 11:41 AM: --

[jira] [Comment Edited] (FLINK-23945) can not open dashboard

[ https://issues.apache.org/jira/browse/FLINK-23945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404366#comment-17404366 ] Arvid Heise edited comment on FLINK-23945 at 8/25/21, 11:41 AM: --

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404373#comment-17404373 ] Arvid Heise commented on FLINK-23886: - {quote} Flink actually synchronizes invocatio

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404373#comment-17404373 ] Arvid Heise edited comment on FLINK-23886 at 8/25/21, 11:49 AM: --

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

Arvid Heise created FLINK-23969: --- Summary: Test Pulsar source end 2 end Key: FLINK-23969 URL: https://issues.apache.org/jira/browse/FLINK-23969 Project: Flink Issue Type: Sub-task Com

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

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23969: --- Assignee: Liu > Test Pulsar source end 2 end > > >

<    5   6   7   8   9   10   11   12   13   >