[GitHub] flink pull request: [FLINK-2691] fix broken links to Python script...

2015-09-17 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1140#issuecomment-140979385 Nice catch! Looks good 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

[jira] [Commented] (FLINK-2691) Broken links to Python script on QuickStart doc

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14791638#comment-14791638 ] ASF GitHub Bot commented on FLINK-2691: --- Github user chiwanpark commented on the pull request:

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-09-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-141016403 Sorry for the late response, I didn't see this new pull request. The failed test is okay. The test is known for being unstable. --- If your project is set up

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

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

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2637] [api-breaking] [scala, types] Add...

2015-09-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39725082 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/IntegerTypeInfo.java --- @@ -18,15 +18,33 @@ package

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

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

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

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

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-09-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-141019208 For others who follow this PR, there was already some discussion on this change here: https://github.com/apache/flink/pull/1107 --- If your project is set up for it,

[GitHub] flink pull request: [FLINK-2691] fix broken links to Python script...

2015-09-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1140#issuecomment-141021568 Thanks for the patch! Will merge this. --- 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

[jira] [Commented] (FLINK-2691) Broken links to Python script on QuickStart doc

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

[jira] [Commented] (FLINK-2684) Make TypeInformation non-serializable again by removing Table API's need for it

2015-09-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14802692#comment-14802692 ] Till Rohrmann commented on FLINK-2684: -- Yes, I think this is the better solution here. In fact, I

[jira] [Commented] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

2015-09-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14802695#comment-14802695 ] Till Rohrmann commented on FLINK-2690: -- Extracting properly all declared fields in the

[jira] [Commented] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

2015-09-17 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14802697#comment-14802697 ] Chiwan Park commented on FLINK-2690: Okay. :-) > CsvInputFormat cannot find the field of derived POJO

[jira] [Updated] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

2015-09-17 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park updated FLINK-2690: --- Assignee: Till Rohrmann (was: Chiwan Park) > CsvInputFormat cannot find the field of derived POJO

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1139#issuecomment-141035389 Yes, the values you refer to are still placeholders. I would like to merge this in its current state and improve on it in the master branch. The old

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1139#issuecomment-141035558 I agree with this approach, so +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

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1139#issuecomment-141050563 Another follow-up todo is adding support for yarn: ``` 11:31:01,955 ERROR org.apache.flink.runtime.jobmanager.JobManager - WebServer could

[GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co...

2015-09-17 Thread twalthr
Github user twalthr closed the pull request at: https://github.com/apache/flink/pull/943 --- 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-2410) PojoTypeInfo is not completely serializable

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

[jira] [Commented] (FLINK-2653) Enable object reuse in MergeIterator

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

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1139#issuecomment-141046424 Your change set is very large large but this inevitably comes with major reworks like this. What I checked out already works nicely. Improvements here and there will be

[GitHub] flink pull request: [FLINK-2689] [runtime] Fix reuse of null objec...

2015-09-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1136 --- 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

[GitHub] flink pull request: [FLINK-2640][yarn] integrate off-heap configur...

2015-09-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1132 --- 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

[GitHub] flink pull request: [FLINK-2659] Fix object reuse in UnionWithTemp...

2015-09-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1130 --- 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

[GitHub] flink pull request: [FLINK-2691] fix broken links to Python script...

2015-09-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1140 --- 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

[GitHub] flink pull request: FLINK-2595 Unclosed JarFile may leak resource ...

2015-09-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1137 --- 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

[GitHub] flink pull request: [FLINK-2689] [runtime] Fix reuse of null objec...

2015-09-17 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1136#issuecomment-141003929 LGTM --- 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

[jira] [Commented] (FLINK-2689) Reusing null object for joins with SolutionSet

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14791782#comment-14791782 ] ASF GitHub Bot commented on FLINK-2689: --- Github user mxm commented on the pull request:

[jira] [Commented] (FLINK-2689) Reusing null object for joins with SolutionSet

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

[jira] [Commented] (FLINK-2684) Make TypeInformation non-serializable again by removing Table API's need for it

2015-09-17 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14791818#comment-14791818 ] Chiwan Park commented on FLINK-2684: Although {{TypeInformation}} is not serializable, we can fix

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-09-17 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1121#discussion_r39725184 --- Diff: flink-dist/src/main/resources/flink-conf.yaml --- @@ -130,6 +130,15 @@ state.backend: jobmanager

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1139#issuecomment-141018736 Very nice. I tried the new interface locally, and it seems to work. I suspect these values are still test values? http://i.imgur.com/d9ZRR7g.png There

[jira] [Commented] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation

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

[GitHub] flink pull request: FLINK-2595 Unclosed JarFile may leak resource ...

2015-09-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1137#issuecomment-141006345 Thanks for the update. Will merge this now. --- 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

[GitHub] flink pull request: [FLINK-2689] [runtime] Fix reuse of null objec...

2015-09-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1136#issuecomment-141006389 Thanks for the review. Will merge this. --- 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

[jira] [Commented] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest

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

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-09-17 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1121#discussion_r39725238 --- Diff: flink-yarn-tests/src/main/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -111,6 +111,20 @@ public void testClientStartup() {

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

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

[jira] [Commented] (FLINK-2557) Manual type information via "returns" fails in DataSet API

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14799236#comment-14799236 ] ASF GitHub Bot commented on FLINK-2557: --- Github user mjsax commented on the pull request:

[GitHub] flink pull request: [FLINK-2557] TypeExtractor properly returns Mi...

2015-09-17 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1045#issuecomment-141024224 Can you add a test case that checks if "returns" works now. See the JIRA example. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1139#issuecomment-141062133 The YARN support needs to ship the static contents to the JobManager (AppMaster). The current implementation does not support to serve the static contents out of a

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-09-17 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/1106#issuecomment-141066672 Should be fixed according to your comments @fhueske --- 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-2613) Print usage information for Scala Shell

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14802846#comment-14802846 ] ASF GitHub Bot commented on FLINK-2613: --- Github user nikste commented on the pull request:

[jira] [Resolved] (FLINK-2410) PojoTypeInfo is not completely serializable

2015-09-17 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-2410. - Resolution: Fixed Fix Version/s: 0.10 > PojoTypeInfo is not completely serializable >

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-09-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1106#discussion_r39763329 --- Diff: flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala --- @@ -212,6 +212,49 @@ class ScalaShellITSuite

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[GitHub] flink pull request: [FLINK-2557] TypeExtractor properly returns Mi...

2015-09-17 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1045#issuecomment-141110503 Looks good to merge, if build succeeds. --- 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

[GitHub] flink pull request: [FLINK-2557] TypeExtractor properly returns Mi...

2015-09-17 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1045#issuecomment-141121393 One failing test in new to me. Do we need a JIRA for it? ``` Tests in error: CompactingHashTableTest.testHashTableGrowthWithInsert:98->getMemory:243 »

[jira] [Commented] (FLINK-2557) Manual type information via "returns" fails in DataSet API

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803089#comment-14803089 ] ASF GitHub Bot commented on FLINK-2557: --- Github user mjsax commented on the pull request:

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

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

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

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

[GitHub] flink pull request: [FLINK-2689] [runtime] Fix reuse of null objec...

2015-09-17 Thread srowen
Github user srowen commented on the pull request: https://github.com/apache/flink/pull/1136#issuecomment-141122197 @fhueske not sure where else to mention this, but for some reason, PRs like this are causing Apache JIRA to comment on Spark JIRAs (see

[jira] [Commented] (FLINK-2689) Reusing null object for joins with SolutionSet

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803091#comment-14803091 ] ASF GitHub Bot commented on FLINK-2689: --- Github user srowen commented on the pull request:

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-09-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1106#discussion_r39763373 --- Diff: flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellLocalStartupITCase.scala --- @@ -0,0 +1,58 @@ +/* + *

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

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

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-09-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1106#issuecomment-141131210 Thanks for the update @nikste! I have only one minor thing to add. After that it's good to merge, IMO. Thanks! --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14802919#comment-14802919 ] ASF GitHub Bot commented on FLINK-2357: --- Github user aljoscha commented on the pull request:

[jira] [Commented] (FLINK-2557) Manual type information via "returns" fails in DataSet API

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14802932#comment-14802932 ] ASF GitHub Bot commented on FLINK-2557: --- Github user zentol commented on the pull request:

[jira] [Resolved] (FLINK-2640) Integrate the off-heap configurations with YARN runner

2015-09-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2640. -- Resolution: Implemented Implemented with 93c95b6a6f150a2c55dc387e4ef1d603b3ef3f22 > Integrate

[jira] [Commented] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

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

[GitHub] flink pull request: [FLINK-2537] Add scala examples.jar to build-t...

2015-09-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1123#issuecomment-141102303 I agree with @uce and I don't think we should add the Scala example JARs again. @chenliang613, could you please close this PR? I am really sorry that we

[jira] [Commented] (FLINK-2537) Add scala examples.jar to build-target/examples

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

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803024#comment-14803024 ] Till Rohrmann commented on FLINK-2392: -- I observed the failure multiple times again (50 builds). The

[GitHub] flink pull request: [FLINK-2537] Add scala examples.jar to build-t...

2015-09-17 Thread chenliang613
Github user chenliang613 closed the pull request at: https://github.com/apache/flink/pull/1123 --- 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

[GitHub] flink pull request: [FLINK-2537] Add scala examples.jar to build-t...

2015-09-17 Thread chenliang613
Github user chenliang613 commented on the pull request: https://github.com/apache/flink/pull/1123#issuecomment-141116565 ok,fine. --- 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-2125][streaming] Delimiter change from ...

2015-09-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1077#discussion_r39749641 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java ---

[jira] [Created] (FLINK-2693) Refactor InvalidTypesException to be checked

2015-09-17 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2693: --- Summary: Refactor InvalidTypesException to be checked Key: FLINK-2693 URL: https://issues.apache.org/jira/browse/FLINK-2693 Project: Flink Issue Type:

[jira] [Created] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis

2015-09-17 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2695: Summary: KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis Key: FLINK-2695 URL: https://issues.apache.org/jira/browse/FLINK-2695 Project: Flink

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

2015-09-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803038#comment-14803038 ] Till Rohrmann commented on FLINK-2616: -- Encountered it again:

[jira] [Comment Edited] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2015-09-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803050#comment-14803050 ] Till Rohrmann edited comment on FLINK-2600 at 9/17/15 3:10 PM: --- Occurred

[jira] [Created] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat

2015-09-17 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2692: Summary: Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat Key: FLINK-2692 URL: https://issues.apache.org/jira/browse/FLINK-2692

[jira] [Commented] (FLINK-2557) Manual type information via "returns" fails in DataSet API

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803013#comment-14803013 ] ASF GitHub Bot commented on FLINK-2557: --- Github user twalthr commented on the pull request:

[jira] [Closed] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation

2015-09-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2637. Resolution: Fixed Fixed with 8ca853e0f6c18be8e6b066c6ec0f23badb797323 > Add abstract equals,

[jira] [Created] (FLINK-2694) JobManagerProcessReapingTest.testReapProcessOnFailure failed on Travis

2015-09-17 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2694: Summary: JobManagerProcessReapingTest.testReapProcessOnFailure failed on Travis Key: FLINK-2694 URL: https://issues.apache.org/jira/browse/FLINK-2694 Project: Flink

[jira] [Assigned] (FLINK-2653) Enable object reuse in MergeIterator

2015-09-17 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-2653: - Assignee: Greg Hogan > Enable object reuse in MergeIterator >

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

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

[GitHub] flink pull request: [FLINK-2690] [api-breaking] [scala api] [java ...

2015-09-17 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1141 [FLINK-2690] [api-breaking] [scala api] [java api] Allows CsvInputFormat to use derived Pojos This PR adds support for the `CsvInputFormat` to use derived Pojos. In order to also find pojo

[jira] [Created] (FLINK-2697) Deadlock in StreamDiscretizer

2015-09-17 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2697: Summary: Deadlock in StreamDiscretizer Key: FLINK-2697 URL: https://issues.apache.org/jira/browse/FLINK-2697 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2689) Reusing null object for joins with SolutionSet

2015-09-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2689. Resolution: Fixed Fix Version/s: (was: 0.9.2) 0.9 Fixed for 0.10 with

[jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer

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

[jira] [Closed] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest

2015-09-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2595. Resolution: Fixed Fix Version/s: 0.10 Fixed with 2c9e2c8bbe1547709d820949d1739f7ea2ce89cf >

[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-09-17 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-14654 @jkovacs and @r-pogalz, thank you very much for this PR and the detailed description! It's quite a bit of code so it will take some time to be reviewed. I hope to

[jira] [Closed] (FLINK-2691) Broken links to Python script on QuickStart doc

2015-09-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2691. Resolution: Fixed Fix Version/s: 0.10 0.9 Fixed for 0.10 with

[jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2015-09-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803050#comment-14803050 ] Till Rohrmann commented on FLINK-2600: -- Occured again

[jira] [Closed] (FLINK-2687) Moniroting api / web dashboard: Create request handlers list subtask details and accumulators

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2687. --- > Moniroting api / web dashboard: Create request handlers list subtask details > and accumulators >

[jira] [Resolved] (FLINK-2687) Moniroting api / web dashboard: Create request handlers list subtask details and accumulators

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2687. - Resolution: Fixed Implemented in b3f791727c0713251a4b02a766eb177eb9327113 > Moniroting api / web

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

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

[GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon...

2015-09-17 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1139 --- 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

[jira] [Created] (FLINK-2698) Add trailing newline to flink-conf.yaml

2015-09-17 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2698: - Summary: Add trailing newline to flink-conf.yaml Key: FLINK-2698 URL: https://issues.apache.org/jira/browse/FLINK-2698 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-2637] [api-breaking] [scala, types] Add...

2015-09-17 Thread rxin
Github user rxin commented on the pull request: https://github.com/apache/flink/pull/1134#issuecomment-141163582 I understand you took the bot from Spark, but can you change the JIRA link? It is spamming the Spark JIRA right now.

[jira] [Resolved] (FLINK-2547) Provide Cluster Status Info

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2547. - Resolution: Fixed Implemented in 01b0fc8fc44d2454ef351928e73f5d49f9e41247 > Provide Cluster

[jira] [Resolved] (FLINK-2415) Link nodes in plan to vertices

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2415. - Resolution: Fixed Fix Version/s: 0.10 Implemened in

[jira] [Closed] (FLINK-2547) Provide Cluster Status Info

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2547. --- > Provide Cluster Status Info > --- > > Key: FLINK-2547 >

[jira] [Resolved] (FLINK-2357) New JobManager Runtime Web Frontend

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2357. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.10 Implemented in

[jira] [Commented] (FLINK-2627) Make Scala Data Set utils easier to access

2015-09-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14803222#comment-14803222 ] ASF GitHub Bot commented on FLINK-2627: --- Github user sachingoel0101 commented on the pull request:

[jira] [Closed] (FLINK-2415) Link nodes in plan to vertices

2015-09-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2415. --- > Link nodes in plan to vertices > -- > > Key: FLINK-2415 >

  1   2   >