[GitHub] flink pull request: [hotfix] Simplify new windowing API

2015-09-29 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1195#issuecomment-144290792 Yes, that seems valid, I'm changing it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Moved] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output

2015-09-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu moved HBASE-14514 to FLINK-2789: --- Workflow: jira (was: no-reopen-closed, patch-avail) Key: FLINK-2789 (was: H

[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&focusedCommentId=14936014#comment-14936014 ] ASF GitHub Bot commented on FLINK-2764: --- Github user StephanEwen commented on the pu

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

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1181#issuecomment-144206289 Thanks for fixing 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] [Closed] (FLINK-2764) WebClient cannot display multiple Jobs

2015-09-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2764. -- Resolution: Fixed > WebClient cannot display multiple Jobs > ---

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

2015-09-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14936011#comment-14936011 ] Matthias J. Sax commented on FLINK-2764: fixed via 622c1be8c61c3a9a37c30454c717c99

[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&focusedCommentId=14935999#comment-14935999 ] ASF GitHub Bot commented on FLINK-2764: --- Github user mjsax commented on the pull req

[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&focusedCommentId=14936007#comment-14936007 ] ASF GitHub Bot commented on FLINK-2764: --- Github user asfgit closed the pull request

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

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1181 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] 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-144205184 Merging this now to master. --- 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 t

[jira] [Created] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type

2015-09-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2788: --- Summary: Add type hint with TypeExtactor call on Hint Type Key: FLINK-2788 URL: https://issues.apache.org/jira/browse/FLINK-2788 Project: Flink Issue Type: Imp

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

2015-09-29 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra resolved FLINK-2775. -- Resolution: Fixed Merged to master branch. > [CLEANUP] Cleanup code as part of theme to be more

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

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1189 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[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&focusedCommentId=14935991#comment-14935991 ] ASF GitHub Bot commented on FLINK-2775: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-09-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14935862#comment-14935862 ] ASF GitHub Bot commented on FLINK-2703: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-2703] Prepare Flink for using it with L...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1194#issuecomment-144192517 Nice addition, looks good to me! +1 to merge this --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-2703] Prepare Flink for using it with L...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1194#discussion_r40730119 --- Diff: flink-dist/src/main/assemblies/bin.xml --- @@ -40,6 +40,9 @@ under the License. or

[jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

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

[GitHub] flink pull request: [hotfix] Simplify new windowing API

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1195#issuecomment-144189701 Looks like a nice improvement to me, makes the relationship between the variants easier to grasp. How about allowing the `timeWindows()` method to take an `

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

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

[GitHub] flink pull request: [FLINK-2778] Add API for non-parallel non-keye...

2015-09-29 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1196 [FLINK-2778] Add API for non-parallel non-keyed Windows This adds two new operators for non-keyed windows: Regular trigger operator and evicting trigger operator. This also adds the API

[GitHub] flink pull request: [hotfix] Simplify new windowing API

2015-09-29 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1195 [hotfix] Simplify new windowing API Before, there would be three different window() methods on KeyedDataStream: one that takes two policies, one that takes one policy and one that takes a wi

[jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

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

[GitHub] flink pull request: [FLINK-2703] Prepare Flink for using it with L...

2015-09-29 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1194 [FLINK-2703] Prepare Flink for using it with Logback. i was talking to a user recently who asked for using Logback instead of Log4j. This pull request is adding a section in the "Best prac

[jira] [Created] (FLINK-2787) Prevent explicit use of RemoteEnvironment when running a job through the command line

2015-09-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2787: --- Summary: Prevent explicit use of RemoteEnvironment when running a job through the command line Key: FLINK-2787 URL: https://issues.apache.org/jira/browse/FLINK-2787 Pro

[jira] [Updated] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2786: Issue Type: Sub-task (was: Task) Parent: FLINK-2782 > Remove Spargel from source code and u

[GitHub] flink pull request: [FLINK-2754] Add a new module for micro benchm...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1177 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[GitHub] flink pull request: [FLINK-2766] [core] Add proper handling for IP...

2015-09-29 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1192#issuecomment-144158273 Test failure in unrelated test `ComplexIntegrationTest` ``` org.apache.flink.streaming.api.complex.ComplexIntegrationTest complexIntegrationTest1(org.apac

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

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

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

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

[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&focusedCommentId=14935651#comment-14935651 ] ASF GitHub Bot commented on FLINK-2754: --- Github user asfgit closed the pull request

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

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2777. - Resolution: Fixed Fixed via bb899f708b536d1056d106bf131e67d9f1e545c7 Thank you for the contributi

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

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

[jira] [Resolved] (FLINK-2745) Create a new module for all Flink micro benchmark.

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2745. - Resolution: Done Fix Version/s: 0.10 Added in 2598709fa3e011620f980f93dccffa0e687cac8d Tha

[jira] [Closed] (FLINK-2745) Create a new module for all Flink micro benchmark.

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2745. --- > Create a new module for all Flink micro benchmark. > --

[GitHub] flink pull request: [FLINK-2777] The description of programming_gu...

2015-09-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1193 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Updated] (FLINK-1611) [REFACTOR] Rename classes and packages in test that contains Nephele

2015-09-29 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-1611: - Summary: [REFACTOR] Rename classes and packages in test that contains Nephele (was: [REFACTOR] Re

[jira] [Closed] (FLINK-1704) Change AbstractFlinkYarnClient and AbstractFlinkYarnCluster from abstract to interface

2015-09-29 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra closed FLINK-1704. Resolution: Won't Fix No additional benefits for now so closing it. > Change AbstractFlinkYarnClien

[jira] [Updated] (FLINK-1611) [REFACTOR] Rename classes and packages that contains Nephele

2015-09-29 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-1611: - Summary: [REFACTOR] Rename classes and packages that contains Nephele (was: Rename classes and pa

[jira] [Created] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly

2015-09-29 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-2786: Summary: Remove Spargel from source code and update documentation in favor of Gelly Key: FLINK-2786 URL: https://issues.apache.org/jira/browse/FLINK-2786 Project: Fli

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

2015-09-29 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1189#issuecomment-144136876 Build passes, will squash commits and 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] [Updated] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-09-29 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri updated FLINK-2785: - Issue Type: Sub-task (was: Task) Parent: FLINK-2561 > Implement Graph's fromCsvReader in

[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&focusedCommentId=14935536#comment-14935536 ] ASF GitHub Bot commented on FLINK-2775: --- Github user hsaputra commented on the pull

[jira] [Created] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-09-29 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2785: Summary: Implement Graph's fromCsvReader in Gelly-Scala Key: FLINK-2785 URL: https://issues.apache.org/jira/browse/FLINK-2785 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-2784) Remove deprecated config keys

2015-09-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2784: --- Summary: Remove deprecated config keys Key: FLINK-2784 URL: https://issues.apache.org/jira/browse/FLINK-2784 Project: Flink Issue Type: Sub-task Affects Ve

[jira] [Created] (FLINK-2783) Remove "degreeOfParallelism" API calls

2015-09-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2783: --- Summary: Remove "degreeOfParallelism" API calls Key: FLINK-2783 URL: https://issues.apache.org/jira/browse/FLINK-2783 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2782) Remove deprecated features for 0.10

2015-09-29 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2782: --- Summary: Remove deprecated features for 0.10 Key: FLINK-2782 URL: https://issues.apache.org/jira/browse/FLINK-2782 Project: Flink Issue Type: Improvement A

[jira] [Commented] (FLINK-2663) Update Gelly library methods to use any key type

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

[jira] [Commented] (FLINK-2759) TaskManagerProcessReapingTest fails on Windows

2015-09-29 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14935421#comment-14935421 ] Stephan Ewen commented on FLINK-2759: - Any chance you have the logs with more output?

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14935417#comment-14935417 ] Stephan Ewen commented on FLINK-2766: - [~nyaapa] I opened a pull request with a patch:

[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&focusedCommentId=14935418#comment-14935418 ] ASF GitHub Bot commented on FLINK-2775: --- Github user hsaputra commented on the pull

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

2015-09-29 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/1189#issuecomment-144114134 Thanks guys, updated based comments. Will merge end of day if no more comments. --- If your project is set up for it, you can reply to this email and have your reply

[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&focusedCommentId=14935410#comment-14935410 ] ASF GitHub Bot commented on FLINK-2775: --- Github user hsaputra commented on a diff in

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

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

[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 emai

[GitHub] flink pull request: [FLINK-2754] Add a new module for micro benchm...

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

[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&focusedCommentId=14935394#comment-14935394 ] ASF GitHub Bot commented on FLINK-2754: --- Github user StephanEwen commented on the pu

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

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

[GitHub] flink pull request: [FLINK-2777] The description of programming_gu...

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

[GitHub] flink pull request: [FLINK-2777] The description of programming_gu...

2015-09-29 Thread chenliang613
GitHub user chenliang613 opened a pull request: https://github.com/apache/flink/pull/1193 [FLINK-2777] The description of programming_guide.html has some issues def createLocalEnvironment(parallelism: Int = Runtime.getRuntime.availableProcessors())) //issue1: In the end, there

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

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

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

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

[GitHub] flink pull request: [FLINK-2766] [core] Add proper handling for IP...

2015-09-29 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1192 [FLINK-2766] [core] Add proper handling for IPv6 literals in URLs All URLs and literals of the form `host:port` are now handled through the `NetUtils` class, which ensures that IPv6 address lite

[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&focusedCommentId=14935322#comment-14935322 ] ASF GitHub Bot commented on FLINK-2725: --- GitHub user greghogan opened a pull request

[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 2725_max_min_sum_aggreg

[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-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&focusedCommentId=14935277#comment-14935277 ] Bryan Bende commented on FLINK-2740: Hi all, I'm going to start ramping up on flink st

[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&focusedCommentId=14935263#comment-14935263 ] ASF GitHub Bot commented on FLINK-2781: --- GitHub user StephanEwen opened a pull reque

[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 some

[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 Components

[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&focusedCommentId=14935229#comment-14935229 ] ASF GitHub Bot commented on FLINK-1984: --- Github user rmetzger commented on the pull

[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 t

[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 > ---

[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&focusedCommentId=14935210#comment-14935210 ] Stephan Ewen commented on FLINK-1753: - [~rmetzger] This one is done, correct? > Add m

[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&focusedCommentId=14935205#comment-14935205 ] ASF GitHub Bot commented on FLINK-2167: --- Github user twalthr commented on a diff in

[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-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&focusedCommentId=14935204#comment-14935204 ] ASF GitHub Bot commented on FLINK-2167: --- Github user rmetzger commented on a diff in

[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] [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] [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 Stre

[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] [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&focusedCommentId=14935149#comment-14935149 ] Stephan Ewen commented on FLINK-2763: - [~greghogan] Can you check whether the latest m

[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: Labels: (was: 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-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] [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] [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 >

[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 T

[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 T

[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: FLI

[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-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&focusedCommentId=14935073#comment-14935073 ] Stephan Ewen commented on FLINK-2780: - I would be in favor of this. The old API had to

[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&focusedCommentId=14935070#comment-14935070 ] Stephan Ewen commented on FLINK-2763: - I have a fix coming up... > Bug in Hybrid Hash

[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 T

[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 > --

  1   2   >