[jira] [Updated] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9913: --- Description: Currently the {{RecordWriter}} emits output into multi channels via 

[jira] [Updated] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9913: --- Priority: Major (was: Minor) > Improve output serialization only once in RecordWriter >

[jira] [Closed] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit

[ https://issues.apache.org/jira/browse/FLINK-5060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-5060. -- Resolution: Duplicate Assignee: (was: Nico Kruber) > only serialise records once in

[jira] [Closed] (FLINK-4893) Use single RecordSerializer per RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-4893. -- Resolution: Duplicate > Use single RecordSerializer per RecordWriter >

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586571#comment-16586571 ] Nico Kruber commented on FLINK-9878: Fixed via: - `release-1.5`:

[jira] [Updated] (FLINK-10177) Use network transport type AUTO by default

[ https://issues.apache.org/jira/browse/FLINK-10177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10177: Summary: Use network transport type AUTO by default (was: Use transport type AUTO by default) >

[jira] [Created] (FLINK-10177) Use transport type AUTO by default

Nico Kruber created FLINK-10177: --- Summary: Use transport type AUTO by default Key: FLINK-10177 URL: https://issues.apache.org/jira/browse/FLINK-10177 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10147) numBytesOut metric lagging behind

Nico Kruber created FLINK-10147: --- Summary: numBytesOut metric lagging behind Key: FLINK-10147 URL: https://issues.apache.org/jira/browse/FLINK-10147 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10146) numBuffersOut not updated properly

Nico Kruber created FLINK-10146: --- Summary: numBuffersOut not updated properly Key: FLINK-10146 URL: https://issues.apache.org/jira/browse/FLINK-10146 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10022. - Resolution: Fixed Fix Version/s: 1.7.0 1.6.1 1.5.3

[jira] [Updated] (FLINK-10141) Reduce lock contention introduced with 1.5

[ https://issues.apache.org/jira/browse/FLINK-10141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10141: Description: With the changes around introducing credit-based flow control as well as the low

[jira] [Created] (FLINK-10142) Reduce synchronization overhead for credit notifications

Nico Kruber created FLINK-10142: --- Summary: Reduce synchronization overhead for credit notifications Key: FLINK-10142 URL: https://issues.apache.org/jira/browse/FLINK-10142 Project: Flink Issue

[jira] [Created] (FLINK-10141) Reduce lock contention introduced with 1.5

Nico Kruber created FLINK-10141: --- Summary: Reduce lock contention introduced with 1.5 Key: FLINK-10141 URL: https://issues.apache.org/jira/browse/FLINK-10141 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10131) Improve logging around ResultSubpartition

Nico Kruber created FLINK-10131: --- Summary: Improve logging around ResultSubpartition Key: FLINK-10131 URL: https://issues.apache.org/jira/browse/FLINK-10131 Project: Flink Issue Type:

[jira] [Updated] (FLINK-10006) Improve logging in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10006: Component/s: Logging > Improve logging in BarrierBuffer > > >

[jira] [Resolved] (FLINK-10006) Improve logging in BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10006. - Resolution: Fixed Fix Version/s: 1.7.0 1.6.1 1.5.3

[jira] [Assigned] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-8336: -- Assignee: (was: Nico Kruber) > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3

[jira] [Assigned] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-8408: -- Assignee: (was: Nico Kruber) > YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n

[jira] [Resolved] (FLINK-9972) Debug memory logging not working

[ https://issues.apache.org/jira/browse/FLINK-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9972. Resolution: Fixed Fixed in: - master: 7e31f7a75899cf84cbbd3a513c0ce3f53dc33ce5 - release-1.6:

[jira] [Reopened] (FLINK-9972) Debug memory logging not working

[ https://issues.apache.org/jira/browse/FLINK-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-9972: > Debug memory logging not working > - > > Key:

[jira] [Updated] (FLINK-9972) Debug memory logging not working

[ https://issues.apache.org/jira/browse/FLINK-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9972: --- Fix Version/s: 1.6.1 1.5.3 > Debug memory logging not working >

[jira] [Created] (FLINK-10035) ConcurrentModificationException with flink-metrics-slf4j

Nico Kruber created FLINK-10035: --- Summary: ConcurrentModificationException with flink-metrics-slf4j Key: FLINK-10035 URL: https://issues.apache.org/jira/browse/FLINK-10035 Project: Flink Issue

[jira] [Updated] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10022: Component/s: Metrics > Add metrics for input/output buffers >

[jira] [Updated] (FLINK-10022) Add metrics for input/output buffers

[ https://issues.apache.org/jira/browse/FLINK-10022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10022: Affects Version/s: 1.6.0 1.5.2 > Add metrics for input/output buffers >

[jira] [Created] (FLINK-10022) Add metrics for input/output buffers

Nico Kruber created FLINK-10022: --- Summary: Add metrics for input/output buffers Key: FLINK-10022 URL: https://issues.apache.org/jira/browse/FLINK-10022 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10006) Improve logging in BarrierBuffer

Nico Kruber created FLINK-10006: --- Summary: Improve logging in BarrierBuffer Key: FLINK-10006 URL: https://issues.apache.org/jira/browse/FLINK-10006 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-10004) Test instability in OneInputStreamTaskTest#testWatermarkMetrics

[ https://issues.apache.org/jira/browse/FLINK-10004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10004: Description: This happened once (in a branch with only changes in shading and only in one test

[jira] [Updated] (FLINK-10004) Test instability in OneInputStreamTaskTest#testWatermarkMetrics

[ https://issues.apache.org/jira/browse/FLINK-10004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10004: Labels: test-stability (was: ) > Test instability in OneInputStreamTaskTest#testWatermarkMetrics

[jira] [Created] (FLINK-10004) Test instability in OneInputStreamTaskTest#testWatermarkMetrics

Nico Kruber created FLINK-10004: --- Summary: Test instability in OneInputStreamTaskTest#testWatermarkMetrics Key: FLINK-10004 URL: https://issues.apache.org/jira/browse/FLINK-10004 Project: Flink

[jira] [Commented] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16558825#comment-16558825 ] Nico Kruber commented on FLINK-8523: Sorry for coming back so late, but we recently discovered that

[jira] [Created] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not shaded away

Nico Kruber created FLINK-9975: -- Summary: Netty dependency of Hadoop >= 2.7 is not shaded away Key: FLINK-9975 URL: https://issues.apache.org/jira/browse/FLINK-9975 Project: Flink Issue Type:

[jira] [Created] (FLINK-9974) "Implementation error: Unhandled exception" in CheckpointingStatisticsHandler

Nico Kruber created FLINK-9974: -- Summary: "Implementation error: Unhandled exception" in CheckpointingStatisticsHandler Key: FLINK-9974 URL: https://issues.apache.org/jira/browse/FLINK-9974 Project:

[jira] [Resolved] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9435. Resolution: Fixed Fix Version/s: 1.6.0 Fixed in: - master:

[jira] [Resolved] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9755. Resolution: Fixed Fixed in master: 5857f5543a7d9d3082d2f74342758d5a452a3c13 1.6:

[jira] [Created] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

Nico Kruber created FLINK-9879: -- Summary: Find sane defaults for (advanced) SSL session parameters Key: FLINK-9879 URL: https://issues.apache.org/jira/browse/FLINK-9879 Project: Flink Issue

[jira] [Created] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

Nico Kruber created FLINK-9878: -- Summary: IO worker threads BLOCKED on SSL Session Cache while CMS full gc Key: FLINK-9878 URL: https://issues.apache.org/jira/browse/FLINK-9878 Project: Flink

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546579#comment-16546579 ] Nico Kruber commented on FLINK-9860: FYI: with leak detection (as well as error logging!) enabled,

[jira] [Updated] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9860: --- Affects Version/s: 1.5.1 > Netty resource leak on receiver side >

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545495#comment-16545495 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 5:04 PM: - oh, with our

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545495#comment-16545495 ] Nico Kruber commented on FLINK-9860: oh, with our shaded netty version, I actually need to set

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:46 PM: - The e2e test

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:38 PM: - The e2e test

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:37 PM: - The e2e test

[jira] [Commented] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545457#comment-16545457 ] Nico Kruber commented on FLINK-9860: The e2e test that was running when the leak occurred actually

[jira] [Comment Edited] (FLINK-9860) Netty resource leak on receiver side

[ https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545457#comment-16545457 ] Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:36 PM: - The e2e test

[jira] [Commented] (FLINK-9842) Job submission fails via CLI with SSL enabled

[ https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544976#comment-16544976 ] Nico Kruber commented on FLINK-9842: Sorry, my initial bug report contained the wrong exception (that

[jira] [Updated] (FLINK-9842) Job submission fails via CLI with SSL enabled

[ https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9842: --- Description: There's a regression in Flink 1.5.1 which leads to the job submission via CLI failing

[jira] [Updated] (FLINK-9842) Job submission fails via CLI with SSL enabled

[ https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9842: --- Description: There's a regression in Flink 1.5.1 which leads to the job submission via CLI failing

[jira] [Assigned] (FLINK-9842) Job submission fails via CLI with SSL enabled

[ https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-9842: -- Assignee: Nico Kruber (was: Chesnay Schepler) > Job submission fails via CLI with SSL

[jira] [Updated] (FLINK-9842) Job submission fails via CLI with SSL enabled

[ https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9842: --- Labels: regression (was: ) > Job submission fails via CLI with SSL enabled >

[jira] [Commented] (FLINK-9839) End-to-end test: Streaming job with SSL

[ https://issues.apache.org/jira/browse/FLINK-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542696#comment-16542696 ] Nico Kruber commented on FLINK-9839: That's what I originally planned but all streaming e2e tests

[jira] [Created] (FLINK-9842) Job submission fails via CLI with SSL enabled

Nico Kruber created FLINK-9842: -- Summary: Job submission fails via CLI with SSL enabled Key: FLINK-9842 URL: https://issues.apache.org/jira/browse/FLINK-9842 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9839) End-to-end test: Streaming job with SSL

Nico Kruber created FLINK-9839: -- Summary: End-to-end test: Streaming job with SSL Key: FLINK-9839 URL: https://issues.apache.org/jira/browse/FLINK-9839 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-9424) BlobClientSslTest does not work in all environments

[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16541843#comment-16541843 ] Nico Kruber commented on FLINK-9424: If this is a JDK issue and updating it indeed fixes the problem

[jira] [Created] (FLINK-9838) Slot request failed Exceptions after completing a job

Nico Kruber created FLINK-9838: -- Summary: Slot request failed Exceptions after completing a job Key: FLINK-9838 URL: https://issues.apache.org/jira/browse/FLINK-9838 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-9766) Incomplete/incorrect cleanup in RemoteInputChannelTest

[ https://issues.apache.org/jira/browse/FLINK-9766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9766. Resolution: Fixed Fixed via 1.6.0: 598e4604440bc327e64c747f66470a0d65609f70 1.5.2:

[jira] [Resolved] (FLINK-9785) Add remote addresses to LocalTransportException instances

[ https://issues.apache.org/jira/browse/FLINK-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9785. Resolution: Fixed Fix Version/s: 1.5.2 Fixed via 1.6.0:

[jira] [Created] (FLINK-9817) Version not correctly bumped to 5.0

Nico Kruber created FLINK-9817: -- Summary: Version not correctly bumped to 5.0 Key: FLINK-9817 URL: https://issues.apache.org/jira/browse/FLINK-9817 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9816) Support Netty SslEngine based on openSSL

Nico Kruber created FLINK-9816: -- Summary: Support Netty SslEngine based on openSSL Key: FLINK-9816 URL: https://issues.apache.org/jira/browse/FLINK-9816 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9797) Separate state serializers from network serializers

Nico Kruber created FLINK-9797: -- Summary: Separate state serializers from network serializers Key: FLINK-9797 URL: https://issues.apache.org/jira/browse/FLINK-9797 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9785) Add remote addresses to LocalTransportException instances

[ https://issues.apache.org/jira/browse/FLINK-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9785: --- Description: {{LocalTransportException}} instantiations do not always add the remote address into

[jira] [Updated] (FLINK-9785) Add remote addresses to LocalTransportException instances

[ https://issues.apache.org/jira/browse/FLINK-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9785: --- Summary: Add remote addresses to LocalTransportException instances (was: Add remote addresses to

[jira] [Created] (FLINK-9785) Add remote addresses to TransportException instances

Nico Kruber created FLINK-9785: -- Summary: Add remote addresses to TransportException instances Key: FLINK-9785 URL: https://issues.apache.org/jira/browse/FLINK-9785 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9706) DispatcherTest#testSubmittedJobGraphListener fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16534505#comment-16534505 ] Nico Kruber commented on FLINK-9706: I also just stumbled upon this which is quite easy to reproduce

[jira] [Closed] (FLINK-9756) Exceptions in BufferListener#notifyBufferAvailable do not trigger further listeners in LocalBufferPool#recycle()

[ https://issues.apache.org/jira/browse/FLINK-9756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-9756. -- Resolution: Invalid Fix Version/s: (was: 1.5.2) (was: 1.6.0)

[jira] [Updated] (FLINK-9766) Incomplete/incorrect cleanup in RemoteInputChannelTest

[ https://issues.apache.org/jira/browse/FLINK-9766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9766: --- Description: If an assertion in the tests fails and as a result the cleanup code wrapped into a

[jira] [Created] (FLINK-9766) Incomplete/incorrect cleanup in RemoteInputChannelTest

Nico Kruber created FLINK-9766: -- Summary: Incomplete/incorrect cleanup in RemoteInputChannelTest Key: FLINK-9766 URL: https://issues.apache.org/jira/browse/FLINK-9766 Project: Flink Issue Type:

[jira] [Created] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

Nico Kruber created FLINK-9764: -- Summary: Failure in LocalRecoveryRocksDBFullITCase Key: FLINK-9764 URL: https://issues.apache.org/jira/browse/FLINK-9764 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9764: --- Labels: test-stability (was: ) > Failure in LocalRecoveryRocksDBFullITCase >

[jira] [Created] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

Nico Kruber created FLINK-9761: -- Summary: Potential buffer leak in PartitionRequestClientHandler during job failures Key: FLINK-9761 URL: https://issues.apache.org/jira/browse/FLINK-9761 Project: Flink

[jira] [Resolved] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

[ https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9676. Resolution: Fixed Fixed via 1.6.0: a9b5579b397b6c56e44e21ebb8b2a6a7e6d8b2d1 1.5.0:

[jira] [Created] (FLINK-9756) Exceptions in BufferListener#notifyBufferAvailable do not trigger further listeners in LocalBufferPool#recycle()

Nico Kruber created FLINK-9756: -- Summary: Exceptions in BufferListener#notifyBufferAvailable do not trigger further listeners in LocalBufferPool#recycle() Key: FLINK-9756 URL:

[jira] [Updated] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9755: --- Priority: Critical (was: Major) > Exceptions in RemoteInputChannel#notifyBufferAvailable() are not

[jira] [Created] (FLINK-9755) Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread

Nico Kruber created FLINK-9755: -- Summary: Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread Key: FLINK-9755 URL: https://issues.apache.org/jira/browse/FLINK-9755

[jira] [Assigned] (FLINK-9676) Deadlock during canceling task and recycling exclusive buffer

[ https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-9676: -- Assignee: Nico Kruber > Deadlock during canceling task and recycling exclusive buffer >

[jira] [Created] (FLINK-9708) Network buffer leaks when buffer request fails during buffer redistribution

Nico Kruber created FLINK-9708: -- Summary: Network buffer leaks when buffer request fails during buffer redistribution Key: FLINK-9708 URL: https://issues.apache.org/jira/browse/FLINK-9708 Project: Flink

[jira] [Comment Edited] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16529613#comment-16529613 ] Nico Kruber edited comment on FLINK-9636 at 7/2/18 9:59 AM: Actually,

[jira] [Updated] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9636: --- Description: In {{NetworkBufferPool#requestMemorySegments}}, {{numTotalRequiredBuffers}} is

[jira] [Updated] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9636: --- Fix Version/s: 1.5.1 > Network buffer leaks in requesting a batch of segments during canceling >

[jira] [Commented] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16529613#comment-16529613 ] Nico Kruber commented on FLINK-9636: Actually, {{numRequiredBuffers}} is only a local variable in

[jira] [Updated] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9636: --- Affects Version/s: 1.5.0 > Network buffer leaks in requesting a batch of segments during canceling >

[jira] [Updated] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9636: --- Description: In {{NetworkBufferPool#requestMemorySegments}}, {{numTotalRequiredBuffers}} is

[jira] [Updated] (FLINK-9636) Network buffer leaks in requesting a batch of segments during canceling

[ https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9636: --- Description: In {{NetworkBufferPool#requestMemorySegments}}, {{numTotalRequiredBuffers}} is

[jira] [Commented] (FLINK-8941) SpanningRecordSerializationTest fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501739#comment-16501739 ] Nico Kruber commented on FLINK-8941: [~till.rohrmann], the log you linked to actually contains a

[jira] [Comment Edited] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116515#comment-16116515 ] Nico Kruber edited comment on FLINK-2032 at 6/5/18 7:14 AM: Hi [~heytitle],

[jira] [Assigned] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-2032: -- Assignee: Deepak Sharma (was: Pattarawat Chormai) > Migrate integration tests from temp

[jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501397#comment-16501397 ] Nico Kruber commented on FLINK-2032: I checked a few of the mentioned tests and it seems this is

[jira] [Updated] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9435: --- Description: Inside {{KeySelectorUtil}}, every {{ComparableKeySelector#getKey()}} call currently

[jira] [Updated] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9435: --- Description: Inside {{KeySelectorUtil}}, every {{ComparableKeySelector#getKey()}} call currently

[jira] [Updated] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9435: --- Summary: Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and

[jira] [Created] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in KeySelectorUtil#ComparableKeySelector

Nico Kruber created FLINK-9435: -- Summary: Remove per-key selection Tuple instantiation via reflection in KeySelectorUtil#ComparableKeySelector Key: FLINK-9435 URL: https://issues.apache.org/jira/browse/FLINK-9435

[jira] [Updated] (FLINK-9434) Test instability in YARNSessionCapacitySchedulerITCase#

[ https://issues.apache.org/jira/browse/FLINK-9434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9434: --- Labels: test-stability (was: ) > Test instability in YARNSessionCapacitySchedulerITCase# >

[jira] [Created] (FLINK-9434) Test instability in YARNSessionCapacitySchedulerITCase#

Nico Kruber created FLINK-9434: -- Summary: Test instability in YARNSessionCapacitySchedulerITCase# Key: FLINK-9434 URL: https://issues.apache.org/jira/browse/FLINK-9434 Project: Flink Issue

[jira] [Created] (FLINK-9409) Missing assembly-dependencies in flink-dist/pom.xml

Nico Kruber created FLINK-9409: -- Summary: Missing assembly-dependencies in flink-dist/pom.xml Key: FLINK-9409 URL: https://issues.apache.org/jira/browse/FLINK-9409 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9305) Register flink-s3-fs-hadoop for the s3a:// scheme as well

[ https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16467203#comment-16467203 ] Nico Kruber commented on FLINK-9305: I would actually follow your argumentation that it does not

[jira] [Updated] (FLINK-9305) Register flink-s3-fs-hadoop for the s3a:// scheme as well

[ https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9305: --- Description: For enhanced user experience, we should also register our Hadoop S3A-based shaded S3

[jira] [Updated] (FLINK-9305) Register flink-s3-fs-hadoop for the s3a:// scheme as well

[ https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9305: --- Summary: Register flink-s3-fs-hadoop for the s3a:// scheme as well (was: Register flink-s3-fs-* for

[jira] [Created] (FLINK-9305) Register flink-s3-fs-* for the s3a:// scheme as well

Nico Kruber created FLINK-9305: -- Summary: Register flink-s3-fs-* for the s3a:// scheme as well Key: FLINK-9305 URL: https://issues.apache.org/jira/browse/FLINK-9305 Project: Flink Issue Type:

[jira] [Created] (FLINK-9275) Set more distinctive output flusher thread names

Nico Kruber created FLINK-9275: -- Summary: Set more distinctive output flusher thread names Key: FLINK-9275 URL: https://issues.apache.org/jira/browse/FLINK-9275 Project: Flink Issue Type:

[jira] [Created] (FLINK-9274) Add thread name to Kafka Partition Discovery

Nico Kruber created FLINK-9274: -- Summary: Add thread name to Kafka Partition Discovery Key: FLINK-9274 URL: https://issues.apache.org/jira/browse/FLINK-9274 Project: Flink Issue Type:

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