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

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

[GitHub] flink pull request: Hits

2015-09-15 Thread mfahimazizi
Github user mfahimazizi commented on the pull request: https://github.com/apache/flink/pull/765#issuecomment-140633835 Hi @vasia, Thank you. for this algorithm, we need to calculate edges values inside VertexUpdateFunction, so I will try to build my own delta iteration. --- If

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

2015-09-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2595: -- Description: Here is related code: {code} try { new JarF

[jira] [Updated] (FLINK-2649) Potential resource leak in JarHelper#unjar()

2015-09-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2649: -- Description: {code} dest = new BufferedOutputStream(fos, BUFFER_SIZE); while ((count = jis.read(data, 0,

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-09-15 Thread Daniel Blazevski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14746552#comment-14746552 ] Daniel Blazevski commented on FLINK-1745: - Thanks! Pulled and built Chinwan's bra

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

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

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

2015-09-15 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/1135 [FLINK-2566] FlinkTopologyContext not populated completely - extended FlinkTopologyContext to be populted with all supportable attributes - added JUnit test - updated README.md addit

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

2015-09-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2566: --- Summary: FlinkTopologyContext not populated completely (was: FlinkTopologyContext no populate

[jira] [Created] (FLINK-2686) Extend JSON plan dump to contain channel info

2015-09-15 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2686: -- Summary: Extend JSON plan dump to contain channel info Key: FLINK-2686 URL: https://issues.apache.org/jira/browse/FLINK-2686 Project: Flink Issue Type: Improveme

[jira] [Assigned] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-2685: -- Assignee: Ufuk Celebi > TaskManager deadlock on NetworkBufferPool > ---

[jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14746211#comment-14746211 ] Ufuk Celebi commented on FLINK-2685: Hey Greg, thanks for the write up. Deadlocks ofte

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

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

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

2015-09-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-140523411 I fixed the bug and now I'm confident that it should work. Also, I updated the travis build matrix because the sink does not work with hadoop 2.0.0-alpha. We ha

[jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2685: -- Description: This deadlock occurs intermittently. I have a {{join}} followed by a {{chain}} followed by

[jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2685: -- Description: This deadlock occurs intermittently. I have a {{join}} followed by a {{chain}} followed by

[jira] [Created] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-15 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-2685: - Summary: TaskManager deadlock on NetworkBufferPool Key: FLINK-2685 URL: https://issues.apache.org/jira/browse/FLINK-2685 Project: Flink Issue Type: Bug C

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

2015-09-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745831#comment-14745831 ] Chesnay Schepler commented on FLINK-2684: - What are the benefits of making them no

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

2015-09-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2684: Summary: Make TypeInformation non-serializable again by removing Table API's need for it Key: FLINK-2684 URL: https://issues.apache.org/jira/browse/FLINK-2684 Project

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

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

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

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

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

2015-09-15 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/943#issuecomment-140468581 The non-serializable problem of the `PojoTypeInfo` has been fixed in #1134. Thus, the PR can be closed. --- 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-15 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1134 [FLINK-2637] [api-breaking] [scala, types] Adds equals and hashCode method to TypeInformations and TypeSerializers Adds abstract `equals`, `hashCode`, `canEqual` and `toString` methods to `Typ

[jira] [Closed] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method

2015-09-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2633. Resolution: Fixed Subsumed by FLINK-2637 > OptionTypeInfo does not have proper equals and hashCode

[GitHub] flink pull request: [FLINK-2675] [streaming] Add utilities for sch...

2015-09-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1133#discussion_r39526103 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/TriggerTimer.java --- @@ -0,0 +1,

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

[GitHub] flink pull request: [FLINK-2675] [streaming] Add utilities for sch...

2015-09-15 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/1133#discussion_r39525474 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/TriggerTimer.java --- @@ -0,0 +1,119

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

[jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers

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

[GitHub] flink pull request: [FLINK-2675] [streaming] Add utilities for sch...

2015-09-15 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1133 [FLINK-2675] [streaming] Add utilities for scheduled triggers. These utilities are used by processing time triggers to schedule evaluations for the future. They are the first part of reworking t

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

2015-09-15 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1131#issuecomment-140420760 +1 from me too. --- 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 featur

[jira] [Assigned] (FLINK-2642) Scala Table API crashes when executing word count example

2015-09-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-2642: --- Assignee: Timo Walther > Scala Table API crashes when executing word count example >

[jira] [Commented] (FLINK-2642) Scala Table API crashes when executing word count example

2015-09-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745565#comment-14745565 ] Timo Walther commented on FLINK-2642: - Will look into it... > Scala Table API crashes

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

2015-09-15 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1131#issuecomment-140418355 I think this is OK, it just ensures that the code is non-ambiguous. So for me it looks good-to-merge. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [FLINK-2097] Implement job session management

2015-09-15 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/858#issuecomment-140405615 I've rebased again...If nobody objects, I will merge this soon. The new API-facing methods on `ExecutionEnvironment` will be disabled until we implement first applications of

[jira] [Commented] (FLINK-2097) Add support for JobSessions

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

[jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode

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

[GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write...

2015-09-15 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/1098#issuecomment-140396374 @fhueske @chiwanpark Hello! I opened a new PR:https://github.com/apache/flink/pull/1131 to fix the problem of Table API tests. Is it valid? I jus

[jira] [Commented] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method

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

[jira] [Commented] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method

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

[GitHub] flink pull request: [FLINK-2633] [scala, types] Adds equals and ha...

2015-09-15 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1104#issuecomment-140388248 Sure. --- 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 ena

[GitHub] flink pull request: [FLINK-2633] [scala, types] Adds equals and ha...

2015-09-15 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/1104 --- 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 i

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

2015-09-15 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/1131#issuecomment-140386897 Hello? I got the last CI log, this seems to be passed? Why display failure in this web? --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-2633] [scala, types] Adds equals and ha...

2015-09-15 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1104#issuecomment-140387087 @tillrohrmann You are extending this PR and opening a new one, right? Can you close this PR? --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method

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

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745421#comment-14745421 ] Fabian Hueske commented on FLINK-2668: -- I think it should be pretty easy to remove th

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745415#comment-14745415 ] Aljoscha Krettek commented on FLINK-2668: - IMHO it seems more intuitive that a sec

[jira] [Resolved] (FLINK-2230) Add Support for Null-Values in TupleSerializer

2015-09-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2230. -- Resolution: Won't Fix Closed because of consensus to not add null-value support to TupleSerializ

[jira] [Closed] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method

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

[jira] [Closed] (FLINK-2655) Minimize intermediate merging of spilled buffers

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

[jira] [Closed] (FLINK-2665) ExecutionConfig is not serializable

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

[jira] [Resolved] (FLINK-2533) Gap based random sample optimization

2015-09-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2533. -- Resolution: Implemented Fix Version/s: 0.10 Implemented as c923fb3c1c1d61462e1079198ae9fb

[jira] [Comment Edited] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745391#comment-14745391 ] Greg Hogan edited comment on FLINK-2668 at 9/15/15 12:52 PM: -

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745391#comment-14745391 ] Greg Hogan commented on FLINK-2668: --- The project methods work well, particularly for int

[GitHub] flink pull request: [FLINK-2373] Add configuration parameter to cr...

2015-09-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1066 --- 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-2533] [core] Gap based random sample op...

2015-09-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1110 --- 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-2665] [api-breaking] [runtime] Makes Ex...

2015-09-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1128 --- 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-2655) Minimize intermediate merging of spilled buffers

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

[jira] [Commented] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method

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

[jira] [Commented] (FLINK-2533) Gap based random sample optimization

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

[jira] [Commented] (FLINK-2665) ExecutionConfig is not serializable

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

[GitHub] flink pull request: [FLINK-2230] handling null values for TupleSer...

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

[GitHub] flink pull request: [FLINK-2655] Minimize intermediate merging of ...

2015-09-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1118 --- 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-2230) Add Support for Null-Values in TupleSerializer

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

[jira] [Closed] (FLINK-2383) Add new Window Operator that can use Timestamps/Watermarks

2015-09-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2383. --- Resolution: Fixed > Add new Window Operator that can use Timestamps/Watermarks > -

[jira] [Updated] (FLINK-2550) Rework DataStream API

2015-09-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2550: Assignee: Maximilian Michels (was: Aljoscha Krettek) > Rework DataStream API >

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

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

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-09-15 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-140375020 I thinks it should be fine. The `TaskOperationResult` should only indicate, that the signal was delivered successful (ie, only sent to "streaming sources"). All other opera

[jira] [Commented] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys

2015-09-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745356#comment-14745356 ] Till Rohrmann commented on FLINK-2678: -- Might not be too common. But looking at our {

[jira] [Created] (FLINK-2683) Add utilities for heap-backed keyed state in time panes

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2683: --- Summary: Add utilities for heap-backed keyed state in time panes Key: FLINK-2683 URL: https://issues.apache.org/jira/browse/FLINK-2683 Project: Flink Issue Typ

[jira] [Commented] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745338#comment-14745338 ] Stephan Ewen commented on FLINK-2668: - The behavior is a bit curious. Is there a good

[jira] [Commented] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys

2015-09-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745335#comment-14745335 ] Stephan Ewen commented on FLINK-2678: - Wow, is this a common case? > Java/Scala API d

[jira] [Created] (FLINK-2682) Add a dedicated processing time aligned keyed window operator

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2682: --- Summary: Add a dedicated processing time aligned keyed window operator Key: FLINK-2682 URL: https://issues.apache.org/jira/browse/FLINK-2682 Project: Flink Is

[jira] [Created] (FLINK-2680) Create a dedicated aligned-event time window operator

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2680: --- Summary: Create a dedicated aligned-event time window operator Key: FLINK-2680 URL: https://issues.apache.org/jira/browse/FLINK-2680 Project: Flink Issue Type:

[jira] [Created] (FLINK-2681) Scala API does not support Either type to be used as key

2015-09-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2681: Summary: Scala API does not support Either type to be used as key Key: FLINK-2681 URL: https://issues.apache.org/jira/browse/FLINK-2681 Project: Flink Issue

[jira] [Updated] (FLINK-2679) Scala API does not support Try type as key

2015-09-15 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2679: - Summary: Scala API does not support Try type as key (was: Scala API does not support Try type as

[jira] [Created] (FLINK-2679) Scala API does not support Try type as keys

2015-09-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2679: Summary: Scala API does not support Try type as keys Key: FLINK-2679 URL: https://issues.apache.org/jira/browse/FLINK-2679 Project: Flink Issue Type: Wish

[jira] [Updated] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2677: Description: This operator should support: - Customizable triggers - Eviction on triggers: all /

[jira] [Created] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys

2015-09-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2678: Summary: Java/Scala API does not support multi-dimensional arrays as keys Key: FLINK-2678 URL: https://issues.apache.org/jira/browse/FLINK-2678 Project: Flink

[jira] [Updated] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2677: Assignee: Aljoscha Krettek > Add a general-purpose keyed-window operator > -

[jira] [Created] (FLINK-2677) Add a general-purpose keyed-window operator

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2677: --- Summary: Add a general-purpose keyed-window operator Key: FLINK-2677 URL: https://issues.apache.org/jira/browse/FLINK-2677 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2676) Add abstraction for keyed window state

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2676: --- Summary: Add abstraction for keyed window state Key: FLINK-2676 URL: https://issues.apache.org/jira/browse/FLINK-2676 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-2668) ProjectOperator method to close projection

2015-09-15 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-2668: -- Description: I have come across an issue in my code where I called project(...) on a {{DataSet}} which

[jira] [Created] (FLINK-2675) Add utilities for scheduled triggers

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2675: --- Summary: Add utilities for scheduled triggers Key: FLINK-2675 URL: https://issues.apache.org/jira/browse/FLINK-2675 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-2674) Rework windowing logic

2015-09-15 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2674: --- Summary: Rework windowing logic Key: FLINK-2674 URL: https://issues.apache.org/jira/browse/FLINK-2674 Project: Flink Issue Type: Bug Components: Stre

[jira] [Created] (FLINK-2673) Scala API does not support Option type as key

2015-09-15 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2673: Summary: Scala API does not support Option type as key Key: FLINK-2673 URL: https://issues.apache.org/jira/browse/FLINK-2673 Project: Flink Issue Type: Wish

[jira] [Assigned] (FLINK-2667) Rework configuration parameters

2015-09-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2667: - Assignee: Maximilian Michels > Rework configuration parameters >

[jira] [Commented] (FLINK-2667) Rework configuration parameters

2015-09-15 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14745287#comment-14745287 ] Maximilian Michels commented on FLINK-2667: --- You're right. That's a shortcoming.

[GitHub] flink pull request: [FLINK1919] add HCatOutputFormat

2015-09-15 Thread jamescao
Github user jamescao commented on the pull request: https://github.com/apache/flink/pull/1079#issuecomment-140359144 @chiwanpark pr is now updated, I pull out code related to HCatInputFormat and incorporated Flink-2555 and Flink-2617. I also change the test environment to from `C

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

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

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

2015-09-15 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1127#issuecomment-140355813 Hi @chiwanpark, yes I think splitting it up makes sense. I just opened this PR to get some feedback and to show why my changes are necessary to integrate new input forma

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

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

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-09-15 Thread mliesenberg
Github user mliesenberg commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r39497481 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameter.java --- @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

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

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-09-15 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r39496768 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameter.java --- @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache Softwa

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

2015-09-15 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1129#issuecomment-140349703 Thanks for the update. Good to merge, IMO --- 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 pro

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

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

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-09-15 Thread mliesenberg
Github user mliesenberg commented on a diff in the pull request: https://github.com/apache/flink/pull/1097#discussion_r39496043 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameter.java --- @@ -0,0 +1,124 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

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

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-09-15 Thread mliesenberg
Github user mliesenberg commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-140348478 Ok, I will add that. --- 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] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

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

  1   2   >