[jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934763#comment-14934763 ] Fabian Hueske commented on FLINK-2168: -- Hi, glad to hear that you would like to contribute to Flink!

[jira] [Commented] (FLINK-2169) Add fromParquet() to TableEnvironment

2015-09-29 Thread rerngvit yanggratoke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934814#comment-14934814 ] rerngvit yanggratoke commented on FLINK-2169: - [~aljoscha] Thanks for letting me know. I will

[jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-29 Thread Wilmer DAZA (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934827#comment-14934827 ] Wilmer DAZA commented on FLINK-2168: [~aljoscha] thanks so much for the info ... I'll better do that.

[jira] [Comment Edited] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-29 Thread Wilmer DAZA (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14933174#comment-14933174 ] Wilmer DAZA edited comment on FLINK-2168 at 9/29/15 6:53 AM: - Hello

[jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

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

[jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

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

[jira] [Commented] (FLINK-2169) Add fromParquet() to TableEnvironment

2015-09-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934804#comment-14934804 ] Aljoscha Krettek commented on FLINK-2169: - There is currently an open PR

[jira] [Comment Edited] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934803#comment-14934803 ] Aljoscha Krettek edited comment on FLINK-2168 at 9/29/15 7:50 AM: -- There

[jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934803#comment-14934803 ] Aljoscha Krettek commented on FLINK-2168: - There is currently an open pull request by [~twalthr]

[jira] [Created] (FLINK-2777) The description of programming_guide.html has some issues

2015-09-29 Thread chenliang613 (JIRA)
chenliang613 created FLINK-2777: --- Summary: The description of programming_guide.html has some issues Key: FLINK-2777 URL: https://issues.apache.org/jira/browse/FLINK-2777 Project: Flink Issue

[GitHub] flink pull request: [FLINK-2775] [CLEANUP] Cleanup code as part of...

2015-09-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1189#discussion_r40645927 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/ExampleUtils.java --- @@ -117,7 +117,7 @@ public void

[jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

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

[jira] [Updated] (FLINK-2168) Add fromHBase() to TableEnvironment

2015-09-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2168: - Assignee: Wilmer DAZA > Add fromHBase() to TableEnvironment > ---

[jira] [Commented] (FLINK-2776) Print job id to standard out on CLI job submission

2015-09-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934809#comment-14934809 ] Aljoscha Krettek commented on FLINK-2776: - +2 > Print job id to standard out on CLI job

[jira] [Commented] (FLINK-2764) WebClient cannot display multiple Jobs

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

[GitHub] flink pull request: [FLINK-2764] [WebClient] [0.10.0-milestone-1] ...

2015-09-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1181#issuecomment-143976787 Is this just a fix for the milestone-1 or the master? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink pull request: [FLINK-2775] [CLEANUP] Cleanup code as part of...

2015-09-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1189#discussion_r40646086 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ClassLoaderUtil.java --- @@ -129,4 +129,11 @@ public static boolean

[GitHub] flink pull request: [FLINK-2775] [CLEANUP] Cleanup code as part of...

2015-09-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1189#discussion_r40646129 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/util/ClusterUtil.java --- @@ -26,11 +26,17 @@

[jira] [Updated] (FLINK-2777) The description of programming_guide.html has some issues

2015-09-29 Thread chenliang613 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenliang613 updated FLINK-2777: Labels: (was: documentation) > The description of programming_guide.html has some issues >

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

2015-09-29 Thread chenliang613 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenliang613 closed FLINK-2537. --- Resolution: Not A Problem > Add scala examples.jar to build-target/examples >

[jira] [Updated] (FLINK-2777) The description of programming_guide.html has some issues

2015-09-29 Thread chenliang613 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenliang613 updated FLINK-2777: Component/s: Documentation > The description of programming_guide.html has some issues >

[jira] [Updated] (FLINK-2777) The description of programming_guide.html has some issues

2015-09-29 Thread chenliang613 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenliang613 updated FLINK-2777: Fix Version/s: 0.10 > The description of programming_guide.html has some issues >

[jira] [Updated] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-09-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2779: Assignee: Kostas Tzoumas (was: Aljoscha Krettek) > Update documentation to reflect new

[jira] [Assigned] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-09-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2779: --- Assignee: Aljoscha Krettek > Update documentation to reflect new Stream/Window API >

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-29 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40674158 --- Diff: flink-staging/flink-table/pom.xml --- @@ -37,7 +37,7 @@ under the License. com.google.guava

[jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment

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

[GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn...

2015-09-29 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1127#discussion_r40674516 --- Diff: flink-staging/flink-table/pom.xml --- @@ -37,7 +37,7 @@ under the License. com.google.guava

[jira] [Commented] (FLINK-1753) Add more tests for Kafka Connectors

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14935210#comment-14935210 ] Stephan Ewen commented on FLINK-1753: - [~rmetzger] This one is done, correct? > Add more tests for

[jira] [Updated] (FLINK-2777) The description of programming_guide.html has some issues

2015-09-29 Thread chenliang613 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenliang613 updated FLINK-2777: Labels: documentation (was: ) > The description of programming_guide.html has some issues >

[jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14935149#comment-14935149 ] Stephan Ewen commented on FLINK-2763: - [~greghogan] Can you check whether the latest master solves

[jira] [Resolved] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

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

[jira] [Resolved] (FLINK-1753) Add more tests for Kafka Connectors

2015-09-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1753. --- Resolution: Fixed Yes, I'm closing the issue. > Add more tests for Kafka Connectors >

[GitHub] flink pull request: [FLINK-2769] [dashboard] Remove hard coded job...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1185#issuecomment-144012726 Merging 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-2756) start/stop scripts fail in directories with spaces

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

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

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

[jira] [Resolved] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page

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

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

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

[jira] [Resolved] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell

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

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

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2653. --- > Enable object reuse in MergeIterator > > > Key:

[jira] [Closed] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2761. --- > Prevent instantiation of new ExecutionEnvironments in the Scala Shell >

[GitHub] flink pull request: [FLINK-2753] [streaming] [api breaking] Add fi...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1175#issuecomment-144015350 Subsumed by #1184 --- 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] [Commented] (FLINK-2753) Add new window API to streaming API

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

[GitHub] flink pull request: [FLINK-2754] FixedLengthRecordSorter can not w...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1178#issuecomment-144015272 Merging 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-2723) CopyableValue method to copy into new instance

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

[jira] [Created] (FLINK-2778) Add API for non-parallel non-keyed Windows

2015-09-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2778: --- Summary: Add API for non-parallel non-keyed Windows Key: FLINK-2778 URL: https://issues.apache.org/jira/browse/FLINK-2778 Project: Flink Issue Type:

[jira] [Created] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-09-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2779: --- Summary: Update documentation to reflect new Stream/Window API Key: FLINK-2779 URL: https://issues.apache.org/jira/browse/FLINK-2779 Project: Flink

[jira] [Closed] (FLINK-2723) CopyableValue method to copy into new instance

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2723. --- > CopyableValue method to copy into new instance > -- > >

[jira] [Closed] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2754. --- > FixedLengthRecordSorter can not write to output cross MemorySegments. >

[jira] [Commented] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell

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

[GitHub] flink pull request: [FLINK-2761][scala-shell]Prevent creation of n...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1180#issuecomment-144016570 Looks good, 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

[jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7: - Component/s: Distributed Runtime > [GitHub] Enable Range Partitioner > - > >

[jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14934979#comment-14934979 ] Stephan Ewen commented on FLINK-7: -- Good idea, +1 This is the issue with number 7 - which means it has been

[jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7: - Labels: (was: github-import) > [GitHub] Enable Range Partitioner > - > >

[jira] [Commented] (FLINK-2723) CopyableValue method to copy into new instance

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

[GitHub] flink pull request: [FLINK-2761][scala-shell]Prevent creation of n...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1180 --- 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-2756) start/stop scripts fail in directories with spaces

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

[jira] [Commented] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell

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

[GitHub] flink pull request: [FLINK-2756] Fix start/stop scripts for paths ...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1182 --- 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-2723] CopyableValue method to copy into...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1169 --- 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-2653) Enable object reuse in MergeIterator

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

[GitHub] flink pull request: [FLINK-2754] FixedLengthRecordSorter can not w...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1178 --- 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-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

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

[GitHub] flink pull request: [FLINK-2769] [dashboard] Remove hard coded job...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1185 --- 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-2769) Web dashboard port not configurable on client side

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

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1188 --- 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-2775] [CLEANUP] Cleanup code as part of...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1189#issuecomment-144011547 Looks good. @zentol's comments are nice-to-address issues. +1 to merge with addressing the comments --- If your project is set up for it, you can reply to

[jira] [Created] (FLINK-2780) Remove Old Windowing Logic and API

2015-09-29 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2780: --- Summary: Remove Old Windowing Logic and API Key: FLINK-2780 URL: https://issues.apache.org/jira/browse/FLINK-2780 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2768. --- > Wrong Java version requirements in "Quickstart: Scala API" page >

[GitHub] flink pull request: [FLINK-2764] [WebClient] [0.10.0-milestone-1] ...

2015-09-29 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1181#issuecomment-143995828 Both. I labeled it as milestone-1 because I opened this PR before it was decided that the next RC will be forked from master. So I would just merge in into master right

[jira] [Commented] (FLINK-2764) WebClient cannot display multiple Jobs

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

[jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes

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

[GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1188#issuecomment-144011605 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

[jira] [Commented] (FLINK-2769) Web dashboard port not configurable on client side

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

[GitHub] flink pull request: [FLINK-2756] Fix start/stop scripts for paths ...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1182#issuecomment-144014613 +1 Merging 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

[GitHub] flink pull request: [FLINK-2727] [streaming] Add a base class for ...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1163#issuecomment-144015953 Any objection against merging 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

[GitHub] flink pull request: [FLINK-2653] Enable object reuse in MergeItera...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1115#issuecomment-144015985 Merging 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] [Resolved] (FLINK-2756) start/stop scripts fail in directories with spaces

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2756. - Resolution: Fixed Fixed via 40cbf7e4b038c945916fa8843b60bd4a59a4ae31 > start/stop scripts fail

[jira] [Resolved] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

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

[jira] [Closed] (FLINK-2756) start/stop scripts fail in directories with spaces

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2756. --- > start/stop scripts fail in directories with spaces > --

[jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14935070#comment-14935070 ] Stephan Ewen commented on FLINK-2763: - I have a fix coming up... > Bug in Hybrid Hash Join: Request

[jira] [Closed] (FLINK-2769) Web dashboard port not configurable on client side

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2769. --- > Web dashboard port not configurable on client side > --

[jira] [Resolved] (FLINK-2769) Web dashboard port not configurable on client side

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

[jira] [Resolved] (FLINK-2723) CopyableValue method to copy into new instance

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

[jira] [Assigned] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-2763: --- Assignee: Stephan Ewen > Bug in Hybrid Hash Join: Request to spill a partition with less

[GitHub] flink pull request: [FLINK-2723] CopyableValue method to copy into...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1169#issuecomment-144015414 Merging 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-2753] [streaming] [api breaking] Add fi...

2015-09-29 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/1175 --- 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] [Commented] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments.

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

[jira] [Commented] (FLINK-2780) Remove Old Windowing Logic and API

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14935073#comment-14935073 ] Stephan Ewen commented on FLINK-2780: - I would be in favor of this. The old API had too many issues

[jira] [Assigned] (FLINK-2766) Bad ipv6 urls

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-2766: --- Assignee: Stephan Ewen > Bad ipv6 urls > - > > Key: FLINK-2766 >

[jira] [Created] (FLINK-2781) Consolidate NetUtils

2015-09-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2781: --- Summary: Consolidate NetUtils Key: FLINK-2781 URL: https://issues.apache.org/jira/browse/FLINK-2781 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2781) Consolidate NetUtils

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

[GitHub] flink pull request: [FLINK-2781] [core] Cleanup NetUtils.

2015-09-29 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1190 [FLINK-2781] [core] Cleanup NetUtils. We currently have two classes called `NetUtils` with different networking related helpers. In some cases you need both classes, which results in quite

[GitHub] flink pull request: [FLINK-2725] Max/Min/Sum Aggregation of mutabl...

2015-09-29 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1191 [FLINK-2725] Max/Min/Sum Aggregation of mutable types You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[jira] [Closed] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers.

2015-09-29 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-2763. - Success! > Bug in Hybrid Hash Join: Request to spill a partition with less than two > buffers. >

[jira] [Commented] (FLINK-2725) Max/Min/Sum Aggregation of mutable types

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

[GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos

2015-09-29 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/948#issuecomment-144074252 Thank you for the update @ankurcha. I'm trying to review your PR in the next few days. Sorry for the delay. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[jira] [Commented] (FLINK-2740) Create data consumer for Apache NiFi

2015-09-29 Thread Bryan Bende (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14935277#comment-14935277 ] Bryan Bende commented on FLINK-2740: Hi all, I'm going to start ramping up on flink streaming and

[GitHub] flink pull request: [FLINK-2663] [gelly] Changes library methods t...

2015-09-29 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1152#issuecomment-144117546 Travis has a failure on `YARNSessionFIFOITCase ` (FLINK-2392). If no objections, I can merge this one. --- If your project is set up for it, you can reply to this

  1   2   >