[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274140#comment-16274140
]
Till Rohrmann commented on FLINK-8175:
--
I agree that we should move {{flink-statebackend-rocksdb}}
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274094#comment-16274094
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r154286901
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -306,12 +306,10 @@ public
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5108#discussion_r154290155
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5099#discussion_r154315071
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/MetricOptions.java ---
@@ -25,20 +25,9 @@
public class MetricOptions {
[
https://issues.apache.org/jira/browse/FLINK-8080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274227#comment-16274227
]
ASF GitHub Bot commented on FLINK-8080:
---
Github user zentol commented on a diff in the pull request:
Shashank Agarwal created FLINK-8182:
---
Summary: Unable to read hdfs file system directory(which contains
sub directories) recursively
Key: FLINK-8182
URL: https://issues.apache.org/jira/browse/FLINK-8182
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274090#comment-16274090
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4559
@NicoK , thanks for your reviews and I have updated the codes for above
comments.
Regarding the tests for backlog statistics, do you think I should add new
tests in this PR or update your
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274206#comment-16274206
]
Fabian Hueske commented on FLINK-8182:
--
yes
> Unable to read hdfs file system directory(which
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4552
@NicoK , I have rebased the latest codes. Wish your reviews!
---
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4509
@NicoK , the codes are updated.
---
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274099#comment-16274099
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274122#comment-16274122
]
Timo Walther commented on FLINK-8173:
-
[~xiatao123] generally speaking every type of object is
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5108#discussion_r154293212
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274125#comment-16274125
]
ASF GitHub Bot commented on FLINK-8181:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274168#comment-16274168
]
Fabian Hueske commented on FLINK-8182:
--
There is no built-in shortcut for that but the
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274235#comment-16274235
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274110#comment-16274110
]
ASF GitHub Bot commented on FLINK-8181:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274132#comment-16274132
]
Till Rohrmann commented on FLINK-8167:
--
I agree that we should probably clean up {{flink-contrib}},
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8182.
Resolution: Fixed
> Unable to read hdfs file system directory(which contains sub directories)
>
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-8182:
--
> Unable to read hdfs file system directory(which contains sub directories)
> recursively
>
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274223#comment-16274223
]
Fabian Hueske commented on FLINK-8182:
--
Does it fail at some point with an exception?
> Unable to
[
https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274108#comment-16274108
]
ASF GitHub Bot commented on FLINK-8181:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5108#discussion_r154289435
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-8173:
---
Assignee: Timo Walther
> InvalidProgramException: Table program cannot be compiled. This is
[
https://issues.apache.org/jira/browse/FLINK-8181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274156#comment-16274156
]
ASF GitHub Bot commented on FLINK-8181:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5108#discussion_r154299536
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/partitioner/FlinkFixedPartitioner.java
---
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274195#comment-16274195
]
Shashank Agarwal commented on FLINK-8182:
-
are you using :
import
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274215#comment-16274215
]
Shashank Agarwal commented on FLINK-8182:
-
Actually it's unable to access listing after the change
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-8175:
---
Assignee: Bowen Li
> remove flink-streaming-contrib and migrate its classes to
>
Bowen Li created FLINK-8189:
---
Summary: move flink-statebackend-rocksdb out of flink-contrib
Key: FLINK-8189
URL: https://issues.apache.org/jira/browse/FLINK-8189
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274913#comment-16274913
]
Sebastian Klemke commented on FLINK-8186:
-
[~twalthr] Thanks for looking into it. To summarize:
Bowen Li created FLINK-8188:
---
Summary: Clean up flink-contrib
Key: FLINK-8188
URL: https://issues.apache.org/jira/browse/FLINK-8188
Project: Flink
Issue Type: Improvement
Affects Versions:
[
https://issues.apache.org/jira/browse/FLINK-8175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8175:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-8188
> remove flink-streaming-contrib and
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5070
---
[
https://issues.apache.org/jira/browse/FLINK-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274705#comment-16274705
]
Eron Wright commented on FLINK-7294:
-
[~bbayani] I too thought it would be fine but upon further
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274601#comment-16274601
]
Sebastian Klemke commented on FLINK-8186:
-
What puzzles me is
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274656#comment-16274656
]
Sebastian Klemke commented on FLINK-8186:
-
With -Pbuild-jar, the job fat-jar includes avro,
Till Rohrmann created FLINK-8184:
Summary: Return raw JsonPlan instead of escaped string value in
JobDetailsInfo
Key: FLINK-8184
URL: https://issues.apache.org/jira/browse/FLINK-8184
Project: Flink
Sebastian Klemke created FLINK-8186:
---
Summary: AvroInputFormat regression: fails to deserialize
GenericRecords on cluster with hadoop27 compat
Key: FLINK-8186
URL:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r154344889
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
---
@@ -133,7 +135,7 @@ int
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r154343510
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java
---
@@ -39,13 +39,15 @@
private
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r154344924
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpilledSubpartitionView.java
---
@@ -114,7 +116,7 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r154343587
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
---
@@ -22,32 +22,57 @@
import
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r154343656
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java
---
@@ -22,32 +22,57 @@
import
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274405#comment-16274405
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274409#comment-16274409
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r154344942
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java
---
@@ -174,19 +175,21 @@ public
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r154320903
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -117,84 +135,78 @@ public void testJobSubmission() throws
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16271183#comment-16271183
]
Christos Hadjinikolis edited comment on FLINK-5506 at 12/1/17 11:25 AM:
[
https://issues.apache.org/jira/browse/FLINK-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274262#comment-16274262
]
Shashank Agarwal commented on FLINK-8182:
-
Actually I have checked it for around 10 mins till 300
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274340#comment-16274340
]
Vasia Kalavri commented on FLINK-5506:
--
I only had a quick look at the code; I will need to re-read
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sebastian Klemke updated FLINK-8186:
Priority: Minor (was: Major)
> AvroInputFormat regression: fails to deserialize
[
https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274435#comment-16274435
]
Sebastian Klemke commented on FLINK-8186:
-
Test program runs with Flink 1.4 hadoop27 on YARN. Is
GitHub user chuanlei opened a pull request:
https://github.com/apache/flink/pull/5110
[hotfix][docs] Fix typo in Checkpointing doc
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chuanlei/flink fix-typo-in-checkpointing-doc
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274278#comment-16274278
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL closed the pull request at:
Github user GJL closed the pull request at:
https://github.com/apache/flink/pull/5107
---
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5109
[FLINK-8141] [flip6] Fix JsonPlan serialization in JobDetailsInfo
## What is the purpose of the change
The JsonPlan in JobDetailInfo must be serialized as a raw value
to make it
[
https://issues.apache.org/jira/browse/FLINK-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274346#comment-16274346
]
ASF GitHub Bot commented on FLINK-8141:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274368#comment-16274368
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274373#comment-16274373
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274364#comment-16274364
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274375#comment-16274375
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274377#comment-16274377
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274369#comment-16274369
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274372#comment-16274372
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Miguel E. Coimbra updated FLINK-5506:
-
Affects Version/s: 1.4.1
1.3.2
Remaining Estimate: 2h (was:
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274256#comment-16274256
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r154320952
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java
---
@@ -117,84 +135,78 @@ public void testJobSubmission() throws
[
https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274257#comment-16274257
]
ASF GitHub Bot commented on FLINK-8176:
---
Github user GJL commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154320189
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154321304
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274379#comment-16274379
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274367#comment-16274367
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154322427
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154319502
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -108,17 +117,75 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154322032
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154318950
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -280,94 +280,120 @@ public String
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154321125
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154338813
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274378#comment-16274378
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154321327
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274365#comment-16274365
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154338695
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154315390
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -144,20 +147,19 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274371#comment-16274371
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274374#comment-16274374
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274370#comment-16274370
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154337233
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -223,11 +229,13 @@ void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154338491
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -244,54 +237,89 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154336638
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClient.java
---
@@ -167,6 +167,13 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274366#comment-16274366
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274376#comment-16274376
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154316689
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandlerTest.java
---
@@ -170,29 +172,20 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r154318828
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -378,6 +381,11 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274407#comment-16274407
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274406#comment-16274406
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274408#comment-16274408
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16274404#comment-16274404
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user NicoK commented on a diff in the pull request:
1 - 100 of 154 matches
Mail list logo
