[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=16370052#comment-16370052 ] Arvid Heise commented on FLINK-8716: In the email thread, [~till.rohrmann] also pointed out that

[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=16370067#comment-16370067 ] Arvid Heise commented on FLINK-8716: Btw, the current behavior is that it will fail with an

[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

[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

[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] [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: --- Description: Any changes to the serializer done in #ensureCompability are lost during the state

[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=16413453#comment-16413453 ] Arvid Heise edited comment on FLINK-8715 at 3/26/18 6:58 AM: - I don't have an

[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=16413453#comment-16413453 ] Arvid Heise commented on FLINK-8715: I don't have an overview for all the different use cases, so the

[jira] [Created] (FLINK-13956) Add sequence file format with repeated sync blocks

Arvid Heise created FLINK-13956: --- Summary: Add sequence file format with repeated sync blocks Key: FLINK-13956 URL: https://issues.apache.org/jira/browse/FLINK-13956 Project: Flink Issue Type:

[jira] [Created] (FLINK-13995) Fix shading of the licence information of netty

Arvid Heise created FLINK-13995: --- Summary: Fix shading of the licence information of netty Key: FLINK-13995 URL: https://issues.apache.org/jira/browse/FLINK-13995 Project: Flink Issue Type:

[jira] [Created] (FLINK-14044) Reducing synchronization in AsyncWaitOperator

Arvid Heise created FLINK-14044: --- Summary: Reducing synchronization in AsyncWaitOperator Key: FLINK-14044 URL: https://issues.apache.org/jira/browse/FLINK-14044 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14044) Reducing synchronization in AsyncWaitOperator

[ https://issues.apache.org/jira/browse/FLINK-14044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-14044: Component/s: Runtime / Task > Reducing synchronization in AsyncWaitOperator >

[jira] [Created] (FLINK-14304) Avoid task starvation with mailbox

Arvid Heise created FLINK-14304: --- Summary: Avoid task starvation with mailbox Key: FLINK-14304 URL: https://issues.apache.org/jira/browse/FLINK-14304 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14199) Only use dedicated/named classes for mailbox letters.

Arvid Heise created FLINK-14199: --- Summary: Only use dedicated/named classes for mailbox letters. Key: FLINK-14199 URL: https://issues.apache.org/jira/browse/FLINK-14199 Project: Flink Issue

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962842#comment-16962842 ] Arvid Heise commented on FLINK-14544: - Small update: Found the issue and will provide a fix later.

[jira] [Comment Edited] (FLINK-14304) Avoid task starvation with mailbox

[ https://issues.apache.org/jira/browse/FLINK-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969251#comment-16969251 ] Arvid Heise edited comment on FLINK-14304 at 11/7/19 1:31 PM: -- Merged in

[jira] [Comment Edited] (FLINK-14304) Avoid task starvation with mailbox

[ https://issues.apache.org/jira/browse/FLINK-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969251#comment-16969251 ] Arvid Heise edited comment on FLINK-14304 at 11/7/19 1:31 PM: -- Merged in

[jira] [Commented] (FLINK-14304) Avoid task starvation with mailbox

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

[jira] [Created] (FLINK-14747) Performance regression with latest changes to Mailbox

Arvid Heise created FLINK-14747: --- Summary: Performance regression with latest changes to Mailbox Key: FLINK-14747 URL: https://issues.apache.org/jira/browse/FLINK-14747 Project: Flink Issue

[jira] [Updated] (FLINK-14794) KeyedStream#transform not working with factories

[ https://issues.apache.org/jira/browse/FLINK-14794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-14794: Fix Version/s: 1.10.0 > KeyedStream#transform not working with factories >

[jira] [Updated] (FLINK-14794) KeyedStream#transform not working with factories

[ https://issues.apache.org/jira/browse/FLINK-14794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-14794: Affects Version/s: 1.10.0 > KeyedStream#transform not working with factories >

[jira] [Created] (FLINK-14794) KeyedStream#transform not working with factories

Arvid Heise created FLINK-14794: --- Summary: KeyedStream#transform not working with factories Key: FLINK-14794 URL: https://issues.apache.org/jira/browse/FLINK-14794 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14346) Performance issue with StringSerializer

[ https://issues.apache.org/jira/browse/FLINK-14346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987677#comment-16987677 ] Arvid Heise commented on FLINK-14346: - That's some impressive improvements. I'd suggest to modify

[jira] [Commented] (FLINK-13589) DelimitedInputFormat index error on multi-byte delimiters with whole file input splits

[ https://issues.apache.org/jira/browse/FLINK-13589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995659#comment-16995659 ] Arvid Heise commented on FLINK-13589: - Thank you very much for the bug report and the patch. I will

[jira] [Commented] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16998145#comment-16998145 ] Arvid Heise commented on FLINK-15285: - FLINK-15105 will improve test stability, hence the downgrade.

[jira] [Commented] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993493#comment-16993493 ] Arvid Heise commented on FLINK-14311: - I adjusted this test with FLINK-14574 , so I'd probably wait

[jira] [Commented] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993500#comment-16993500 ] Arvid Heise commented on FLINK-14223: - Probably caused by FLINK-14370 and solved by

[jira] [Commented] (FLINK-14308) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993499#comment-16993499 ] Arvid Heise commented on FLINK-14308: - Probably caused by FLINK-14370 and solved by

[jira] [Commented] (FLINK-14574) flink-s3-fs-hadoop doesn't work with plugins mechanism

[ https://issues.apache.org/jira/browse/FLINK-14574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994454#comment-16994454 ] Arvid Heise commented on FLINK-14574: - Backporting and open PR, once Travis passes. >

[jira] [Commented] (FLINK-15215) Not able to provide a custom AWS credentials provider with flink-s3-fs-hadoop

[ https://issues.apache.org/jira/browse/FLINK-15215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994667#comment-16994667 ] Arvid Heise commented on FLINK-15215: - For 1.10, we want to get rid of shading altogether. We fixed

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15219: Description: Currently, plugins cannot be used in `LocalEnvironment` as `FileSystem`s are only

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15219: Description: Currently, plugins cannot be used in `LocalEnvironment` as `FileSystem`s are only

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15219: Description: Currently, plugins cannot be used in `LocalEnvironment` as `FileSystem`s are only

[jira] [Created] (FLINK-15219) LocalEnvironment is not initializing plugins

Arvid Heise created FLINK-15219: --- Summary: LocalEnvironment is not initializing plugins Key: FLINK-15219 URL: https://issues.apache.org/jira/browse/FLINK-15219 Project: Flink Issue Type:

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15219: Issue Type: Bug (was: Improvement) > LocalEnvironment is not initializing plugins >

[jira] [Updated] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-15219: Affects Version/s: 1.10.0 > LocalEnvironment is not initializing plugins >

[jira] [Commented] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994878#comment-16994878 ] Arvid Heise commented on FLINK-15219: - You simply add a plugins folder to your working directory and

[jira] [Comment Edited] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955110#comment-16955110 ] Arvid Heise edited comment on FLINK-14370 at 10/19/19 8:32 AM: --- We found

[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955110#comment-16955110 ] Arvid Heise commented on FLINK-14370: - We found the root cause and are currently discussing fixes as

[jira] [Comment Edited] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955110#comment-16955110 ] Arvid Heise edited comment on FLINK-14370 at 10/19/19 8:30 AM: --- We found

[jira] [Created] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

Arvid Heise created FLINK-14480: --- Summary: Sort out exception supression during snapshotting for non-running tasks. Key: FLINK-14480 URL: https://issues.apache.org/jira/browse/FLINK-14480 Project:

[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956135#comment-16956135 ] Arvid Heise commented on FLINK-14370: - So [~pnowojski] will merge a better fix for stabilizing the

[jira] [Updated] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

[ https://issues.apache.org/jira/browse/FLINK-14480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-14480: Description: Following-up on FLINK-14370. As [~becket_qin] wrote: "The cause [of FLINK-14370]

[jira] [Updated] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

[ https://issues.apache.org/jira/browse/FLINK-14480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-14480: Description: Following-up on FLINK-14370. As [~becket_qin] wrote: "The cause [of the unstable

[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956751#comment-16956751 ] Arvid Heise commented on FLINK-14370: - Yes, that's a good idea.

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961863#comment-16961863 ] Arvid Heise commented on FLINK-14544: - Can someone assign that ticket to me? I will take a look. >

[jira] [Created] (FLINK-14935) Improve mailbox exception handling

Arvid Heise created FLINK-14935: --- Summary: Improve mailbox exception handling Key: FLINK-14935 URL: https://issues.apache.org/jira/browse/FLINK-14935 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981342#comment-16981342 ] Arvid Heise commented on FLINK-13758: - If FLINK-14908 is indeed a duplicate, then this is also

[jira] [Created] (FLINK-14975) Presto filesystem plugin shades wrong version of guava

Arvid Heise created FLINK-14975: --- Summary: Presto filesystem plugin shades wrong version of guava Key: FLINK-14975 URL: https://issues.apache.org/jira/browse/FLINK-14975 Project: Flink Issue

[jira] [Commented] (FLINK-14346) Performance issue with StringSerializer

[ https://issues.apache.org/jira/browse/FLINK-14346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986110#comment-16986110 ] Arvid Heise commented on FLINK-14346: - Hi [~rgrebennikov] , I'm looking at your PR's. One oddity

[jira] [Created] (FLINK-14934) Remove error log statement in ES connector

Arvid Heise created FLINK-14934: --- Summary: Remove error log statement in ES connector Key: FLINK-14934 URL: https://issues.apache.org/jira/browse/FLINK-14934 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14975) Presto filesystem plugin shades wrong version of guava

[ https://issues.apache.org/jira/browse/FLINK-14975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984798#comment-16984798 ] Arvid Heise commented on FLINK-14975: - Turns out the issue arrives just by my local build with my

[jira] [Commented] (FLINK-15219) LocalEnvironment is not initializing plugins

[ https://issues.apache.org/jira/browse/FLINK-15219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999166#comment-16999166 ] Arvid Heise commented on FLINK-15219: - Piotr suggested to provide a manual hook for users to

[jira] [Commented] (FLINK-15268) Shaded Hadoop S3A end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999092#comment-16999092 ] Arvid Heise commented on FLINK-15268: - Is this related to Java 11 not having jaxb anymore? > Shaded

[jira] [Commented] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis

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

[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=17001629#comment-17001629 ] Arvid Heise commented on FLINK-15355: - Most likely the Hadoop `Configuration` from

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

Arvid Heise created FLINK-15355: --- Summary: Nightly streaming file sink fails with unshaded hadoop Key: FLINK-15355 URL: https://issues.apache.org/jira/browse/FLINK-15355 Project: Flink Issue

[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=17001932#comment-17001932 ] Arvid Heise commented on FLINK-15355: - Initial suspicion could not be verified: `Configuration` from

[jira] [Created] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

Arvid Heise created FLINK-16014: --- Summary: S3 plugin ClassNotFoundException SAXParser Key: FLINK-16014 URL: https://issues.apache.org/jira/browse/FLINK-16014 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16015) Refine fallback filesystems to only handle specific filesystems

Arvid Heise created FLINK-16015: --- Summary: Refine fallback filesystems to only handle specific filesystems Key: FLINK-16015 URL: https://issues.apache.org/jira/browse/FLINK-16015 Project: Flink

[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=17049222#comment-17049222 ] Arvid Heise commented on FLINK-15786: - First of all, I'd very much like to also make connectors

[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=17050301#comment-17050301 ] Arvid Heise commented on FLINK-16400: - That is most likely caused by FLINK-16015 . We could either

[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=17051089#comment-17051089 ] Arvid Heise commented on FLINK-16245: - What do you mean with clear the classloader? If we have one

[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=17047253#comment-17047253 ] Arvid Heise commented on FLINK-16142: - [~sewen], are we using

[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=17047253#comment-17047253 ] Arvid Heise edited comment on FLINK-16142 at 2/28/20 6:39 AM: -- [~sewen],

[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=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:44 PM: -- I

[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=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:44 PM: -- I

[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=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:38 PM: -- I

[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=17046933#comment-17046933 ] Arvid Heise commented on FLINK-16245: - I investigated a bit and I'm convinced that this fix will not

[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=17046933#comment-17046933 ] Arvid Heise edited comment on FLINK-16245 at 2/27/20 7:47 PM: -- I

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

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

[jira] [Commented] (FLINK-15903) Make REST port configurable in end to end test scripts

[ https://issues.apache.org/jira/browse/FLINK-15903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029870#comment-17029870 ] Arvid Heise commented on FLINK-15903: - I'd go with random port approach. > Make REST port

[jira] [Comment Edited] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/17/20 4:31 PM: -- Root cause

[jira] [Commented] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise commented on FLINK-16014: - Preliminary assessment: Root cause is a bug in JDK8.

[jira] [Comment Edited] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/17/20 4:43 PM: -- Root cause

[jira] [Commented] (FLINK-16116) Remove shading from oss filesystems build

[ https://issues.apache.org/jira/browse/FLINK-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038937#comment-17038937 ] Arvid Heise commented on FLINK-16116: - +1 for unshading. We should do that for all filesystems in

[jira] [Comment Edited] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/18/20 8:02 AM: -- Root cause

[jira] [Comment Edited] (FLINK-16014) S3 plugin ClassNotFoundException SAXParser

[ https://issues.apache.org/jira/browse/FLINK-16014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/18/20 8:03 AM: -- Root cause

[jira] [Created] (FLINK-16219) Make AsyncWaitOperator chainable again

Arvid Heise created FLINK-16219: --- Summary: Make AsyncWaitOperator chainable again Key: FLINK-16219 URL: https://issues.apache.org/jira/browse/FLINK-16219 Project: Flink Issue Type: Improvement

[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=17039213#comment-17039213 ] Arvid Heise commented on FLINK-16142: - Would it be possible to give some

[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=17039213#comment-17039213 ] Arvid Heise edited comment on FLINK-16142 at 2/18/20 4:28 PM: -- Would it be

[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=17014442#comment-17014442 ] Arvid Heise commented on FLINK-15355: - [~liyu], you are right this issue is related to the

[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=17017452#comment-17017452 ] Arvid Heise commented on FLINK-15623: - In general, I'd only whitelist stuff in `src/`. > Buildling

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

[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

[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=17015014#comment-17015014 ] Arvid Heise commented on FLINK-15583: - Related to FLINK-14276 and FLINK-9781. > Scala walkthrough

[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=17003658#comment-17003658 ] Arvid Heise commented on FLINK-15355: - I reran [https://github.com/apache/flink/pull/10678] three

[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=17002988#comment-17002988 ] Arvid Heise commented on FLINK-15355: - Hi [~banmoy] , thank you for the throughout investigation.

[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=17008610#comment-17008610 ] Arvid Heise commented on FLINK-15355: - Btw concerning why *{{org.apache.hadoop}}* is in the list: my

[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=17008608#comment-17008608 ] Arvid Heise commented on FLINK-15355: - Like I said before, option 4 assumes that no one bundles

[jira] [Commented] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008911#comment-17008911 ] Arvid Heise commented on FLINK-15327: - Hi [~rmetzger] , this is independent of legacy source and

[jira] [Commented] (FLINK-16550) HadoopS3* tests fail with NullPointerException exceptions

[ https://issues.apache.org/jira/browse/FLINK-16550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058036#comment-17058036 ] Arvid Heise commented on FLINK-16550: - Should also be backported to 1.10. > HadoopS3* tests fail

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

[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

[jira] [Created] (FLINK-16587) Add basic CheckpointBarrierHandler for unaligned checkpoint

Arvid Heise created FLINK-16587: --- Summary: Add basic CheckpointBarrierHandler for unaligned checkpoint Key: FLINK-16587 URL: https://issues.apache.org/jira/browse/FLINK-16587 Project: Flink

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074486#comment-17074486 ] Arvid Heise commented on FLINK-16850: - {quote}but explaining it to everyone that checks for GPLv2 is

[jira] [Created] (FLINK-16972) Fix non-blocking output availability logic.

Arvid Heise created FLINK-16972: --- Summary: Fix non-blocking output availability logic. Key: FLINK-16972 URL: https://issues.apache.org/jira/browse/FLINK-16972 Project: Flink Issue Type: Bug

  1   2   3   4   5   6   7   8   9   10   >