[
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
{{ChannelSelector}}
[
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
>
[
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 RecordWri
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586571#comment-16586571
]
Nico Kruber commented on FLINK-9878:
Fixed via:
- `release-1.5`: 9e421a438dd830c6be72
[
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)
>
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
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
Com
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
Co
[
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
[
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 lat
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
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
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: Improveme
[
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
>
>
>
[
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
[
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 test
[
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 uns
[
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: 6f1c4
[
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: FLINK-
[
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
> -
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
[
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
>
[
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
> ---
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
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
[
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 pr
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558825#comment-16558825
]
Nico Kruber commented on FLINK-8523:
Sorry for coming back so late, but we recently d
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: Bu
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: Flin
[
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: 95eadfe15203ee0ab1459a9ade943234d
[
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: 0fec75c03bba0fa85a
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 Type
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
I
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546579#comment-16546579
]
Nico Kruber commented on FLINK-9860:
FYI: with leak detection (as well as error loggi
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545495#comment-16545495
]
Nico Kruber edited comment on FLINK-9860 at 7/16/18 5:04 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545495#comment-16545495
]
Nico Kruber commented on FLINK-9860:
oh, with our shaded netty version, I actually ne
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457
]
Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:46 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457
]
Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:38 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457
]
Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:37 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457
]
Nico Kruber commented on FLINK-9860:
The e2e test that was running when the leak occu
[
https://issues.apache.org/jira/browse/FLINK-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545457#comment-16545457
]
Nico Kruber edited comment on FLINK-9860 at 7/16/18 4:36 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544976#comment-16544976
]
Nico Kruber commented on FLINK-9842:
Sorry, my initial bug report contained the wrong
[
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 w
[
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 w
[
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 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
> ---
[
https://issues.apache.org/jira/browse/FLINK-9839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16542696#comment-16542696
]
Nico Kruber commented on FLINK-9839:
That's what I originally planned but all streami
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
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
[
https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16541843#comment-16541843
]
Nico Kruber commented on FLINK-9424:
If this is a JDK issue and updating it indeed fi
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: B
[
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: bbe5930dc0aaf46f
[
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: 9e87e2030d5a8232b80e6dbb93166fb9ac9e
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
Compo
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
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: Imp
[
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 th
[
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 Tra
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: Im
[
https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16534505#comment-16534505
]
Nico Kruber commented on FLINK-9706:
I also just stumbled upon this which is quite ea
[
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)
Actually
[
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 {{fi
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:
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
[
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
> ---
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
[
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: 6ce8211bab84308a
Nico Kruber created FLINK-9756:
--
Summary: Exceptions in BufferListener#notifyBufferAvailable do not
trigger further listeners in LocalBufferPool#recycle()
Key: FLINK-9756
URL: https://issues.apache.org/jira/browse/FL
[
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 p
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
[
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
> --
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
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529613#comment-16529613
]
Nico Kruber edited comment on FLINK-9636 at 7/2/18 9:59 AM:
A
[
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
increase
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529613#comment-16529613
]
Nico Kruber commented on FLINK-9636:
Actually, {{numRequiredBuffers}} is only a local
[
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
>
[
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
increase
[
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
increase
[
https://issues.apache.org/jira/browse/FLINK-8941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501739#comment-16501739
]
Nico Kruber commented on FLINK-8941:
[~till.rohrmann], the log you linked to actually
[
https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116515#comment-16116515
]
Nico Kruber edited comment on FLINK-2032 at 6/5/18 7:14 AM:
H
[
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 outpu
[
https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501397#comment-16501397
]
Nico Kruber commented on FLINK-2032:
I checked a few of the mentioned tests and it se
[
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 cre
[
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 cre
[
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 Arr
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
[
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#
> --
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 Type:
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: Imp
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16467203#comment-16467203
]
Nico Kruber commented on FLINK-9305:
I would actually follow your argumentation that i
[
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 file
[
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 t
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: Im
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: Improv
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: Improvemen
701 - 800 of 1422 matches
Mail list logo