[
https://issues.apache.org/jira/browse/FLINK-8596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372533#comment-16372533
]
ASF GitHub Bot commented on FLINK-8596:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5543
E2E test isn't fully working yet, debugging...
---
[
https://issues.apache.org/jira/browse/FLINK-8705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8705.
Resolution: Fixed
Fixed via
facf2ac67ae3ffd4cffd7c6f8536fd7953795fb9
[
https://issues.apache.org/jira/browse/FLINK-8711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8711.
--
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-8632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8632.
Resolution: Fixed
Fixed via 831349a617d2bd3b9be6d3c1ca777baa25276c88
> Generalize
[
https://issues.apache.org/jira/browse/FLINK-8631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-8631.
Resolution: Fixed
Fixed via 313284f535bc84ca3f47bdb07f0553fe3326f70c
> Add support for generic
Chesnay Schepler created FLINK-8743:
---
Summary: Add annotation to override documented default
Key: FLINK-8743
URL: https://issues.apache.org/jira/browse/FLINK-8743
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7712.
--
Resolution: Fixed
Added via 0db9c5bc3d3f61a3af3a94281ed2bf580007b873
> Port JarDeleteHandler
[
https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7714.
--
Resolution: Fixed
Added via 46e6d483c63caad90dbe8f6bc50049c001f74edc
> Port JarPlanHandler to
[
https://issues.apache.org/jira/browse/FLINK-8710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-8710.
--
Resolution: Fixed
Fixed via d3114cd90d99bb11f1f55b5d5ad0576527541b41
>
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372534#comment-16372534
]
chris snow commented on FLINK-8543:
---
[~aljoscha] - what are your thoughts on this?
> Output Stream
Tzu-Li (Gordon) Tai created FLINK-8741:
--
Summary: KafkaFetcher09/010/011 uses wrong user code classloader
Key: FLINK-8741
URL: https://issues.apache.org/jira/browse/FLINK-8741
Project: Flink
Chesnay Schepler created FLINK-8742:
---
Summary: Move ConfigDocsGenerator annotationt to flink-annotations
Key: FLINK-8742
URL: https://issues.apache.org/jira/browse/FLINK-8742
Project: Flink
Chesnay Schepler created FLINK-8744:
---
Summary: Add annotations for documentation common/advanced options
Key: FLINK-8744
URL: https://issues.apache.org/jira/browse/FLINK-8744
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372587#comment-16372587
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372599#comment-16372599
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169899133
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372612#comment-16372612
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user StefanRRichter commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5552#discussion_r169918501
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5552#discussion_r169918485
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372648#comment-16372648
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372649#comment-16372649
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8740:
Priority: Blocker (was: Major)
> Job-level metrics lost during job re-submission in HA
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169632755
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/RescalingBehaviour.java
---
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169917845
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -447,6 +453,165 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169917224
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -447,6 +453,165 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169911850
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -447,6 +453,165 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169919835
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/RescaleParallelismQueryParameter.java
---
@@ -0,0 +1,41 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169918052
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -447,6 +453,165 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169916387
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -447,6 +453,165 @@ public void postStop() throws Exception {
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169913228
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -963,6 +1120,36 @@ private Acknowledge suspendExecution(final
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169920801
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/RescalingStatusMessageParameters.java
---
@@ -0,0 +1,39 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169912256
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -447,6 +453,165 @@ public void postStop() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-8742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8742:
Summary: Move ConfigDocsGenerator annotation to flink-annotations (was:
Move
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372585#comment-16372585
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169897306
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169898758
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372598#comment-16372598
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169898668
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372602#comment-16372602
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169899631
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372623#comment-16372623
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169909152
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372645#comment-16372645
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372647#comment-16372647
]
ASF GitHub Bot commented on FLINK-7944:
---
Github user aljoscha closed the pull request at:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/4920
---
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372653#comment-16372653
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5552#discussion_r169919719
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372652#comment-16372652
]
Chesnay Schepler commented on FLINK-8744:
-
We can probably remove the advanced section if we move
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372654#comment-16372654
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5552#discussion_r169919922
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372655#comment-16372655
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372657#comment-16372657
]
ASF GitHub Bot commented on FLINK-8735:
---
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/5552#discussion_r169920122
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372682#comment-16372682
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372677#comment-16372677
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169896622
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryKeyedStateHandle.java
---
@@ -0,0 +1,105 @@
+/*
+ * Licensed
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169896224
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamWithResultProvider.java
---
@@ -172,4 +167,30 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372594#comment-16372594
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169905515
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372613#comment-16372613
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user StefanRRichter commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169905650
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5545
I agree with @aljoscha, there is a sanity check that `maxParallelism` of
operators did not change when restoring.
---
[
https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372660#comment-16372660
]
ASF GitHub Bot commented on FLINK-8718:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169895663
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r169895777
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372583#comment-16372583
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372590#comment-16372590
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372600#comment-16372600
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372603#comment-16372603
]
Stephan Ewen commented on FLINK-8744:
-
IIRC, we initially had only "common" and "advanced" was the
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169904243
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java
---
@@ -61,8 +61,9 @@
* over it
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372615#comment-16372615
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user tillrohrmann commented on a diff in the pull
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5545
Yes, no source can use keyed state. ð But the `StateAssignmentOperation`
will still fail a restore if the `maxParallelism` of an operator changes. Maybe
@StefanRRichter can chime in on that but
[
https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372641#comment-16372641
]
ASF GitHub Bot commented on FLINK-8718:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372643#comment-16372643
]
Aljoscha Krettek commented on FLINK-8543:
-
The comments are correct, S3 simply does not support
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5552#discussion_r169917696
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5552#discussion_r169919494
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
---
@@ -0,0 +1,658 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372664#comment-16372664
]
ASF GitHub Bot commented on FLINK-8735:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5552
I will have a look at the current state of the PR, but given that you
started the effort, it would be good for completeness, to also refactor the
`scala` equivalent `ITcase` to get rid of all the
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372673#comment-16372673
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372676#comment-16372676
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372671#comment-16372671
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372670#comment-16372670
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372674#comment-16372674
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372669#comment-16372669
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8740:
Fix Version/s: 1.5.0
> Job-level metrics lost during job re-submission in HA mode
>
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372675#comment-16372675
]
ASF GitHub Bot commented on FLINK-8656:
---
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/5487#discussion_r169922284
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/RescaleParallelismQueryParameter.java
---
@@ -0,0 +1,41 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372672#comment-16372672
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372679#comment-16372679
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372668#comment-16372668
]
ASF GitHub Bot commented on FLINK-8656:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372678#comment-16372678
]
ASF GitHub Bot commented on FLINK-8656:
---
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/5487#discussion_r169918959
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationInfo.java
---
@@ -0,0 +1,64 @@
+/*
+ * Licensed
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5487#discussion_r169634082
--- Diff:
flink-core/src/main/java/org/apache/flink/util/function/BiConsumerWithException.java
---
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169946803
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169948460
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBRocksIteratorWrapperTest.java
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372783#comment-16372783
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user StefanRRichter commented on a diff in the pull
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5548#discussion_r169943180
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -377,14 +377,14 @@ public boolean scheduleForExecution() {
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16372785#comment-16372785
]
ASF GitHub Bot commented on FLINK-8679:
---
Github user StefanRRichter commented on a diff in the pull
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5518#discussion_r169949298
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
1 - 100 of 329 matches
Mail list logo