Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2622
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568268#comment-15568268
]
ASF GitHub Bot commented on FLINK-3706:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4802:
---
Assignee: Chesnay Schepler
> distinct() implicitly uses 0th field, when called
[
https://issues.apache.org/jira/browse/FLINK-4805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4805:
---
Assignee: Chesnay Schepler
> Stringify() crashes with Python3 (run with pyflink3)
>
[
https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568290#comment-15568290
]
ASF GitHub Bot commented on FLINK-4799:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4794:
---
Assignee: Chesnay Schepler
> partition_by_hash() crashes if no parameter is provided
[
https://issues.apache.org/jira/browse/FLINK-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4795:
---
Assignee: Chesnay Schepler
> CsvStringify crashes in case of tuple in tuple, t.e.
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568348#comment-15568348
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82978898
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java
---
@@ -256,29 +306,51 @@ public boolean acknowledgeTask(
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4793.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 1dda3ad009667697a620359e997e83a5ba2447dd.
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2599
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568220#comment-15568220
]
Nikolay Vasilishin commented on FLINK-4492:
---
This issue has been resolved since [FLINK-3761]
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82970716
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -219,33 +245,9 @@ public CheckpointCoordinator(
Robert Metzger created FLINK-4812:
-
Summary: Export currentLowWatermark metric also for sources
Key: FLINK-4812
URL: https://issues.apache.org/jira/browse/FLINK-4812
Project: Flink
Issue
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82972407
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java
---
@@ -64,9 +62,9 @@ public void recover()
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568316#comment-15568316
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82976869
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointLoader.java
---
@@ -48,13 +48,12 @@
public static
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568319#comment-15568319
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568191#comment-15568191
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user uce commented on the issue:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82969876
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -637,20 +637,25 @@ protected int savepoint(String[] args) {
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568207#comment-15568207
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82976383
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -172,7 +168,7 @@ public void recover()
[
https://issues.apache.org/jira/browse/FLINK-4804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4804:
---
Assignee: Chesnay Schepler
> Grouping.first() function usage fails
>
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568313#comment-15568313
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-4283:
-
Assignee: Alexander Shoshin
> ExecutionGraphRestartTest fails
> ---
>
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82988652
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/windows/Session.java
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed to
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83005706
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -256,11 +265,11 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83006923
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83022754
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
---
@@ -257,74 +190,158 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569021#comment-15569021
]
Timo Walther commented on FLINK-4604:
-
You cannot use
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2608
+1 to the general approach and the code
Some suggestions for name polishing:
- How about renaming `DISCARD_ON_CANCELLATION` to
`DELETE_ON_CANCELLATION`? That would sound more
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82990268
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/expressions/properties.scala
---
@@ -0,0 +1,57 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-4806.
-
Resolution: Won't Fix
> ResourceManager stop listening JobManager's leader address
>
[
https://issues.apache.org/jira/browse/FLINK-4787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568599#comment-15568599
]
ASF GitHub Bot commented on FLINK-4787:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568940#comment-15568940
]
Alexander Shoshin commented on FLINK-4283:
--
It is still relevant. I have just strated researching
[
https://issues.apache.org/jira/browse/FLINK-4803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569025#comment-15569025
]
Shannon Carey commented on FLINK-4803:
--
Yes, that's right. cancel() blocks on close(), and therefore
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15569028#comment-15569028
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user StephanEwen commented on the issue:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2627
Kafka 0.10 follow-up fixes
After merging https://github.com/apache/flink/pull/2369, there was some
follow-up feedback in the final commit:
[
https://issues.apache.org/jira/browse/FLINK-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4635:
--
Issue Type: Sub-task (was: Task)
Parent: FLINK-3930
> Implement Data Transfer
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83017556
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83014810
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83007178
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83019658
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -107,10 +113,10 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83016929
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83005668
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -111,8 +114,8 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83019574
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -295,7 +256,7 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83016682
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -336,237 +348,294 @@ public int compare(String o1,
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83020529
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -60,26 +63,27 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83019134
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -146,102 +152,57 @@
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83004834
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingITCase.java
---
@@ -111,174 +115,191 @@ protected void testProgram()
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83014794
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -578,18 +647,28 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83015686
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -578,18 +647,28 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83022623
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ContinuousFileProcessingCheckpointITCase.java
---
@@ -257,74 +190,158 @@ public void
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r83005541
--- Diff:
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingTests.java
---
@@ -54,8 +55,10 @@
import java.util.List;
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82990475
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/RexNodeTranslator.scala
---
@@ -27,48 +27,65 @@ import
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568534#comment-15568534
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82999720
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeutils/RowIntervalTypeInfo.scala
---
@@ -0,0 +1,108 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568653#comment-15568653
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
Github user albertoRamon commented on the issue:
https://github.com/apache/flink/pull/2619
Works OK ¡¡
[Capture
Output](http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/jdbc-JDBCInputFormat-tp9393p9489.html)
Thanks, Alb
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568712#comment-15568712
]
ASF GitHub Bot commented on FLINK-4108:
---
Github user albertoRamon commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2439
Okay, then we should re-add all the dependency exclusions that were removed
from the `flink-storm/pom.xml`.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568657#comment-15568657
]
Maximilian Michels commented on FLINK-4813:
---
+1 That sounds like a good solution.
> Having
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568798#comment-15568798
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568544#comment-15568544
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82993938
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/PropertyRead.scala
---
@@ -0,0 +1,33 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568782#comment-15568782
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2623
As far as I read it, Kryo 3.x is not strictly serialization compatible with
2.x, hence the major version number bump.
If the interfaces are still stable, then it should be fine to bump
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568532#comment-15568532
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568564#comment-15568564
]
Robert Metzger commented on FLINK-3398:
---
Maybe we should close this JIRA and have the discussion
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568664#comment-15568664
]
Anton Mushin commented on FLINK-4604:
-
I tried check function in
[
https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3037:
--
Description:
Currently, if the {{FlinkKafkaConsumer}} is restoring a checkpoint and the
offset
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r83003348
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r83008188
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeutils/RowIntervalTypeInfo.scala
---
@@ -0,0 +1,108 @@
+/*
+ *
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r83009444
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/PropertyRead.scala
---
@@ -0,0 +1,33 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568745#comment-15568745
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568768#comment-15568768
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568789#comment-15568789
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r83000595
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/windows/Session.java
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568669#comment-15568669
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568819#comment-15568819
]
Stephan Ewen commented on FLINK-4283:
-
Is this issue still relevant, or has this instability been
[
https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568527#comment-15568527
]
Kurt Young commented on FLINK-4806:
---
Yes, you are right about this. [~mxm]
> ResourceManager stop
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2562#discussion_r82991170
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AvgAggregate.scala
---
@@ -23,6 +23,8 @@ import
[
https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568586#comment-15568586
]
ASF GitHub Bot commented on FLINK-4691:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4813:
--
Description:
The {{flink-test-utils}} depend on {{hadoop-minikdc}}, which has a dependency,
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568701#comment-15568701
]
Robert Metzger commented on FLINK-4280:
---
This issue is related:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568703#comment-15568703
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2623
This change adds Kryo-shaded to our dependency tree:
```
[INFO] | +- com.twitter:chill_2.10:jar:0.8.1:compile
[INFO] | | +- com.twitter:chill-java:jar:0.8.1:compile
[INFO] |
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568803#comment-15568803
]
Stephan Ewen commented on FLINK-4813:
-
+1
> Having flink-test-utils as a dependency outside Flink
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568548#comment-15568548
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user uce commented on the issue:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2626
[FLINK-4787] [runtime-web] Expose cancel-with-savepoint via REST API
Follow up to #2609, exposing the cancel-with-savepoint command via the REST
API. The relevant commits are the last two ones.
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15568635#comment-15568635
]
Robert Metzger commented on FLINK-3706:
---
Fix for release-1.1:
Robert Metzger created FLINK-4813:
-
Summary: Having flink-test-utils as a dependency outside Flink
fails the build
Key: FLINK-4813
URL: https://issues.apache.org/jira/browse/FLINK-4813
Project: Flink
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2627
Thanks a lot for fixing this.
+1 from my side
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15567867#comment-15567867
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user shijinkui commented on the issue:
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2541
@StephanEwen Iâve a new function name `createCustomLocalEnv`. Sorry for
late ack.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Ufuk Celebi created FLINK-4814:
--
Summary: Remove extra storage location for externalized checkpoint
metadata
Key: FLINK-4814
URL: https://issues.apache.org/jira/browse/FLINK-4814
Project: Flink
Stephan Ewen created FLINK-4816:
---
Summary: Executions from "DEPLOYING" should retain restored
checkpoint information
Key: FLINK-4816
URL: https://issues.apache.org/jira/browse/FLINK-4816
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3844.
---
> Checkpoint failures should not always lead to job failures
>
[
https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3844.
-
Resolution: Duplicate
Duplicate of FLINK-4809
The other issue has already fine grained subtasks
[
https://issues.apache.org/jira/browse/FLINK-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3594.
---
> StreamTask may fail when checkpoint is concurrent to regular termination
>
101 - 200 of 224 matches
Mail list logo
