[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&focusedCommentId=17451122#comment-17451122 ] Arvid Heise commented on FLINK-24392: - This is blocked on dropping Java 8 on which t

[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-24851) KafkaSourceBuilder: auto.offset.reset is ignored

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

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

[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] [Resolved] (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 resolved FLINK-24741. - Resolution: Fixed Merged into master as 1dac395967e5870833d67c6bf1103ba874fce601. > Deprecate F

[jira] [Resolved] (FLINK-24765) Upgrade Kafka dependency

[ https://issues.apache.org/jira/browse/FLINK-24765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24765. - Fix Version/s: 1.15.0 Release Note: Kafka connector uses Kafka client 2.8.1 by default now.

[jira] [Resolved] (FLINK-24733) Data loss in pulsar source when using shared mode

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

[jira] [Resolved] (FLINK-24383) Remove the deprecated SlidingTimeWindows, TumblingTimeWindows, BaseAlignedWindowAssigner.

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

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

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

[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&focusedCommentId=17442786#comment-17442786 ] Arvid Heise commented on FLINK-24867: - In particular, it seems that a slow download

[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&focusedCommentId=17442786#comment-17442786 ] Arvid Heise edited comment on FLINK-24867 at 11/12/21, 2:57 PM: --

[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-24821) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-24821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442802#comment-17442802 ] Arvid Heise commented on FLINK-24821: - This seems to be caused by the use of [NetUt

[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&focusedCommentId=17442832#comment-17442832 ] Arvid Heise commented on FLINK-24795: - Let's check if the Kafka version bump to 2.8.

[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&focusedCommentId=17442833#comment-17442833 ] Arvid Heise commented on FLINK-24744: - Let's check if the Kafka version bump to 2.8.

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

[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&focusedCommentId=17442840#comment-17442840 ] Arvid Heise commented on FLINK-24763: - Please stop pinging me. Blame shows that [~lz

[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] [Commented] (FLINK-6573) Flink MongoDB Connector

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

[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&focusedCommentId=17443278#comment-17443278 ] Arvid Heise edited comment on FLINK-6573 at 11/14/21, 9:49 AM:

[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&focusedCommentId=17443602#comment-17443602 ] Arvid Heise commented on FLINK-24763: - How does the fetcher thread determines if the

[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=17443605#comment-17443605 ] Arvid Heise commented on FLINK-6573: That's good looking already :) Looking forward t

[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&focusedCommentId=17443687#comment-17443687 ] Arvid Heise commented on FLINK-24811: - [~renqs] can you please take a look if this a

[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&focusedCommentId=17444082#comment-17444082 ] Arvid Heise commented on FLINK-24763: - For me, it still not clear why the reader is

[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&focusedCommentId=17444316#comment-17444316 ] Arvid Heise commented on FLINK-20950: - I can also take a look. > SinkITCase.writerA

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

[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) > FlinkKafkaProducerITCase.testRecoverCommittedTr

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

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

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

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

[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] [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] [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-24916) AvroExternalJarProgramITCase JVM crash on Azure

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

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

[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&focusedCommentId=17444380#comment-17444380 ] Arvid Heise commented on FLINK-24811: - If the solution can be easily backported to 1

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

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

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

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

[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&focusedCommentId=17444388#comment-17444388 ] Arvid Heise commented on FLINK-24844: - [~echauchot] one more cassandra issue. Can yo

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

[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&focusedCommentId=17444399#comment-17444399 ] Arvid Heise commented on FLINK-24112: - This test passes on Linux. We should move the

[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&focusedCommentId=1766#comment-1766 ] Arvid Heise commented on FLINK-24844: - Ideally, you should be able to execute the te

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

[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-22775) CassandraConnectorITCase.testCassandraTableSink Fail

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

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

[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&focusedCommentId=17444688#comment-17444688 ] Arvid Heise commented on FLINK-16908: - We bumped Kafka to 2.8.1 in FLINK-24765, hope

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

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

[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&focusedCommentId=17424842#comment-17424842 ] Arvid Heise commented on FLINK-24382: - Merged into master as 9595767047259087820dca5

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

[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&focusedCommentId=17424851#comment-17424851 ] Arvid Heise commented on FLINK-24405: - Merged into master as ade011ec139f8258db356a

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

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

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

[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&focusedCommentId=17425382#comment-17425382 ] Arvid Heise commented on FLINK-24405: - Merged into 1.14 as 8eaee0ffe47b21d01f5c013d

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

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

[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&focusedCommentId=17429245#comment-17429245 ] Arvid Heise commented on FLINK-24493: - Hi Rion, unfortunately documentation is stil

[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&focusedCommentId=17429260#comment-17429260 ] Arvid Heise commented on FLINK-24459: - [~ykt836] shouldn't we also have backports fo

[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 > KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:27

[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 > KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:

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

[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] [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=17433111#comment-17433111 ] Arvid Heise commented on FLINK-21407: - Merged into 1.13 as 85a7f18fa5d299b18776addc

[jira] [Updated] (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 updated FLINK-21407: Fix Version/s: 1.13.4 > Clarify which sources and APIs support which formats > ---

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322030#comment-17322030 ] Arvid Heise commented on FLINK-22259: - I'd close this issue in hopes that the upcomi

[jira] [Closed] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22259. --- Resolution: Duplicate > UnalignedCheckpointITCase fails with "Value too large for header, this > in

[jira] [Commented] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322038#comment-17322038 ] Arvid Heise commented on FLINK-22173: - Given the frequency and the lack of logs, I'm

[jira] [Resolved] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22173. - Assignee: Arvid Heise Resolution: Cannot Reproduce > UnalignedCheckpointRescaleITCase fail

[jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API.

Arvid Heise created FLINK-22290: --- Summary: Add new unaligned checkpiont options to Python API. Key: FLINK-22290 URL: https://issues.apache.org/jira/browse/FLINK-22290 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22290: Affects Version/s: 1.13.0 > Add new unaligned checkpiont options to Python API. >

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322118#comment-17322118 ] Arvid Heise commented on FLINK-22019: - Let's wait for FLINK-21346 for more investiga

[jira] [Resolved] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22290. - Resolution: Fixed > Add new unaligned checkpiont options to Python API. > --

[jira] [Commented] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323936#comment-17323936 ] Arvid Heise commented on FLINK-22290: - Merged as 52b400f717dc9a5c903a9b834d02b0cbf6

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325641#comment-17325641 ] Arvid Heise commented on FLINK-22368: - The test doesn't finish as checkpointing gets

[jira] [Updated] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22368: Component/s: Runtime / Checkpointing > UnalignedCheckpointITCase hangs on azure >

[jira] [Comment Edited] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325641#comment-17325641 ] Arvid Heise edited comment on FLINK-22368 at 4/20/21, 9:30 AM: ---

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325647#comment-17325647 ] Arvid Heise commented on FLINK-22368: - Okay, it makes sense that it doesn't checkpoi

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325658#comment-17325658 ] Arvid Heise commented on FLINK-22368: - All source tasks are finished, but the job is

[jira] [Updated] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22368: Component/s: (was: Runtime / Checkpointing) Runtime / Task > UnalignedCheckpo

[jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20379: Fix Version/s: (was: 1.12.3) 1.12.4 > Update KafkaRecordDeserializationSche

[jira] [Updated] (FLINK-20114) Test Kafka Source based on the new Source API 

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Fix Version/s: (was: 1.12.3) 1.12.4 > Test Kafka Source based on the new So

[jira] [Updated] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover

[ https://issues.apache.org/jira/browse/FLINK-20465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20465: Fix Version/s: (was: 1.12.3) 1.12.4 > Fail globally when not resuming from

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20951: Fix Version/s: (was: 1.12.3) 1.12.4 > IllegalArgumentException when reading

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20431: Fix Version/s: (was: 1.12.3) 1.12.4 > KafkaSourceReaderTest.testCommitOffse

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22282: Fix Version/s: (was: 1.12.3) 1.12.4 > Move creation of SplitEnumerator to t

[jira] [Updated] (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 updated FLINK-19743: Fix Version/s: (was: 1.12.3) 1.12.4 > Add Source metrics definitions >

[jira] [Updated] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20553: Fix Version/s: (was: 1.12.3) 1.12.4 1.13.1 > Add end-to-

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20576: Fix Version/s: (was: 1.12.3) 1.12.4 > Flink Temporal Join Hive Dim Error >

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20457: Fix Version/s: (was: 1.12.3) 1.12.4 > Fix the handling of timestamp in Data

<    7   8   9   10   11   12   13   >