[jira] [Commented] (FLINK-2030) Implement an online histogram with Merging and equalization features

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

[GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/861#discussion_r38616759 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/accumulators/ContinuousHistogram.java --- @@ -0,0 +1,490 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api

[ https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14728338#comment-14728338 ] ASF GitHub Bot commented on FLINK-2480: --- Github user HuangWHWHW commented on the pul

[GitHub] flink pull request: [FLINK-2480][test]add a test for Print Sink wi...

Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/1073#issuecomment-137289902 @mxm @StephanEwen Hi,I squashed commits into one but it seems that the CI doesn't run. Any other way to do? --- If your project is set up for it, you can

[jira] [Updated] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler

[ https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2605: -- Attachment: flink-2605-v1.txt Can I use try-with-resources ? > Unclosed RandomAccessFile may leak resource in S

[jira] [Commented] (FLINK-1674) Add test with nested avro type

[ https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727925#comment-14727925 ] Ozturk Gokal commented on FLINK-1674: - If no one is working on this issue, I would lik

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

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727885#comment-14727885 ] ASF GitHub Bot commented on FLINK-2493: --- GitHub user chenliang613 opened a pull requ

[GitHub] flink pull request: [FLINK-2493] Simplify names of example program...

GitHub user chenliang613 opened a pull request: https://github.com/apache/flink/pull/1087 [FLINK-2493] Simplify names of example program JARs The names of the example JARs under build-target/examples have some confusion, the version number might stop users from submitting examples t

[GitHub] flink pull request: [Flink 2493] Simplify names of example program...

Github user chenliang613 closed the pull request at: https://github.com/apache/flink/pull/1086 --- 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: [Flink 2493] Simplify names of example program...

GitHub user chenliang613 reopened a pull request: https://github.com/apache/flink/pull/1086 [Flink 2493] Simplify names of example program JARs The names of the example JARs under build-target/examples have some confusion, the version number might stop users from submitting examples

[jira] [Closed] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

[ https://issues.apache.org/jira/browse/FLINK-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2610. -- Resolution: Duplicate Not all features are supported yet. See here for details https://github.c

[GitHub] flink pull request: [Flink 2493] Simplify names of example program...

Github user chenliang613 closed the pull request at: https://github.com/apache/flink/pull/1086 --- 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: [Flink 2493] Simplify names of example program...

GitHub user chenliang613 opened a pull request: https://github.com/apache/flink/pull/1086 [Flink 2493] Simplify names of example program JARs The names of the example JARs under build-target/examples have some confusion, the version number might stop users from submitting examples t

[jira] [Updated] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

[ https://issues.apache.org/jira/browse/FLINK-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Jerry Peng updated FLINK-2610: - Description: In the method: public final void run(final SourceContext ctx) throws Except

[jira] [Created] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

Boyang Jerry Peng created FLINK-2610: Summary: run method in AbstractStormSpoutWrapper causes NPE Key: FLINK-2610 URL: https://issues.apache.org/jira/browse/FLINK-2610 Project: Flink Issu

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

[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727633#comment-14727633 ] ASF GitHub Bot commented on FLINK-2373: --- Github user akunft commented on a diff in t

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

Github user akunft commented on a diff in the pull request: https://github.com/apache/flink/pull/1066#discussion_r38556752 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/RemoteEnvironmentITCase.java --- @@ -0,0 +1,166 @@ +/* + * Licensed to the

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

[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727628#comment-14727628 ] ASF GitHub Bot commented on FLINK-2373: --- Github user akunft commented on a diff in t

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

Github user akunft commented on a diff in the pull request: https://github.com/apache/flink/pull/1066#discussion_r38556479 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/RemoteEnvironmentITCase.java --- @@ -0,0 +1,166 @@ +/* + * Licensed to the

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

[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727608#comment-14727608 ] ASF GitHub Bot commented on FLINK-2373: --- Github user akunft commented on the pull re

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

Github user akunft commented on the pull request: https://github.com/apache/flink/pull/1066#issuecomment-137165900 Yes, I didn't enforce that the config parameter is not used, but the setParallelism overrides it. I let it like this, as it is more confusing to the user if all this i

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

[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727604#comment-14727604 ] ASF GitHub Bot commented on FLINK-2373: --- Github user tillrohrmann commented on a dif

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

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1066#discussion_r38555428 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/RemoteEnvironmentITCase.java --- @@ -0,0 +1,166 @@ +/* + * Licensed t

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-137164902 Thanks :-) On Wed, Sep 2, 2015 at 6:39 PM, Gianmarco De Francisci Morales < notificati...@github.com> wrote: > @tillrohrmann

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727601#comment-14727601 ] ASF GitHub Bot commented on FLINK-1725: --- Github user tillrohrmann commented on the p

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

[ https://issues.apache.org/jira/browse/FLINK-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727598#comment-14727598 ] ASF GitHub Bot commented on FLINK-2373: --- Github user akunft commented on a diff in t

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

Github user akunft commented on a diff in the pull request: https://github.com/apache/flink/pull/1066#discussion_r38554964 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/RemoteEnvironmentITCase.java --- @@ -0,0 +1,166 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

Github user gdfm commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-137163339 @tillrohrmann here a paper that describes the effect for a very similar setting: http://www.eecs.harvard.edu/~michaelm/postscripts/tpds2001.pdf The same arguments ap

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727596#comment-14727596 ] ASF GitHub Bot commented on FLINK-1725: --- Github user gdfm commented on the pull requ

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-137156333 @gdfm, could you please explain to me why 1 to 2 gives you an exponential gain (what kind of gain? reduction in data skew?) and anything further only a gain by a co

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727584#comment-14727584 ] ASF GitHub Bot commented on FLINK-1725: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-2607][quickstart] ignore signature file...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1085 --- 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] [Closed] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

[ https://issues.apache.org/jira/browse/FLINK-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2607. - Resolution: Fixed > Shade plugin copies signature files from original jar into fat jar > -

[jira] [Commented] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

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

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

[ https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727565#comment-14727565 ] ASF GitHub Bot commented on FLINK-2583: --- Github user tillrohrmann commented on the p

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

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-137148970 What about renaming the files upon checkpointing? I mean not triggering the rolling mechanism but to write the current temp file as the latest part and start a new

[jira] [Commented] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727561#comment-14727561 ] Márton Balassi commented on FLINK-2474: --- I have not actually seen this test fail in

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727545#comment-14727545 ] ASF GitHub Bot commented on FLINK-1725: --- Github user gdfm commented on the pull requ

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

Github user gdfm commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-137144309 Sure, you can connect multiple containers. But while the gain you have from going from 1 to 2 is exponential, the gain from 2 to 3 and forward is just a constant factor.

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

[ https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727543#comment-14727543 ] 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 ...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-137144072 Should be, but then we can also just keep them in memory and write when checkpointing. But this has more potential of blowing up because OOM. --- If your project is se

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

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-137143368 Concerning the second short term option: Is the problem there that the checkpointing is not aligned with the rolling? Thus, you can take a checkpoint but you still

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

[ https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727540#comment-14727540 ] ASF GitHub Bot commented on FLINK-2583: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-137140076 @gdfm, thanks for the great explanation. A good way to visualize what's happening. I'm just wondering why you shouldn't be able to connect more than 2 cont

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727532#comment-14727532 ] ASF GitHub Bot commented on FLINK-1725: --- Github user tillrohrmann commented on the p

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

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-137125224 If it fails in the middle of writing or before sync/flush is called on the writer then the data can be in an inconsistent state. I see three ways of dealing with this,

[jira] [Created] (FLINK-2609) Automatic type registration is only called from the batch execution environment

Robert Metzger created FLINK-2609: - Summary: Automatic type registration is only called from the batch execution environment Key: FLINK-2609 URL: https://issues.apache.org/jira/browse/FLINK-2609 Proje

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

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

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727471#comment-14727471 ] ASF GitHub Bot commented on FLINK-2488: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-137116109 Travis Passes successfully. https://travis-ci.org/apache/flink/builds/78368635 --- If your project is set up for it, you can reply to this email and have your re

[GitHub] flink pull request: [FLINK-2161] modified Scala shell start script...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/805#issuecomment-137104511 Sorry, it fell behind in the long list of Pull Requests. I'll check it and will merge it if Travis gives a green light. --- If your project is set up for it, you

[jira] [Commented] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML)

[ https://issues.apache.org/jira/browse/FLINK-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727426#comment-14727426 ] ASF GitHub Bot commented on FLINK-2161: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727411#comment-14727411 ] Stephan Ewen commented on FLINK-2602: - Actually, I saw this in one spot that was actua

[GitHub] flink pull request: [FLINK-2493] Simplify names of example program...

Github user chenliang613 commented on the pull request: https://github.com/apache/flink/pull/1068#issuecomment-137098642 @StephanEwen yes. may use another solution :) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

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

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727409#comment-14727409 ] ASF GitHub Bot commented on FLINK-2493: --- Github user chenliang613 commented on the p

[jira] [Commented] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler

[ https://issues.apache.org/jira/browse/FLINK-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727404#comment-14727404 ] Stephan Ewen commented on FLINK-2605: - Good observation, thank you! Do you want to pr

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727399#comment-14727399 ] ASF GitHub Bot commented on FLINK-1725: --- Github user gdfm commented on the pull requ

[GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ...

Github user gdfm commented on the pull request: https://github.com/apache/flink/pull/1069#issuecomment-137096426 @tillrohrmann the reason why 2 is a "magic number" is the following. Immagine channels as containers, and the load (the incoming data stream) as a liquid. When a key

[jira] [Closed] (FLINK-2601) IOManagerAsync may produce NPE during shutdown

[ https://issues.apache.org/jira/browse/FLINK-2601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2601. --- > IOManagerAsync may produce NPE during shutdown > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727394#comment-14727394 ] ASF GitHub Bot commented on FLINK-2493: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2607][quickstart] ignore signature file...

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

[jira] [Commented] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

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

[GitHub] flink pull request: [FLINK-2493] Simplify names of example program...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1068#issuecomment-137095444 @chenliang613 Do you want to open another poll request with the fix? --- If your project is set up for it, you can reply to this email and have your reply appear on

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

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-137094936 Looks very good from a first glance! Can you explain how the writing behaves in cases of failues? Will it start a new file? Will it try to append to the prev

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

[ https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727391#comment-14727391 ] ASF GitHub Bot commented on FLINK-2583: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

[ https://issues.apache.org/jira/browse/FLINK-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727385#comment-14727385 ] ASF GitHub Bot commented on FLINK-2607: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-2607][quickstart] ignore signature file...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1085#issuecomment-137093481 Very good fix! +1 to merge both into `master` and `0.10-milestone1`. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Resolved] (FLINK-2601) IOManagerAsync may produce NPE during shutdown

[ https://issues.apache.org/jira/browse/FLINK-2601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2601. - Resolution: Fixed Fix Version/s: 0.10 Fixed via dd9979f8ffc7de178968298d8c21df7315633e9b >

[jira] [Closed] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

[ https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2545. --- > NegativeArraySizeException while creating hash table bloom filters > ---

[jira] [Resolved] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

[ https://issues.apache.org/jira/browse/FLINK-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2545. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 2e6e4de5d1d2b5123f4311493763fd84f52779ab T

[jira] [Closed] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

[ https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2448. --- > registerCacheFile fails with MultipleProgramsTestbase >

[jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

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

[jira] [Resolved] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

[ https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2448. - Resolution: Fixed Fix Version/s: 0.10 Fixed via 166b3705c9079efafe9217d98e7edaf54e6a84cf >

[jira] [Commented] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters

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

[GitHub] flink pull request: [FLINK-2448]Create new Test environments on ge...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1031 --- 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-2545] add bucket member count verificat...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1067 --- 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-2607) Shade plugin copies signature files from original jar into fat jar

[ https://issues.apache.org/jira/browse/FLINK-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727364#comment-14727364 ] ASF GitHub Bot commented on FLINK-2607: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2607][quickstart] ignore signature file...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1085#issuecomment-137088288 During a Flink training, many people were experiencing this problem. I'd also like to merge this to the Milestone branch. --- If your project is set up for it, you can repl

[GitHub] flink pull request: [FLINK-2493] Simplify names of example program...

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

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

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727359#comment-14727359 ] ASF GitHub Bot commented on FLINK-2493: --- Github user chenliang613 closed the pull re

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

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

[jira] [Commented] (FLINK-2603) Flink hangs before starting execution

[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727334#comment-14727334 ] Stephan Ewen commented on FLINK-2603: - Is the join now hanging or was it hanging befor

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

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1064#issuecomment-137080649 @jamescao: It seems that you also wrote tests for the HCatInputFormat, right? is it possible to split the PR into a OutputFormat part and open a separate PR for the HCat

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727328#comment-14727328 ] Behrouz Derakhshan commented on FLINK-2021: --- First I will have a look at a coupl

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727331#comment-14727331 ] Robert Metzger commented on FLINK-2021: --- Sure ;) > Rework examples to use new Param

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

[ https://issues.apache.org/jira/browse/FLINK-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727311#comment-14727311 ] ASF GitHub Bot commented on FLINK-2410: --- Github user twalthr commented on a diff in

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

Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/943#discussion_r38529490 --- Diff: flink-staging/flink-table/src/test/java/org/apache/flink/api/java/table/test/PojoGroupingITCase.java --- @@ -0,0 +1,109 @@ +/* + * Licensed

[jira] [Comment Edited] (FLINK-2603) Flink hangs before starting execution

[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727286#comment-14727286 ] Greg Hogan edited comment on FLINK-2603 at 9/2/15 12:58 PM: Th

[jira] [Comment Edited] (FLINK-2603) Flink hangs before starting execution

[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727286#comment-14727286 ] Greg Hogan edited comment on FLINK-2603 at 9/2/15 12:54 PM: Th

[jira] [Commented] (FLINK-2603) Flink hangs before starting execution

[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727286#comment-14727286 ] Greg Hogan commented on FLINK-2603: --- Thanks, [~StephanEwen]. Changing {code}akka.framesi

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727226#comment-14727226 ] Robert Metzger commented on FLINK-2021: --- No, I think nobody is working on this. Bef

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727212#comment-14727212 ] Behrouz Derakhshan commented on FLINK-2021: --- Hi Robert, If no one has picked th

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

[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727191#comment-14727191 ] Martin Liesenberg commented on FLINK-2017: -- OK, thanks for the feedback, I hope t

[jira] [Created] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

Maximilian Michels created FLINK-2608: - Summary: Arrays.asList(..) does not work with CollectionInputFormat Key: FLINK-2608 URL: https://issues.apache.org/jira/browse/FLINK-2608 Project: Flink

[jira] [Commented] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

[ https://issues.apache.org/jira/browse/FLINK-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727142#comment-14727142 ] ASF GitHub Bot commented on FLINK-2607: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-2607][quickstart] ignore signature file...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1085 [FLINK-2607][quickstart] ignore signature files when creating fat jar You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink quickstart Alternat

[jira] [Created] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar

Maximilian Michels created FLINK-2607: - Summary: Shade plugin copies signature files from original jar into fat jar Key: FLINK-2607 URL: https://issues.apache.org/jira/browse/FLINK-2607 Project: F

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

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727118#comment-14727118 ] ASF GitHub Bot commented on FLINK-2111: --- Github user aljoscha commented on a diff in

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

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r38516254 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala --- @@ -411,6 +411,23 @@ class TaskManager( lo

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

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14727116#comment-14727116 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in th

  1   2   >