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

2015-09-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14746964#comment-14746964 ] Matthias J. Sax commented on FLINK-2616: Unfortunately not. It just hit me twice:

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

2015-09-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14747222#comment-14747222 ] Ufuk Celebi commented on FLINK-2616: Why don't wait w/o an explicit timeout in the test? Our Travis

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

2015-09-16 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14747122#comment-14747122 ] Ufuk Celebi commented on FLINK-2595: Hey Ted, would you like to provide a fix for this? > Unclosed

[GitHub] flink pull request: Hits

2015-09-16 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/765#issuecomment-140669850 Hey @mfahimazizi, thank you for your reply! Could you give me some details on what you mean by "calculate edges values"? What is the computation that you want to do and

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

2015-09-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14747171#comment-14747171 ] Till Rohrmann commented on FLINK-2684: -- The benefits would be to re-establish the old contract that

[GitHub] flink pull request: [hotfix][Table API tests]add toDataSet in tabl...

2015-09-16 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1131#issuecomment-140658458 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 not have

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

2015-09-16 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1134#issuecomment-140663091 Big change, but I didn't spot anything suspicious. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on

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

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

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

2015-09-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14747205#comment-14747205 ] Aljoscha Krettek commented on FLINK-2684: - For the Table API to work we would only need to move

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Summary: Memory Manager memory release can get live-locked in case of concurrent modifications

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Priority: Blocker (was: Critical) > Memory Manager memory release can get live-locked in case of

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Labels: (was: test-stability) > Memory Manager memory release can get live-locked in case of

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Component/s: (was: Tests) Local Runtime > Memory Manager memory release can

[jira] [Assigned] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-2670: --- Assignee: Stephan Ewen > Memory Manager memory release can get live-locked in case of

[jira] [Commented] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14768867#comment-14768867 ] Stephan Ewen commented on FLINK-2670: - Sorry, I was mistaken here, the MemoryManager is actually goo,

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Labels: test-stability (was: ) > Memory Manager memory release can get live-locked in case of

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Priority: Critical (was: Blocker) > Memory Manager memory release can get live-locked in case of

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

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

[jira] [Commented] (FLINK-2348) IterateExampleITCase failing

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14747319#comment-14747319 ] Stephan Ewen commented on FLINK-2348: - Should be able to use a DOP1 sink and test there... >

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

2015-09-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39612554 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeinfo/NumericTypeInfo.java --- @@ -18,16 +18,36 @@ package

[jira] [Commented] (FLINK-2670) Instable Test S3FileSystemTest

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14747369#comment-14747369 ] Stephan Ewen commented on FLINK-2670: - Actually, this is not an S3 test failing, it is the Combiner

[jira] [Updated] (FLINK-2670) Unstable CombineTaskTest

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Summary: Unstable CombineTaskTest (was: Memory Manager memory release can get live-locked in case

[GitHub] flink pull request: [FLINK-2566] FlinkTopologyContext not populate...

2015-09-16 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1135#issuecomment-140730955 There is a test failure ``` StormWrapperSetupHelperTest.testCreateTopologyContext:190 » ClassCast class su... ``` --- If your project is set up for

[GitHub] flink pull request: [FLINK-2583] Add Stream Sink For Rolling HDFS ...

2015-09-16 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-140732373 I think the pull request has grown quite a lot. I think we should merge it now and then improve it from there. --- If your project is set up for it, you can reply to

[jira] [Assigned] (FLINK-2660) Yarn Tests fail with Hadoop 2.3.0

2015-09-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2660: - Assignee: Robert Metzger > Yarn Tests fail with Hadoop 2.3.0 >

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

2015-09-16 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1132#issuecomment-140748694 +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-2583] Add Stream Sink For Rolling HDFS ...

2015-09-16 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1084#discussion_r39624668 --- Diff: .travis.yml --- @@ -19,9 +19,9 @@ matrix: - jdk: "oraclejdk7" # this will also deploy a uberjar to s3 at some point env:

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

2015-09-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39625961 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java --- @@ -68,4 +72,24 @@ private void readObject(ObjectInputStream in)

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

2015-09-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2687: --- Summary: Moniroting api / web dashboard: Create request handlers list subtask details and accumulators Key: FLINK-2687 URL: https://issues.apache.org/jira/browse/FLINK-2687

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

2015-09-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39630227 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala --- @@ -20,6 +20,8 @@ package

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

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

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

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

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

2015-09-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39630864 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RenamingProxyTypeInfo.scala --- @@ -31,7 +32,8 @@ import

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

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

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

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

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

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

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

2015-09-16 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-140731019 I agree. We need to use the script. --- 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-2200) Flink API with Scala 2.11 - Maven Repository

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

[jira] [Commented] (FLINK-2566) FlinkTopologyContext not populated completely

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

[jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2670: Component/s: (was: Local Runtime) Tests > Memory Manager memory release can

[jira] [Commented] (FLINK-2566) FlinkTopologyContext not populated completely

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

[GitHub] flink pull request: [FLINK-2566] FlinkTopologyContext not populate...

2015-09-16 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1135#discussion_r39624182 --- Diff: flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/api/FlinkTopology.java ---

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

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

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

2015-09-16 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39629488 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/ValueTypeInfoTest.java --- @@ -0,0 +1,34 @@ +/* + * Licensed to the

[GitHub] flink pull request: [hotfix][Table API tests]add toDataSet in tabl...

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1131#issuecomment-140749715 I 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 project does not have this

[jira] [Commented] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script

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

[GitHub] flink pull request: [FLINK-2641] integrate off-heap memory configu...

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1129#issuecomment-140749638 I 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 project does not have this

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

2015-09-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39633196 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/PojoField.java --- @@ -68,4 +72,24 @@ private void readObject(ObjectInputStream

[jira] [Commented] (FLINK-2670) Unstable CombineTaskTest

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14768989#comment-14768989 ] Stephan Ewen commented on FLINK-2670: - I added an extra test for the critical part (that I originally

[jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

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

[jira] [Commented] (FLINK-2670) Unstable CombineTaskTest

2015-09-16 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14768901#comment-14768901 ] Stephan Ewen commented on FLINK-2670: - I cannot see any issue with this test. It looks absolutely

[jira] [Created] (FLINK-2688) Add documentation about monitoring api

2015-09-16 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2688: --- Summary: Add documentation about monitoring api Key: FLINK-2688 URL: https://issues.apache.org/jira/browse/FLINK-2688 Project: Flink Issue Type: Sub-task

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

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

[jira] [Commented] (FLINK-1851) Java Table API does not support Casting

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

[GitHub] flink pull request: [FLINK-1851] Add support for casting in Table ...

2015-09-16 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/592#issuecomment-140748342 I updated the documentation, it is very bare bones but should be sufficient. Should we now merge this? --- If your project is set up for it, you can reply to this

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

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1134#issuecomment-140748369 Very good refactoring! I had just a few inline comments. Thanks for this effort! --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-1851) Java Table API does not support Casting

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

[jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

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

[jira] [Commented] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-09-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14768887#comment-14768887 ] Robert Metzger commented on FLINK-1831: --- I'm not re-opening this issue, but I saw this test failing

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

2015-09-16 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-140744071 I think more tests for the Table API can not harm. I will adapt the PR after #1134 is merged. --- If your project is set up for it, you can reply to this email and have

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

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

[GitHub] flink pull request: [FLINK-1851] Add support for casting in Table ...

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/592#issuecomment-140752002 Looks good. 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 project does not

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

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

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

2015-09-16 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1134#issuecomment-140756486 Thanks for reviewing @fhueske and @rmetzger. I addressed the comments and updated the PR. --- If your project is set up for it, you can reply to this email and

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

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

[GitHub] flink pull request: [FLINK-2641] integrate off-heap memory configu...

2015-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1129 --- 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-1851] Add support for casting in Table ...

2015-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/592 --- 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-2583] Add Stream Sink For Rolling HDFS ...

2015-09-16 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1084#discussion_r39640862 --- Diff: .travis.yml --- @@ -19,9 +19,9 @@ matrix: - jdk: "oraclejdk7" # this will also deploy a uberjar to s3 at some point env:

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

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

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

2015-09-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39634911 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RenamingProxyTypeInfo.scala --- @@ -31,7 +32,8 @@ import

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

2015-09-16 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-140757194 The test is included in the PR #1134. --- 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-2410) PojoTypeInfo is not completely serializable

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

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

2015-09-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39634744 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala --- @@ -20,6 +20,8 @@ package

[jira] [Commented] (FLINK-1851) Java Table API does not support Casting

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

[GitHub] flink pull request: [hotfix][Table API tests]add toDataSet in tabl...

2015-09-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1131 --- 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] [Created] (FLINK-2689) Reusing null object for joins with SolutionSet

2015-09-16 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2689: Summary: Reusing null object for joins with SolutionSet Key: FLINK-2689 URL: https://issues.apache.org/jira/browse/FLINK-2689 Project: Flink Issue Type: Bug

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

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

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

2015-09-16 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1134#discussion_r39634683 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/ValueTypeInfoTest.java --- @@ -0,0 +1,34 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-2583] Add Stream Sink For Rolling HDFS ...

2015-09-16 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1084#discussion_r39640472 --- Diff: .travis.yml --- @@ -19,9 +19,9 @@ matrix: - jdk: "oraclejdk7" # this will also deploy a uberjar to s3 at some point env:

[jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

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

[jira] [Resolved] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script

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

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

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-140773221 So this PR can be closed? --- 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

[jira] [Updated] (FLINK-2659) Object reuse in UnionWithTempOperator

2015-09-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2659: - Assignee: Greg Hogan > Object reuse in UnionWithTempOperator >

[jira] [Commented] (FLINK-2659) Object reuse in UnionWithTempOperator

2015-09-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14790540#comment-14790540 ] Fabian Hueske commented on FLINK-2659: -- Hi [~greghogan], thanks for the PR. I gave you contributor

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

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

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

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

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

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1134#issuecomment-140771931 Thanks for the fast update, LGTM. Will merge this tomorrow unless somebody speaks up. --- If your project is set up for it, you can reply to this email and have

[jira] [Closed] (FLINK-1851) Java Table API does not support Casting

2015-09-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1851. Resolution: Implemented Implemented with 7bea90150309156536558d94cb5c244369af81b9 > Java Table API

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

2015-09-16 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1130#issuecomment-140788192 Thanks for the patch, looks good. Will merge this tomorrow. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

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

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

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

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

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

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

[jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

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

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

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

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

2015-09-16 Thread Chiwan Park (JIRA)
Chiwan Park created FLINK-2690: -- Summary: CsvInputFormat cannot find the field of derived POJO class Key: FLINK-2690 URL: https://issues.apache.org/jira/browse/FLINK-2690 Project: Flink Issue

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

2015-09-16 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: --- Description: A user report {{CsvInputFormat}} cannot find the field of derived POJO class.

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

2015-09-16 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: --- Description: A user reports {{CsvInputFormat}} cannot find the field of derived POJO class.

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

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

[jira] [Commented] (FLINK-2659) Object reuse in UnionWithTempOperator

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

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

2015-09-16 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1136 [FLINK-2689] [runtime] Fix reuse of null object for solution set Joins and CoGroups Reuse object can become null if not match is found in the hash table. The next look-up will happen with a

  1   2   >