Hai Zhou UTC+8 created FLINK-7742:
-
Summary: Fix array access might be out of bounds
Key: FLINK-7742
URL: https://issues.apache.org/jira/browse/FLINK-7742
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186921#comment-16186921
]
ASF GitHub Bot commented on FLINK-7741:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4753
[FLINK-7741][build] Fix NPE when throw new SlotNotFoundException
if taskSlot is null then **throw new
SlotNotFoundException(taskSlot.getAllocationId());** will have NPE.
the code segment in
**o
Hai Zhou UTC+8 created FLINK-7741:
-
Summary: Fix NPE when throw new SlotNotFoundException
Key: FLINK-7741
URL: https://issues.apache.org/jira/browse/FLINK-7741
Project: Flink
Issue Type: Bug
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 rare
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186766#comment-16186766
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user xccui commented on a diff in th
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 Ti
[
https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186631#comment-16186631
]
Bowen Li commented on FLINK-7648:
-
[~till.rohrmann] I successfully started the cluster in
[
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186602#comment-16186602
]
Shuyi Chen commented on FLINK-7491:
---
[~fhueske] can you help take another look at the PR
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&focusedCommentId=16186260#comment-16186260
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user bowenli86 commented on a diff i
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 recycle(Memor
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186258#comment-16186258
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186255#comment-16186255
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on a diff i
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&focusedCommentId=16186254#comment-16186254
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186256#comment-16186256
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user bowenli86 commented on a diff i
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
---
@@
Github user EXPjbucher commented on the issue:
https://github.com/apache/flink/pull/3359
Hey, I was actually looking into this today and was wondering what the
status of this is? We have this exact case where lots of timers are causing
high memory use (most of which don't need to be i
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186202#comment-16186202
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user EXPjbucher commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186083#comment-16186083
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user zhijiangW commented on the issu
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&focusedCommentId=16186049#comment-16186049
]
ASF GitHub Bot commented on FLINK-7416:
---
Github user NicoK commented on a diff in th
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 java.i
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&focusedCommentId=16186043#comment-16186043
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186040#comment-16186040
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186038#comment-16186038
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186045#comment-16186045
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186046#comment-16186046
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
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 to
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 BufferPro
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 BufferPro
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 BufferPro
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 onB
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186035#comment-16186035
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186037#comment-16186037
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186044#comment-16186044
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186041#comment-16186041
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186039#comment-16186039
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186042#comment-16186042
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186036#comment-16186036
]
ASF GitHub Bot commented on FLINK-7406:
---
Github user NicoK commented on a diff in th
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 BufferPro
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 BufferPro
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 onB
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 BufferPro
[
https://issues.apache.org/jira/browse/FLINK-7735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16186007#comment-16186007
]
Alexey Diomin commented on FLINK-7735:
--
Java 7 will be dropped very soon FLINK-7242
[
https://issues.apache.org/jira/browse/FLINK-7700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 `NormalizedKeyS
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 reposit
[
https://issues.apache.org/jira/browse/FLINK-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185921#comment-16185921
]
Malcolm Taylor commented on FLINK-7736:
---
Identified 14 alerts to address:
1) derefer
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&focusedCommentId=16185911#comment-16185911
]
ASF GitHub Bot commented on FLINK-7710:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 pull
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 serializabl
[
https://issues.apache.org/jira/browse/FLINK-7710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185821#comment-16185821
]
ASF GitHub Bot commented on FLINK-7710:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-7072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185816#comment-16185816
]
ASF GitHub Bot commented on FLINK-7072:
---
Github user asfgit closed the pull request
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:
$ gi
[
https://issues.apache.org/jira/browse/FLINK-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=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:
$ g
[
https://issues.apache.org/jira/browse/FLINK-7708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185663#comment-16185663
]
ASF GitHub Bot commented on FLINK-7708:
---
Github user zentol commented on a diff in t
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&focusedCommentId=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&focusedCommentId=16185591#comment-16185591
]
ASF GitHub Bot commented on FLINK-6233:
---
Github user fhueske commented on a diff in
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&focusedCommentId=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
resou
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185544#comment-16185544
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185532#comment-16185532
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on a diff in
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
resou
[
https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16185518#comment-16185518
]
ASF GitHub Bot commented on FLINK-7668:
---
Github user tzulitai commented on a diff in
[
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&focusedCommentId=16185507#comment-16185507
]
ASF GitHub Bot commented on FLINK-7668:
---
Github user tillrohrmann commented on the i
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&focusedCommentId=16185506#comment-16185506
]
ASF GitHub Bot commented on FLINK-7667:
---
Github user asfgit closed the pull request
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&focusedCommentId=16185503#comment-16185503
]
ASF GitHub Bot commented on FLINK-7667:
---
Github user tillrohrmann commented on the i
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&focusedCommentId=16185502#comment-16185502
]
Till Rohrmann commented on FLINK-7648:
--
In order to wait on the completion you can do
[
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&focusedCommentId=16185498#comment-16185498
]
Till Rohrmann commented on FLINK-7694:
--
Yes, this will make sure that the web gui wil
[
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&focusedCommentId=16185497#comment-16185497
]
ASF GitHub Bot commented on FLINK-7695:
---
Github user tillrohrmann commented on the i
1 - 100 of 113 matches
Mail list logo
