[jira] [Updated] (FLINK-10762) Do not try to request partitions in SingleInputGate per getRecord

2018-12-19 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10762: Description: Every call to {{SingleInputGate#getNextBufferOrEvent()}} will also try to request

[jira] [Commented] (FLINK-11158) Do not show empty page for unknown jobs

2018-12-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723165#comment-16723165 ] Nico Kruber commented on FLINK-11158: - Thanks for the update. I guess, it would be nice to have it

[jira] [Comment Edited] (FLINK-11103) Set a default uncaught exception handler

2018-12-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723157#comment-16723157 ] Nico Kruber edited comment on FLINK-11103 at 12/17/18 4:54 PM: --- Maybe I

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

2018-12-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723157#comment-16723157 ] Nico Kruber commented on FLINK-11103: - Maybe I did not look into FLINK-5232 thoroughly enough: I

[jira] [Commented] (FLINK-10661) Initial credit should be configured in a separate parameter

2018-12-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723037#comment-16723037 ] Nico Kruber commented on FLINK-10661: - [~zjwang] I'm not quite sure I get the problem, so let's

[jira] [Created] (FLINK-11159) Allow configuration whether to fall back to savepoints for restore

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11159: --- Summary: Allow configuration whether to fall back to savepoints for restore Key: FLINK-11159 URL: https://issues.apache.org/jira/browse/FLINK-11159 Project: Flink

[jira] [Updated] (FLINK-11154) Upgrade Netty to 4.1.32

2018-12-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11154: Affects Version/s: (was: 1.8.0) > Upgrade Netty to 4.1.32 > --- > >

[jira] [Created] (FLINK-11158) Do not show empty page for unknown jobs

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11158: --- Summary: Do not show empty page for unknown jobs Key: FLINK-11158 URL: https://issues.apache.org/jira/browse/FLINK-11158 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11154) Upgrade Netty to 4.1.32

2018-12-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11154: Fix Version/s: 1.8.0 > Upgrade Netty to 4.1.32 > --- > > Key:

[jira] [Created] (FLINK-11157) Web UI should show timestamps relative to server time zone

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11157: --- Summary: Web UI should show timestamps relative to server time zone Key: FLINK-11157 URL: https://issues.apache.org/jira/browse/FLINK-11157 Project: Flink

[jira] [Created] (FLINK-11154) Upgrade Netty to 4.1.32

2018-12-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11154: --- Summary: Upgrade Netty to 4.1.32 Key: FLINK-11154 URL: https://issues.apache.org/jira/browse/FLINK-11154 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-10074) Allowable number of checkpoint failures

2018-12-11 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-10074. --- Resolution: Duplicate > Allowable number of checkpoint failures >

[jira] [Updated] (FLINK-10074) Allowable number of checkpoint failures

2018-12-11 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10074: Release Note: (was: Duplicate of FLINK-10074) > Allowable number of checkpoint failures >

[jira] [Reopened] (FLINK-10074) Allowable number of checkpoint failures

2018-12-11 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-10074: - > Allowable number of checkpoint failures > > >

[jira] [Created] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

2018-12-07 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11102: --- Summary: Enable check for previous data in SpanningRecordSerializer Key: FLINK-11102 URL: https://issues.apache.org/jira/browse/FLINK-11102 Project: Flink

[jira] [Created] (FLINK-11103) Set a default uncaught exception handler

2018-12-07 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-11103: --- Summary: Set a default uncaught exception handler Key: FLINK-11103 URL: https://issues.apache.org/jira/browse/FLINK-11103 Project: Flink Issue Type:

[jira] [Closed] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

2018-12-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-10809. --- Resolution: Fixed > Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state

[jira] [Reopened] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

2018-12-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-10809: - > Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state > after restore >

[jira] [Updated] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

2018-12-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10809: Affects Version/s: 1.5.5 1.6.2 > Using

[jira] [Created] (FLINK-10962) Allow correlations between subtask metrics and checkpoint metrics

2018-11-21 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10962: --- Summary: Allow correlations between subtask metrics and checkpoint metrics Key: FLINK-10962 URL: https://issues.apache.org/jira/browse/FLINK-10962 Project: Flink

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

2018-11-20 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-9761: -- Assignee: (was: Nico Kruber) > Potential buffer leak in PartitionRequestClientHandler

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

2018-11-19 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691515#comment-16691515 ] Nico Kruber commented on FLINK-10662: - [~pnowojski] thanks for the clarification. So this change

[jira] [Commented] (FLINK-10662) Refactor the ChannelSelector interface for single selected channel

2018-11-15 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688257#comment-16688257 ] Nico Kruber commented on FLINK-10662: - If we never call {{BroadcastPartitioner#selectChannels()}},

[jira] [Assigned] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-07 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-10419: --- Assignee: (was: Nico Kruber) > ClassNotFoundException while deserializing user

[jira] [Created] (FLINK-10804) Transfer suppressed exceptions with SerializedThrowable

2018-11-06 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10804: --- Summary: Transfer suppressed exceptions with SerializedThrowable Key: FLINK-10804 URL: https://issues.apache.org/jira/browse/FLINK-10804 Project: Flink Issue

[jira] [Comment Edited] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676610#comment-16676610 ] Nico Kruber edited comment on FLINK-10419 at 11/6/18 11:27 AM: --- With the

[jira] [Updated] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10419: Fix Version/s: 1.7.0 > ClassNotFoundException while deserializing user exceptions from

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-11-06 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676610#comment-16676610 ] Nico Kruber commented on FLINK-10419: - With the new debug infos from FLINK-10655, we finally have

[jira] [Closed] (FLINK-10727) Remove unnecessary synchronization in SingleInputGate#requestPartitions()

2018-11-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-10727. --- Resolution: Won't Fix Fix Version/s: (was: 1.7.0) will do this properly in FLINK-10762

[jira] [Reopened] (FLINK-10727) Remove unnecessary synchronization in SingleInputGate#requestPartitions()

2018-11-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-10727: - re-opening (will revert the commit) > Remove unnecessary synchronization in

[jira] [Created] (FLINK-10762) Do not try to request partitions in SingleInputGate per getRecord

2018-11-02 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10762: --- Summary: Do not try to request partitions in SingleInputGate per getRecord Key: FLINK-10762 URL: https://issues.apache.org/jira/browse/FLINK-10762 Project: Flink

[jira] [Commented] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2018-11-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672891#comment-16672891 ] Nico Kruber commented on FLINK-10742: - [~gaoyunhaii] thanks for taking care of this - I didn't have

[jira] [Created] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2018-10-31 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10742: --- Summary: Let Netty use Flink's buffers directly in credit-based mode Key: FLINK-10742 URL: https://issues.apache.org/jira/browse/FLINK-10742 Project: Flink

[jira] [Updated] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-31 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10356: Issue Type: Sub-task (was: Improvement) Parent: FLINK-3462 > Add sanity checks to

[jira] [Resolved] (FLINK-10727) Remove unnecessary synchronization in SingleInputGate#requestPartitions()

2018-10-31 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10727. - Resolution: Fixed Fix Version/s: 1.7.0 fixed via: - master:

[jira] [Created] (FLINK-10727) Remove unnecessary synchronization in SingleInputGate#requestPartitions()

2018-10-30 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10727: --- Summary: Remove unnecessary synchronization in SingleInputGate#requestPartitions() Key: FLINK-10727 URL: https://issues.apache.org/jira/browse/FLINK-10727 Project:

[jira] [Assigned] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint with iterations

2018-10-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-9552: -- Assignee: Nico Kruber (was: vinoyang) > NPE in SpanningRecordSerializer during checkpoint

[jira] [Updated] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-10-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10655: Description: {{RemoteRpcInvocation}} tries to give a more detailed {{ClassNotFoundException}} if

[jira] [Updated] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-10-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10655: Description: {{RemoteRpcInvocation}} tries to give a more details {{ClassNotFoundException}} if

[jira] [Updated] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-10-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10655: Environment: (was: {{RemoteRpcInvocation}} tries to give a more details

[jira] [Created] (FLINK-10655) RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException

2018-10-23 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10655: --- Summary: RemoteRpcInvocation not overwriting ObjectInputStream's ClassNotFoundException Key: FLINK-10655 URL: https://issues.apache.org/jira/browse/FLINK-10655

[jira] [Resolved] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not relocated

2018-10-23 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9975. Resolution: Fixed Release Note: We now also relocate Hadoop's Netty dependency from

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

2018-10-22 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9878. Resolution: Fixed Also forward-ported to: - release-1.6: b0496f21d70cc1af15569f3632d7a58fd53b8f95

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

2018-10-18 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9878: --- Fix Version/s: (was: 1.5.6) 1.5.4 > IO worker threads BLOCKED on SSL Session

[jira] [Commented] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

2018-10-10 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644629#comment-16644629 ] Nico Kruber commented on FLINK-10519: - same for 1.5.4: {code} [ERROR] Failed to execute goal on

[jira] [Resolved] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10469. - Resolution: Fixed Fixed via: - master: 1e0a77959d27031048c1c4079a504274c82cc173 - release-1.6:

[jira] [Commented] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643673#comment-16643673 ] Nico Kruber commented on FLINK-10367: - As a rough sketch for option 3 (maybe this can be optimised):

[jira] [Commented] (FLINK-10468) Potential missing break for PARTITION_CUSTOM in OutputEmitter ctor

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643653#comment-16643653 ] Nico Kruber commented on FLINK-10468: - I'd agree with [~Tison] after looking at the code. However,

[jira] [Updated] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10491: Fix Version/s: 1.5.5 1.6.2 1.7.0 > Deadlock during spilling

[jira] [Commented] (FLINK-9812) SpanningRecordSerializationTest fails on travis

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643566#comment-16643566 ] Nico Kruber commented on FLINK-9812: The fix is in my PR which is still missing a review. See

[jira] [Assigned] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-10469: --- Assignee: Nico Kruber (was: Yun Gao) > FileChannel may not write the whole buffer in a

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-10-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16641794#comment-16641794 ] Nico Kruber commented on FLINK-10419: - Unfortunately, I couldn't reproduce it with any failure I

[jira] [Commented] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636087#comment-16636087 ] Nico Kruber commented on FLINK-10469: - [~gaoyunhaii] I hacked something together - only tests are

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635693#comment-16635693 ] Nico Kruber commented on FLINK-10419: - One more note on my original issue: there should have been

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635519#comment-16635519 ] Nico Kruber commented on FLINK-10455: - The following symptom may actually be a follow-up of this

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10469: Component/s: Network > FileChannel may not write the whole buffer in a single call to >

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10469: Fix Version/s: 1.5.5 1.6.2 1.7.0 > FileChannel may not

[jira] [Commented] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635176#comment-16635176 ] Nico Kruber commented on FLINK-10469: - That's actually a very critical bug you discovered and may

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10469: Priority: Critical (was: Major) > FileChannel may not write the whole buffer in a single call to

[jira] [Commented] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-10-01 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633879#comment-16633879 ] Nico Kruber commented on FLINK-10462: - Yes, you are right about the changes that credit-based flow

[jira] [Resolved] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory

2018-10-01 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10339. - Resolution: Fixed Fix Version/s: 1.7.0 Fixed via: - master:

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632167#comment-16632167 ] Nico Kruber commented on FLINK-10419: - Hi [~Xeli], I don't think, your Exception is related - the

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-27 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16630660#comment-16630660 ] Nico Kruber commented on FLINK-10419: - The initial error on the task managers leading to the error

[jira] [Updated] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-27 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10419: Description: It seems that somewhere in the operator's failure handling, we hand a user-code

[jira] [Created] (FLINK-10455) Potential Kafka producer leak in case of failures

2018-09-27 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10455: --- Summary: Potential Kafka producer leak in case of failures Key: FLINK-10455 URL: https://issues.apache.org/jira/browse/FLINK-10455 Project: Flink Issue Type:

[jira] [Created] (FLINK-10445) CLI stuck with (potentially incorrect) SSL config

2018-09-26 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10445: --- Summary: CLI stuck with (potentially incorrect) SSL config Key: FLINK-10445 URL: https://issues.apache.org/jira/browse/FLINK-10445 Project: Flink Issue Type:

[jira] [Created] (FLINK-10443) Flink Yarn CLI hanging after unsuccessful deployment

2018-09-26 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10443: --- Summary: Flink Yarn CLI hanging after unsuccessful deployment Key: FLINK-10443 URL: https://issues.apache.org/jira/browse/FLINK-10443 Project: Flink Issue

[jira] [Created] (FLINK-10442) Make declined savepoints visible in WebUI

2018-09-26 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10442: --- Summary: Make declined savepoints visible in WebUI Key: FLINK-10442 URL: https://issues.apache.org/jira/browse/FLINK-10442 Project: Flink Issue Type:

[jira] [Created] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-25 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10419: --- Summary: ClassNotFoundException while deserializing user exceptions from checkpointing Key: FLINK-10419 URL: https://issues.apache.org/jira/browse/FLINK-10419 Project:

[jira] [Commented] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

2018-09-25 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627115#comment-16627115 ] Nico Kruber commented on FLINK-10367: - After taking a brief look at the code, I'd also prefer option

[jira] [Resolved] (FLINK-10332) Move data available notification in PipelinedSubpartition out of the synchronized block

2018-09-19 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10332. - Resolution: Fixed Fix Version/s: 1.5.5 1.6.2 1.7.0

[jira] [Resolved] (FLINK-10331) Fix unnecessary flush requests to the network stack

2018-09-19 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10331. - Resolution: Fixed Fix Version/s: 1.5.5 1.6.2 1.7.0

[jira] [Created] (FLINK-10364) Test instability in NonHAQueryableStateFsBackendITCase#testMapState

2018-09-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10364: --- Summary: Test instability in NonHAQueryableStateFsBackendITCase#testMapState Key: FLINK-10364 URL: https://issues.apache.org/jira/browse/FLINK-10364 Project: Flink

[jira] [Updated] (FLINK-10364) Test instability in NonHAQueryableStateFsBackendITCase#testMapState

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

[jira] [Assigned] (FLINK-9812) SpanningRecordSerializationTest fails on travis

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-9812: -- Assignee: Nico Kruber > SpanningRecordSerializationTest fails on travis >

[jira] [Commented] (FLINK-9812) SpanningRecordSerializationTest fails on travis

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617982#comment-16617982 ] Nico Kruber commented on FLINK-9812: please find my additions in the linked PR >

[jira] [Updated] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10356: Description: {{SpillingAdaptiveSpanningRecordDeserializer}} doesn't have any consistency checks

[jira] [Updated] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10356: Description: {{SpillingAdaptiveSpanningRecordDeserializer}} doesn't have any consistency checks

[jira] [Created] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-09-17 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10356: --- Summary: Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer Key: FLINK-10356 URL: https://issues.apache.org/jira/browse/FLINK-10356 Project: Flink

[jira] [Commented] (FLINK-9812) SpanningRecordSerializationTest fails on travis

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617593#comment-16617593 ] Nico Kruber commented on FLINK-9812: Nice find [~yanghua]. Actually, setting {{spillingChannel =

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

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-9878: --- Fix Version/s: (was: 1.5.5) 1.5.4 > IO worker threads BLOCKED on SSL Session

[jira] [Commented] (FLINK-10317) Configure Metaspace size by default

2018-09-17 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617204#comment-16617204 ] Nico Kruber commented on FLINK-10317: - I don't think, it should be tied to {{containerSize}} in any

[jira] [Updated] (FLINK-10331) Fix unnecessary flush requests to the network stack

2018-09-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10331: Description: With the re-design of the record writer interaction with the result(sub)partitions,

[jira] [Updated] (FLINK-10331) Fix unnecessary flush requests to the network stack

2018-09-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10331: Description: With the re-design of the record writer interaction with the result(sub)partitions,

[jira] [Resolved] (FLINK-10301) Allow a custom Configuration in StreamNetworkBenchmarkEnvironment

2018-09-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10301. - Resolution: Fixed Fix Version/s: 1.5.4 1.7.0 1.6.1

[jira] [Updated] (FLINK-10301) Allow a custom Configuration in StreamNetworkBenchmarkEnvironment

2018-09-13 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10301: Affects Version/s: 1.5.0 1.5.1 1.5.2

[jira] [Created] (FLINK-10332) Move data available notification in PipelinedSubpartition out of the synchronized block

2018-09-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10332: --- Summary: Move data available notification in PipelinedSubpartition out of the synchronized block Key: FLINK-10332 URL: https://issues.apache.org/jira/browse/FLINK-10332

[jira] [Created] (FLINK-10331) Fix unnecessary flush requests to the network stack

2018-09-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10331: --- Summary: Fix unnecessary flush requests to the network stack Key: FLINK-10331 URL: https://issues.apache.org/jira/browse/FLINK-10331 Project: Flink Issue

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

2018-09-10 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10131. - Resolution: Fixed Fix Version/s: 1.5.4 1.7.0 1.6.1

[jira] [Closed] (FLINK-10313) Wrong FileCache warning about improper use of releaseJob() when not using DistributedCache

2018-09-10 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-10313. --- Resolution: Duplicate Fix Version/s: (was: 1.6.1) (was: 1.7.0) >

[jira] [Created] (FLINK-10313) Wrong FileCache warning about improper use of releaseJob() when not using DistributedCache

2018-09-10 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10313: --- Summary: Wrong FileCache warning about improper use of releaseJob() when not using DistributedCache Key: FLINK-10313 URL: https://issues.apache.org/jira/browse/FLINK-10313

[jira] [Created] (FLINK-10301) Allow a custom Configuration in StreamNetworkBenchmarkEnvironment

2018-09-07 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10301: --- Summary: Allow a custom Configuration in StreamNetworkBenchmarkEnvironment Key: FLINK-10301 URL: https://issues.apache.org/jira/browse/FLINK-10301 Project: Flink

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10141. - Resolution: Fixed Fix Version/s: 1.5.4 1.7.0 1.6.1

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reopened FLINK-10142: - > Reduce synchronization overhead for credit notifications >

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16597926#comment-16597926 ] Nico Kruber edited comment on FLINK-10142 at 8/30/18 9:07 PM: -- Fixed via: -

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10142. - Resolution: Fixed > Reduce synchronization overhead for credit notifications >

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10142. - Resolution: Fixed Fix Version/s: 1.5.4 1.7.0 1.6.1

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10142: Affects Version/s: 1.5.0 1.5.1 1.5.3 > Reduce

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

2018-08-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10141: Affects Version/s: 1.5.0 1.5.1 1.5.3 > Reduce lock

[jira] [Created] (FLINK-10236) Reduce histogram percentile/quantile retrieval overhead

2018-08-28 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10236: --- Summary: Reduce histogram percentile/quantile retrieval overhead Key: FLINK-10236 URL: https://issues.apache.org/jira/browse/FLINK-10236 Project: Flink Issue

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