[
https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901098#comment-15901098
]
ASF GitHub Bot commented on FLINK-5635:
---
GitHub user patricklucas opened a pull request:
Github user patricklucas commented on the issue:
https://github.com/apache/flink/pull/3493
I've opened my PR, #3494.
---
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 patricklucas opened a pull request:
https://github.com/apache/flink/pull/3494
[FLINK-5635] [docker] Improve Docker tooling
This PR supplants and extends @jgrier's #3205, updating with master, fixing
merge conflicts, making use of the new `start-foreground` param, and
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-5874:
-
Assignee: Kostas Kloudas
> Reject arrays as keys in DataStream API to avoid inconsistent
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901094#comment-15901094
]
ASF GitHub Bot commented on FLINK-4460:
---
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/3484#discussion_r104895136
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -333,32 +356,41 @@ public void addEdge(Integer
[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901090#comment-15901090
]
ASF GitHub Bot commented on FLINK-3026:
---
Github user patricklucas commented on the issue:
Github user patricklucas commented on the issue:
https://github.com/apache/flink/pull/3493
I took a look through the [top official
Docker](https://hub.docker.com/explore/) repos to see what variants they
provide, and the first-listed Java-based project is
[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901071#comment-15901071
]
ASF GitHub Bot commented on FLINK-3026:
---
Github user iemejia commented on the issue:
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/3493
Cool ! Just ping me when you are done and I will rebase to finish the clean
ups, I am going to start contacting the docker people to see what else do we
need and continue to work in the ubuntu
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3492
Thanks for this PR and the fixes on top of it Patrick. If there are no
objections, I would like to merge this. Since the commits are still attributed
to Greg, I think it's fine to merge this instead of
[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901052#comment-15901052
]
ASF GitHub Bot commented on FLINK-3026:
---
Github user patricklucas commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901053#comment-15901053
]
Ufuk Celebi commented on FLINK-5780:
[~dawidwys] Thanks for picking this up.
> Extend ConfigOption
Github user patricklucas commented on the issue:
https://github.com/apache/flink/pull/3493
Thanks @iemejia. I have a branch building on @jgrier's commits from #3205
which I hope to push before any further changes are made. Hopefully I can get
it done today.
---
If your project is
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3366
Thanks for addressing the comments. I added small refactorings on top of
your changes here: (https://github.com/uce/flink/tree/watermarks) and will
merge this later today. Thanks again for this
[
https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901049#comment-15901049
]
ASF GitHub Bot commented on FLINK-3427:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5995:
---
Description:
When use OperatorState and creating the ListStateDescriptor with a
TypeInformation，I
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/3493
R: @greghogan
cc: @jgrier @patricklucas
---
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
[
https://issues.apache.org/jira/browse/FLINK-3026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901042#comment-15901042
]
ASF GitHub Bot commented on FLINK-3026:
---
Github user iemejia commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901040#comment-15901040
]
Ufuk Celebi commented on FLINK-5985:
I fully agree that this whole UID business is very tricky and
[
https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrick Lucas reassigned FLINK-5635:
Assignee: Patrick Lucas (was: Jamie Grier)
> Improve Docker tooling to make it easier to
Github user patricklucas commented on the issue:
https://github.com/apache/flink/pull/3204
I vote to close this issue since #3492 has been merged/FLINK-4326 has been
resolved.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901032#comment-15901032
]
Ufuk Celebi commented on FLINK-5996:
Just to understand this correctly, eventually the JM recovers
[
https://issues.apache.org/jira/browse/FLINK-5634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901025#comment-15901025
]
ASF GitHub Bot commented on FLINK-5634:
---
Github user patricklucas commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrick Lucas reassigned FLINK-4326:
Assignee: Greg Hogan
> Flink start-up scripts should optionally start services on the
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Patrick Lucas resolved FLINK-4326.
--
Resolution: Fixed
> Flink start-up scripts should optionally start services on the foreground
>
[
https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-5995:
--
Assignee: sunjincheng
> Get a Exception when creating the ListStateDescriptor with a
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104883119
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedNonPartitionedProcessingOverProcessFunction.scala
sunjincheng created FLINK-5995:
--
Summary: Get a Exception when creating the ListStateDescriptor
with a TypeInformation
Key: FLINK-5995
URL: https://issues.apache.org/jira/browse/FLINK-5995
Project:
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901008#comment-15901008
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/3491
HI, @fhueske Thanks a lot for your review. I had updated the PR according
to your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901014#comment-15901014
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user sunjincheng121 commented on the issue:
Gyula Fora created FLINK-5996:
-
Summary: Jobmanager HA should not crash on lost ZK node
Key: FLINK-5996
URL: https://issues.apache.org/jira/browse/FLINK-5996
Project: Flink
Issue Type: Bug
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3351
---
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-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-5780:
---
Assignee: Dawid Wysakowicz
> Extend ConfigOption with descriptions
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3492
---
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-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-5781:
---
Assignee: Dawid Wysakowicz
> Generation HTML from ConfigOption
>
[
https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-5779:
---
Assignee: Dawid Wysakowicz
> Auto generate configuration docs
>
[
https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901005#comment-15901005
]
Dawid Wysakowicz commented on FLINK-5779:
-
If nobody is currently working on this one, I will take
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r104880615
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
---
@@ -85,6 +86,7 @@
private Set sources;
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900998#comment-15900998
]
ASF GitHub Bot commented on FLINK-4326:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900999#comment-15900999
]
ASF GitHub Bot commented on FLINK-4326:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900996#comment-15900996
]
ASF GitHub Bot commented on FLINK-4460:
---
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/3484#discussion_r104881269
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
---
@@ -60,6 +60,7 @@
import
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900995#comment-15900995
]
Gyula Fora commented on FLINK-5985:
---
even something as simple as stream.filter(event -> true) requires a
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900991#comment-15900991
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900988#comment-15900988
]
ASF GitHub Bot commented on FLINK-4460:
---
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/3484#discussion_r104880412
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
---
@@ -416,4 +418,35 @@ private
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900987#comment-15900987
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user huawei-flink commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900986#comment-15900986
]
ASF GitHub Bot commented on FLINK-4326:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-5994:
Affects Version/s: 1.2.0
> Add Janino to flink-table JAR file
> --
Timo Walther created FLINK-5994:
---
Summary: Add Janino to flink-table JAR file
Key: FLINK-5994
URL: https://issues.apache.org/jira/browse/FLINK-5994
Project: Flink
Issue Type: Bug
Github user huawei-flink commented on the issue:
https://github.com/apache/flink/pull/3459
@fhueske @wuchong @twalthr can you please take a look to see if you can
merge this. Thanks
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900985#comment-15900985
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104879651
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedNonPartitionedProcessingOverProcessFunction.scala
---
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900982#comment-15900982
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104879219
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedNonPartitionedProcessingOverProcessFunction.scala
[
https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900981#comment-15900981
]
ASF GitHub Bot commented on FLINK-4326:
---
GitHub user patricklucas opened a pull request:
Ufuk Celebi created FLINK-5993:
--
Summary: Add section about Azure deployment
Key: FLINK-5993
URL: https://issues.apache.org/jira/browse/FLINK-5993
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900980#comment-15900980
]
Gyula Fora commented on FLINK-5985:
---
It should be possible to set it for *only* the stateful ones but it
GitHub user patricklucas opened a pull request:
https://github.com/apache/flink/pull/3492
[FLINK-4326] [scripts] Flink foreground services
This PR consists of @greghogan's commits from #3351 with the merge
conflicts fixed.
If merged, this PR supplants #3351, which can be
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900973#comment-15900973
]
Ufuk Celebi commented on FLINK-5985:
It should be possible to change the topology if you set the UIDs
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900964#comment-15900964
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900963#comment-15900963
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900962#comment-15900962
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900965#comment-15900965
]
ASF GitHub Bot commented on FLINK-5804:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104874462
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -143,10 +143,18 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104874829
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedNonPartitionedProcessingOverProcessFunction.scala
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104875937
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -94,15 +94,18 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3491#discussion_r104875504
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedNonPartitionedProcessingOverProcessFunction.scala
---
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900957#comment-15900957
]
sunjincheng commented on FLINK-5990:
Yes, [~fhueske] It is difficult to deal with disorderly problem.
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900943#comment-15900943
]
Fabian Hueske commented on FLINK-5990:
--
Actually, we decided to not cover this case because it does
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5656.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900935#comment-15900935
]
Fabian Hueske commented on FLINK-5656:
--
You're right [~sunjincheng121]. I'll close it.
> Add
[
https://issues.apache.org/jira/browse/FLINK-5656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900776#comment-15900776
]
sunjincheng edited comment on FLINK-5656 at 3/8/17 8:55 AM:
Hi, [~fhueske] I
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900933#comment-15900933
]
ASF GitHub Bot commented on FLINK-5134:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/3455
@StephanEwen , thank you for reviews and suggestions.
I would add the related tests for `JobGraphGenerator` and try to cover
different chained modes.
BTW, I will also remove the
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900925#comment-15900925
]
sunjincheng edited comment on FLINK-5658 at 3/8/17 8:50 AM:
HI [~Yuhong_kyo]
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900925#comment-15900925
]
sunjincheng edited comment on FLINK-5658 at 3/8/17 8:42 AM:
HI [~Yuhong_kyo]
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900925#comment-15900925
]
sunjincheng commented on FLINK-5658:
HI [~Yuhong_kyo] Let me share some ideas about this.
First of
[
https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900921#comment-15900921
]
ASF GitHub Bot commented on FLINK-5903:
---
Github user WangTaoTheTonic commented on the issue:
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3408
I move the initiallization of this config to constructor of cluster
descripter and restore the deleted configuration setting.
Please check if we are good with the usage of `YARN_VCORES`.
[
https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900918#comment-15900918
]
ASF GitHub Bot commented on FLINK-5903:
---
Github user WangTaoTheTonic commented on a diff in the pull
Github user WangTaoTheTonic commented on a diff in the pull request:
https://github.com/apache/flink/pull/3408#discussion_r104867661
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -537,7 +543,6 @@ public YarnClusterClient
Zohar Mizrahi created FLINK-5992:
Summary: Enable file registration at distributed cache in stream
execution environment
Key: FLINK-5992
URL: https://issues.apache.org/jira/browse/FLINK-5992
Project:
Github user WangTaoTheTonic commented on a diff in the pull request:
https://github.com/apache/flink/pull/3414#discussion_r104862993
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -306,12 +308,16 @@ public AbstractYarnClusterDescriptor
[
https://issues.apache.org/jira/browse/FLINK-5904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900884#comment-15900884
]
ASF GitHub Bot commented on FLINK-5904:
---
Github user WangTaoTheTonic commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900883#comment-15900883
]
ASF GitHub Bot commented on FLINK-5903:
---
Github user WangTaoTheTonic commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900882#comment-15900882
]
ASF GitHub Bot commented on FLINK-5904:
---
Github user tillrohrmann commented on a diff in the pull
Github user WangTaoTheTonic commented on a diff in the pull request:
https://github.com/apache/flink/pull/3408#discussion_r104862308
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -317,6 +319,10 @@ public AbstractYarnClusterDescriptor
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3414#discussion_r104862218
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -306,12 +308,16 @@ public AbstractYarnClusterDescriptor
[
https://issues.apache.org/jira/browse/FLINK-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900880#comment-15900880
]
ASF GitHub Bot commented on FLINK-5903:
---
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/3408#discussion_r104862066
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java ---
@@ -537,7 +543,6 @@ public YarnClusterClient createCluster(
301 - 393 of 393 matches
Mail list logo
