GitHub user guochuanzhi opened a pull request:
https://github.com/apache/flink/pull/1459
Release 0.10
flink test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/flink release-0.10
Alternatively you can review and apply the
radu created FLINK-3176:
---
Summary: Window Apply Website Example
Key: FLINK-3176
URL: https://issues.apache.org/jira/browse/FLINK-3176
Project: Flink
Issue Type: Improvement
Components: websit
[
https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058901#comment-15058901
]
ASF GitHub Bot commented on FLINK-3172:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1458
[FLINK-3172] Specify JobManager port in HA mode
- Adds support for job manager port configuration for standalone HA clusters
- Re-uses everthing introduced in #1416, but moves the `retry` method to
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2882.
Resolution: Fixed
Fix Version/s: 1.0.0
Fixed with b9ce8abb1bfc0cbc43e8c1800b4aeb7aee7c6e62
>
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3147.
Resolution: Fixed
Fix Version/s: 0.10.2
1.0.0
Fixed for 1.0 with 19cbc787b
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058749#comment-15058749
]
ASF GitHub Bot commented on FLINK-2882:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058748#comment-15058748
]
ASF GitHub Bot commented on FLINK-3147:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1455
---
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 enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1442
---
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 enab
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1455#issuecomment-164880926
Looks good. 1+ for removing `toShortString` in a separate issue.
I'll merge this PR.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058690#comment-15058690
]
ASF GitHub Bot commented on FLINK-2882:
---
Github user fhueske commented on the pull r
Github user ndimiduk commented on the pull request:
https://github.com/apache/flink/pull/1442#issuecomment-164882643
Should I post a second PR for merging to 0.10-SNAPSHOT, or will you handle
cherry-pick to active release branches? Thanks a lot @fhueske !
---
If your project is set u
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1442#issuecomment-164883472
I will cherry-pick the commit over to the 0.10 branch. Thanks @ndimiduk!
---
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-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058705#comment-15058705
]
ASF GitHub Bot commented on FLINK-3147:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058702#comment-15058702
]
ASF GitHub Bot commented on FLINK-3147:
---
Github user ndimiduk commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1442#issuecomment-164880422
Thanks for the PR! I'll merge it.
---
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 no
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058687#comment-15058687
]
ASF GitHub Bot commented on FLINK-3147:
---
Github user fhueske commented on the pull r
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1442#issuecomment-164828376
+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
e
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058337#comment-15058337
]
ASF GitHub Bot commented on FLINK-3147:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058304#comment-15058304
]
ASF GitHub Bot commented on FLINK-2882:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1455#issuecomment-164824368
@tillrohrmann There exists StringUtilsTest with small test.
One of the TravisCI errors was a timeout and the other killed by the
watchdog. Are timeouts being r
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058260#comment-15058260
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47658721
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -155,12 +156,14 @@ class YarnJobManager(
rmClientOption for
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058244#comment-15058244
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058250#comment-15058250
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47656932
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -155,12 +156,14 @@ class YarnJobManager(
rmClientOptio
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47656011
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -155,12 +156,14 @@ class YarnJobManager(
rmClientOption for
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058223#comment-15058223
]
ASF GitHub Bot commented on FLINK-2882:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1455#issuecomment-164802103
Yes, that's good to remove. I pointed that out as well when Greg opened the
initial issue.
We can either do it as part of this PR or I can do it as a follow up.
--
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058218#comment-15058218
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47651966
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -155,12 +156,14 @@ class YarnJobManager(
rmClientOptio
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058187#comment-15058187
]
Stephan Ewen commented on FLINK-3169:
-
I guess the current {{Key}} types that do not b
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1457#issuecomment-164794316
Personal Travis is green: https://travis-ci.org/mjsax/flink/builds/96973608
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Matthias J. Sax created FLINK-3175:
--
Summary: KafkaITCase.testOffsetAutocommitTest
Key: FLINK-3175
URL: https://issues.apache.org/jira/browse/FLINK-3175
Project: Flink
Issue Type: Bug
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1455#issuecomment-164790091
Thanks for your contribution @greghogan. Efficiency improvements look
really good. The test failures seem to be unrelated.
Would be great if you could add a
Aljoscha Krettek created FLINK-3174:
---
Summary: Add merging WindowAssigner
Key: FLINK-3174
URL: https://issues.apache.org/jira/browse/FLINK-3174
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058174#comment-15058174
]
ASF GitHub Bot commented on FLINK-2882:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058176#comment-15058176
]
Chesnay Schepler commented on FLINK-3169:
-
FloatValue and DoubleValue don't suppor
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1455#issuecomment-164790880
Looks very good.
I am wondering if we can get rid of the toShortString method. What is that
one actually used for?
---
If your project is set up for it, yo
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058169#comment-15058169
]
ASF GitHub Bot commented on FLINK-2882:
---
Github user tillrohrmann commented on the p
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47642649
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
}
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1450#issuecomment-164783687
Thanks for the comments. I've updated the pull request.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058149#comment-15058149
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058142#comment-15058142
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1416#discussion_r47642522
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterBase.scala ---
@@ -120,18 +125,79 @@ abstract class ApplicationMasterBase {
[
https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058140#comment-15058140
]
ASF GitHub Bot commented on FLINK-3074:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058137#comment-15058137
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47642396
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
}
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058132#comment-15058132
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-164781638
Thank you for your patch. I've added it to the PR.
Regarding your question: I would keep name changes separate from this PR.
Once this one is merged, we can sta
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058113#comment-15058113
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-164777618
I addressed all issues you've mentioned and rebased the code to the current
master. I would like to merge this soon!
---
If your project is set up for it, you can repl
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/1457
Set current class loader to user-class loader and disable class
initialization.
This PR fixes class loading issues with regard to Clojure. It is required
to execute a Clojure example via `bin/flink r
[
https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058071#comment-15058071
]
Gyula Fora commented on FLINK-3168:
---
Thanks, that's exactly what I am doing, that's why
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-164768159
> Are inner classes of a class tagged as PublicInterface also marked as
public/stable?
Yes!
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058068#comment-15058068
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058054#comment-15058054
]
Robert Metzger commented on FLINK-3168:
---
As a workaround for now, you could use the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-164764484
I didn't make `MemorySegment` a public API. Lets declare it in the pull
request as stable.
I decided to mark `XORShiftRandom` and `NumberSequenceIterator` as stable
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058045#comment-15058045
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058040#comment-15058040
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-164762014
Thank you all for the comments.
I'll rename the interfaces to `@Public` and `@Experimental`.
I'll keep the annotation on the `ConfigConstants` class to ensur
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1456
[FLINK-3173] Bump httpclient and httpcore to version 4.2.6 to solve bug in
http client
The bug prevents the `TwitterStream` example from working.
You can merge this pull request into a Git rep
[
https://issues.apache.org/jira/browse/FLINK-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058023#comment-15058023
]
ASF GitHub Bot commented on FLINK-3173:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058021#comment-15058021
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058019#comment-15058019
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058020#comment-15058020
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47632308
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationClient.scala ---
@@ -29,6 +31,7 @@ import org.apache.flink.runtime.akka.AkkaUtils
import
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47632302
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
}
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47632315
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
}
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15058018#comment-15058018
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-3169:
---
Assignee: Chesnay Schepler
> Drop {{Key}} type from Record Data Model
> -
Till Rohrmann created FLINK-3173:
Summary: Bump org.apache.httpcomponents.httpclient version to 4.2.6
Key: FLINK-3173
URL: https://issues.apache.org/jira/browse/FLINK-3173
Project: Flink
Issu
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47632106
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
}
[
https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057957#comment-15057957
]
ASF GitHub Bot commented on FLINK-2882:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1455
[FLINK-2882] [core] Improve performance of string conversions
Memoize string representations of AbstractID.
Use lookup table for byte-to-hex conversion in StringUtils.
You can merge this
[
https://issues.apache.org/jira/browse/FLINK-3130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3130:
---
Assignee: (was: Ufuk Celebi)
> Visualize throughput of tasks
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057861#comment-15057861
]
Ufuk Celebi commented on FLINK-3172:
Thanks for the tip. I hadn't looked into it yeste
[
https://issues.apache.org/jira/browse/FLINK-3165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057854#comment-15057854
]
ASF GitHub Bot commented on FLINK-3165:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/1454
[FLINK-3165] [py] Windows OS support
This PR allows the usage of the Python API on the Windows Operating System.
Essentially, 4 changes were made:
* pyflinkX.bat start scripts were added
[
https://issues.apache.org/jira/browse/FLINK-766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057853#comment-15057853
]
Stephan Ewen commented on FLINK-766:
This particular one has not seen recent activity.
[
https://issues.apache.org/jira/browse/FLINK-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3171.
---
> Consolidate zoo of wrapper classes for input/output-stream to
> data-input/output-view
> --
[
https://issues.apache.org/jira/browse/FLINK-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3171.
-
Resolution: Fixed
Fixed via d9a061c674a0e64e6ec419ff614347ecc08d4eb6
> Consolidate zoo of wrapper
[
https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057698#comment-15057698
]
Till Rohrmann commented on FLINK-3172:
--
Can't we use the identical approach as it was
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1450#issuecomment-164696473
I've tested the change on a cluster and everything is working fine.
I had some minor comments.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057689#comment-15057689
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057687#comment-15057687
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47612925
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057683#comment-15057683
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47612509
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47611847
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationClient.scala ---
@@ -29,6 +31,7 @@ import org.apache.flink.runtime.akka.AkkaUtils
i
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057676#comment-15057676
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1450#discussion_r47611363
--- Diff:
flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala ---
@@ -754,6 +538,243 @@ class YarnJobManager(
memoryLimit
[
https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15057656#comment-15057656
]
ASF GitHub Bot commented on FLINK-3134:
---
Github user rmetzger commented on a diff in
94 matches
Mail list logo
