[jira] [Created] (FLINK-21378) Rescale pointwise connection during unaligned checkpoint recovery

Arvid Heise created FLINK-21378: --- Summary: Rescale pointwise connection during unaligned checkpoint recovery Key: FLINK-21378 URL: https://issues.apache.org/jira/browse/FLINK-21378 Project: Flink

[jira] [Assigned] (FLINK-21373) Port RabbitMQ Sink to FLIP-143 API

[ https://issues.apache.org/jira/browse/FLINK-21373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21373: --- Assignee: Jan Westphal > Port RabbitMQ Sink to FLIP-143 API > -

[jira] [Commented] (FLINK-21373) Port RabbitMQ Sink to FLIP-143 API

[ https://issues.apache.org/jira/browse/FLINK-21373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285775#comment-17285775 ] Arvid Heise commented on FLINK-21373: - [~Wosinsan] would you like to review a potent

[jira] [Created] (FLINK-21452) FLIP-27 sources cannot reliably downscale

Arvid Heise created FLINK-21452: --- Summary: FLIP-27 sources cannot reliably downscale Key: FLINK-21452 URL: https://issues.apache.org/jira/browse/FLINK-21452 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-21490) UnalignedCheckpointITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290742#comment-17290742 ] Arvid Heise commented on FLINK-21490: - The error is probably test-only: For some rea

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291114#comment-17291114 ] Arvid Heise commented on FLINK-17510: - https://dev.azure.com/apache-flink/apache-fli

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291119#comment-17291119 ] Arvid Heise commented on FLINK-17510: - https://dev.azure.com/arvidheise0209/arvidhei

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291126#comment-17291126 ] Arvid Heise commented on FLINK-17510: - https://dev.azure.com/apache-flink/apache-fli

[jira] [Commented] (FLINK-21490) UnalignedCheckpointITCase fails on azure

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

[jira] [Resolved] (FLINK-21490) UnalignedCheckpointITCase fails on azure

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

[jira] [Commented] (FLINK-21452) FLIP-27 sources cannot reliably downscale

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

[jira] [Resolved] (FLINK-21452) FLIP-27 sources cannot reliably downscale

[ https://issues.apache.org/jira/browse/FLINK-21452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21452. - Resolution: Fixed > FLIP-27 sources cannot reliably downscale >

[jira] [Updated] (FLINK-21452) FLIP-27 sources cannot reliably downscale

[ https://issues.apache.org/jira/browse/FLINK-21452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21452: Description: Sources currently store their registered readers into the snapshot. However, when do

[jira] [Assigned] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21511: --- Assignee: zhangmeng > Flink connector elasticsearch 6.x has a bug about BulkProcessor hang

[jira] [Commented] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17292715#comment-17292715 ] Arvid Heise commented on FLINK-21511: - Thank you [~zhangmeng0426] for bringing this

[jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413453#comment-16413453 ] Arvid Heise commented on FLINK-8715: I don't have an overview for all the different us

[jira] [Comment Edited] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413453#comment-16413453 ] Arvid Heise edited comment on FLINK-8715 at 3/26/18 6:58 AM: -

[jira] [Created] (FLINK-18403) Ensure that only exactly once checkpointing can be unaligned

Arvid Heise created FLINK-18403: --- Summary: Ensure that only exactly once checkpointing can be unaligned Key: FLINK-18403 URL: https://issues.apache.org/jira/browse/FLINK-18403 Project: Flink I

[jira] [Updated] (FLINK-18403) Ensure that only exactly once checkpointing can be unaligned

[ https://issues.apache.org/jira/browse/FLINK-18403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18403: Issue Type: Bug (was: Improvement) > Ensure that only exactly once checkpointing can be unaligned

[jira] [Created] (FLINK-18404) Make unaligned checkpoints rescalable

Arvid Heise created FLINK-18404: --- Summary: Make unaligned checkpoints rescalable Key: FLINK-18404 URL: https://issues.apache.org/jira/browse/FLINK-18404 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18405) Add watermark support for unaligned checkpoints

Arvid Heise created FLINK-18405: --- Summary: Add watermark support for unaligned checkpoints Key: FLINK-18405 URL: https://issues.apache.org/jira/browse/FLINK-18405 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144723#comment-17144723 ] Arvid Heise commented on FLINK-18433: - Some possible causes from the network stack:

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144723#comment-17144723 ] Arvid Heise edited comment on FLINK-18433 at 6/25/20, 7:47 AM: ---

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17144952#comment-17144952 ] Arvid Heise commented on FLINK-18433: - Doing some bisect on a specific test would de

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146099#comment-17146099 ] Arvid Heise commented on FLINK-18433: - I'm starting to bisect on some EC2 instance.

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146139#comment-17146139 ] Arvid Heise commented on FLINK-18433: - Puh, this is not easy to reproduce. First,

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146139#comment-17146139 ] Arvid Heise edited comment on FLINK-18433 at 6/26/20, 9:27 AM: ---

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146650#comment-17146650 ] Arvid Heise commented on FLINK-18433: - Hi [~liyu], thanks for the update - I feared

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146650#comment-17146650 ] Arvid Heise edited comment on FLINK-18433 at 6/26/20, 9:25 PM: ---

[jira] [Updated] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18433: Attachment: flink_11.log.gz > From the end-to-end performance test results, 1.11 has a regression

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146650#comment-17146650 ] Arvid Heise edited comment on FLINK-18433 at 6/27/20, 9:12 AM: ---

[jira] [Comment Edited] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146650#comment-17146650 ] Arvid Heise edited comment on FLINK-18433 at 6/27/20, 9:12 AM: ---

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17147409#comment-17147409 ] Arvid Heise commented on FLINK-18433: - [~trohrmann], I used the local executor with

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148336#comment-17148336 ] Arvid Heise commented on FLINK-18433: - Would it be a good idea to check for the slav

[jira] [Commented] (FLINK-18307) Replace "slave" file name with "workers"

[ https://issues.apache.org/jira/browse/FLINK-18307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148773#comment-17148773 ] Arvid Heise commented on FLINK-18307: - Since https://issues.apache.org/jira/browse/F

[jira] [Comment Edited] (FLINK-18307) Replace "slave" file name with "workers"

[ https://issues.apache.org/jira/browse/FLINK-18307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17148773#comment-17148773 ] Arvid Heise edited comment on FLINK-18307 at 6/30/20, 3:29 PM: ---

[jira] [Assigned] (FLINK-18501) Mapping of Pluggable Filesystems to scheme is not properly logged

[ https://issues.apache.org/jira/browse/FLINK-18501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-18501: --- Assignee: Fabian Paul > Mapping of Pluggable Filesystems to scheme is not properly logged >

[jira] [Commented] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014442#comment-17014442 ] Arvid Heise commented on FLINK-15355: - [~liyu], you are right this issue is related

[jira] [Created] (FLINK-15583) Scala walkthrough archetype does not compile on Java 11

Arvid Heise created FLINK-15583: --- Summary: Scala walkthrough archetype does not compile on Java 11 Key: FLINK-15583 URL: https://issues.apache.org/jira/browse/FLINK-15583 Project: Flink Issue T

[jira] [Commented] (FLINK-15583) Scala walkthrough archetype does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-15583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015014#comment-17015014 ] Arvid Heise commented on FLINK-15583: - Related to FLINK-14276 and FLINK-9781. > Sca

[jira] [Commented] (FLINK-15623) Buildling flink-python with maven profile docs-and-source fails

[ https://issues.apache.org/jira/browse/FLINK-15623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017452#comment-17017452 ] Arvid Heise commented on FLINK-15623: - In general, I'd only whitelist stuff in `src/

[jira] [Reopened] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reopened FLINK-15355: - Current PluginClassLoader fails to load module classes in Java 9+. {noformat} Caused by: java.lang.C

[jira] [Created] (FLINK-15777) Truncate not working with plugins (as expected)

Arvid Heise created FLINK-15777: --- Summary: Truncate not working with plugins (as expected) Key: FLINK-15777 URL: https://issues.apache.org/jira/browse/FLINK-15777 Project: Flink Issue Type: Bug

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

Arvid Heise created FLINK-15845: --- Summary: Add java-based StreamingFileSink test using s3 Key: FLINK-15845 URL: https://issues.apache.org/jira/browse/FLINK-15845 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-18139) Unaligned checkpoints checks wrong channels for inflight data.

Arvid Heise created FLINK-18139: --- Summary: Unaligned checkpoints checks wrong channels for inflight data. Key: FLINK-18139 URL: https://issues.apache.org/jira/browse/FLINK-18139 Project: Flink

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126501#comment-17126501 ] Arvid Heise commented on FLINK-17949: - I like the idea of ensuring the test setup is

[jira] [Commented] (FLINK-17949) KafkaShuffleITCase.testSerDeIngestionTime:156->testRecordSerDe:388 expected:<310> but was:<0>

[ https://issues.apache.org/jira/browse/FLINK-17949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17127968#comment-17127968 ] Arvid Heise commented on FLINK-17949: - That solution would be fine by me. Of course,

[jira] [Created] (FLINK-18252) Resuming Savepoint (file, async, no parallelism change) end-to-end test fails with unaligned checkpoint enabled

Arvid Heise created FLINK-18252: --- Summary: Resuming Savepoint (file, async, no parallelism change) end-to-end test fails with unaligned checkpoint enabled Key: FLINK-18252 URL: https://issues.apache.org/jira/browse/

[jira] [Updated] (FLINK-18252) Resuming Savepoint (file, async, no parallelism change) end-to-end test fails with unaligned checkpoint enabled

[ https://issues.apache.org/jira/browse/FLINK-18252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18252: Issue Type: Bug (was: Improvement) > Resuming Savepoint (file, async, no parallelism change) end-

[jira] [Commented] (FLINK-18209) Replace "charged" words in the Flink codebase.

[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17134015#comment-17134015 ] Arvid Heise commented on FLINK-18209: - Btw, are there also related tickets for updat

[jira] [Updated] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Affects Version/s: 1.12.0 1.11.0 > Enable latency tracker would corrupt the

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17134561#comment-17134561 ] Arvid Heise commented on FLINK-17322: - Proper fix has been merged to master; current

[jira] [Updated] (FLINK-16432) Building Hive connector gives problems

[ https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-16432: Affects Version/s: 1.10.2 > Building Hive connector gives problems > -

[jira] [Reopened] (FLINK-16432) Building Hive connector gives problems

[ https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reopened FLINK-16432: - Assignee: Arvid Heise (was: Niels Basjes) Also 1.10 affected. > Building Hive connector give

[jira] [Updated] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Fix Version/s: 1.12.0 1.10.2 > Enable latency tracker would corrupt the broadca

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17135772#comment-17135772 ] Arvid Heise commented on FLINK-17322: - Merged fix to 1.11 and 1.10 is about to be me

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17136400#comment-17136400 ] Arvid Heise commented on FLINK-17322: - Merged to master as 7e7b132f611f5a564e8c7b1e6

[jira] [Updated] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Release Note: (was: Merged to master as 7e7b132f611f5a564e8c7b1e6b195692293fa90f Merged to 1.11

[jira] [Closed] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-17322. --- Release Note: Merged to master as 7e7b132f611f5a564e8c7b1e6b195692293fa90f Merged to 1.11 as dfdfdad

[jira] [Created] (FLINK-19026) Improve threading model of Unaligner

Arvid Heise created FLINK-19026: --- Summary: Improve threading model of Unaligner Key: FLINK-19026 URL: https://issues.apache.org/jira/browse/FLINK-19026 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-18955) Add snapshot path to job startup message

[ https://issues.apache.org/jira/browse/FLINK-18955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-18955. --- Fix Version/s: (was: 1.10.3) (was: 1.11.2) Resolution: Fixed Merge

[jira] [Created] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

Arvid Heise created FLINK-17819: --- Summary: Yarn error unhelpful when forgetting HADOOP_CLASSPATH Key: FLINK-17819 URL: https://issues.apache.org/jira/browse/FLINK-17819 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-17322: --- Assignee: Arvid Heise > Enable latency tracker would corrupt the broadcast state >

[jira] [Updated] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Affects Version/s: (was: 1.9.2) (was: 1.10.0)

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113083#comment-17113083 ] Arvid Heise commented on FLINK-17322: - There is a fundamental issue with latency mar

[jira] [Comment Edited] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113083#comment-17113083 ] Arvid Heise edited comment on FLINK-17322 at 5/22/20, 8:45 AM: ---

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120968#comment-17120968 ] Arvid Heise commented on FLINK-17918: - Yes [~ykt836] . I'm suspecting that during [u

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120974#comment-17120974 ] Arvid Heise commented on FLINK-17918: - Btw see this [commit|https://github.com/apac

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123385#comment-17123385 ] Arvid Heise commented on FLINK-17918: - Yes, the root cause is {{LIMIT}} swallowing u

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123503#comment-17123503 ] Arvid Heise commented on FLINK-17918: - I fear that these errors are independent, but

[jira] [Commented] (FLINK-17918) Blink Jobs are loosing data on recovery

[ https://issues.apache.org/jira/browse/FLINK-17918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125109#comment-17125109 ] Arvid Heise commented on FLINK-17918: - The ticket originally was "[FLINK-17918] Jobs

[jira] [Created] (FLINK-18094) Index offset not consistent in CheckpointedInputGate for unaligned checkpoints.

Arvid Heise created FLINK-18094: --- Summary: Index offset not consistent in CheckpointedInputGate for unaligned checkpoints. Key: FLINK-18094 URL: https://issues.apache.org/jira/browse/FLINK-18094 Project

[jira] [Commented] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096929#comment-17096929 ] Arvid Heise commented on FLINK-17315: - If even shouldPerformUnalignedCheckpointOnRem

[jira] [Commented] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101503#comment-17101503 ] Arvid Heise commented on FLINK-17315: - [~jark] can you double check that your commit

[jira] [Created] (FLINK-17580) NPE in unaligned checkpoint for EndOfPartition events

Arvid Heise created FLINK-17580: --- Summary: NPE in unaligned checkpoint for EndOfPartition events Key: FLINK-17580 URL: https://issues.apache.org/jira/browse/FLINK-17580 Project: Flink Issue Typ

[jira] [Created] (FLINK-17218) Add recovery to integration tests of unaligned checkpoints

Arvid Heise created FLINK-17218: --- Summary: Add recovery to integration tests of unaligned checkpoints Key: FLINK-17218 URL: https://issues.apache.org/jira/browse/FLINK-17218 Project: Flink Issu

[jira] [Created] (FLINK-17258) Enable unaligned checkpoints in tests by default

Arvid Heise created FLINK-17258: --- Summary: Enable unaligned checkpoints in tests by default Key: FLINK-17258 URL: https://issues.apache.org/jira/browse/FLINK-17258 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046933#comment-17046933 ] Arvid Heise commented on FLINK-16245: - I investigated a bit and I'm convinced that t

[jira] [Comment Edited] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:38 PM:

[jira] [Comment Edited] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:44 PM:

[jira] [Comment Edited] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:44 PM:

[jira] [Comment Edited] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:47 PM:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047253#comment-17047253 ] Arvid Heise commented on FLINK-16142: - [~sewen], are we using [URLClassLoader#close

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17047253#comment-17047253 ] Arvid Heise edited comment on FLINK-16142 at 2/28/20 6:39 AM:

[jira] [Commented] (FLINK-15786) Load connector code with separate classloader

[ https://issues.apache.org/jira/browse/FLINK-15786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049222#comment-17049222 ] Arvid Heise commented on FLINK-15786: - First of all, I'd very much like to also make

[jira] [Commented] (FLINK-16400) HdfsKindTest.testS3Kind fails in Hadoop 2.4.1 nightly test

[ https://issues.apache.org/jira/browse/FLINK-16400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050301#comment-17050301 ] Arvid Heise commented on FLINK-16400: - That is most likely caused by FLINK-16015 .

[jira] [Commented] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051089#comment-17051089 ] Arvid Heise commented on FLINK-16245: - What do you mean with clear the classloader?

[jira] [Created] (FLINK-18773) Enable parallel classloading

Arvid Heise created FLINK-18773: --- Summary: Enable parallel classloading Key: FLINK-18773 URL: https://issues.apache.org/jira/browse/FLINK-18773 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18694) Add unaligned checkpoint config to web ui

[ https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172976#comment-17172976 ] Arvid Heise commented on FLINK-18694: - Awesome addition. We had a similar (or the sa

[jira] [Created] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI

Arvid Heise created FLINK-18851: --- Summary: Add checkpoint type to checkpoint history entries in Web UI Key: FLINK-18851 URL: https://issues.apache.org/jira/browse/FLINK-18851 Project: Flink Is

[jira] [Created] (FLINK-8715) RocksDB does propagate reconfiguration of serializer to the states

Arvid Heise created FLINK-8715: -- Summary: RocksDB does propagate reconfiguration of serializer to the states Key: FLINK-8715 URL: https://issues.apache.org/jira/browse/FLINK-8715 Project: Flink

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-8715: --- Summary: RocksDB does not propagate reconfiguration of serializer to the states (was: RocksDB does pr

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-8715: --- Description: Any changes to the serializer done in #ensureCompability are lost during the state creat

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-8715: --- Description: Any changes to the serializer done in #ensureCompability are lost during the state creat

[jira] [Created] (FLINK-8716) AvroSerializer does not use schema of snapshot

Arvid Heise created FLINK-8716: -- Summary: AvroSerializer does not use schema of snapshot Key: FLINK-8716 URL: https://issues.apache.org/jira/browse/FLINK-8716 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states

[ https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-8715: --- Component/s: State Backends, Checkpointing > RocksDB does not propagate reconfiguration of serializer

[jira] [Commented] (FLINK-8716) AvroSerializer does not use schema of snapshot

[ https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370052#comment-16370052 ] Arvid Heise commented on FLINK-8716: In the email thread, [~till.rohrmann] also pointe

[jira] [Commented] (FLINK-8716) AvroSerializer does not use schema of snapshot

[ https://issues.apache.org/jira/browse/FLINK-8716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16370067#comment-16370067 ] Arvid Heise commented on FLINK-8716: Btw, the current behavior is that it will fail wi

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

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

[jira] [Commented] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17304783#comment-17304783 ] Arvid Heise commented on FLINK-20130: - Remerged as a407322a452b8a371d0ce25e8f5f84185

<    1   2   3   4   5   6   7   8   9   10   >