[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058260#comment-15058260 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058250#comment-15058250 ] ASF GitHub Bot commented on FLINK-3134: --- Github user rmetzger commented on a diff in the pull

[jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058337#comment-15058337 ] ASF GitHub Bot commented on FLINK-3147: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread rmetzger
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(

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058304#comment-15058304 ] ASF GitHub Bot commented on FLINK-2882: --- Github user greghogan commented on the pull request:

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058244#comment-15058244 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3147] HadoopOutputFormatBase should exp...

2015-12-15 Thread rmetzger
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

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread greghogan
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

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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

[GitHub] flink pull request: [FLINK-3147] HadoopOutputFormatBase should exp...

2015-12-15 Thread fhueske
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

[GitHub] flink pull request: [FLINK-3147] HadoopOutputFormatBase should exp...

2015-12-15 Thread ndimiduk
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

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058690#comment-15058690 ] ASF GitHub Bot commented on FLINK-2882: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058687#comment-15058687 ] ASF GitHub Bot commented on FLINK-3147: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3147] HadoopOutputFormatBase should exp...

2015-12-15 Thread fhueske
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

[jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058705#comment-15058705 ] ASF GitHub Bot commented on FLINK-3147: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058702#comment-15058702 ] ASF GitHub Bot commented on FLINK-3147: --- Github user ndimiduk commented on the pull request:

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057676#comment-15057676 ] ASF GitHub Bot commented on FLINK-3134: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread rmetzger
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

[jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode

2015-12-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057698#comment-15057698 ] Till Rohrmann commented on FLINK-3172: -- Can't we use the identical approach as it was implemented for

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057656#comment-15057656 ] ASF GitHub Bot commented on FLINK-3134: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread rmetzger
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

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057687#comment-15057687 ] ASF GitHub Bot commented on FLINK-3134: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread rmetzger
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

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057689#comment-15057689 ] ASF GitHub Bot commented on FLINK-3134: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread tillrohrmann
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

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread rmetzger
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

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057683#comment-15057683 ] ASF GitHub Bot commented on FLINK-3134: --- Github user rmetzger commented on a diff in the pull

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057957#comment-15057957 ] ASF GitHub Bot commented on FLINK-2882: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread greghogan
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

[jira] [Resolved] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view

2015-12-15 Thread Stephan Ewen (JIRA)
[ 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

[jira] [Updated] (FLINK-3130) Visualize throughput of tasks

2015-12-15 Thread Ufuk Celebi (JIRA)
[ 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 > - > >

[jira] [Commented] (FLINK-3165) [py] Add support for Windows OS

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057854#comment-15057854 ] ASF GitHub Bot commented on FLINK-3165: --- GitHub user zentol opened a pull request:

[jira] [Closed] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view

2015-12-15 Thread Stephan Ewen (JIRA)
[ 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 >

[jira] [Commented] (FLINK-766) Web interface progress monitoring for DataSources and DataSinks with splits

2015-12-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057853#comment-15057853 ] Stephan Ewen commented on FLINK-766: This particular one has not seen recent activity. [~uce] is

[GitHub] flink pull request: [FLINK-3165] [py] Windows OS support

2015-12-15 Thread zentol
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

[jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode

2015-12-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057861#comment-15057861 ] Ufuk Celebi commented on FLINK-3172: Thanks for the tip. I hadn't looked into it yesterday, but it

[jira] [Closed] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected

2015-12-15 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Closed] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread Fabian Hueske (JIRA)
[ 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

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread fhueske
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

[GitHub] flink pull request: [FLINK-3172] Specify JobManager port in HA mod...

2015-12-15 Thread uce
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

[jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058901#comment-15058901 ] ASF GitHub Bot commented on FLINK-3172: --- GitHub user uce opened a pull request:

[jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058748#comment-15058748 ] ASF GitHub Bot commented on FLINK-3147: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread asfgit
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

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058749#comment-15058749 ] ASF GitHub Bot commented on FLINK-2882: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: Release 0.10

2015-12-15 Thread guochuanzhi
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

[jira] [Created] (FLINK-3176) Window Apply Website Example

2015-12-15 Thread radu (JIRA)
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:

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058018#comment-15058018 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[jira] [Assigned] (FLINK-3169) Drop {{Key}} type from Record Data Model

2015-12-15 Thread Chesnay Schepler (JIRA)
[ 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 >

[GitHub] flink pull request: [FLINK-3173] Bump httpclient and httpcore to v...

2015-12-15 Thread tillrohrmann
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

[jira] [Commented] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058023#comment-15058023 ] ASF GitHub Bot commented on FLINK-3173: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-15 Thread rmetzger
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

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058040#comment-15058040 ] ASF GitHub Bot commented on FLINK-3093: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-15 Thread rmetzger
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

[jira] [Created] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6

2015-12-15 Thread Till Rohrmann (JIRA)
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

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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 }

[jira] [Commented] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml

2015-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058054#comment-15058054 ] Robert Metzger commented on FLINK-3168: --- As a workaround for now, you could use the

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-15 Thread rmetzger
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

[jira] [Commented] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml

2015-12-15 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058071#comment-15058071 ] Gyula Fora commented on FLINK-3168: --- Thanks, that's exactly what I am doing, that's why I thought that

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058045#comment-15058045 ] ASF GitHub Bot commented on FLINK-3093: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058021#comment-15058021 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058020#comment-15058020 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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 }

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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 }

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058019#comment-15058019 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058068#comment-15058068 ] ASF GitHub Bot commented on FLINK-3093: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: Set current class loader to user-class loader ...

2015-12-15 Thread mjsax
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

[GitHub] flink pull request: [FLINK-3147] HadoopOutputFormatBase should exp...

2015-12-15 Thread asfgit
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

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058113#comment-15058113 ] ASF GitHub Bot commented on FLINK-3093: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058140#comment-15058140 ] ASF GitHub Bot commented on FLINK-3074: --- Github user uce commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A...

2015-12-15 Thread uce
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 {

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058174#comment-15058174 ] ASF GitHub Bot commented on FLINK-2882: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058169#comment-15058169 ] ASF GitHub Bot commented on FLINK-2882: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-15 Thread rmetzger
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

[GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa...

2015-12-15 Thread rmetzger
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

[GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread mxm
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 }

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058137#comment-15058137 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058132#comment-15058132 ] ASF GitHub Bot commented on FLINK-3093: --- Github user rmetzger commented on the pull request:

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058142#comment-15058142 ] ASF GitHub Bot commented on FLINK-3134: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread StephanEwen
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,

[jira] [Commented] (FLINK-3169) Drop {{Key}} type from Record Data Model

2015-12-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058176#comment-15058176 ] Chesnay Schepler commented on FLINK-3169: - FloatValue and DoubleValue don't support key

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread tillrohrmann
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

[jira] [Created] (FLINK-3174) Add merging WindowAssigner

2015-12-15 Thread Aljoscha Krettek (JIRA)
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

[jira] [Created] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest

2015-12-15 Thread Matthias J. Sax (JIRA)
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] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager...

2015-12-15 Thread rmetzger
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(

[jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058218#comment-15058218 ] ASF GitHub Bot commented on FLINK-3134: --- Github user rmetzger commented on a diff in the pull

[jira] [Commented] (FLINK-2882) Improve performance of string conversions

2015-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058223#comment-15058223 ] ASF GitHub Bot commented on FLINK-2882: --- Github user uce commented on the pull request:

[GitHub] flink pull request: Set current class loader to user-class loader ...

2015-12-15 Thread mjsax
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

[jira] [Commented] (FLINK-3169) Drop {{Key}} type from Record Data Model

2015-12-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058187#comment-15058187 ] Stephan Ewen commented on FLINK-3169: - I guess the current {{Key}} types that do not become

[GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str...

2015-12-15 Thread uce
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.