[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268142#comment-15268142 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on the pull request:

[GitHub] flink pull request: FLINK-3650 Add maxBy/minBy to Scala DataSet AP...

2016-05-02 Thread ramkrish86
Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1856#issuecomment-216442490 Removed the unused import. That was causing a build error. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread gallenvara
Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1956#issuecomment-216433392 @greghogan @vasia thanks a lot for your review and codes have been modified. :) --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268085#comment-15268085 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on the pull request:

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267946#comment-15267946 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61832489 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[GitHub] flink pull request: Jackson version upgrade: default from 2.4.2 to...

2016-05-02 Thread cowtowncoder
Github user cowtowncoder commented on the pull request: https://github.com/apache/flink/pull/1952#issuecomment-216415361 @smarthi Updated as suggested. --- 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-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267901#comment-15267901 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61831147 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267897#comment-15267897 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61831064 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[GitHub] flink pull request: Jackson version upgrade: default from 2.4.2 to...

2016-05-02 Thread smarthi
Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1952#issuecomment-216409045 ElasticSearch 2.x requires jackson >= 2.6.2, hence the Elastic 2.x connector jackson version is set at 2.7.x. Locally, I changed the Jackson version to be 2.7.x in the

[GitHub] flink pull request: [Flink-3691] extend avroinputformat to support...

2016-05-02 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1920#issuecomment-216390708 Thanks for the PR @gna-phetsarath! I had one suggestion and one comment about passing null in a objectReuse test. Thanks, Fabian --- If your project is set up for

[GitHub] flink pull request: [Flink-3691] extend avroinputformat to support...

2016-05-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1920#discussion_r61819570 --- Diff: flink-batch-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroInputFormat.java --- @@ -119,12 +138,14 @@ public E nextRecord(E

[GitHub] flink pull request: [Flink-3691] extend avroinputformat to support...

2016-05-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1920#discussion_r61819193 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/io/avro/AvroRecordInputFormatTest.java --- @@ -289,6 +290,119 @@ public void

[jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267587#comment-15267587 ] ASF GitHub Bot commented on FLINK-3519: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass...

2016-05-02 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1724#issuecomment-216378193 +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

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267556#comment-15267556 ] ASF GitHub Bot commented on FLINK-2220: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-2220] Join on Pojo without hashCode() s...

2016-05-02 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1940#issuecomment-216372861 I added a comment to FLINK-2220. I think the original analysis of the problem was not correct. It is not necessary to check for POJOs whether they override `equals()`

[jira] [Commented] (FLINK-2220) Join on Pojo without hashCode() silently fails

2016-05-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267555#comment-15267555 ] Fabian Hueske commented on FLINK-2220: -- I think the cause of the original problem was not correctly

[jira] [Commented] (FLINK-3581) Add Special Aligned Event-Time WindowOperator

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267450#comment-15267450 ] ASF GitHub Bot commented on FLINK-3581: --- Github user gyfora commented on the pull request:

[GitHub] flink pull request: [FLINK-3581] [FLINK-3582] State Iterator and A...

2016-05-02 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1957#issuecomment-216354689 Is that a problem? Maybe we could do some periodic garbage collection on the empty column families. --- If your project is set up for it, you can reply to this email

[jira] [Assigned] (FLINK-1996) Add output methods to Table API

2016-05-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1996: Assignee: Fabian Hueske > Add output methods to Table API >

[GitHub] flink pull request: Jackson version upgrade: default from 2.4.2 to...

2016-05-02 Thread cowtowncoder
Github user cowtowncoder commented on the pull request: https://github.com/apache/flink/pull/1952#issuecomment-216337481 @aljoscha @fhueske Nothing special, just thought I'd start with smallest step, given that this is my first contribution here. But given that 2.7.4 is out now, I

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267240#comment-15267240 ] ASF GitHub Bot commented on FLINK-3854: --- Github user IgorBerman commented on the pull request:

[GitHub] flink pull request: [FLINK-3854] Support Avro key-value rolling si...

2016-05-02 Thread IgorBerman
Github user IgorBerman commented on the pull request: https://github.com/apache/flink/pull/1953#issuecomment-216324472 @aljoscha , @rmetzger thanks for the review. I've updated PR : moved verifications to the C'tor --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method

2016-05-02 Thread Martin Liesenberg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267231#comment-15267231 ] Martin Liesenberg commented on FLINK-2926: -- yes, will do. thanks for the feedback. :) > Add a

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267211#comment-15267211 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61780580 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61780511 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267206#comment-15267206 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61780238 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3772) Graph algorithms for vertex and edge degree

2016-05-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267132#comment-15267132 ] Greg Hogan commented on FLINK-3772: --- I added documentation and removed algorithm caching, the latter

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

2016-05-02 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-1984: Description: There are some users asking for an integration of Flink into Mesos. -There also is a

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267049#comment-15267049 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61772427 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267033#comment-15267033 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61770727 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267014#comment-15267014 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on the pull request:

[GitHub] flink pull request: FLINK-3650 Add maxBy/minBy to Scala DataSet AP...

2016-05-02 Thread ramkrish86
Github user ramkrish86 commented on the pull request: https://github.com/apache/flink/pull/1856#issuecomment-216300472 Added maxBy and minBy to GroupedDataSet too. So should be fine now. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267012#comment-15267012 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61769569 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267010#comment-15267010 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request: FLINK-3650 Add maxBy/minBy to Scala DataSet AP...

2016-05-02 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r61769507 --- Diff: flink-scala/src/test/scala/org/apache/flink/api/operator/MaxByOperatorTest.scala --- @@ -0,0 +1,110 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15267009#comment-15267009 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request: FLINK-3650 Add maxBy/minBy to Scala DataSet AP...

2016-05-02 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r61769474 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java --- @@ -72,8 +73,8 @@ public T reduce(T value1, T value2)

[jira] [Resolved] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices

2016-05-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-3845. --- Resolution: Fixed Fixed in 9c7a6598dd84e6739b50cfc8f6c5194e3a3ace9f > Gelly allows duplicate

[jira] [Commented] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266995#comment-15266995 ] ASF GitHub Bot commented on FLINK-3845: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-3845] [gelly] Gelly allows duplicate ve...

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

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266984#comment-15266984 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61767543 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3669) WindowOperator registers a lot of timers at StreamTask

2016-05-02 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266976#comment-15266976 ] Konstantin Knauf commented on FLINK-3669: - The problem in the gist, yes. As I said, I could not

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266974#comment-15266974 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61766847 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266947#comment-15266947 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61764570 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266941#comment-15266941 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-3845) Gelly allows duplicate vertices in Graph.addVertices

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266939#comment-15266939 ] ASF GitHub Bot commented on FLINK-3845: --- Github user greghogan commented on the pull request:

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61764033 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[GitHub] flink pull request: [FLINK-3845] [gelly] Gelly allows duplicate ve...

2016-05-02 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1949#issuecomment-216287144 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 not have this feature

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266918#comment-15266918 ] ASF GitHub Bot commented on FLINK-3793: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1955#discussion_r61762758 --- Diff: docs/apis/table.md --- @@ -57,6 +52,170 @@ The following dependency must be added to your project in order to use the Table Note that the

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266915#comment-15266915 ] ASF GitHub Bot commented on FLINK-3793: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1955#discussion_r61762024 --- Diff: docs/apis/table.md --- @@ -57,6 +52,170 @@ The following dependency must be added to your project in order to use the Table Note that

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266909#comment-15266909 ] ASF GitHub Bot commented on FLINK-3793: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1955#discussion_r61761448 --- Diff: docs/apis/table.md --- @@ -57,6 +52,170 @@ The following dependency must be added to your project in order to use the Table Note that the

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

2016-05-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266907#comment-15266907 ] Fabian Hueske commented on FLINK-3856: -- I think it makes sense to add these time types. We can add

[jira] [Closed] (FLINK-3771) Methods for translating Graphs

2016-05-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3771. - Resolution: Implemented > Methods for translating Graphs > -- > >

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266901#comment-15266901 ] ASF GitHub Bot commented on FLINK-3771: --- Github user greghogan commented on the pull request:

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

2016-05-02 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-216280065 Implemented in 08e4bf9440a566c874c2b8e74ae2127ff264c672 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266887#comment-15266887 ] ASF GitHub Bot commented on FLINK-3771: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

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

[jira] [Commented] (FLINK-3771) Methods for translating Graphs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266882#comment-15266882 ] ASF GitHub Bot commented on FLINK-3771: --- Github user greghogan commented on the pull request:

[GitHub] flink pull request: [FLINK-3771] [gelly] Methods for translating G...

2016-05-02 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1900#issuecomment-216277509 Updated docs. 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 not

[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

2016-05-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

[jira] [Updated] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode()

2016-05-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3733: -- Description: {code} if (serializedRegisteredTypesWithKryoSerializers != null) {

[jira] [Updated] (FLINK-1984) Integrate Flink with Apache Mesos

2016-05-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1984: Assignee: Eron Wright > Integrate Flink with Apache Mesos > - > >

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-05-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

2016-05-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266863#comment-15266863 ] Josep RubiĆ³ commented on FLINK-1707: Hi Vasia, I could not work on it last weekend and I don't think

[GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo...

2016-05-02 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1916#issuecomment-216270686 Great, thanks! --- 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-3754) Add a validation phase before construct RelNode using TableAPI

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266825#comment-15266825 ] ASF GitHub Bot commented on FLINK-3754: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266821#comment-15266821 ] ASF GitHub Bot commented on FLINK-3793: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1955#issuecomment-216270394 Thanks for the quick update. A few minor suggestions, otherwise good to merge. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266816#comment-15266816 ] ASF GitHub Bot commented on FLINK-3793: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1955#discussion_r61755610 --- Diff: docs/apis/table.md --- @@ -57,6 +52,170 @@ The following dependency must be added to your project in order to use the Table Note that

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266812#comment-15266812 ] ASF GitHub Bot commented on FLINK-3793: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1955#discussion_r61755531 --- Diff: docs/apis/table.md --- @@ -57,6 +52,170 @@ The following dependency must be added to your project in order to use the Table Note that

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266803#comment-15266803 ] ASF GitHub Bot commented on FLINK-3793: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo...

2016-05-02 Thread yjshen
Github user yjshen commented on the pull request: https://github.com/apache/flink/pull/1916#issuecomment-216269369 Will start to work on eager validation now. :) --- 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

[GitHub] flink pull request: [FLINK-3793][docs] re-organize table API and S...

2016-05-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1955#discussion_r61755204 --- Diff: docs/apis/table.md --- @@ -33,10 +28,10 @@ under the License. **Table API and SQL are experimental features** -The Table API is

[jira] [Resolved] (FLINK-1991) Return Table as DataSet

2016-05-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-1991. - Resolution: Fixed Fix Version/s: 1.1.0 Has been implemented as part of FLINK-3226. >

[jira] [Created] (FLINK-3859) Add BigDecimal/BigInteger support to Table API

2016-05-02 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3859: --- Summary: Add BigDecimal/BigInteger support to Table API Key: FLINK-3859 URL: https://issues.apache.org/jira/browse/FLINK-3859 Project: Flink Issue Type: New

[GitHub] flink pull request: [FLINK-3581] [FLINK-3582] State Iterator and A...

2016-05-02 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1957#issuecomment-216257051 Hi, So just a quick question regarding the namespace dropping in rocks. I though you said it would be possible to do this by using prefixes in rocks. Are there some

[GitHub] flink pull request: [FLINK-3581] [FLINK-3582] State Iterator and A...

2016-05-02 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1957#issuecomment-216261831 I had a version that was doing this. The problem there is that you don't know when you can drop column families. For knowing when a column family is empty you would

[jira] [Commented] (FLINK-3581) Add Special Aligned Event-Time WindowOperator

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266754#comment-15266754 ] ASF GitHub Bot commented on FLINK-3581: --- Github user aljoscha commented on the pull request:

[jira] [Resolved] (FLINK-3837) Create FLOOR/CEIL function

2016-05-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3837. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed in a0f5397. > Create FLOOR/CEIL function >

[jira] [Commented] (FLINK-3793) Re-organize the Table API and SQL docs

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266743#comment-15266743 ] ASF GitHub Bot commented on FLINK-3793: --- Github user vasia commented on the pull request:

[GitHub] flink pull request: [FLINK-3581] [FLINK-3582] State Iterator and A...

2016-05-02 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1957#issuecomment-216259593 The other possibility would be to store them in different column families. Not sure about the performance there though --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3837) Create FLOOR/CEIL function

2016-05-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266735#comment-15266735 ] ASF GitHub Bot commented on FLINK-3837: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-3837] [table] Create FLOOR/CEIL functio...

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

  1   2   >