[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635011#comment-14635011 ] ASF GitHub Bot commented on FLINK-2371: --- Github user mxm commented on the pull

[jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

[ https://issues.apache.org/jira/browse/FLINK-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635016#comment-14635016 ] Ufuk Celebi commented on FLINK-1658: Regarding

[jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

[ https://issues.apache.org/jira/browse/FLINK-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635028#comment-14635028 ] Matthias J. Sax commented on FLINK-1658: I prefer to name abstract classes

[jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

[ https://issues.apache.org/jira/browse/FLINK-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635006#comment-14635006 ] Matthias J. Sax commented on FLINK-1658: I still see

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634800#comment-14634800 ] Till Rohrmann commented on FLINK-1901: -- Oh I forgot. Sorry. What about the iteration

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634797#comment-14634797 ] Sachin Goel commented on FLINK-1901: [~trohrm...@apache.org], this is already a part

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/925#discussion_r35080434 --- Diff: flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java --- @@ -109,125 +123,157 @@ public void testProgram() throws

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634772#comment-14634772 ] ASF GitHub Bot commented on FLINK-2371: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/925#discussion_r35080374 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -400,20 +400,16 @@ class JobManager( import

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634773#comment-14634773 ] ASF GitHub Bot commented on FLINK-2371: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/925#discussion_r35081074 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -400,20 +400,16 @@ class JobManager(

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634826#comment-14634826 ] Till Rohrmann commented on FLINK-1901: -- To be honest, I doubt that the sampling is

[GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/892#issuecomment-123236061 Hi @shghatge, let me try to explain the implementation in detail here :) First of all, can you change this to a library method instead of an example? The

[jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

[ https://issues.apache.org/jira/browse/FLINK-1658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634847#comment-14634847 ] Matthias J. Sax commented on FLINK-1658: Can this issue be tackled now? Rename

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634853#comment-14634853 ] ASF GitHub Bot commented on FLINK-1967: --- Github user gyfora commented on the pull

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634862#comment-14634862 ] ASF GitHub Bot commented on FLINK-2371: --- Github user mxm commented on the pull

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/925#issuecomment-123243258 I've updated the pull request: - add flag to FlinkMiniCluster to disabled asynchronous execution of futures via the CallingThreadDispatcher - revert changes to

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634787#comment-14634787 ] ASF GitHub Bot commented on FLINK-2371: --- Github user tillrohrmann commented on a

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634802#comment-14634802 ] Sachin Goel commented on FLINK-1901: I didn't think there would be any such issue

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634822#comment-14634822 ] Chengxiang Li commented on FLINK-1901: -- Hi, [~sachingoel0101], I didn't find any

[jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example

[ https://issues.apache.org/jira/browse/FLINK-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634839#comment-14634839 ] ASF GitHub Bot commented on FLINK-2310: --- Github user vasia commented on the pull

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/906#issuecomment-123241744 I think you should go ahead with it. The sooner it is in the more testing it gets :) --- If your project is set up for it, you can reply to this email and have your

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634628#comment-14634628 ] Chengxiang Li commented on FLINK-1901: -- Hi, [~tvas], i would like to contribute on

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1901: - Assignee: Chengxiang Li Create sample operator for Dataset --

[jira] [Commented] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635100#comment-14635100 ] Sachin Goel commented on FLINK-2312: [~albermax], usually, when the ratios are not too

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635102#comment-14635102 ] Sachin Goel commented on FLINK-1901: Yes. I do agree. I'll see if what I've written

[GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/913#issuecomment-123304832 @fhueske Are you still available for writing the section about the batch API? Or is this void now due to recent events? :smile_cat: --- If your project is set up for

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635105#comment-14635105 ] ASF GitHub Bot commented on FLINK-2363: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/642#issuecomment-123306327 Hi @rainiraj. We want to rework and unify client code. This PR would be part of it. Can you update your code soon so it can be merged? Otherwise, it might get reworked by

[jira] [Commented] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635095#comment-14635095 ] Sachin Goel commented on FLINK-2312: While trying to generalize to any type, I

[jira] [Commented] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log file can't auto be recovered/detected after mistaking delete

[ https://issues.apache.org/jira/browse/FLINK-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635093#comment-14635093 ] Stephan Ewen commented on FLINK-2367: - I think this is simply the default Unix

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635082#comment-14635082 ] Sachin Goel commented on FLINK-1901: Okay. So I checked the whole code and well, the

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

[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635096#comment-14635096 ] Till Rohrmann commented on FLINK-1901: -- The problem is that a sampling operator

[jira] [Commented] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source

[ https://issues.apache.org/jira/browse/FLINK-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635097#comment-14635097 ] Stephan Ewen commented on FLINK-2325: - I think the latest version of the master should

[jira] [Comment Edited] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635095#comment-14635095 ] Sachin Goel edited comment on FLINK-2312 at 7/21/15 1:21 PM: -

[jira] [Comment Edited] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635095#comment-14635095 ] Sachin Goel edited comment on FLINK-2312 at 7/21/15 1:21 PM: -

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/925#issuecomment-123326290 +1, looks good --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635169#comment-14635169 ] ASF GitHub Bot commented on FLINK-2377: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2377] Add reader.close() to readAllResu...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/924#issuecomment-123326390 +1, will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635167#comment-14635167 ] ASF GitHub Bot commented on FLINK-2371: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635171#comment-14635171 ] Stephan Ewen commented on FLINK-2380: - How much of an inconvenience is? Allow to

[GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/922#issuecomment-123330725 Looks good, will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation

[ https://issues.apache.org/jira/browse/FLINK-2362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635173#comment-14635173 ] ASF GitHub Bot commented on FLINK-2362: --- Github user StephanEwen commented on the

[jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635188#comment-14635188 ] ASF GitHub Bot commented on FLINK-2371: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635192#comment-14635192 ] pietro pinoli commented on FLINK-2312: -- [~sachingoel0101] I may be very wrong, but

[GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase

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

<    1   2