Timo Walther created FLINK-8538:
---
Summary: Add a Kafka table source factory with JSON format support
Key: FLINK-8538
URL: https://issues.apache.org/jira/browse/FLINK-8538
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346684#comment-16346684
]
ASF GitHub Bot commented on FLINK-8101:
---
Github user yew1eb commented on a diff in the pull request:
Timo Walther created FLINK-8537:
---
Summary: Add a Kafka table source factory with Avro format support
Key: FLINK-8537
URL: https://issues.apache.org/jira/browse/FLINK-8537
Project: Flink
Issue
Github user yew1eb commented on a diff in the pull request:
https://github.com/apache/flink/pull/5374#discussion_r165032079
--- Diff:
flink-connectors/flink-connector-elasticsearch5.3/src/main/java/org/apache/flink/streaming/connectors/elasticsearch53/BulkProcessorIndexer.java
---
Timo Walther created FLINK-8536:
---
Summary: Improve CSVTableSourceFactory to support all descriptor
properties
Key: FLINK-8536
URL: https://issues.apache.org/jira/browse/FLINK-8536
Project: Flink
Timo Walther created FLINK-8535:
---
Summary: Implement a basic set of table source factories
Key: FLINK-8535
URL: https://issues.apache.org/jira/browse/FLINK-8535
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8240.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346669#comment-16346669
]
ASF GitHub Bot commented on FLINK-8240:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5240
---
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346665#comment-16346665
]
ASF GitHub Bot commented on FLINK-8240:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5240
Thanks for the review @fhueske. I will merge this now. We definitely need
follow-up issues for this.
---
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5370
Thanks for the PR @fhueske. I will merge this.
---
[
https://issues.apache.org/jira/browse/FLINK-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346646#comment-16346646
]
Fabian Hueske commented on FLINK-8534:
--
Thanks for reporting this issue.
Can you please provide the
Github user tzulitai commented on the pull request:
https://github.com/apache/flink/commit/547d19f9196512231661f427f3792f2e1f831339#commitcomment-27231640
In
[
https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346636#comment-16346636
]
ASF GitHub Bot commented on FLINK-8419:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346635#comment-16346635
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346639#comment-16346639
]
ASF GitHub Bot commented on FLINK-8419:
---
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/5336#discussion_r165023649
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165023129
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5295
I like the functionality of this a lot! However, I don't like that we
change the signature of existing triggers or that we introduce new triggers
that duplicate existing code.
As an
[
https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346634#comment-16346634
]
ASF GitHub Bot commented on FLINK-8419:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346633#comment-16346633
]
ASF GitHub Bot commented on FLINK-8419:
---
Github user tzulitai commented on a diff in the pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5335#discussion_r165022709
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -95,21
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165022738
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
[
https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346624#comment-16346624
]
ASF GitHub Bot commented on FLINK-8419:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346623#comment-16346623
]
ASF GitHub Bot commented on FLINK-8419:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346621#comment-16346621
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user aljoscha commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165021513
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@ -92,21
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5161
So this ensures that the parent is actually a `TaskManagerJobMetricGroup`,
right?
This LGTM for me, now. Could you open a follow-up issue for the
operator-name thing?
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5336#discussion_r165021339
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346617#comment-16346617
]
Aljoscha Krettek commented on FLINK-8042:
-
This sounds like a bigger change that I wouldn't want
[
https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8042:
Fix Version/s: (was: 1.4.1)
> Retry individual failover-strategy for some time first
[
https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8042:
Component/s: State Backends, Checkpointing
> Retry individual failover-strategy for some
[
https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346615#comment-16346615
]
ASF GitHub Bot commented on FLINK-6004:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5269#discussion_r165020094
--- Diff:
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcherTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8042:
Summary: Retry individual failover-strategy for some time first before
reverting to full
[
https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346613#comment-16346613
]
ASF GitHub Bot commented on FLINK-6004:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5269#discussion_r165019903
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhu.qing updated FLINK-8534:
Summary: if insert too much BucketEntry into one bucket in join of
iteration will cause a error (Caused :
[
https://issues.apache.org/jira/browse/FLINK-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhu.qing updated FLINK-8534:
Summary: if insert too much BucketEntry into one bucket in join of
iteration. Will cause Caused :
zhu.qing created FLINK-8534:
---
Summary: if insert too much BucketEntry into one bucket in join of
iteration. Will cause Caused by: java.io.FileNotFoundException release file
error
Key: FLINK-8534
URL:
[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346606#comment-16346606
]
ASF GitHub Bot commented on FLINK-8503:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5353#discussion_r165018462
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java
---
@@ -175,4 +177,13 @@
final
[
https://issues.apache.org/jira/browse/FLINK-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8019.
---
Resolution: Duplicate
The kafka source stopped due to backpressure since the operator
[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346601#comment-16346601
]
ASF GitHub Bot commented on FLINK-8503:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346599#comment-16346599
]
Steven Langbroek commented on FLINK-8308:
-
As far as I can tell current {{jekyll}} version (2.5.3)
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5353#discussion_r165017798
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java
---
@@ -175,4 +177,13 @@
final
[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346600#comment-16346600
]
ASF GitHub Bot commented on FLINK-8503:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5353#discussion_r165017616
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java
---
@@ -175,4 +177,13 @@
final
[
https://issues.apache.org/jira/browse/FLINK-8498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8498:
Priority: Major (was: Blocker)
> GetExecutionPlan fails with IllegalArgumentException in
[
https://issues.apache.org/jira/browse/FLINK-8020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346590#comment-16346590
]
Chesnay Schepler commented on FLINK-8020:
-
are you certain that you're actually completing the
[
https://issues.apache.org/jira/browse/FLINK-8498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346592#comment-16346592
]
Chesnay Schepler commented on FLINK-8498:
-
I will downgrade the priority since we can't reproduce
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346570#comment-16346570
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5161
I've rebased the branch and did one more change:
```
this.latencyStats = new
LatencyStats(this.metrics.parent().parent().addGroup("latency"), historySize,
container.getIndexInSubtaskGroup(),
[
https://issues.apache.org/jira/browse/FLINK-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346560#comment-16346560
]
ASF GitHub Bot commented on FLINK-8496:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5343
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346550#comment-16346550
]
yanxiaobin commented on FLINK-8500:
---
hi, [~aljoscha] . What do you think?
> Get the timestamp of the
[
https://issues.apache.org/jira/browse/FLINK-7607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Langbroek reassigned FLINK-7607:
---
Assignee: Steven Langbroek
> Web Frontend Hangs with Large Numbers of Tasks
>
[
https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346544#comment-16346544
]
ASF GitHub Bot commented on FLINK-8407:
---
Github user xccui closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346542#comment-16346542
]
ASF GitHub Bot commented on FLINK-8496:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346543#comment-16346543
]
ASF GitHub Bot commented on FLINK-8407:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5369
Sure. Thanks for helping merge this!
---
Github user xccui closed the pull request at:
https://github.com/apache/flink/pull/5369
---
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5343
From eyeballing this change it seems correct. I'm assuming you did that
manual check so I'd say this is good to go.
---
[
https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346538#comment-16346538
]
ASF GitHub Bot commented on FLINK-8407:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5369
Thanks for fixing this! ð
I merged, could you please close the PR if it doesn't close automatically?
---
[
https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-8407.
---
Resolution: Fixed
Fixed on master in
a5476cdcdfe231bc8e06e7b453eeb1cbab57ed0d
> Setting the
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346533#comment-16346533
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5161
yes the display will now work.
---
[
https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8407:
Fix Version/s: 1.5.0
> Setting the parallelism after a partitioning operation should be
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5292
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346529#comment-16346529
]
ASF GitHub Bot commented on FLINK-8422:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346523#comment-16346523
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346512#comment-16346512
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user zentol commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5161
I'd say we merge without operator names/operator id and leave that as a
follow-up, issue. To at least make it possible to get latency metrics. WDYT?
Btw, with this, can we now show the
[
https://issues.apache.org/jira/browse/FLINK-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346520#comment-16346520
]
ASF GitHub Bot commented on FLINK-8489:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5378
merging,
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5161
I'm wary about using the operator name (or _any_ variant that inexplicably
exists) as that significantly increases the size of watermarks.
I see the use-case, and ideally I would like to have
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346506#comment-16346506
]
ASF GitHub Bot commented on FLINK-7608:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5161#discussion_r165000781
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -194,14 +190,20 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346503#comment-16346503
]
ASF GitHub Bot commented on FLINK-7095:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5375
I have updated the code and write a test. @tillrohrmann Thanks in advance
to review those codes ~
---
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346492#comment-16346492
]
ASF GitHub Bot commented on FLINK-8523:
---
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/5381#discussion_r164993308
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
---
@@ -485,6 +494,23 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346484#comment-16346484
]
ASF GitHub Bot commented on FLINK-8101:
---
Github user cjolif commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346488#comment-16346488
]
ASF GitHub Bot commented on FLINK-8503:
---
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/5353#discussion_r164992599
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java
---
@@ -175,4 +177,13 @@
final
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346485#comment-16346485
]
ASF GitHub Bot commented on FLINK-8523:
---
Github user zhijiangW commented on the issue:
Github user cjolif commented on a diff in the pull request:
https://github.com/apache/flink/pull/5374#discussion_r164992369
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java
---
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/5381
Thanks for reviews and suggestions! :)
I will add some unit tests first to verify the related logics. For itcase,
I will consider the necessary and feasibility.
---
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346480#comment-16346480
]
ASF GitHub Bot commented on FLINK-8523:
---
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/5381#discussion_r164990652
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java
---
@@ -138,6 +148,24 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346467#comment-16346467
]
ASF GitHub Bot commented on FLINK-8523:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346469#comment-16346469
]
ASF GitHub Bot commented on FLINK-8523:
---
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/5381#discussion_r164988630
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
---
@@ -315,6 +322,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346468#comment-16346468
]
ASF GitHub Bot commented on FLINK-8523:
---
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/5381#discussion_r164988413
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
---
@@ -133,8 +134,13 @@
*
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/5381#discussion_r164988217
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -360,8 +360,9 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346463#comment-16346463
]
ASF GitHub Bot commented on FLINK-8523:
---
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/5381#discussion_r164987333
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java
---
@@ -165,6 +168,14 @@ protected void
201 - 300 of 324 matches
Mail list logo
