[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-tabpanelfocusedCommentId=14720994#comment-14720994 ] ASF GitHub Bot commented on FLINK-2480: --- GitHub user HuangWHWHW opened a pull

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

GitHub user HuangWHWHW opened a pull request: https://github.com/apache/flink/pull/1073 [FLINK-2480][test]add a test for Print Sink with prefix I check the coverage of sink and add a test for sink to print with prefix. You can merge this pull request into a Git repository by

[jira] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721001#comment-14721001 ] Chiwan Park commented on FLINK-2596: Oh I got it. I'll investigate about this. I

[jira] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax commented on FLINK-2596: Of course I did rebase. Furthermore in

[jira] [Comment Edited] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax edited comment on FLINK-2596 at 8/29/15 7:16 AM:

[jira] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14721002#comment-14721002 ] Chiwan Park commented on FLINK-2596: Maybe It occured because of non-transitive

[jira] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720996#comment-14720996 ] Chiwan Park commented on FLINK-2596: Did you rebase on current master? It seems

[jira] [Comment Edited] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax edited comment on FLINK-2596 at 8/29/15 7:18 AM:

[jira] [Comment Edited] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax edited comment on FLINK-2596 at 8/29/15 7:19 AM:

[jira] [Created] (FLINK-2597) Add a test for Avro-serialized Kafka messages

Robert Metzger created FLINK-2597: - Summary: Add a test for Avro-serialized Kafka messages Key: FLINK-2597 URL: https://issues.apache.org/jira/browse/FLINK-2597 Project: Flink Issue Type:

[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-tabpanelfocusedCommentId=1472#comment-1472 ] ASF GitHub Bot commented on FLINK-2545: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-2545] add bucket member count verificat...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1067#issuecomment-135983916 Ah, that makes perfect sense. The last memory segment is not fully used (only until the hash index has initialized enough buckets). The bloom filter initialization

[GitHub] flink pull request:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/a18994aabfba7c3775f6dc911bd9d59016216817#commitcomment-12961159 In flink-runtime/src/test/java/org/apache/flink/runtime/util/SerializedValueTest.java: In

[GitHub] flink pull request:

Github user mxm commented on the pull request: https://github.com/apache/flink/commit/a18994aabfba7c3775f6dc911bd9d59016216817#commitcomment-12961579 In flink-runtime/src/test/java/org/apache/flink/runtime/util/SerializedValueTest.java: In

[jira] [Updated] (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 updated FLINK-2475: --- Component/s: Start-Stop Scripts Rename Flink Client log file

[GitHub] flink pull request:

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/commit/a18994aabfba7c3775f6dc911bd9d59016216817#commitcomment-12961618 In flink-runtime/src/test/java/org/apache/flink/runtime/util/SerializedValueTest.java: In

[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-tabpanelfocusedCommentId=14721141#comment-14721141 ] ASF GitHub Bot commented on FLINK-2475: --- GitHub user mjsax opened a pull request:

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

GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/1074 [FLINK-2475] Rename Flink Client log file You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/flink flink-2475-renameClientLogFile

[jira] [Updated] (FLINK-2475) Rename Flink Client log and out file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2475: --- Description: Currently, JoManager and TaskManager log/out files are names as follows: -

[jira] [Assigned] (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 reassigned FLINK-2475: -- Assignee: Matthias J. Sax Rename Flink Client log file

[jira] [Updated] (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 updated FLINK-2475: --- Summary: Rename Flink Client log file (was: Rename Flink Client log and out file) Rename

[jira] [Closed] (FLINK-2564) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2564. -- Failing Test: RandomSamplerTest --- Key: FLINK-2564

[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-tabpanelfocusedCommentId=14721271#comment-14721271 ] ASF GitHub Bot commented on FLINK-2106: --- Github user r-pogalz commented on the pull

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

Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/1052#issuecomment-136056199 Hi @tillrohrmann, @fhueske and @chiwanpark, thanks for your reviews and comments. I went through the classes and changed the formatting. Moreover, I refactored the

[GitHub] flink pull request: [FLINK-2590] fixing DataSetUtils.zipWithUnique...

GitHub user s1ck opened a pull request: https://github.com/apache/flink/pull/1075 [FLINK-2590] fixing DataSetUtils.zipWithUniqueId() * modified algorithm as explained in the issue * updated method documentation You can merge this pull request into a Git repository by running:

[jira] [Commented] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs

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