Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3511
> So I think a simpler and better approach is to just make sure that most
types have a good implementation of putNormalizedKey, and then
NormalizedKeySorter.compareRecords would be called only
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186766#comment-16186766
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in the pull request:
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r141993041
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class
[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186631#comment-16186631
]
Bowen Li commented on FLINK-7648:
-
[~till.rohrmann] I successfully started the cluster in a unit test.
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186602#comment-16186602
]
Shuyi Chen commented on FLINK-7491:
---
[~fhueske] can you help take another look at the PR? I've addressed
Bin Wang created FLINK-7740:
---
Summary: Add parameter support in CassandraInputFormat
Key: FLINK-7740
URL: https://issues.apache.org/jira/browse/FLINK-7740
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186260#comment-16186260
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141945843
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -235,14 +240,15 @@ void releaseBuffer() {
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141945644
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -131,6 +136,63 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186258#comment-16186258
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186255#comment-16186255
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3359#discussion_r141942758
--- Diff:
flink-contrib/flink-timerserivce-rocksdb/src/main/java/org/apache/flink/contrib/streaming/api/operators/RocksDBInternalTimerService.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186254#comment-16186254
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186256#comment-16186256
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on a diff in the pull
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3359#discussion_r141944569
--- Diff:
flink-contrib/flink-timerserivce-rocksdb/src/main/java/org/apache/flink/contrib/streaming/api/operators/RocksDBInternalTimerService.java
---
@@
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3359#discussion_r141944634
--- Diff:
flink-contrib/flink-timerserivce-rocksdb/src/main/java/org/apache/flink/contrib/streaming/api/operators/RocksDBInternalTimerService.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186202#comment-16186202
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user EXPjbucher commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186083#comment-16186083
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/4509
@NicoK , thanks for reviews and talking about this key point.
I think I understand your point and agree with that. I will submit the
modifications before Monday.
---
[
https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186049#comment-16186049
]
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_r141911428
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java
---
@@ -37,20 +43,31 @@
import
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141906648
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -374,6 +376,64 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186043#comment-16186043
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186040#comment-16186040
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186046#comment-16186046
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186038#comment-16186038
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186045#comment-16186045
]
ASF GitHub Bot commented on FLINK-7406:
---
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/4509#discussion_r141901569
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -209,6 +276,95 @@ public String
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141886467
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -390,7 +390,63 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141865540
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -390,7 +390,63 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141890624
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -390,7 +390,63 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141896356
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -412,23 +468,35 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186035#comment-16186035
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186037#comment-16186037
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186044#comment-16186044
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186041#comment-16186041
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186039#comment-16186039
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186042#comment-16186042
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186036#comment-16186036
]
ASF GitHub Bot commented on FLINK-7406:
---
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/4509#discussion_r141902956
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -70,6 +79,21 @@
*/
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141865630
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -390,7 +390,63 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141908388
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -374,6 +376,64 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141890343
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -390,7 +390,63 @@ public
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141896488
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -412,23 +468,35 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r141890051
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -390,7 +390,63 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16186007#comment-16186007
]
Alexey Diomin commented on FLINK-7735:
--
Java 7 will be dropped very soon FLINK-7242
Maybe make sense
[
https://issues.apache.org/jira/browse/FLINK-7700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185950#comment-16185950
]
ASF GitHub Bot commented on FLINK-7700:
---
GitHub user aljoscha opened a pull request:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/3511
> IMHO, in addition to these changes, there are still some potential
improvements we can do about the sorter, like deserialization when comparing
the real records.
Do you mean
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4752
[FLINK-7700] Fix RocksDB state merging on release-1.3
This is only for running the tests, which I can't do on my own Travis since
tests time out.
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185921#comment-16185921
]
Malcolm Taylor commented on FLINK-7736:
---
Identified 14 alerts to address:
1) dereferenced variable
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4750#discussion_r141882415
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/CheckpointStatistics.java
---
@@ -0,0 +1,763 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185911#comment-16185911
]
ASF GitHub Bot commented on FLINK-7710:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185839#comment-16185839
]
ASF GitHub Bot commented on FLINK-7739:
---
GitHub user pnowojski opened a pull request:
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4751
[FLINK-7739][kafka-tests] Throttle down data producing thread
Minor tests improvement in tests to avoid busy loop
You can merge this pull request into a Git repository by running:
$ git
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4750
[FLINK-7710] [flip6] Add CheckpointStatisticsHandler for the new REST
endpoint
## What is the purpose of the change
This commit also makes the CheckpointStatsHistory object
[
https://issues.apache.org/jira/browse/FLINK-7710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185821#comment-16185821
]
ASF GitHub Bot commented on FLINK-7710:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185816#comment-16185816
]
ASF GitHub Bot commented on FLINK-7072:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4730
---
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4730
Changes look good to me. Thanks a lot for your contribution @zentol.
Merging this PR.
---
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4749
[FLINK-7739][tests] Properly shutdown resources in tests
This is a fixup of tests, without touching the production code.
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185796#comment-16185796
]
ASF GitHub Bot commented on FLINK-7739:
---
GitHub user pnowojski opened a pull request:
Piotr Nowojski created FLINK-7739:
-
Summary: Improve Kafka*ITCase tests stability
Key: FLINK-7739
URL: https://issues.apache.org/jira/browse/FLINK-7739
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185685#comment-16185685
]
ASF GitHub Bot commented on FLINK-7668:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4728
+1 from my side too.
---
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4748
[hotfix][tests] Use G1GC for tests
We are using G1GC for running TaskManager, I think we should do it so also
for tests.
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-7708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185663#comment-16185663
]
ASF GitHub Bot commented on FLINK-7708:
---
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/4744#discussion_r141836633
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/CheckpointConfigInfo.java
---
@@ -0,0 +1,152 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185592#comment-16185592
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185591#comment-16185591
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4625
Thanks for the update @xccui. I'll have a look in the next days.
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4625#discussion_r141831721
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamInnerJoin.scala
---
@@ -131,340 +116,308 @@ class
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/4747
[FLINK-7728] [DataStream] Flush StatusWatermarkValve once all inputs become
idle
## What is the purpose of the change
This PR is based on #4738. Only the last three commits are relevant.
[
https://issues.apache.org/jira/browse/FLINK-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185574#comment-16185574
]
ASF GitHub Bot commented on FLINK-7728:
---
GitHub user tzulitai opened a pull request:
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4729#discussion_r141822004
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -228,7 +234,14 @@ public void startNewWorker(ResourceProfile
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185544#comment-16185544
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185532#comment-16185532
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on a diff in the pull
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4729#discussion_r141820967
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java ---
@@ -228,7 +234,14 @@ public void startNewWorker(ResourceProfile
[
https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185519#comment-16185519
]
ASF GitHub Bot commented on FLINK-7668:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4728
Thanks for addressing / replying to my comments.
LGTM, +1 from me
---
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4728#discussion_r141817520
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java
---
@@ -0,0 +1,357 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185518#comment-16185518
]
ASF GitHub Bot commented on FLINK-7668:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7710:
Assignee: Till Rohrmann
> Port CheckpointStatsHandler to new REST endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185507#comment-16185507
]
ASF GitHub Bot commented on FLINK-7668:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4728
I've rebased the code onto the latest master. Are all PR comments resolved
@zentol and @tzulitai?
---
[
https://issues.apache.org/jira/browse/FLINK-7667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185506#comment-16185506
]
ASF GitHub Bot commented on FLINK-7667:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4727
---
[
https://issues.apache.org/jira/browse/FLINK-7667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7667.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed via 2dd557fad4a0a205a3e163fa918507d34c933c6a
>
[
https://issues.apache.org/jira/browse/FLINK-7667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185503#comment-16185503
]
ASF GitHub Bot commented on FLINK-7667:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4727
Merging this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185502#comment-16185502
]
Till Rohrmann commented on FLINK-7648:
--
In order to wait on the completion you can do
{code}
@Test
[
https://issues.apache.org/jira/browse/FLINK-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7541.
-
There are still parts of the code in the Flink that Relays on operator order
> Redistribute operator
[
https://issues.apache.org/jira/browse/FLINK-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7541.
---
Resolution: Fixed
Fix Version/s: 1.4.0
> Redistribute operator state using OperatorID
[
https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185498#comment-16185498
]
Till Rohrmann commented on FLINK-7694:
--
Yes, this will make sure that the web gui will also
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7683.
-
> Add method to iterate over all of the existing keys in a statebackend
>
[
https://issues.apache.org/jira/browse/FLINK-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185497#comment-16185497
]
ASF GitHub Bot commented on FLINK-7695:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7683.
---
Resolution: Fixed
Fix Version/s: 1.4.0
> Add method to iterate over all of the
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4737
Thanks for the review @zentol and @yew1eb. I have to throw this PR once
more on Travis to see if everything passes. Once this is done and the depended
PRs are merged, I'll merge this one as
[
https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185493#comment-16185493
]
Till Rohrmann commented on FLINK-7704:
--
Hi [~haizhou], great to hear that you want to help with
[
https://issues.apache.org/jira/browse/FLINK-7695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16185473#comment-16185473
]
ASF GitHub Bot commented on FLINK-7695:
---
Github user yew1eb commented on the issue:
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/4737
Hey @tillrohrmann, Will you merge this PR ?
I want to fix sibling issues (FLINK-7704, FLINK-7705, FLINK-7706).
:beers:
Best,
Hai Zhou
---
1 - 100 of 112 matches
Mail list logo
