[jira] [Created] (FLINK-22573) AsyncIO can timeout elements after completion

Arvid Heise created FLINK-22573: --- Summary: AsyncIO can timeout elements after completion Key: FLINK-22573 URL: https://issues.apache.org/jira/browse/FLINK-22573 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17339861#comment-17339861 ] Arvid Heise commented on FLINK-22573: - Merged the fix into master as 56e292b92ec0dc

[jira] [Commented] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340014#comment-17340014 ] Arvid Heise commented on FLINK-22573: - Merged into 1.12 as 41dc5871d76e913bad9be59d6

[jira] [Updated] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22573: Fix Version/s: 1.12.4 1.13.1 1.14.0 > AsyncIO can timeout el

[jira] [Resolved] (FLINK-22573) AsyncIO can timeout elements after completion

[ https://issues.apache.org/jira/browse/FLINK-22573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22573. - Resolution: Fixed > AsyncIO can timeout elements after completion >

[jira] [Commented] (FLINK-22566) Running Kerberized YARN application on Docker test (default input) fails with no resources

[ https://issues.apache.org/jira/browse/FLINK-22566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340237#comment-17340237 ] Arvid Heise commented on FLINK-22566: - I disabled the tests in 1.12 with 59f764ba504

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340239#comment-17340239 ] Arvid Heise commented on FLINK-17170: - Merged into 1.12 as 1de3d6345a4132dda4b31f662

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

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

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

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

[jira] [Resolved] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-17170. - Fix Version/s: 1.12.4 1.13.1 1.14.0 Resolution: Fixe

[jira] [Updated] (FLINK-22502) DefaultCompletedCheckpointStore drops unrecoverable checkpoints silently

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

[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.4) 1.12.5 > Update KafkaRecordDeserializationSche

[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.4) 1.12.5 > KafkaSourceReaderTest.testCommitOffse

[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.4) 1.12.5 > Add Source metrics definitions >

[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.4) 1.12.5 > Flink Temporal Join Hive Dim Error >

[jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19925: Fix Version/s: (was: 1.12.4) 1.12.5 > Errors$NativeIoException: readAddress

[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.4) 1.12.5 > Move creation of SplitEnumerator to t

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20655: Fix Version/s: (was: 1.12.4) 1.12.5 > Add E2E tests to the new KafkaSource

[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.4) 1.12.5 > Fix the handling of timestamp in Data

[jira] [Updated] (FLINK-22494) Avoid discarding checkpoints in case of failure

[ https://issues.apache.org/jira/browse/FLINK-22494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22494: Fix Version/s: (was: 1.12.4) 1.12.5 > Avoid discarding checkpoints in case

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20656: Fix Version/s: (was: 1.12.4) 1.12.5 > Update docs for new KafkaSource conne

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20849: Fix Version/s: (was: 1.12.4) 1.12.5 > Improve JavaDoc and logging of new Ka

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21445: Fix Version/s: (was: 1.12.4) 1.12.5 > Application mode does not set the con

[jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

[ https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21589: Fix Version/s: (was: 1.12.4) 1.12.5 > Document Table/SQL API limitations re

[jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20777: Fix Version/s: (was: 1.12.4) 1.12.5 > Default value of property "partition.

[jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22040: Fix Version/s: (was: 1.12.4) 1.12.5 > Maven: Entry has not been leased from

[jira] [Updated] (FLINK-22434) Dispatcher does not store suspended jobs in execution graph store

[ https://issues.apache.org/jira/browse/FLINK-22434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22434: Fix Version/s: (was: 1.12.4) 1.12.5 > Dispatcher does not store suspended j

[jira] [Updated] (FLINK-22564) Kubernetes-related ITCases do not fail even in case of failure

[ https://issues.apache.org/jira/browse/FLINK-22564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22564: Fix Version/s: (was: 1.12.4) 1.12.5 > Kubernetes-related ITCases do not fai

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20687: Fix Version/s: (was: 1.12.4) 1.12.5 > Missing 'yarn-application' target in

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21711: Fix Version/s: (was: 1.12.4) 1.12.5 > DataStreamSink doesn't allow setting

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21876: Fix Version/s: (was: 1.12.4) 1.12.5 > Handle it properly when the returned

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21693: Fix Version/s: (was: 1.12.4) 1.12.5 > TestStreamEnvironment does not implem

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22479: Fix Version/s: 1.13.1 > [Kinesis][Consumer] Potential lock-up under error condition >

[jira] [Resolved] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22479. - Resolution: Fixed > [Kinesis][Consumer] Potential lock-up under error condition > --

[jira] [Updated] (FLINK-18952) Add 10 minutes to DataStream API documentation

[ https://issues.apache.org/jira/browse/FLINK-18952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-18952: Parent: (was: FLINK-18761) Issue Type: Improvement (was: Sub-task) > Add 10 minutes t

[jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Summary: Fix a few KafkaSource-related bugs (was: Test Kafka Source based on the new Source API )

[jira] [Updated] (FLINK-20114) Fix a few KafkaSource-related bugs

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20114: Parent: (was: FLINK-20112) Issue Type: Bug (was: Sub-task) > Fix a few KafkaSource-re

[jira] [Created] (FLINK-22682) Checkpoint interval too large for higher DOP

Arvid Heise created FLINK-22682: --- Summary: Checkpoint interval too large for higher DOP Key: FLINK-22682 URL: https://issues.apache.org/jira/browse/FLINK-22682 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22682) Checkpoint interval too large for higher DOP

[ https://issues.apache.org/jira/browse/FLINK-22682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22682: Description: When running a job on EMR with DOP of 160, checkpoints are not triggered at the set

[jira] [Created] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

Arvid Heise created FLINK-22686: --- Summary: Incompatible subtask mappings while resuming from unaligned checkpoints Key: FLINK-22686 URL: https://issues.apache.org/jira/browse/FLINK-22686 Project: Flink

[jira] [Updated] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22686: Fix Version/s: 1.13.1 > Incompatible subtask mappings while resuming from unaligned checkpoints >

[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&focusedCommentId=16962842#comment-16962842 ] Arvid Heise commented on FLINK-14544: - Small update: Found the issue and will provid

[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&focusedCommentId=16969251#comment-16969251 ] Arvid Heise commented on FLINK-14304: - Merged in edeec8d7420185d1c49b2739827bd921d2

[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&focusedCommentId=16969251#comment-16969251 ] Arvid Heise edited comment on FLINK-14304 at 11/7/19 1:31 PM:

[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&focusedCommentId=16969251#comment-16969251 ] Arvid Heise edited comment on FLINK-14304 at 11/7/19 1:31 PM:

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

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

[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] [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&focusedCommentId=17029870#comment-17029870 ] Arvid Heise commented on FLINK-15903: - I'd go with random port approach. > Make RES

[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] [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&focusedCommentId=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/17/20 4:31 PM:

[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&focusedCommentId=17038494#comment-17038494 ] Arvid Heise commented on FLINK-16014: - Preliminary assessment: Root cause is a bug

[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&focusedCommentId=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/17/20 4:43 PM:

[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&focusedCommentId=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/18/20 8:02 AM:

[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&focusedCommentId=17038494#comment-17038494 ] Arvid Heise edited comment on FLINK-16014 at 2/18/20 8:03 AM:

[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&focusedCommentId=17038937#comment-17038937 ] Arvid Heise commented on FLINK-16116: - +1 for unshading. We should do that for all f

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

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

[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-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&focusedCommentId=16993493#comment-16993493 ] Arvid Heise commented on FLINK-14311: - I adjusted this test with FLINK-14574 , so I'

[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&focusedCommentId=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&focusedCommentId=16993499#comment-16993499 ] Arvid Heise commented on FLINK-14308: - Probably caused by FLINK-14370 and solved by

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

[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-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&focusedCommentId=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&focusedCommentId=16994667#comment-16994667 ] Arvid Heise commented on FLINK-15215: - For 1.10, we want to get rid of shading altog

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

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

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

[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&focusedCommentId=16994878#comment-16994878 ] Arvid Heise commented on FLINK-15219: - You simply add a plugins folder to your worki

[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&focusedCommentId=16995659#comment-16995659 ] Arvid Heise commented on FLINK-13589: - Thank you very much for the bug report and th

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

[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&focusedCommentId=16981342#comment-16981342 ] Arvid Heise commented on FLINK-13758: - If FLINK-14908 is indeed a duplicate, then th

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

[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&focusedCommentId=16984798#comment-16984798 ] Arvid Heise commented on FLINK-14975: - Turns out the issue arrives just by my local

[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&focusedCommentId=16986110#comment-16986110 ] Arvid Heise commented on FLINK-14346: - Hi [~rgrebennikov] , I'm looking at your PR's

[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&focusedCommentId=16987677#comment-16987677 ] Arvid Heise commented on FLINK-14346: - That's some impressive improvements. I'd sugg

[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&focusedCommentId=16955110#comment-16955110 ] Arvid Heise commented on FLINK-14370: - We found the root cause and are currently dis

[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&focusedCommentId=16955110#comment-16955110 ] Arvid Heise edited comment on FLINK-14370 at 10/19/19 8:30 AM: ---

[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&focusedCommentId=16955110#comment-16955110 ] Arvid Heise edited comment on FLINK-14370 at 10/19/19 8:32 AM: ---

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

[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&focusedCommentId=16956135#comment-16956135 ] Arvid Heise commented on FLINK-14370: - So [~pnowojski] will merge a better fix for s

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

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

[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&focusedCommentId=16956751#comment-16956751 ] Arvid Heise commented on FLINK-14370: - Yes, that's a good idea. [https://github.com/

[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&focusedCommentId=16961863#comment-16961863 ] Arvid Heise commented on FLINK-14544: - Can someone assign that ticket to me? I will

[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&focusedCommentId=17058036#comment-17058036 ] Arvid Heise commented on FLINK-16550: - Should also be backported to 1.10. > HadoopS

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

[jira] [Commented] (FLINK-16791) Could not deploy Yarn job cluster when using flink-s3-fs-hadoop-1.10.0.jar

[ https://issues.apache.org/jira/browse/FLINK-16791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067721#comment-17067721 ] Arvid Heise commented on FLINK-16791: - Do you want to use AWS S3 SDK manually or wit

[jira] [Commented] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067722#comment-17067722 ] Arvid Heise commented on FLINK-13483: - Azure pipeline now runs most e2e tests on eac

[jira] [Resolved] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24131. - Resolution: Fixed Merged into master as da0e7dd05f486fef8922f6677d25e1fe00ea90a5 .. 85684e4aa91

[jira] [Assigned] (FLINK-24126) Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-24126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-24126: --- Assignee: Qingsheng Ren > Use increment of bytes-consumed-total for updating numBytesIn in

[jira] [Commented] (FLINK-24126) Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource

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

[jira] [Commented] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411380#comment-17411380 ] Arvid Heise commented on FLINK-24179: - Might be resolved through FLINK-24131, where

[jira] [Commented] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411461#comment-17411461 ] Arvid Heise commented on FLINK-24182: - I'm not entirely sure, but when spinning the

[jira] [Comment Edited] (FLINK-24182) Tasks canceler should not immediately interrupt

[ https://issues.apache.org/jira/browse/FLINK-24182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411461#comment-17411461 ] Arvid Heise edited comment on FLINK-24182 at 9/7/21, 8:18 PM:

<    3   4   5   6   7   8   9   10   11   12   >