[jira] [Commented] (FLINK-2398) Decouple StreamGraph Building from the API

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

[GitHub] flink pull request: [FLINK-2314]

GitHub user sheetalparade opened a pull request: https://github.com/apache/flink/pull/997 [FLINK-2314] [FLINK-2314] - Added checkpointing feature into File Source You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660703#comment-14660703 ] ASF GitHub Bot commented on FLINK-2314: --- GitHub user sheetalparade opened a pull

[jira] [Commented] (FLINK-1138) Allow users to specify methods instead of fields in key expressions

[ https://issues.apache.org/jira/browse/FLINK-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660700#comment-14660700 ] Fabian Hueske commented on FLINK-1138: -- +1 for won't fix Allow users to specify

[jira] [Created] (FLINK-2491) Operators are not participating in state checkpointing in some cases

Robert Metzger created FLINK-2491: - Summary: Operators are not participating in state checkpointing in some cases Key: FLINK-2491 URL: https://issues.apache.org/jira/browse/FLINK-2491 Project: Flink

[jira] [Commented] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket

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

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

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/962#discussion_r36395811 --- Diff: flink-staging/flink-language-binding/flink-python/src/test/python/org/apache/flink/languagebinding/api/python/flink/test/test_custom.py --- @@ -0,0

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

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

[GitHub] flink pull request: [FLINK-2490][FIX]Remove the retryForever check...

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/992#issuecomment-128309202 If you think it was necessary why was your first step to remove it's usage... --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket

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

[jira] [Commented] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket

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

[GitHub] flink pull request: [FLINK-2490][FIX]Remove the retryForever check...

Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/992#issuecomment-128322151 Hah Sorry, this thought was generated after this PR. --- 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-2494) Fix StreamGraph getJobGraph bug

fangfengbin created FLINK-2494: -- Summary: Fix StreamGraph getJobGraph bug Key: FLINK-2494 URL: https://issues.apache.org/jira/browse/FLINK-2494 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2494) Fix StreamGraph getJobGraph bug

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

[GitHub] flink pull request: [FLINK-2494 ]Fix StreamGraph getJobGraph bug

Github user zentol commented on the pull request: https://github.com/apache/flink/pull/998#issuecomment-128605743 i would assume that forceCheckpoint is supposed to do exactly that, enforce checkpointing regardless of its support. this change also means that if checkPointint

[GitHub] flink pull request: Fix StreamGraph getJobGraph bug

GitHub user ffbin opened a pull request: https://github.com/apache/flink/pull/998 Fix StreamGraph getJobGraph bug When forceCheckpoint is true,checkpointing will be enabled for iterative jobs.But now temporarily forbid checkpointing for iterative jobs, so if forceCheckpoint is

[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=14661258#comment-14661258 ] ASF GitHub Bot commented on FLINK-1901: --- Github user ChengXiangLi commented on the

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

Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/949#issuecomment-128580607 Hi, @tillrohrmann , current implementation of sample with fixed size would generate fixed size sample for each partition randomly instead of the whole dataset, user

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

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

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128563750 Thanks for the review, @StephanEwen , i'm very interesting in this project, and i would like to contribute more. @vasia , I think stephan has helped to answer the

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request: [FLINK-2314]

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/997#discussion_r36478648 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileSourceFunction.java --- @@

[jira] [Resolved] (FLINK-2464) BufferSpillerTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2464. - Resolution: Duplicate Problem is tracked in [FLINK-2466] BufferSpillerTest sometimes fails

[jira] [Closed] (FLINK-2464) BufferSpillerTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2464. --- BufferSpillerTest sometimes fails - Key: FLINK-2464

[jira] [Commented] (FLINK-2466) Travis build failure

[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659928#comment-14659928 ] Stephan Ewen commented on FLINK-2466: - If someone could double check whether they see

[jira] [Comment Edited] (FLINK-2466) Travis build failure

[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659928#comment-14659928 ] Stephan Ewen edited comment on FLINK-2466 at 8/6/15 12:29 PM: --

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[jira] [Commented] (FLINK-2466) Travis build failure

[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659904#comment-14659904 ] Stephan Ewen commented on FLINK-2466: - It is the BarrierBufferMassiveRandomTest again.

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36408610 --- Diff:

[jira] [Created] (FLINK-2492) Rename remaining runtime classes from match to join

Stephan Ewen created FLINK-2492: --- Summary: Rename remaining runtime classes from match to join Key: FLINK-2492 URL: https://issues.apache.org/jira/browse/FLINK-2492 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2466) Travis build failure

[ https://issues.apache.org/jira/browse/FLINK-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659893#comment-14659893 ] Sachin Goel commented on FLINK-2466: Most of my builds are still failing too.

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36408368 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple0Builder.java --- @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36408488 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/Tuple0Serializer.java --- @@ -0,0 +1,86 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36411464 --- Diff:

[jira] [Updated] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2491: -- Description: While implementing a test case for the Kafka Consumer, I came across the

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[GitHub] flink pull request: [FLINK-2307] Drop Java 6 support

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/993 [FLINK-2307] Drop Java 6 support This pull request updates Travis to use only openjdk7, oraclejdk7, and oraclejdk8 for tests. Root pom and quickstarts poms bump the Java version to 1.7.

[jira] [Commented] (FLINK-2307) Drop Java 6 support

[ https://issues.apache.org/jira/browse/FLINK-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659963#comment-14659963 ] ASF GitHub Bot commented on FLINK-2307: --- GitHub user StephanEwen opened a pull

[jira] [Reopened] (FLINK-2464) BufferSpillerTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reopened FLINK-2464: --- Thanks for the fix, [~StephanEwen]. Unfortunately I still see tests of the

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36408352 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple0Builder.java --- @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-128350696 Some comments inline, other than that, two issues with this pull request: - A lot of whitespace reformatting. We explicitly ask not to do this. Some IDEs do it

[jira] [Commented] (FLINK-2307) Drop Java 6 support

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

[jira] [Commented] (FLINK-2457) Integrate Tuple0

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

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128441993 This was a super cool contribution. A pretty sophisticated addition, super testing, high code quality. I am very impressed! I hope you will contribute

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

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

[ https://issues.apache.org/jira/browse/FLINK-2444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660371#comment-14660371 ] James Cao commented on FLINK-2444: -- Hi, for a sufficient test, what's the expected

[jira] [Commented] (FLINK-981) Support for generated Cloudera Hadoop configuration

[ https://issues.apache.org/jira/browse/FLINK-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660492#comment-14660492 ] Robert Metzger commented on FLINK-981: -- I will close this issue for now. No user every

[jira] [Created] (FLINK-2493) Simplify names of example program JARs

Stephan Ewen created FLINK-2493: --- Summary: Simplify names of example program JARs Key: FLINK-2493 URL: https://issues.apache.org/jira/browse/FLINK-2493 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128440090 Manually merged in 61dcae391cb3b45ba3aff47d4d9163889d2958a4 I added a commit on top to pass the flag to enable/disable bloom filters through the runtime

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

[jira] [Closed] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group)

[ https://issues.apache.org/jira/browse/FLINK-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-100. -- Pact API Proposal: Add keyless CoGroup (send all to a single group)

[jira] [Resolved] (FLINK-202) Workset Iterations: No Match Found Behaviour of Solution Set Join

[ https://issues.apache.org/jira/browse/FLINK-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-202. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.8.0 Solution set

[jira] [Commented] (FLINK-655) Add support for both single and set of broadcast values

[ https://issues.apache.org/jira/browse/FLINK-655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660395#comment-14660395 ] Stephan Ewen commented on FLINK-655: Will this still be done, or should we close it as

[jira] [Resolved] (FLINK-915) Introduce two in one progress bars

[ https://issues.apache.org/jira/browse/FLINK-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-915. Resolution: Invalid Fix Version/s: (was: pre-apache) Outdated and subsumed by new Task

[jira] [Closed] (FLINK-915) Introduce two in one progress bars

[ https://issues.apache.org/jira/browse/FLINK-915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-915. -- Introduce two in one progress bars -- Key: FLINK-915

[jira] [Resolved] (FLINK-1082) WebClient improvements

[ https://issues.apache.org/jira/browse/FLINK-1082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1082. - Resolution: Done Remaining issues will not be fixed. Remainder is subsumed by new web frontend

[jira] [Resolved] (FLINK-1083) WebInterface improvements

[ https://issues.apache.org/jira/browse/FLINK-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1083. - Resolution: Done Remainder is subsumed by new web frontend [FLINK-2357] WebInterface

[jira] [Closed] (FLINK-1082) WebClient improvements

[ https://issues.apache.org/jira/browse/FLINK-1082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1082. --- WebClient improvements -- Key: FLINK-1082 URL:

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128442757 Oh, I forgot to add the closing message to the commit, so the ASF bot did not close the pull request. Can you close the pull request manually (only you as the owner

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

[ https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-7: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-598 [GitHub] Enable Range Partitioner

[GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r...

Github user vasia commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128445757 Hi, this looks great indeed! Just out of curiosity, why did you write your own bloom filter implementation and not use a ready one, e.g. from guava? I'm

[jira] [Closed] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address

[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-938. -- Change start-cluster.sh script so that users don't have to configure the JobManager address

[jira] [Commented] (FLINK-2492) Rename remaining runtime classes from match to join

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

[GitHub] flink pull request: [FLINK-2492] [runtime] Rename former 'match' c...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/995#issuecomment-128439329 Manually merged in 685086a3dd9afcec2eec76485298bc7b3f031a3c --- 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-2240] Use BloomFilter to filter probe r...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/888#issuecomment-128446267 The bloom filters are stored in subregions of Flink's memory segments, not in any additional memory. That is very nice (occupies no extra memory), but

[jira] [Resolved] (FLINK-266) Warn user if cluster did not come up as expected

[ https://issues.apache.org/jira/browse/FLINK-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-266. Resolution: Won't Fix Fix Version/s: (was: pre-apache) The deployment model is different

[jira] [Closed] (FLINK-202) Workset Iterations: No Match Found Behaviour of Solution Set Join

[ https://issues.apache.org/jira/browse/FLINK-202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-202. -- Workset Iterations: No Match Found Behaviour of Solution Set Join

[jira] [Closed] (FLINK-266) Warn user if cluster did not come up as expected

[ https://issues.apache.org/jira/browse/FLINK-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-266. -- Warn user if cluster did not come up as expected

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

[jira] [Resolved] (FLINK-2492) Rename remaining runtime classes from match to join

[ https://issues.apache.org/jira/browse/FLINK-2492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2492. - Resolution: Fixed Fixed via 685086a3dd9afcec2eec76485298bc7b3f031a3c Rename remaining runtime

[jira] [Closed] (FLINK-2492) Rename remaining runtime classes from match to join

[ https://issues.apache.org/jira/browse/FLINK-2492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2492. --- Rename remaining runtime classes from match to join

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

[GitHub] flink pull request: [WIP][FLINK-2386] Add new Kafka Consumers

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/996 [WIP][FLINK-2386] Add new Kafka Consumers I'm opening a WIP pull request (against our rules) to get some feedback on my ongoing work. Please note that I'm on vacation next week (until August

[jira] [Resolved] (FLINK-854) Web interface: show runtime of subtasks

[ https://issues.apache.org/jira/browse/FLINK-854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-854. Resolution: Won't Fix Fix Version/s: (was: pre-apache) Subsumed by effort for the new web

[jira] [Closed] (FLINK-854) Web interface: show runtime of subtasks

[ https://issues.apache.org/jira/browse/FLINK-854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-854. -- Web interface: show runtime of subtasks --- Key:

[jira] [Resolved] (FLINK-871) Create a documentation distribution together with other release artifacts

[ https://issues.apache.org/jira/browse/FLINK-871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-871. Resolution: Fixed Fix Version/s: (was: pre-apache) Documentation is part of the source

[jira] [Resolved] (FLINK-1013) ArithmeticException: / by zero in MutableHashTable

[ https://issues.apache.org/jira/browse/FLINK-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1013. - Resolution: Fixed Assignee: Stephan Ewen Fix Version/s: 0.9 Fixed already a while

[jira] [Closed] (FLINK-1013) ArithmeticException: / by zero in MutableHashTable

[ https://issues.apache.org/jira/browse/FLINK-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1013. --- ArithmeticException: / by zero in MutableHashTable --

[jira] [Resolved] (FLINK-509) Move virtual machines building process / hosting to Amazon S3 / EC2

[ https://issues.apache.org/jira/browse/FLINK-509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-509. Resolution: Invalid Fix Version/s: (was: pre-apache) No virtual machine images are built

[jira] [Closed] (FLINK-509) Move virtual machines building process / hosting to Amazon S3 / EC2

[ https://issues.apache.org/jira/browse/FLINK-509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-509. -- Move virtual machines building process / hosting to Amazon S3 / EC2

[jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

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

[jira] [Commented] (FLINK-2452) Add a playcount threshold to the MusicProfiles example

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

[jira] [Closed] (FLINK-848) Move combine() from GroupReduceFunction to Interface

[ https://issues.apache.org/jira/browse/FLINK-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-848. -- Move combine() from GroupReduceFunction to Interface

[GitHub] flink pull request: [FLINK-2452] [Gelly] adds a playcount threshol...

Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/968#issuecomment-128456801 Nope, no comment. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Resolved] (FLINK-848) Move combine() from GroupReduceFunction to Interface

[ https://issues.apache.org/jira/browse/FLINK-848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-848. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.7.1-incubating

[jira] [Closed] (FLINK-701) Change new Java API functions to SAMs

[ https://issues.apache.org/jira/browse/FLINK-701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-701. -- Change new Java API functions to SAMs - Key:

[jira] [Closed] (FLINK-967) Make intermediate results a first-class citizen in the JobGraph

[ https://issues.apache.org/jira/browse/FLINK-967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-967. -- Make intermediate results a first-class citizen in the JobGraph

[jira] [Commented] (FLINK-981) Support for generated Cloudera Hadoop configuration

[ https://issues.apache.org/jira/browse/FLINK-981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660484#comment-14660484 ] Stephan Ewen commented on FLINK-981: Is this still valid, or is this fixed already by

[jira] [Resolved] (FLINK-1116) Packaged Scala Examples do not work due to missing test data

[ https://issues.apache.org/jira/browse/FLINK-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1116. - Resolution: Invalid Scala examples are not packaged any more (redundancy with java examples)

[jira] [Closed] (FLINK-1116) Packaged Scala Examples do not work due to missing test data

[ https://issues.apache.org/jira/browse/FLINK-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1116. --- Packaged Scala Examples do not work due to missing test data

[jira] [Closed] (FLINK-1083) WebInterface improvements

[ https://issues.apache.org/jira/browse/FLINK-1083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1083. --- WebInterface improvements - Key: FLINK-1083

[jira] [Commented] (FLINK-1135) Blog post with topic Accessing Data Stored in Hive with Flink

[ https://issues.apache.org/jira/browse/FLINK-1135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660516#comment-14660516 ] Stephan Ewen commented on FLINK-1135: - I this still going to happen? Blog post with

[jira] [Resolved] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

[ https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2240. - Resolution: Implemented Fix Version/s: 0.10 Implemented in

[jira] [Closed] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

[ https://issues.apache.org/jira/browse/FLINK-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2240. --- Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join

  1   2   >