[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7789:
--
Assignee: blues zheng
> Add handler for Async IO operator timeouts
>
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466809#comment-16466809
]
ASF GitHub Bot commented on FLINK-9073:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466810#comment-16466810
]
ASF GitHub Bot commented on FLINK-9073:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5926
Thanks for the review @StefanRRichter! Will address your comment and merge
this.
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5926#discussion_r186608526
--- Diff: flink-end-to-end-tests/run-nightly-tests.sh ---
@@ -58,25 +58,97 @@ fi
if [ $EXIT_CODE == 0 ]; then
printf
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Description:
Currently the TaskManagerRunner would be waiting for rpc service terminated
synchronously. If
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466795#comment-16466795
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466797#comment-16466797
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5958
Thanks for the update @FredTing.
I'll try to take another look at the PR within the next days.
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186606104
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Summary: TaskManagerRunner.shutDown() may be stuck in waiting rpc service
terminated (was:
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Description: Currently shutdown TaskManagerRunner may be stuck. Because
(was: Currently shutdown
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Summary: TaskManagerRunner.shutDown() would be stuck in waiting rpc service
terminated (was:
[
https://issues.apache.org/jira/browse/FLINK-9315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-9315:
Description: Currently shutdown TaskManagerRunner would stuck
> TaskManagerRunner.shutDown() would stuck in
Biao Liu created FLINK-9315:
---
Summary: TaskManagerRunner.shutDown() would stuck in waiting rpc
service terminated
Key: FLINK-9315
URL: https://issues.apache.org/jira/browse/FLINK-9315
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466777#comment-16466777
]
ASF GitHub Bot commented on FLINK-9258:
---
Github user yuqi1129 commented on a diff in the pull
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5959#discussion_r186603684
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/ComponentMetricGroup.java
---
@@ -57,11 +57,12 @@ public
[
https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466736#comment-16466736
]
ASF GitHub Bot commented on FLINK-9194:
---
Github user yuqi1129 commented on a diff in the pull
Github user yuqi1129 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5902#discussion_r186599431
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java
---
@@ -162,7 +166,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8237.
Resolution: Fixed
Fix Version/s: 1.4.3
1.5.0
Fixed for 1.4.3 with
[
https://issues.apache.org/jira/browse/FLINK-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466438#comment-16466438
]
Tim commented on FLINK-9281:
Not really. Here's what I know
a) If I run the Flink job in my IDE, logback
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-8237:
Assignee: Pavel Shvetsov
> BucketingSink throws NPE when Writer.duplicate returns null
>
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466435#comment-16466435
]
ASF GitHub Bot commented on FLINK-9312:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5966
@EronWright This might be interesting to you as well
---
[
https://issues.apache.org/jira/browse/FLINK-9312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466431#comment-16466431
]
ASF GitHub Bot commented on FLINK-9312:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5966
[FLINK-9312] [security] Add mutual authentication for RPC and data plane
## What is the purpose of the change
Currently, the Flink processes encrypted connections via SSL:
- Data
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466409#comment-16466409
]
Richard Deurwaarder edited comment on FLINK-9311 at 5/7/18 8:06 PM:
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466409#comment-16466409
]
Richard Deurwaarder commented on FLINK-9311:
PubSub works more like RabbitMQ than Kafka using
Stephan Ewen created FLINK-9314:
---
Summary: Enable SSL mutual authentication for Netty / TaskManagers
Key: FLINK-9314
URL: https://issues.apache.org/jira/browse/FLINK-9314
Project: Flink
Issue
Stephan Ewen created FLINK-9313:
---
Summary: Enable mutual authentication for RPC (akka)
Key: FLINK-9313
URL: https://issues.apache.org/jira/browse/FLINK-9313
Project: Flink
Issue Type:
Stephan Ewen created FLINK-9312:
---
Summary: Perform mutual authentication during SSL handshakes
Key: FLINK-9312
URL: https://issues.apache.org/jira/browse/FLINK-9312
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466383#comment-16466383
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466382#comment-16466382
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466385#comment-16466385
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466381#comment-16466381
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466384#comment-16466384
]
ASF GitHub Bot commented on FLINK-8255:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186528901
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/typeutils/FieldAccessorTest.java
---
@@ -368,4 +369,23 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186484649
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/MaxByOperatorTest.java
---
@@ -230,4 +235,43 @@ public String toString() {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186477977
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -41,7 +41,7 @@
* is regarded in the reduce
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186527205
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -157,15 +156,15 @@ public T set(T record,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186527277
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -197,7 +196,7 @@ public T set(T record, F
[
https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466380#comment-16466380
]
ASF GitHub Bot commented on FLINK-9310:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5965
@EronWright This might be interesting to you.
---
[
https://issues.apache.org/jira/browse/FLINK-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466379#comment-16466379
]
ASF GitHub Bot commented on FLINK-9310:
---
GitHub user StephanEwen opened a pull request:
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5965
[FLINK-9310] [security] Update standard cipher suites for secure mode
## What is the purpose of the change
This sets the cipher suits accepted by default to those recommended in
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8690.
Resolution: Implemented
Fix Version/s: 1.6.0
Implemented for 1.6.0 with
[
https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466356#comment-16466356
]
Stephan Ewen commented on FLINK-9311:
-
The RichParallelSourceFunction is a good place to start.
What
[
https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466345#comment-16466345
]
ASF GitHub Bot commented on FLINK-6335:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466348#comment-16466348
]
ASF GitHub Bot commented on FLINK-8690:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466346#comment-16466346
]
ASF GitHub Bot commented on FLINK-8237:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466347#comment-16466347
]
ASF GitHub Bot commented on FLINK-6373:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3764
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3765
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5927
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5940
---
Richard Deurwaarder created FLINK-9311:
--
Summary: PubSub connector
Key: FLINK-9311
URL: https://issues.apache.org/jira/browse/FLINK-9311
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466281#comment-16466281
]
Narayanan Arunachalam commented on FLINK-9302:
--
Thanks [~srichter]. I ran some tests over the
Stephan Ewen created FLINK-9310:
---
Summary: Update default cyphersuites
Key: FLINK-9310
URL: https://issues.apache.org/jira/browse/FLINK-9310
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-9265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466236#comment-16466236
]
ASF GitHub Bot commented on FLINK-9265:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5936
Yes, before giving +1 to this commit, we need to check that this introduces
no new transitive dependency, or need to make sure that dependency is not an
issue.
---
[
https://issues.apache.org/jira/browse/FLINK-9281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466229#comment-16466229
]
Stephan Ewen commented on FLINK-9281:
-
Do you have any insights into why it does not work with newer
[
https://issues.apache.org/jira/browse/FLINK-9300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466227#comment-16466227
]
Stephan Ewen commented on FLINK-9300:
-
This should actually not happen with the FsStateBackend. The
[
https://issues.apache.org/jira/browse/FLINK-9301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466224#comment-16466224
]
Stephan Ewen commented on FLINK-9301:
-
Okay, so apparently the required memory per TaskManager is now
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466222#comment-16466222
]
Stephan Ewen commented on FLINK-9305:
-
I am not 100% sure about this issue.
Flink's shaded s3a
[
https://issues.apache.org/jira/browse/FLINK-9308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466209#comment-16466209
]
Stephan Ewen commented on FLINK-9308:
-
The rate at which Kafka can handle offset commits should not be
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466166#comment-16466166
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user FredTing commented on a diff in the pull
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186480680
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466157#comment-16466157
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user FredTing commented on a diff in the pull
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186479633
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466141#comment-16466141
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user FredTing commented on a diff in the pull
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186479026
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java
---
@@ -42,14 +42,22 @@
@Public
public
[
https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466138#comment-16466138
]
ASF GitHub Bot commented on FLINK-9253:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5923
Apparently, there's a problem with unknown input channels that surfaced
with the newly-merged extra tests: they don't get exclusive buffers (naturally)
but the floating buffers are calculated and
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466112#comment-16466112
]
ASF GitHub Bot commented on FLINK-8655:
---
GitHub user ctamisier opened a pull request:
GitHub user ctamisier opened a pull request:
https://github.com/apache/flink/pull/5964
[FLINK-8655] [Cassandra Connector] add keyspace in cassandra sink builder
## What is the purpose of the change
This PR is an alternative to https://github.com/apache/flink/pull/5538.
[
https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466068#comment-16466068
]
ASF GitHub Bot commented on FLINK-6373:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3765
The features that this PR was going to implement has been resolved by PR
#.
I will close it.
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3764
This PR has been integrated into #5940.
I'll close it.
---
[
https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466067#comment-16466067
]
ASF GitHub Bot commented on FLINK-6335:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466066#comment-16466066
]
ASF GitHub Bot commented on FLINK-8690:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466065#comment-16466065
]
ASF GitHub Bot commented on FLINK-8237:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5940
merging
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5927
merging
---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466062#comment-16466062
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user FredTing commented on a diff in the pull
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186465223
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/serialization/ConsumerRecordMetaInfo.java
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466051#comment-16466051
]
ASF GitHub Bot commented on FLINK-8237:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5927
Thanks for the update @pavel-shvetsov-git.
+1 to merge
---
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466048#comment-16466048
]
ASF GitHub Bot commented on FLINK-8690:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466047#comment-16466047
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user FredTing commented on a diff in the pull
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5940
Thanks for the update @walterddr.
The PR is good to merge.
---
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186462871
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
@@ -78,6
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466037#comment-16466037
]
Ted Yu commented on FLINK-9303:
---
{code}
+ if (!removedPartitions.isEmpty()) {
+
[
https://issues.apache.org/jira/browse/FLINK-9064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466020#comment-16466020
]
ASF GitHub Bot commented on FLINK-9064:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5773
cc @zentol @GJL @tzulitai please review thanks~
---
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466014#comment-16466014
]
Rong Rong commented on FLINK-7001:
--
Thanks [~pgrulich], This is definitely a great solution when handling
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466011#comment-16466011
]
ASF GitHub Bot commented on FLINK-7897:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5777
cc @zentol @GJL @tzulitai this PR takes a long time, please review it
thanks.
---
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8999:
---
Assignee: (was: mingleizhang)
> Ensure the job has an operator with operator state.
>
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466010#comment-16466010
]
ASF GitHub Bot commented on FLINK-7917:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5798
cc @zentol @GJL @tzulitai this PR takes a long time, please review thanks~
---
1 - 100 of 275 matches
Mail list logo
