[
https://issues.apache.org/jira/browse/FLINK-4694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4694.
Resolution: Fixed
Added via f863d16860be24ab6932282db0722eadc51b64a6
> Add wait for termination
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2558
---
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-4694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565455#comment-15565455
]
ASF GitHub Bot commented on FLINK-4694:
---
Github user tillrohrmann closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565507#comment-15565507
]
ASF GitHub Bot commented on FLINK-4799:
---
Github user uce commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2608
Tested the changes locally. I took a savepoint with and without explicit
savepoint directory and resumed from there. Both seemed to work without a
problem :-)
---
If your project is set up
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2621#discussion_r82807840
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java
---
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565648#comment-15565648
]
ASF GitHub Bot commented on FLINK-2608:
---
GitHub user chermenin opened a pull request:
GitHub user chermenin opened a pull request:
https://github.com/apache/flink/pull/2623
[FLINK-2608] Updated Twitter Chill version.
Fixed JIRA issue [[FLINK-2608] Arrays.asList(..) does not work with
CollectionInputFormat](https://issues.apache.org/jira/browse/FLINK-2608) as
issue
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565600#comment-15565600
]
ASF GitHub Bot commented on FLINK-3706:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565707#comment-15565707
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2609#discussion_r82814608
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -581,6 +581,62 @@ class JobManager(
)
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2594
---
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-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4738.
Resolution: Fixed
Added via 8c656d9252fd01ea82c75ff1ea830b110f68f8a9
> Port TaskManager logic to
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565759#comment-15565759
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565850#comment-15565850
]
ASF GitHub Bot commented on FLINK-4793:
---
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/2621#discussion_r82828661
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java
---
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565554#comment-15565554
]
ASF GitHub Bot commented on FLINK-4800:
---
Github user kl0u commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2620
Nice one, +1 to merge
---
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
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2425
I'll take a look.
---
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,
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565625#comment-15565625
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565660#comment-15565660
]
ASF GitHub Bot commented on FLINK-4793:
---
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/2621#discussion_r82812545
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java
---
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565744#comment-15565744
]
ASF GitHub Bot commented on FLINK-4771:
---
Github user qingdao81 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565575#comment-15565575
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565608#comment-15565608
]
ASF GitHub Bot commented on FLINK-4793:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2621#discussion_r82808001
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java
---
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565605#comment-15565605
]
ASF GitHub Bot commented on FLINK-4793:
---
Github user StephanEwen commented on a diff in the pull
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2622#discussion_r82810425
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -670,11 +684,13 @@ public void run() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2622#discussion_r82809975
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -599,15 +602,23 @@ protected void runWithArgs(String[] args, String
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2622#discussion_r82809384
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -599,15 +602,23 @@ protected void runWithArgs(String[] args, String
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565667#comment-15565667
]
ASF GitHub Bot commented on FLINK-3706:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565666#comment-15565666
]
ASF GitHub Bot commented on FLINK-3706:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565665#comment-15565665
]
ASF GitHub Bot commented on FLINK-3706:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2622#discussion_r82809706
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -621,13 +632,16 @@ protected static void sendOutput() {
Github user qingdao81 commented on the issue:
https://github.com/apache/flink/pull/2612
Thanks for the review @fhueske I implemented the changes you requested. Not
sure if the Codec enum in AvroOutputFormat is the best solution because its an
additional wrapper around the avro
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2623
Could you include a simple test to verify that this does in fact fix the
issue?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565842#comment-15565842
]
ASF GitHub Bot commented on FLINK-4793:
---
Github user StephanEwen commented on a diff in the pull
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2622
We should backport the fix to the `release-1.1` branch as well.
---
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
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2621#discussion_r82827707
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java
---
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565590#comment-15565590
]
ASF GitHub Bot commented on FLINK-4799:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-959.
--
Resolution: Invalid
> Automated bare-metal deployment of FLINK on Amazon EC2 and OpenStack
[
https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565664#comment-15565664
]
ASF GitHub Bot commented on FLINK-3706:
---
Github user mxm 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/2618#discussion_r82813612
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -107,10 +113,10 @@
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2609#discussion_r82805867
--- Diff: docs/setup/cli.md ---
@@ -113,6 +113,10 @@ The command line can be used to
./bin/flink cancel
+- Cancel a job
[
https://issues.apache.org/jira/browse/FLINK-4717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565708#comment-15565708
]
ASF GitHub Bot commented on FLINK-4717:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565739#comment-15565739
]
ASF GitHub Bot commented on FLINK-4738:
---
Github user tillrohrmann closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565615#comment-15565615
]
Robert Metzger commented on FLINK-959:
--
No, this issue is very outdated. I'll close it.
> Automated
[
https://issues.apache.org/jira/browse/FLINK-4746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565115#comment-15565115
]
ASF GitHub Bot commented on FLINK-4746:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2599
Rebasing this PR. If Travis gives green light, then I'll merge the PR.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565541#comment-15565541
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565533#comment-15565533
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565526#comment-15565526
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565542#comment-15565542
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565527#comment-15565527
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565535#comment-15565535
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565532#comment-15565532
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565529#comment-15565529
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565540#comment-15565540
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565534#comment-15565534
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565543#comment-15565543
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565536#comment-15565536
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565537#comment-15565537
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565528#comment-15565528
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565538#comment-15565538
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565530#comment-15565530
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565531#comment-15565531
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565539#comment-15565539
]
ASF GitHub Bot commented on FLINK-4512:
---
Github user tillrohrmann commented on a diff in the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376002
In
[
https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565424#comment-15565424
]
Robert Metzger commented on FLINK-3704:
---
So this is a bug in curator, not reporting errors
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565447#comment-15565447
]
Timo Walther commented on FLINK-4743:
-
Power can basically express both. I would just implement power
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2620
Thank you very much for this! Just tested this on OS X and it works as
expected when packaging and cleaning. +1 to merge this.
---
If your project is set up for it, you can reply to this email and have
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82777602
--- Diff: flink-runtime-web/web-dashboard/app/scripts/index.coffee ---
@@ -29,8 +29,8 @@ angular.module('flinkApp', ['ui.router', 'angularMoment'])
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82796670
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java
---
@@ -18,23 +18,105 @@
package
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82786136
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java
---
@@ -233,68 +229,90 @@ public int
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82799818
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/messages/JobManagerMessages.scala
---
@@ -467,8 +467,11 @@ object JobManagerMessages {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82778103
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -219,33 +245,9 @@ public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82783495
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java
---
@@ -256,29 +306,51 @@ public boolean
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82778433
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -282,29 +279,71 @@ public boolean
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82781804
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
---
@@ -51,9 +57,11 @@
/** States of the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82796870
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java
---
@@ -43,24 +125,62 @@
* @return The
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82781688
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java
---
@@ -18,44 +18,243 @@
package
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82787864
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointLoader.java
---
@@ -48,13 +48,12 @@
public static
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82778557
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -282,29 +279,71 @@ public boolean
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82776861
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java ---
@@ -637,20 +637,25 @@ protected int savepoint(String[] args) {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82797030
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java
---
@@ -43,24 +125,62 @@
* @return The
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82784524
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java
---
@@ -64,9 +62,9 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82784661
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java
---
@@ -64,9 +62,9 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2608#discussion_r82782971
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java
---
@@ -51,9 +57,11 @@
/** States of the
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2620
[FLINK-4799] re-add 'build-target' symlink on Unix systems
This adds back the link 'build-target' which points to the final build
assembly in 'flink-dist/target/...'. The link is only created on Unix
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2618
Thanks @rmetzger ! This is the issue:
https://issues.apache.org/jira/browse/FLINK-4800
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
Kostas Kloudas created FLINK-4800:
-
Summary: Refactor the ContinuousFileMonitoringFunction code and
the related tests.
Key: FLINK-4800
URL: https://issues.apache.org/jira/browse/FLINK-4800
Project:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2620
+1 to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565515#comment-15565515
]
ASF GitHub Bot commented on FLINK-4799:
---
Github user rmetzger commented on the issue:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376219
In
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376443
In
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/commit/6731ec1e48d0a0092dd2330adda73bcf37fda8d7#commitcomment-19376877
In
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565341#comment-15565341
]
Timo Walther commented on FLINK-4793:
-
I found another bug that I will fix in a upcoming PR. Now this
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/2621
[FLINK-4793] [types] Improve lambda constructor reference handling
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2622
[FLINK-3706] Fix YARN test instability
The most important change in this commit is that the `YarnTestBase.Runner`
doesn't do `try {} catch (Throwable t) { fail(t); }` anymore, which doesn't
lead
[
https://issues.apache.org/jira/browse/FLINK-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15565337#comment-15565337
]
Timo Walther commented on FLINK-4793:
-
[~tdunning] which Flink version are you using? Your issue might
1 - 100 of 188 matches
Mail list logo