[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-7594:
Summary: Add a SQL client (was: Add a SQL CLI client)
> Add a SQL client
>
>
>
Julio Biason created FLINK-8294:
---
Summary: Missing examples/links in Data Sink docs
Key: FLINK-8294
URL: https://issues.apache.org/jira/browse/FLINK-8294
Project: Flink
Issue Type: Bug
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5158
Thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296829#comment-16296829
]
Till Rohrmann commented on FLINK-8291:
--
[~lynchlee], you are right. We should add at some point user
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296834#comment-16296834
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julio Biason updated FLINK-8284:
Description:
Following the documentation, we changed our filter that removes events with
missing
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4926
@djh4230 could you check whether the Hadoop configuration directory is in
the classpath of the launched Flink components?
---
GitHub user casidiablo opened a pull request:
https://github.com/apache/flink/pull/5182
[FLINK-8162] [kinesis-connector] Emit Kinesis' millisBehindLatest metric
## What is the purpose of the change
- Emits [Kinesis'
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296973#comment-16296973
]
ASF GitHub Bot commented on FLINK-8162:
---
GitHub user casidiablo opened a pull request:
Github user sunjincheng121 closed the pull request at:
https://github.com/apache/flink/pull/4652
---
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296981#comment-16296981
]
sunjincheng commented on FLINK-7465:
I close this issue because I notices that current implementation
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8295:
Affects Version/s: 1.4.0
> Netty shading does not work properly
>
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-7465.
--
Resolution: Workaround
> Add build-in BloomFilterCount on TableAPI
>
Timo Walther created FLINK-8295:
---
Summary: Netty shading does not work properly
Key: FLINK-8295
URL: https://issues.apache.org/jira/browse/FLINK-8295
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296984#comment-16296984
]
ASF GitHub Bot commented on FLINK-7465:
---
Github user sunjincheng121 closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297045#comment-16297045
]
sunjincheng commented on FLINK-7594:
+1, It's a good enhancement to flink.
> Add a SQL client
>
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-8295:
--
Assignee: Nico Kruber
> Netty shading does not work properly
>
[
https://issues.apache.org/jira/browse/FLINK-7594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297096#comment-16297096
]
Timo Walther commented on FLINK-7594:
-
I published an initial design document under FLIP-24. Feel free
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5183
[FLINK-8295][cassandra][build] properly shade netty for the datastax driver
## What is the purpose of the change
`com.datastax.driver.core.NettyUtil` expects netty to be present either at
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297113#comment-16297113
]
ASF GitHub Bot commented on FLINK-8295:
---
GitHub user NicoK opened a pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157877406
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -458,7 +465,14 @@ public JobExecutionResult
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297440#comment-16297440
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297187#comment-16297187
]
Eron Wright edited comment on FLINK-8289 at 12/19/17 6:21 PM:
---
I'll use the
Tzu-Li (Gordon) Tai created FLINK-8296:
--
Summary: Rework FlinkKafkaConsumerBestTest to not use Java
reflection for dependency injection
Key: FLINK-8296
URL: https://issues.apache.org/jira/browse/FLINK-8296
Jan Lukavský created FLINK-8297:
---
Summary: RocksDBListState stores whole list in single byte[]
Key: FLINK-8297
URL: https://issues.apache.org/jira/browse/FLINK-8297
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297436#comment-16297436
]
ASF GitHub Bot commented on FLINK-8234:
---
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/5184#discussion_r157878862
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobDispatcher.java
---
@@ -358,12 +360,12 @@ private
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297450#comment-16297450
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8234:
Priority: Blocker (was: Major)
> Cache JobExecutionResult from finished JobManagerRunners
>
[
https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8233:
Priority: Blocker (was: Major)
> Retrieve ExecutionResult by REST polling
>
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r157907259
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -96,6
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5182#discussion_r157907331
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
@@ -96,6
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297661#comment-16297661
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297662#comment-16297662
]
ASF GitHub Bot commented on FLINK-8162:
---
Github user zentol 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/5184#discussion_r157876761
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -92,4 +94,42 @@
* @return Future containing the
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297435#comment-16297435
]
ASF GitHub Bot commented on FLINK-8234:
---
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/5184#discussion_r157876793
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java
---
@@ -92,4 +94,42 @@
* @return Future containing the
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5184
[FLINK-8234][flip6] Cache JobExecutionResult in Dispatcher
## What is the purpose of the change
Cache `JobExecutionResult` in `Dispatcher`, and add methods to
`RestfulGateway` to enable
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5184#discussion_r157877969
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobExecutionResult.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297187#comment-16297187
]
Eron Wright commented on FLINK-8289:
-
I'll use the terms 'advertised' versus 'bind' address to
[
https://issues.apache.org/jira/browse/FLINK-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297798#comment-16297798
]
Elias Levy commented on FLINK-5880:
---
Came across here to open this issue after reading the latest [blog
Github user djh4230 commented on the issue:
https://github.com/apache/flink/pull/4926
The hadoop config files are in the flink lauched classpath
---
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297813#comment-16297813
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user djh4230 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297820#comment-16297820
]
ASF GitHub Bot commented on FLINK-8295:
---
Github user mcfongtw commented on the issue:
Github user mcfongtw commented on the issue:
https://github.com/apache/flink/pull/5183
+1 for this change, @NicoK . I did not see this error as I was working on
FLINK-6805 - my bad :(. Also, you might want to remove those comment to avoid
future confusion.
---
[
https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297807#comment-16297807
]
ASF GitHub Bot commented on FLINK-8288:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5186
[FLINK-8288] [runtime] register job master rest endpoint url to yarn
## What is the purpose of the change
This pull request pass the endpoint url of job master rest server to
GitHub user laolang113 opened a pull request:
https://github.com/apache/flink/pull/5187
Merge pull request #1 from apache/master
update from apache
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297433#comment-16297433
]
ASF GitHub Bot commented on FLINK-8234:
---
GitHub user GJL opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297443#comment-16297443
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297476#comment-16297476
]
ASF GitHub Bot commented on FLINK-8297:
---
GitHub user je-ik opened a pull request:
GitHub user je-ik opened a pull request:
https://github.com/apache/flink/pull/5185
[FLINK-8297] [flink-rocksdb] optionally use RocksDBMapState internally for
storing lists
## What is the purpose of the change
Enable storing lists not fitting to memory per single key.
[
https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297920#comment-16297920
]
shuai.xu commented on FLINK-8289:
-
Hi [~eronwright], yes, what we need is the advertised address. But for
[
https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui updated FLINK-8257:
---
Description: The {{setParallelism()}} method exist in many components from
different levels. Some of
[
https://issues.apache.org/jira/browse/FLINK-8257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-8257:
--
Assignee: Xingcan Cui
> Unify the value checks for setParallelism()
>
[
https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296435#comment-16296435
]
Haohui Mai commented on FLINK-8240:
---
It seems that it is a great use case of layered table sources /
[
https://issues.apache.org/jira/browse/FLINK-8292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296442#comment-16296442
]
ASF GitHub Bot commented on FLINK-8292:
---
GitHub user Matrix42 opened a pull request:
GitHub user Matrix42 opened a pull request:
https://github.com/apache/flink/pull/5180
[FLINK-8292] Remove unnecessary force cast in DataStreamSource
## What is the purpose of the change
Remove unnecessary force cast in DataStreamSource
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296452#comment-16296452
]
ASF GitHub Bot commented on FLINK-7468:
---
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/4559#discussion_r157691096
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -52,6 +54,10 @@
/** Flag
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r157694294
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java
---
@@ -47,7 +48,14 @@ public void
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4926
Hi @djh4230, try to make sure that your Hadoop configuration file is on the
classpath or that the `HADOOP_CONF_DIR` is properly set.
---
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296417#comment-16296417
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5190.
---
> ZooKeeperLeaderRetrievalService should not close the zk client when stop
>
Lynch Lee created FLINK-8291:
Summary: For security, Job Manager web UI should be accessed with
username/password
Key: FLINK-8291
URL: https://issues.apache.org/jira/browse/FLINK-8291
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5170.
---
> getAkkaConfig will use localhost if hostname is specified
>
[
https://issues.apache.org/jira/browse/FLINK-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5793.
---
> Running slot may not be add to AllocatedMap in SlotPool
>
[
https://issues.apache.org/jira/browse/FLINK-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-5171.
---
> Wrong use of Preconditions.checkState in TaskManagerRunner
>
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r157686388
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
---
@@ -99,6 +82,23 @@ protected Throwable
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296431#comment-16296431
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matrix42 updated FLINK-8292:
Fix Version/s: 1.4.1
1.5.0
> Remove unnecessary force cast in DataStreamSource
>
Matrix42 created FLINK-8292:
---
Summary: Remove unnecessary force cast in DataStreamSource
Key: FLINK-8292
URL: https://issues.apache.org/jira/browse/FLINK-8292
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296434#comment-16296434
]
Lynch Lee commented on FLINK-8291:
--
[~till.rohrmann] Do you aggree with me ??
> For security, Job
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4612
---
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296444#comment-16296444
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Malcolm Taylor updated FLINK-7736:
--
Issue Type: Bug (was: Improvement)
> Fix some of the alerts raised by lgtm.com
>
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296468#comment-16296468
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on a diff in the pull
Timo Walther created FLINK-8293:
---
Summary: Rework Flink's type and serialization docs
Key: FLINK-8293
URL: https://issues.apache.org/jira/browse/FLINK-8293
Project: Flink
Issue Type:
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r157693477
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
---
@@ -181,10 +182,27 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-6434.
---
> There may be allocatedSlots leak in SlotPool
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-7928.
---
> Extend the filed in ResourceProfile for precisely calculating the resource of
> a task manager
>
[
https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu closed FLINK-7878.
---
> Extend the resource type user can define in ResourceSpec
>
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296446#comment-16296446
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user djh4230 commented on the issue:
Github user djh4230 commented on the issue:
https://github.com/apache/flink/pull/4926
Not work! still can't read hdfs-site.xml and can't read hdfs namespace
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-7452.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
[
https://issues.apache.org/jira/browse/FLINK-4352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4352:
Assignee: Till Rohrmann
> Refactor CLI to use RESTful client for cluster communication
>
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296475#comment-16296475
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on a diff in the pull
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r157703075
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
---
@@ -99,6 +82,23 @@ protected Throwable
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296538#comment-16296538
]
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-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296546#comment-16296546
]
Timo Walther commented on FLINK-8240:
-
Thanks for your response [~wheat9]. We need to decide how the
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r157706995
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -52,6 +54,10 @@
/** Flag
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296558#comment-16296558
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296559#comment-16296559
]
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=16296562#comment-16296562
]
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_r157707628
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
---
@@ -99,6 +82,23 @@ protected Throwable
[
https://issues.apache.org/jira/browse/FLINK-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296576#comment-16296576
]
ASF GitHub Bot commented on FLINK-8215:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5148
Thank for this fix @walterddr. The code looks good. I will merge this...
---
[
https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296581#comment-16296581
]
ASF GitHub Bot commented on FLINK-7468:
---
Github user zhijiangW commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5158
---
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r157706951
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
---
@@ -99,6 +82,23 @@ protected Throwable
1 - 100 of 110 matches
Mail list logo
