[jira] [Commented] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

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

[GitHub] flink pull request: [FLINK-2446]Fix SocketTextStreamFunction has m...

2015-07-30 Thread ffbin
GitHub user ffbin opened a pull request: https://github.com/apache/flink/pull/965 [FLINK-2446]Fix SocketTextStreamFunction has memory leak when reconnect server When reconnect server failed, it should call socket.close() to avoid memory leak. You can merge this pull request into a

[jira] [Commented] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14648678#comment-14648678 ] ASF GitHub Bot commented on FLINK-2446: --- Github user ffbin closed the pull request a

[GitHub] flink pull request: [FLINK-2446] Fix SocketTextStreamFunction has ...

2015-07-30 Thread ffbin
Github user ffbin closed the pull request at: https://github.com/apache/flink/pull/964 --- 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 enable

[jira] [Commented] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

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

[GitHub] flink pull request: [FLINK-2446] Fix SocketTextStreamFunction has ...

2015-07-30 Thread ffbin
GitHub user ffbin opened a pull request: https://github.com/apache/flink/pull/964 [FLINK-2446] Fix SocketTextStreamFunction has memory leak when reconnect server When reconnect server failed, it should call socket.close() to avoid memory leak. You can merge this pull request into

[jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14648618#comment-14648618 ] ASF GitHub Bot commented on FLINK-2248: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout...

2015-07-30 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/957#issuecomment-126541106 @mxm , I've added unit tests to verify disabled logging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Created] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

2015-07-30 Thread fangfengbin (JIRA)
fangfengbin created FLINK-2446: -- Summary: SocketTextStreamFunction has memory leak when reconnect server Key: FLINK-2446 URL: https://issues.apache.org/jira/browse/FLINK-2446 Project: Flink Iss

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-07-30 Thread jamescao
Github user jamescao commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-126536010 Hi Chiwan Thanks for your comment! I was new to this community and I am not very familiar with the design conventions. 1. I was a little bit confused about t

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

2015-07-30 Thread ankurcha
Github user ankurcha commented on the pull request: https://github.com/apache/flink/pull/948#issuecomment-126522087 Clearly i don't know how to add stuff correctly to the .travis file. If I could get some help with that, it'll be great. @uce @StephanEwen - I haven't seen a re

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

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

[jira] [Created] (FLINK-2445) Add tests for HadoopOutputFormats

2015-07-30 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2445: Summary: Add tests for HadoopOutputFormats Key: FLINK-2445 URL: https://issues.apache.org/jira/browse/FLINK-2445 Project: Flink Issue Type: Test Co

[jira] [Created] (FLINK-2444) Add tests for HadoopInputFormats

2015-07-30 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2444: Summary: Add tests for HadoopInputFormats Key: FLINK-2444 URL: https://issues.apache.org/jira/browse/FLINK-2444 Project: Flink Issue Type: Test Com

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-126517321 @fhueske, I ran through the classes and tried to catch all occurrences of `match` and replaced them by `join`. Hopefully I did not miss something :) Moreover, I

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[jira] [Closed] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets

2015-07-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2238. Resolution: Fixed Assignee: Sachin Goel Fix Version/s: 0.9.1 0.10

[jira] [Commented] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets

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

