[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15653177#comment-15653177
]
Xiaogang Shi commented on FLINK-5023:
-
[~aljoscha] [~StephanEwen] I have updated the P
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15653044#comment-15653044
]
Tzu-Li (Gordon) Tai commented on FLINK-5017:
Yes I think that's better than {{
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652901#comment-15652901
]
Xiaogang Shi commented on FLINK-5024:
-
I am very poor at English :( But i think "Simpl
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652887#comment-15652887
]
Jark Wu commented on FLINK-4692:
Hi guys, I moved the sliding window into FLINK-5047. And
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-4692:
---
Summary: Add tumbling group-windows for batch tables (was: Add tumbling
and sliding group-windows for batch t
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-4692:
---
Description: Add Tumble group-windows for batch tables as described in
[FLIP-11|https://cwiki.apache.org/confl
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5047:
---
Summary: Add sliding group-windows for batch tables (was: Add Sliding
group-windows for batch tables)
> Add
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5047:
---
Description:
Add Slide group-windows for batch tables as described in
[FLIP-11|https://cwiki.apache.org/confl
[
https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5047:
---
Summary: Add Sliding group-windows for batch tables (was: Add tumbling
group-windows for batch tables)
> Add
Jark Wu created FLINK-5047:
--
Summary: Add tumbling group-windows for batch tables
Key: FLINK-5047
URL: https://issues.apache.org/jira/browse/FLINK-5047
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652869#comment-15652869
]
Jark Wu commented on FLINK-4692:
Yes. I agree to move the sliding window to a separate iss
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Sounds great. Thanks Fabian .
---
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 wi
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652697#comment-15652697
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r87314969
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableEnvironment.scala
---
@@ -152,21 +153,40 @@ abstract class TableE
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652654#comment-15652654
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652552#comment-15652552
]
ASF GitHub Bot commented on FLINK-5046:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2779
[FLINK-5046] [tdd] Preserialize TaskDeploymentDescriptor information
In order to speed up the serialization of the TaskDeploymentDescriptor we
can pre serialize
all information which stays
Till Rohrmann created FLINK-5046:
Summary: Avoid redundant serialization when creating the
TaskDeploymentDescriptor
Key: FLINK-5046
URL: https://issues.apache.org/jira/browse/FLINK-5046
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652469#comment-15652469
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2653
Hi @wuchong, I did a first high-level pass over the PR. From what I've seen
it looks really good and I do not expect that major changes are necessary ð.
Will do a more thorough review in the next
Github user tfournier314 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2740#discussion_r87295380
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StringIndexer.scala
---
@@ -0,0 +1,108 @@
+package org.apache.fl
[
https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652290#comment-15652290
]
ASF GitHub Bot commented on FLINK-4964:
---
Github user tfournier314 commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652272#comment-15652272
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2425
@StephanEwen @mxm - Could you please review the proposed change and let me
know if you are okay with it.
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-4648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4648:
-
Assignee: Ivan Mushketyk
> Implement bipartite graph generators
> ---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2774
Thanks for the fix @BorisOsipov
+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 fea
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2775
Thanks for the fix!
+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
Ufuk Celebi created FLINK-5045:
--
Summary: Latency markers emitted after output buffer pool destroyed
Key: FLINK-5045
URL: https://issues.apache.org/jira/browse/FLINK-5045
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652165#comment-15652165
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2448
@rmetzger @iampeter
I've rebased the code and updated it according to your suggestions.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652132#comment-15652132
]
Fabian Hueske commented on FLINK-3848:
--
Yes, you're both right. The optimizer should
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652113#comment-15652113
]
Fabian Hueske commented on FLINK-3613:
--
Hi [~anmu],
this issue proposes to add more
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652063#comment-15652063
]
Fabian Hueske commented on FLINK-4692:
--
Hi [~jark], I see two ways to implement slidi
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15652028#comment-15652028
]
Fabian Hueske commented on FLINK-4832:
--
It is true that Flink does not support {{null
Github user cresny commented on the issue:
https://github.com/apache/flink/pull/2288
@uce I finally got around to fixing this. Regarding your above comments:
- I think we got the "flattening" concern backwards. What I meant and
wanted to avoid was to move all files into single
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2776
Good catches @wuchong!
+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
enabl
[
https://issues.apache.org/jira/browse/FLINK-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5038.
---
> Errors in the "cancelTask" method prevent closeables from being closed early
> -
[
https://issues.apache.org/jira/browse/FLINK-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5038.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 616c4f5e483f0fd81ce2db05e911f01f15a0b583
- 1.1.4 via 29
Stefan Richter created FLINK-5044:
-
Summary: Converting operator and function state from Flink 1.1 for
all changed operators in 1.2
Key: FLINK-5044
URL: https://issues.apache.org/jira/browse/FLINK-5044
Stefan Richter created FLINK-5043:
-
Summary: Converting keyed state from Flink 1.1 backend
implementations to their new counterparts in 1.2
Key: FLINK-5043
URL: https://issues.apache.org/jira/browse/FLINK-5043
Stefan Richter created FLINK-5042:
-
Summary: Convert old savepoints to new savepoints
Key: FLINK-5042
URL: https://issues.apache.org/jira/browse/FLINK-5042
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-5041:
-
Summary: Implement savepoint backwards compatibility 1.1 -> 1.2
Key: FLINK-5041
URL: https://issues.apache.org/jira/browse/FLINK-5041
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651848#comment-15651848
]
ASF GitHub Bot commented on FLINK-4946:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2708
Thanks @greghogan! The changes look good.
+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 ha
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651812#comment-15651812
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2564
Try switching to `ExecutionEnvironment.createCollectionsEnvironment()`.
---
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 proje
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651797#comment-15651797
]
ASF GitHub Bot commented on FLINK-4521:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2431
Hi @iampeter
I've fixed the code according to your review.
Could you please review it again?
Best regards,
Ivan.
---
If your project is set up for it, you can reply to this em
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651760#comment-15651760
]
ASF GitHub Bot commented on FLINK-2254:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2564
New **gelly** tests failed with errors like:
> Caused by: java.io.IOException: Insufficient number of network buffers:
required 32, but only 3 available. The total number of network buffers
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651634#comment-15651634
]
ASF GitHub Bot commented on FLINK-4946:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2708
@mxm I pushed a new commit that is working in YARN with recursive
directories. The issue looks to have been that YARN was copying files
recursively but the Java classpath can only contain simple wi
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/2778
[hotfix] fix duplicate "ms" time unit
as in "Restart with fixed delay (1 ms ms)." in the web interface under
"Max. number of execution retries"
(org.apache.flink.api.common.time.Time already p
Ufuk Celebi created FLINK-5040:
--
Summary: Set correct input channel types with eager scheduling
Key: FLINK-5040
URL: https://issues.apache.org/jira/browse/FLINK-5040
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651319#comment-15651319
]
Anton Solovev commented on FLINK-3848:
--
So do we need to create an another Projectabl
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651203#comment-15651203
]
Anton Mushin edited comment on FLINK-3613 at 11/9/16 3:38 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651203#comment-15651203
]
Anton Mushin commented on FLINK-3613:
-
Hello everyone.
Do FLINK-4604 extends this issu
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r87202604
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -675,7 +756,69 @@ object ALS {
collecto
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r87199446
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -273,6 +308,14 @@ object ALS {
val defaultVal
[
https://issues.apache.org/jira/browse/FLINK-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651166#comment-15651166
]
ASF GitHub Bot commented on FLINK-5037:
---
Github user StefanRRichter closed the pull
[
https://issues.apache.org/jira/browse/FLINK-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-5037.
-
Resolution: Fixed
Fix Version/s: 1.2.0
> Instability in AbstractUdfStreamOperatorLifecycleT
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/2777
---
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-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651161#comment-15651161
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651159#comment-15651159
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651160#comment-15651160
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651162#comment-15651162
]
ASF GitHub Bot commented on FLINK-4613:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r87195483
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -156,6 +171,26 @@ class ALS extends Predictor[ALS] {
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2542#discussion_r87201508
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala
---
@@ -535,8 +581,17 @@ object ALS {
itemOut: DataS
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2777
Thanks for the fix! ð Could you please close the issue and this 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 project
[
https://issues.apache.org/jira/browse/FLINK-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651140#comment-15651140
]
ASF GitHub Bot commented on FLINK-5037:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87201308
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobClient.java ---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651106#comment-15651106
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user aljoscha commented on a diff in
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2729#discussion_r87201177
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ScalaObjectChecker.java ---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Softwa
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2729#discussion_r87202166
--- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java
---
@@ -181,7 +181,17 @@ protected void fillInType(TypeInformation typeInfo)
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651101#comment-15651101
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651100#comment-15651100
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user StefanRRichter commented on a d
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87050071
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java ---
@@ -207,14 +207,23 @@ public JobExecutionResult
executePlanWithJar
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87052872
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87098055
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/JobClientTest.java
---
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache So
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87053310
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87176485
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87054735
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87175803
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobClient.java ---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Founda
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87052088
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87098367
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobClient.java ---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650979#comment-15650979
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651003#comment-15651003
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87098937
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -911,6 +912,24 @@ public JobExecutionResult execute() throw
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650995#comment-15650995
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651000#comment-15651000
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650975#comment-15650975
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87102646
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
---
@@ -485,6 +485,52 @@ abstract class FlinkMiniClus
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87052197
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650981#comment-15650981
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87104003
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorErrorITCase.java
---
@@ -91,11 +91,9 @@ public void testFaultyAccumula
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87098405
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobClient.java ---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Founda
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87100841
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java
---
@@ -333,4 +354,31 @@ protected boolean isClientConnected()
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87184404
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobClient.java ---
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Founda
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2732#discussion_r87053575
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/program/JobClientEager.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/FLINK-4272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15650998#comment-15650998
]
ASF GitHub Bot commented on FLINK-4272:
---
Github user tillrohrmann commented on a dif
1 - 100 of 188 matches
Mail list logo
