[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

2015-07-14 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627622#comment-14627622 ] Andra Lungu commented on FLINK-2361: Sure, This is the main class: https://github.co

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627601#comment-14627601 ] ASF GitHub Bot commented on FLINK-2359: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

2015-07-14 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/911#issuecomment-121503903 I also prefer `of` as a method name. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627574#comment-14627574 ] ASF GitHub Bot commented on FLINK-2359: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

2015-07-14 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/911#issuecomment-121498601 Should we call it `of` instead of `create`? In other parts, such as the windowing helpers we also have `of` for these shortcut constructors. --- If your project is set

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627371#comment-14627371 ] ASF GitHub Bot commented on FLINK-297: -- Github user chiwanpark commented on the pull r

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

2015-07-14 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-121441621 Looks good to merge. After merging this PR, we need to modify PR #885. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-07-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627228#comment-14627228 ] Fabian Hueske commented on FLINK-2299: -- So this issue can be closed? Should/can we im

[jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

2015-07-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627211#comment-14627211 ] Fabian Hueske commented on FLINK-2361: -- Can you give exact instructions how to reprod

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627191#comment-14627191 ] ASF GitHub Bot commented on FLINK-1963: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121413841 The tests look good! I added a few minor comments in line. Nice that you also updated the JavaDoc of `DataSet.java`. Can you update the documentation of the `distinct(

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

2015-07-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2362: Summary: distinct is missing in DataSet API documentation Key: FLINK-2362 URL: https://issues.apache.org/jira/browse/FLINK-2362 Project: Flink Issue Type: Bu

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/905#discussion_r34627102 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/DistinctITCase.java --- @@ -274,4 +277,81 @@ public Integer map(POJO value) throws

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627150#comment-14627150 ] ASF GitHub Bot commented on FLINK-1963: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/905#discussion_r34626780 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -618,9 +620,9 @@ public long count() throws Exception { }

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/905#discussion_r34626753 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -618,9 +620,9 @@ public long count() throws Exception { }

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627142#comment-14627142 ] ASF GitHub Bot commented on FLINK-1963: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627140#comment-14627140 ] ASF GitHub Bot commented on FLINK-1963: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627127#comment-14627127 ] ASF GitHub Bot commented on FLINK-1963: --- Github user pp86 commented on the pull requ

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread pp86
Github user pp86 commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121406113 Hi guys, I added some tests. I also added a test on a generic data type which does not implement Comparable. --- If your project is set up for it, you can rep

[jira] [Updated] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets

2015-07-14 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-2361: --- Summary: flatMap + distinct gives erroneous results for big data sets (was: flatMap + distinct gives

[jira] [Updated] (FLINK-2361) flatMap + distinct gives eroneous results for big data sets

2015-07-14 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andra Lungu updated FLINK-2361: --- Summary: flatMap + distinct gives eroneous results for big data sets (was: flatMap + distict gives er

[jira] [Created] (FLINK-2361) flatMap + distict gives eroneous results for big data sets

2015-07-14 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2361: -- Summary: flatMap + distict gives eroneous results for big data sets Key: FLINK-2361 URL: https://issues.apache.org/jira/browse/FLINK-2361 Project: Flink Issue Ty

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14627059#comment-14627059 ] ASF GitHub Bot commented on FLINK-297: -- Github user hsaputra commented on the pull req

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

2015-07-14 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-121392244 +1 for the merge. This should provide good building blocks to build new features for the web frontend module. --- If your project is set up for it, you can reply to thi

[jira] [Created] (FLINK-2360) EOFException

2015-07-14 Thread Andra Lungu (JIRA)
Andra Lungu created FLINK-2360: -- Summary: EOFException Key: FLINK-2360 URL: https://issues.apache.org/jira/browse/FLINK-2360 Project: Flink Issue Type: Bug Components: Local Runtime

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

2015-07-14 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626676#comment-14626676 ] Gabor Gevay commented on FLINK-2359: Oh, I didn't know about the diamond thing, thanks

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626640#comment-14626640 ] Stephan Ewen commented on FLINK-2359: - >From 0.10 on, Flink requires at least Java 7.

[jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626639#comment-14626639 ] ASF GitHub Bot commented on FLINK-2359: --- GitHub user ggevay opened a pull request:

[GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to...

2015-07-14 Thread ggevay
GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/911 [FLINK-2359] [java api] Add factory methods to the Java TupleX types I added the creation of the factory method to the TupleGenerator. I also fixed some inconsistencies between the generator a

[jira] [Created] (FLINK-2359) Add factory methods to the Java TupleX types

2015-07-14 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-2359: -- Summary: Add factory methods to the Java TupleX types Key: FLINK-2359 URL: https://issues.apache.org/jira/browse/FLINK-2359 Project: Flink Issue Type: Improvemen

[jira] [Closed] (FLINK-1938) Add Grunt for building the front-end

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1938. --- > Add Grunt for building the front-end > > > Key: FLI

[jira] [Resolved] (FLINK-1938) Add Grunt for building the front-end

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1938. - Resolution: Won't Fix There was no activity lately on this issue. > Add Grunt for building the fr

[jira] [Commented] (FLINK-297) Redesign GUI client-server model

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626554#comment-14626554 ] ASF GitHub Bot commented on FLINK-297: -- Github user StephanEwen commented on the pull

[GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa...

2015-07-14 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/677#issuecomment-121291504 If no one objects, I would like to merge this, with a switch to choose between the old web frontend, and the new web frontend. This should get the development

[jira] [Created] (FLINK-2358) Add Netty-HTTP based server and server handlers

2015-07-14 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2358: --- Summary: Add Netty-HTTP based server and server handlers Key: FLINK-2358 URL: https://issues.apache.org/jira/browse/FLINK-2358 Project: Flink Issue Type: Sub-t

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626550#comment-14626550 ] ASF GitHub Bot commented on FLINK-2292: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

2015-07-14 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/896#issuecomment-121289719 I've integrated the internal accumulators in the test case. Also I changed the byte measurements to operate directly in the serializers/deserializers which, instead of Memeor

[jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626546#comment-14626546 ] Stephan Ewen commented on FLINK-2357: - Attached is a mockup of what the JobManager web

[jira] [Updated] (FLINK-2357) New JobManager Runtime Web Frontend

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2357: Attachment: Webfrontend Mockup.pdf > New JobManager Runtime Web Frontend > -

[jira] [Created] (FLINK-2357) New JobManager Runtime Web Frontend

2015-07-14 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2357: --- Summary: New JobManager Runtime Web Frontend Key: FLINK-2357 URL: https://issues.apache.org/jira/browse/FLINK-2357 Project: Flink Issue Type: New Feature

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121286738 Hi, thanks for the pull request. I noticed that the `CollectionDataSets.getStringDataSet` data set does not contain any duplicates. Therefore, it is not well suit

[GitHub] flink pull request: Addde HBase OutputFormat example (Flink-1828)

2015-07-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/633 --- 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 enabl

[jira] [Commented] (FLINK-2343) Change default garbage collector in streaming environments

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626515#comment-14626515 ] ASF GitHub Bot commented on FLINK-2343: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2008][FLINK-2296] Fix checkpoint commit...

2015-07-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/895 --- 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 enabl

[jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626512#comment-14626512 ] ASF GitHub Bot commented on FLINK-2008: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626523#comment-14626523 ] ASF GitHub Bot commented on FLINK-1963: --- Github user fhueske commented on the pull r

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626514#comment-14626514 ] ASF GitHub Bot commented on FLINK-2235: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo...

2015-07-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/859 --- 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 enabl

[jira] [Commented] (FLINK-2329) Refactor RPCs from within the ExecutionGraph

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626513#comment-14626513 ] ASF GitHub Bot commented on FLINK-2329: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2343] [scripts] Make CMS the default GC...

2015-07-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/901 --- 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 enabl

[GitHub] flink pull request: [FLINK-2329] [runtime] Introduces InstanceGate...

2015-07-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/893 --- 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 enabl

[jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure

2015-07-14 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626504#comment-14626504 ] Ufuk Celebi commented on FLINK-2354: State handle resource clean up needs extra consid

[jira] [Created] (FLINK-2356) Resource leak in checkpoint coordinator

2015-07-14 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2356: -- Summary: Resource leak in checkpoint coordinator Key: FLINK-2356 URL: https://issues.apache.org/jira/browse/FLINK-2356 Project: Flink Issue Type: Bug C

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121283389 @pp86 Looks good to merge. :) If another committer gives LGTM to this PR, I'll merge this PR. --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626488#comment-14626488 ] ASF GitHub Bot commented on FLINK-1963: --- Github user chiwanpark commented on the pul

[jira] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer

2015-07-14 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626474#comment-14626474 ] Ufuk Celebi commented on FLINK-2355: Hey William, thanks for reporting the issue. Coul

[jira] [Created] (FLINK-2355) Job hanging in collector, waiting for request buffer

2015-07-14 Thread William Saar (JIRA)
William Saar created FLINK-2355: --- Summary: Job hanging in collector, waiting for request buffer Key: FLINK-2355 URL: https://issues.apache.org/jira/browse/FLINK-2355 Project: Flink Issue Type:

[GitHub] flink pull request: Updated method documentation in joinDataSet.sc...

2015-07-14 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/909#issuecomment-121246257 Looks good. :) +1 for merging. --- 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

[GitHub] flink pull request: [FLINK-2148] [contrib] Exact and approximate c...

2015-07-14 Thread ggevay
GitHub user ggevay opened a pull request: https://github.com/apache/flink/pull/910 [FLINK-2148] [contrib] Exact and approximate countDistinct on streams For the approximate calculation I used the HyperLogLog implementation in the Clearspring library. Currently it operates o

[jira] [Commented] (FLINK-2148) Approximately calculate the number of distinct elements of a stream

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626360#comment-14626360 ] ASF GitHub Bot commented on FLINK-2148: --- GitHub user ggevay opened a pull request:

[jira] [Commented] (FLINK-2329) Refactor RPCs from within the ExecutionGraph

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626343#comment-14626343 ] ASF GitHub Bot commented on FLINK-2329: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-2329] [runtime] Introduces InstanceGate...

2015-07-14 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/893#issuecomment-121238472 Very nice for testing! *happy* --- 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 t

[jira] [Created] (FLINK-2354) Recover running jobs on JobManager failure

2015-07-14 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-2354: -- Summary: Recover running jobs on JobManager failure Key: FLINK-2354 URL: https://issues.apache.org/jira/browse/FLINK-2354 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-2347) Rendering problem with Documentation website

2015-07-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-2347. - Documentation has been rebuilt. > Rendering problem with Documentation website >

[jira] [Commented] (FLINK-2347) Rendering problem with Documentation website

2015-07-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626315#comment-14626315 ] Matthias J. Sax commented on FLINK-2347: Version 0.10 looks ok for me now, too. >

[jira] [Commented] (FLINK-2347) Rendering problem with Documentation website

2015-07-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626271#comment-14626271 ] Matthias J. Sax commented on FLINK-2347: Version 0.9 look ok for me now (Firefox o

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626259#comment-14626259 ] ASF GitHub Bot commented on FLINK-1520: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-14 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-121215586 yes, I mean `NullValue.class` :) I'd like to know @shghatge's opinion, too! --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f...

2015-07-14 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/847#issuecomment-121215203 Hmmm :-? but can you pass NullValue to tyes... it expects Something.class. Can it be overwritten without type erasure getting in the way? Anyway... I will let

[jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626254#comment-14626254 ] ASF GitHub Bot commented on FLINK-1520: --- Github user andralungu commented on the pul

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626226#comment-14626226 ] ASF GitHub Bot commented on FLINK-938: -- Github user qmlmoon closed the pull request at

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread qmlmoon
Github user qmlmoon closed the pull request at: https://github.com/apache/flink/pull/248 --- 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-2299) The slot on which the task maanger was scheduled was killed

2015-07-14 Thread Andra Lungu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626218#comment-14626218 ] Andra Lungu commented on FLINK-2299: Yup everything is fine :) The fix was to set that

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121208526 Something like "Using address XYZ. Configure via ABC." at startup and a similar error messasge if connecting fails. You could also try to connect from the remote host before

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626214#comment-14626214 ] ASF GitHub Bot commented on FLINK-938: -- Github user uce commented on the pull request:

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626201#comment-14626201 ] ASF GitHub Bot commented on FLINK-938: -- Github user StephanEwen commented on the pull

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121203637 How would you give a good error message? It would manifest itself as the fact that the TaskManagers cannot connect to the JobManager. I would actually agree t

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121195803 I've tested this with default EC2 and GCE instances, which by default return the cloud internal hostname. I would say that this is a reasonable configuration. If it is not co

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626177#comment-14626177 ] ASF GitHub Bot commented on FLINK-938: -- Github user uce commented on the pull request:

[jira] [Commented] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626167#comment-14626167 ] Stephan Ewen commented on FLINK-1321: - Any news on this? > New web interface, contain

[jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed

2015-07-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626164#comment-14626164 ] Stephan Ewen commented on FLINK-2299: - Any update on this? > The slot on which the ta

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread pp86
Github user pp86 commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121192327 hello @chiwanpark! what do you think about the tests? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If yo

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626161#comment-14626161 ] ASF GitHub Bot commented on FLINK-1963: --- Github user pp86 commented on the pull requ

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121192404 Not sure right now. All setups through YARN are not affected anyways. For standalone mode, do we need it? How reliable is this? What happens if you start

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626162#comment-14626162 ] ASF GitHub Bot commented on FLINK-938: -- Github user StephanEwen commented on the pull

[jira] [Commented] (FLINK-1963) Improve distinct() transformation

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626137#comment-14626137 ] ASF GitHub Bot commented on FLINK-1963: --- Github user pp86 commented on the pull requ

[GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation

2015-07-14 Thread pp86
Github user pp86 commented on the pull request: https://github.com/apache/flink/pull/905#issuecomment-121187436 sure thing! --- 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 enable

[jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626135#comment-14626135 ] ASF GitHub Bot commented on FLINK-2292: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc...

2015-07-14 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/896#discussion_r34552275 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java --- @@ -101,9 +101,9 @@ /** * For system inter

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626131#comment-14626131 ] ASF GitHub Bot commented on FLINK-938: -- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121183870 Yeah, I was also thinking about this. This will result in a total of 4 combinations: HA mode | JM address configured | JM address behaviour -

[jira] [Resolved] (FLINK-2343) Change default garbage collector in streaming environments

2015-07-14 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2343. Resolution: Fixed Fixed via d368a9b. > Change default garbage collector in streaming environments >

[GitHub] flink pull request: FLINK-2125

2015-07-14 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/862#issuecomment-121180618 This pull request needs some work. All builds fail and the commit history needs a bit of cleanup. --- If your project is set up for it, you can reply to this email a

[jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626111#comment-14626111 ] ASF GitHub Bot commented on FLINK-2125: --- Github user StephanEwen commented on the pu

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626106#comment-14626106 ] ASF GitHub Bot commented on FLINK-938: -- Github user StephanEwen commented on the pull

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121180165 Are we sure this helps, or will it add yet another way of configuring and starting the cluster. Are we getting to the point that it becomes hard to understand what ha

[GitHub] flink pull request: Addde HBase OutputFormat example (Flink-1828)

2015-07-14 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/633#issuecomment-121179785 Just saw this one was apparently merged... --- 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 pro

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

2015-07-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14626096#comment-14626096 ] ASF GitHub Bot commented on FLINK-938: -- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana...

2015-07-14 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/248#issuecomment-121178791 I waited to merge this, because of the recent ZooKeeper integration (to see whether this would be affected by it or not). Turns out this change is orthogonal, so I think we c

  1   2   >