[GitHub] flink pull request: FLINK-2605 Unclosed RandomAccessFile may leak ...

GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/1089 FLINK-2605 Unclosed RandomAccessFile may leak resource in StaticFileS… …erverHandler You can merge this pull request into a Git repository by running: $ git pull

[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=14729116#comment-14729116 ] ASF GitHub Bot commented on FLINK-2605: --- GitHub user tedyu opened a pull request:

[GitHub] flink pull request: Implementation of distributed copying utility ...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1090#issuecomment-137477152 Thanks for your pull request! I'm assuming you would use this utility to copy files from your local to a remote file system, right? Your utility starts a Flink job to copy

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1052#discussion_r38654830 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/LeftOuterJoinTaskExternalITTest.java --- @@ -0,0 +1,41 @@ +/* + * Licensed

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729289#comment-14729289 ] Arnaud Linz commented on FLINK-2617: (I think that the subject is in fact critical because it happens

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1052#discussion_r38654270 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/AbstractOuterJoinTaskTest.java --- @@ -0,0 +1,452 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2106) Add outer joins to Runtime

[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729183#comment-14729183 ] ASF GitHub Bot commented on FLINK-2106: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: Implementation of distributed copying utility ...

Github user detonator413 commented on the pull request: https://github.com/apache/flink/pull/1090#issuecomment-137480178 Hi Max, Look at the distcp utility (http://hadoop.apache.org/docs/r1.2.1/distcp.html ). The purpose of

[jira] [Commented] (FLINK-2106) Add outer joins to Runtime

[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729233#comment-14729233 ] ASF GitHub Bot commented on FLINK-2106: --- Github user fhueske commented on the pull request:

[jira] [Created] (FLINK-2618) ExternalSortITCase failure

Sachin Goel created FLINK-2618: -- Summary: ExternalSortITCase failure Key: FLINK-2618 URL: https://issues.apache.org/jira/browse/FLINK-2618 Project: Flink Issue Type: Bug Reporter:

[jira] [Commented] (FLINK-2106) Add outer joins to Runtime

[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729193#comment-14729193 ] ASF GitHub Bot commented on FLINK-2106: --- Github user fhueske commented on a diff in the pull

[jira] [Updated] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-2617: --- Priority: Critical (was: Major) > ConcurrentModificationException when using HCatRecordReader to

[GitHub] flink pull request: Implementation of distributed copying utility ...

is a file. You can merge this pull request into a Git repository by running: $ git pull https://github.com/detonator413/flink distcp-example-20150903 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/1090.patch To close this pull req

[jira] [Commented] (FLINK-2106) Add outer joins to Runtime

[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729192#comment-14729192 ] ASF GitHub Bot commented on FLINK-2106: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1052#issuecomment-137483619 Hi @r-pogalz, @jkovacs, thanks for the update. It's good to merge, IMO. Either you resolve my minor comments or I can do it before merging. Anybody

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1052#discussion_r38654400 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/operators/FullOuterJoinTaskExternalITTest.java --- @@ -0,0 +1,41 @@ +/* + * Licensed

[jira] [Commented] (FLINK-2106) Add outer joins to Runtime

[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729186#comment-14729186 ] ASF GitHub Bot commented on FLINK-2106: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729295#comment-14729295 ] Fabian Hueske commented on FLINK-2613: -- How about printing a message such as {code} Flink Scala

[GitHub] flink pull request: Implementation of distributed copying utility ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1090#issuecomment-137533466 @detonator413 Good point with the dynamic assignment. What do sou think, would `flink-contrib` or `flink-examples` be a better place? Is it rather a nice

[GitHub] flink pull request: Implementation of distributed copying utility ...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1090#issuecomment-137499875 Thanks for pointing me to the `distcp` page. So far, I was agnostic of this tool :) The performance difference between Hadoop and Flink should not be too different because

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729346#comment-14729346 ] Nikolaas Steenbergen commented on FLINK-2613: - actually it does this as well already. either:

[GitHub] flink pull request: Implementation of distributed copying utility ...

Github user detonator413 commented on the pull request: https://github.com/apache/flink/pull/1090#issuecomment-137516063 It could be faster because of dynamic assignment of files to copy as opposed to the default method of distcp where set of files are preassigned to mappers in

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729302#comment-14729302 ] Stephan Ewen commented on FLINK-2617: - I agree, this is critical. The reason for this exception is

[jira] [Issue Comment Deleted] (FLINK-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns updated FLINK-2602: Comment: was deleted (was: That were the two spots I also found. Closing the issue.) >

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

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martin Junghanns resolved FLINK-2602. - Resolution: Fixed Fix Version/s: 0.10 Already fixed in hotfix

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

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/992#issuecomment-137372443 I think there is an issue with Travis at the moment. Could you force push to this branch again? --- If your project is set up for it, you can reply to this email and have

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

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137378160 Yes. I was concerned about the API breaking part too. What about keeping the original histogram as such, and add something like `DoubleHistogram`, which

[jira] [Created] (FLINK-2611) YARN reports failed final state for successful jobs

Robert Metzger created FLINK-2611: - Summary: YARN reports failed final state for successful jobs Key: FLINK-2611 URL: https://issues.apache.org/jira/browse/FLINK-2611 Project: Flink Issue

[jira] [Created] (FLINK-2613) Print usage information for Scala Shell

Maximilian Michels created FLINK-2613: - Summary: Print usage information for Scala Shell Key: FLINK-2613 URL: https://issues.apache.org/jira/browse/FLINK-2613 Project: Flink Issue Type:

[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=14728571#comment-14728571 ] ASF GitHub Bot commented on FLINK-2030: --- Github user chiwanpark commented on a diff in the pull

[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=14728651#comment-14728651 ] ASF GitHub Bot commented on FLINK-2480: --- Github user mxm commented on a diff in the pull request:

[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=14728701#comment-14728701 ] ASF GitHub Bot commented on FLINK-2030: --- Github user chiwanpark commented on the pull request:

[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=14728709#comment-14728709 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the pull request:

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

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137380847 Yes. For Discrete fields, quantiles do not make sense. In the paper, they only cover the continuous fields, since the Discrete fields are more or less trivial to

[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=14728718#comment-14728718 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the pull request:

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

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137382016 Okay. Please take a look now. [There is an unintentional formatting introduced by IDE in Histogram.java. Will remove it while squashing.] --- If your

[jira] [Created] (FLINK-2612) ZooKeeperLeaderElectionITCase failure

Sachin Goel created FLINK-2612: -- Summary: ZooKeeperLeaderElectionITCase failure Key: FLINK-2612 URL: https://issues.apache.org/jira/browse/FLINK-2612 Project: Flink Issue Type: Bug

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

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-137390414 I'm currently trying out the module. Some comments: - Why do we name the module `flink-connector-hdfs`. I think a name such as `flink-connector-filesystems` or

[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-2602) Gelly algorithms obtain new execution environments.

[ https://issues.apache.org/jira/browse/FLINK-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728598#comment-14728598 ] Martin Junghanns commented on FLINK-2602: - That were the two spots I also found. Closing the

[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_r38619843 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java --- @@ -248,6 +251,58 @@ public void mapPartition(Iterable values,

[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=14728625#comment-14728625 ] ASF GitHub Bot commented on FLINK-2030: --- Github user chiwanpark commented on a diff in the pull

[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=14728624#comment-14728624 ] ASF GitHub Bot commented on FLINK-2030: --- Github user chiwanpark commented on a diff in the pull

[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_r38619828 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java --- @@ -248,6 +251,58 @@ public void mapPartition(Iterable values,

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

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137381508 I'm inclined to preventing base class for the histogram. Decision Tree will be implemented in Scala and we can use pattern matching (case-match statement) for solving

[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=14728712#comment-14728712 ] ASF GitHub Bot commented on FLINK-2030: --- Github user chiwanpark commented on 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=14728744#comment-14728744 ] ASF GitHub Bot commented on FLINK-2583: --- Github user rmetzger commented on the pull request:

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1084#discussion_r38627730 --- Diff: docs/apis/streaming_guide.md --- @@ -1836,6 +1837,110 @@ More about information about Elasticsearch can be found [here](https://elastic.c

[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=14728745#comment-14728745 ] ASF GitHub Bot commented on FLINK-2583: --- Github user rmetzger commented on a diff in the pull

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

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1073#discussion_r38621410 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java --- @@ -97,20

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

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1073#discussion_r38621439 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java --- @@ -97,20

[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=14728649#comment-14728649 ] ASF GitHub Bot commented on FLINK-2480: --- Github user mxm commented on a diff in the pull request:

[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=14728650#comment-14728650 ] ASF GitHub Bot commented on FLINK-2480: --- Github user mxm commented on a diff in the pull request:

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

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/1073#discussion_r38621376 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/PrintSinkFunctionTest.java --- @@ -73,21

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

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137376194 Hi, I just reviewed the updated PR. Sorry for late. Your implementation is nice. It seems acting like I expected. But I have to check the following:

[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=14728685#comment-14728685 ] ASF GitHub Bot commented on FLINK-2030: --- Github user chiwanpark commented on the pull request:

[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=14728687#comment-14728687 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the pull request:

[jira] [Commented] (FLINK-2606) Extend StormFileSpout to handle HDFS

[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728711#comment-14728711 ] Matthias J. Sax commented on FLINK-2606: It just came to my mind, that there exists a storm-hdfs

[jira] [Commented] (FLINK-2614) Scala Shell's default local execution mode is broken

[ https://issues.apache.org/jira/browse/FLINK-2614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728751#comment-14728751 ] Till Rohrmann commented on FLINK-2614: -- Good catch. I'm wondering why the tests didn't catch it. Do

[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=14728611#comment-14728611 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the pull request:

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

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137358805 Fixed. --- 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

[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-tabpanel=14728655#comment-14728655 ] ASF GitHub Bot commented on FLINK-2490: --- Github user mxm commented on the pull request:

[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=14728730#comment-14728730 ] Ufuk Celebi commented on FLINK-2605: Yes. This is part of the new web interface, which is only part of

[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=14728729#comment-14728729 ] Chiwan Park commented on FLINK-2605: Nice catch, [~tedyu]. If you want your patch to submit, please

[jira] [Created] (FLINK-2614) Scala Shell's default local execution mode is broken

Maximilian Michels created FLINK-2614: - Summary: Scala Shell's default local execution mode is broken Key: FLINK-2614 URL: https://issues.apache.org/jira/browse/FLINK-2614 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728765#comment-14728765 ] Maximilian Michels commented on FLINK-2608: --- Seems to be a Kryo serialization issue we can't do

[GitHub] flink pull request: [FLINK-2475] Rename Flink Client log file

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1074#issuecomment-137393037 +1 --- 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

[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_r38629325 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/RemoteEnvironmentITCase.java --- @@ -0,0 +1,166 @@ +/* + * Licensed

[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=14728777#comment-14728777 ] ASF GitHub Bot commented on FLINK-2373: --- Github user tillrohrmann commented on a diff in the pull

[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=14728812#comment-14728812 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the pull request:

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

Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-137399688 Hey @chiwanpark , travis passes. Let me know if I should squash the commits. I'm only keeping them in case we need to go back to the Scala implementation. [which

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728832#comment-14728832 ] Maximilian Michels commented on FLINK-2613: --- Oh good to know. I guess I only tried {{-h}}. It

[GitHub] flink pull request: [FLINK-2475] Rename Flink Client log file

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

[GitHub] flink pull request: [FLINK-2475] Rename Flink Client log file

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1074#issuecomment-137396215 Looks 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 well. If your project does not have

[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-137396268 Question is, should we do exactly once now or put it in as it is (more or less)? --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728792#comment-14728792 ] Maximilian Michels commented on FLINK-2235: --- Pushed also to the release 0.9 branch. > Local

[jira] [Commented] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728793#comment-14728793 ] ASF GitHub Bot commented on FLINK-2475: --- Github user mjsax commented on the pull request:

[GitHub] flink pull request: [FLINK-2475] Rename Flink Client log file

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1074#issuecomment-137397048 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 this

[jira] [Commented] (FLINK-2475) Rename Flink Client log file

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

[jira] [Closed] (FLINK-2614) Scala Shell's default local execution mode is broken

[ https://issues.apache.org/jira/browse/FLINK-2614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2614. - Resolution: Fixed Fixed via 14ba66b. > Scala Shell's default local execution mode is

[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-137393554 I think using truncate for exactly once is the way to go. To support users with older HDFS versions, how about this: 1. We consider only valid what was

[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=14728770#comment-14728770 ] ASF GitHub Bot commented on FLINK-2583: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-2475) Rename Flink Client log file

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

[jira] [Commented] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728786#comment-14728786 ] ASF GitHub Bot commented on FLINK-2475: --- Github user chiwanpark commented on 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=14728787#comment-14728787 ] ASF GitHub Bot commented on FLINK-2583: --- Github user aljoscha commented on the pull request:

[jira] [Closed] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2235. - Resolution: Fixed > Local Flink cluster allocates too much memory >

[jira] [Reopened] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-2235: --- Fix also in 0.9.2. > Local Flink cluster allocates too much memory >

[jira] [Updated] (FLINK-2235) Local Flink cluster allocates too much memory

[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2235: -- Fix Version/s: 0.9.2 > Local Flink cluster allocates too much memory >

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728833#comment-14728833 ] Maximilian Michels commented on FLINK-2613: --- Adding the message you suggested is also fine for

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728819#comment-14728819 ] Nikolaas Steenbergen commented on FLINK-2613: - There is a {{--help}} option: {code} Flink

[jira] [Closed] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2475. -- Resolution: Fixed fixed via 9f96b32bf8a0c77accdd91b7cfada2f6e751c167 > Rename Flink Client log

[jira] [Assigned] (FLINK-2615) Multiple restarts of Local Cluster for a single program

[ https://issues.apache.org/jira/browse/FLINK-2615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sachin Goel reassigned FLINK-2615: -- Assignee: Sachin Goel > Multiple restarts of Local Cluster for a single program >

[jira] [Created] (FLINK-2615) Multiple restarts of Local Cluster for a single program

Sachin Goel created FLINK-2615: -- Summary: Multiple restarts of Local Cluster for a single program Key: FLINK-2615 URL: https://issues.apache.org/jira/browse/FLINK-2615 Project: Flink Issue

[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=14728884#comment-14728884 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in the pull request:

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

Matthias J. Sax created FLINK-2616: -- Summary: Failing Test: ZooKeeperLeaderElectionTest Key: FLINK-2616 URL: https://issues.apache.org/jira/browse/FLINK-2616 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2615) Multiple restarts of Local Cluster for a single program

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

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

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

[GitHub] flink pull request: [FLINK-2615]Preserve executors for the entire ...

GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/1088 [FLINK-2615]Preserve executors for the entire run of program. 1. Prevents re-starts of local cluster several times on multiple executions. 2. Preserves the executor states for the entire

[GitHub] flink pull request: [FLINK-2615]Preserve executors for the entire ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1088#issuecomment-137418968 The current behavior is actually desired. You can explicitly start the local executor, and explicitly stop it. When you did not explicitly start it, you get an

[jira] [Commented] (FLINK-2615) Multiple restarts of Local Cluster for a single program

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

  1   2   >