[GitHub] flink pull request: [FLINK-2238][scala api]Add env.fromCollection(...

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

[jira] [Commented] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets

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

[GitHub] flink pull request: [FLINK-2238][scala api]Add env.fromCollection(...

2015-07-30 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/956#issuecomment-126509831 merging --- 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

[jira] [Commented] (FLINK-2442) PojoType fields not supported by field position keys

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

[GitHub] flink pull request: [FLINK-2442] [fix] FieldPositionKeys support P...

2015-07-30 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/963 [FLINK-2442] [fix] FieldPositionKeys support Pojo fields Add support to select tuple fields which are Pojo types by field position keys. You can merge this pull request into a Git repository by runn

[jira] [Created] (FLINK-2442) PojoType fields not supported by field position keys

2015-07-30 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2442: Summary: PojoType fields not supported by field position keys Key: FLINK-2442 URL: https://issues.apache.org/jira/browse/FLINK-2442 Project: Flink Issue Typ

[jira] [Comment Edited] (FLINK-2412) Index Out of Bounds Exception

2015-07-30 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14648170#comment-14648170 ] Andra Lungu edited comment on FLINK-2412 at 7/30/15 7:34 PM: -

[jira] [Commented] (FLINK-2412) Index Out of Bounds Exception

2015-07-30 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14648170#comment-14648170 ] Andra Lungu commented on FLINK-2412: Hi Ufuk, The fix has been tested and retested..

[jira] [Created] (FLINK-2441) [py] Introduce an OpInfo object on the python side

2015-07-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2441: --- Summary: [py] Introduce an OpInfo object on the python side Key: FLINK-2441 URL: https://issues.apache.org/jira/browse/FLINK-2441 Project: Flink Issue

[jira] [Created] (FLINK-2440) [py] Expand Environment feature coverage

2015-07-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2440: --- Summary: [py] Expand Environment feature coverage Key: FLINK-2440 URL: https://issues.apache.org/jira/browse/FLINK-2440 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-2439) [py] Expand DataSet feature coverage

2015-07-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2439: --- Summary: [py] Expand DataSet feature coverage Key: FLINK-2439 URL: https://issues.apache.org/jira/browse/FLINK-2439 Project: Flink Issue Type: Improvem

[GitHub] flink pull request: [FLINK-2437] Fix default constructor detection...

2015-07-30 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/960#issuecomment-126428191 Could you please add a test case that verifies the correct behaviour? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14648106#comment-14648106 ] ASF GitHub Bot commented on FLINK-2437: --- Github user gyfora commented on the pull re

[jira] [Commented] (FLINK-2432) [py] Provide support for custom serialization

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

[GitHub] flink pull request: [FLINK-2432] Custom serializer support

2015-07-30 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/962 [FLINK-2432] Custom serializer support Users can now use custom serializers in the Python API. The registration is done using env.register_custom_type(,, ) Objects serialized this way are exis

[jira] [Commented] (FLINK-2431) [py] refactor PlanBinder/OperationInfo

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

[GitHub] flink pull request: [FLINK-2431] Refactor PlanBinder/OperationInfo

2015-07-30 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/961 [FLINK-2431] Refactor PlanBinder/OperationInfo PlanBinder methods were restructured to make the class more readable. Keys are now stored as strings to simplify string-key-expression support.

[jira] [Resolved] (FLINK-2173) Python uses different tmp file than Flink

2015-07-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-2173. --- Resolution: Fixed Fix Version/s: 0.10 This should be resolved now on the master

[jira] [Resolved] (FLINK-1927) [Py] Rework operator distribution

2015-07-30 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-1927. --- Resolution: Fixed Fix Version/s: (was: 0.9) 0.10 Thanks

[GitHub] flink pull request: [FLINK-1927][py] Operator distribution rework

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

[jira] [Commented] (FLINK-1927) [Py] Rework operator distribution

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

[jira] [Created] (FLINK-2438) Improve performance of channel events

2015-07-30 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2438: --- Summary: Improve performance of channel events Key: FLINK-2438 URL: https://issues.apache.org/jira/browse/FLINK-2438 Project: Flink Issue Type: Bug C

[GitHub] flink pull request: [FLINK-2437] Fix default constructor detection...

2015-07-30 Thread ggevay
Github user ggevay commented on the pull request: https://github.com/apache/flink/pull/960#issuecomment-126398181 I removed the added "return null", I just realized that it is not needed. --- If your project is set up for it, you can reply to this email and have your reply appear on G

[jira] [Commented] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647918#comment-14647918 ] ASF GitHub Bot commented on FLINK-2437: --- Github user ggevay commented on the pull re

[jira] [Commented] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection

2015-07-30 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647915#comment-14647915 ] Gabor Gevay commented on FLINK-2437: I just realized that it is not a problem that ana

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-07-30 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-126380793 Hi @jamescao, thanks for your contribution. I read this pull request and have some comments about this. First, Test cases are insufficient. There is no test ca

[jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment

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

[jira] [Commented] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection

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

[GitHub] flink pull request: [FLINK-2437] Fix default constructor detection...

2015-07-30 Thread ggevay
GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/960 [FLINK-2437] Fix default constructor detection in TypeExtractor.analyzePojo - handle the case of a non-public default constructor - added a missing "return null" - removed some duplicating of t

[jira] [Created] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection

2015-07-30 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2437: -- Summary: TypeExtractor.analyzePojo has some problems around the default constructor detection Key: FLINK-2437 URL: https://issues.apache.org/jira/browse/FLINK-2437 Projec

[jira] [Commented] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID

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

[GitHub] flink pull request: [FLINK-2409] [webserver] Replaces ActorRefs wi...

2015-07-30 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/959 [FLINK-2409] [webserver] Replaces ActorRefs with ActorGateways in the web servers Replaces the `ActorRefs` used in the `WebInfoServer`, its servlets and the `WebRuntimeMonitor` with `ActorGatew

[jira] [Resolved] (FLINK-2324) Rework partitioned state storage

2015-07-30 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2324. --- Resolution: Fixed > Rework partitioned state storage > > >

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

2015-07-30 Thread Trevor Grant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647733#comment-14647733 ] Trevor Grant commented on FLINK-1994: - Hey, I'd like to check this out. > Add differe

[jira] [Commented] (FLINK-1919) Add HCatOutputFormat for Tuple data types

2015-07-30 Thread James Cao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647727#comment-14647727 ] James Cao commented on FLINK-1919: -- Thanks! > Add HCatOutputFormat for Tuple data types

[jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig

2015-07-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647726#comment-14647726 ] Robert Metzger commented on FLINK-2428: --- Has this been resolved in https://github.c

[jira] [Resolved] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API

2015-07-30 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2405. --- Resolution: Implemented > Add stateful transformations using lambdas to the Streaming Scala API >

[jira] [Commented] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed

2015-07-30 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647724#comment-14647724 ] Gyula Fora commented on FLINK-2010: --- I believe this is now covered by the different chec

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

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

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

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

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647602#comment-14647602 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-30 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-126320398 If no other comments I would like 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 well. If your pr

[GitHub] flink pull request: Cascading changes for compatibility

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

[jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust

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

[GitHub] flink pull request: [FLINK-2436] [streaming] Make ByteStreamStateH...

2015-07-30 Thread gyfora
GitHub user gyfora opened a pull request: https://github.com/apache/flink/pull/958 [FLINK-2436] [streaming] Make ByteStreamStateHandles more robust You can merge this pull request into a Git repository by running: $ git pull https://github.com/gyfora/flink filehandle Alternat

[jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust

2015-07-30 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647569#comment-14647569 ] Ufuk Celebi commented on FLINK-2436: +1 > Make ByteStreamStateHandles more robust > -

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

2015-07-30 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647551#comment-14647551 ] Andra Lungu commented on FLINK-2361: Hey, Sorry for the super late reply. I had a bi

[jira] [Commented] (FLINK-2412) Index Out of Bounds Exception

2015-07-30 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647546#comment-14647546 ] Ufuk Celebi commented on FLINK-2412: I found a race when releasing a partition and req

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-126304357 Thanks for the update @r-pogalz and @jkovacs! Looks really good. I would like to ask you for one more favor. As you might know, Join was previously called Match a

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

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

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-30 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-126302762 Yes, of course, that's nice. :smile: --- 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 doe

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863850 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeIterator.java --- @@ -138,63 +122,23 @@ public void abort() {

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863809 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeIterator.java --- @@ -138,63 +122,23 @@ public void abort() {

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863787 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeIterator.java --- @@ -138,63 +122,23 @@ public void abort() {

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[jira] [Created] (FLINK-2436) Make ByteStreamStateHandles more robust

2015-07-30 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2436: - Summary: Make ByteStreamStateHandles more robust Key: FLINK-2436 URL: https://issues.apache.org/jira/browse/FLINK-2436 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863699 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeInnerJoinIterator.java --- @@ -0,0 +1,108 @@ +/* + * Licens

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863686 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeInnerJoinIterator.java --- @@ -0,0 +1,108 @@ +/* + * Licens

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

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

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863659 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeInnerJoinIterator.java --- @@ -0,0 +1,108 @@ +/* + * Licens

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/907#discussion_r35863641 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeInnerJoinIterator.java --- @@ -0,0 +1,108 @@ +/* + * Licens

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-30 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-126296402 This is why I tried to make the interface general, to work simply with StateHandle-s. As that will most likely stay, we can implement the advanced logic on top of that.

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647519#comment-14647519 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-30 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-126296064 I think the changes are ok for now but we need to think hard about how we can unify incremental state, partitioned state, out-of-core state and scale-out/in in the futur

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

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

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-07-30 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/949#issuecomment-126296058 Thanks for your contribution @ChengXiangLi. I'll try to review your PR tomorrow morning. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

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

[jira] [Commented] (FLINK-2324) Rework partitioned state storage

2015-07-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647508#comment-14647508 ] ASF GitHub Bot commented on FLINK-2324: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che...

2015-07-30 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/937#issuecomment-126286471 No pressure --- 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 enab

[jira] [Commented] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets

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

[GitHub] flink pull request: [FLINK-2238][scala api]Add env.fromCollection(...

2015-07-30 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/956#issuecomment-126283207 Thanks for the update, @sachingoel0101! Good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

2015-07-30 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647456#comment-14647456 ] Chesnay Schepler commented on FLINK-2351: - does this issue only apply to IO-format

[jira] [Created] (FLINK-2435) Add support for custom CSV field parsers

2015-07-30 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2435: Summary: Add support for custom CSV field parsers Key: FLINK-2435 URL: https://issues.apache.org/jira/browse/FLINK-2435 Project: Flink Issue Type: New Featur

[jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException

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

[GitHub] flink pull request: [FLINK-2391]Fix Storm-compatibility FlinkTopol...

2015-07-30 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/940#issuecomment-126262365 Thanks for reporting the bug and providing a fix. --- 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 pr

  1   2   >