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

2016-05-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1953#issuecomment-216627907 That's a problem we currently have since the wikipedia IRC channel times out. Restarting wouldn't help, but in the future, if you want to restart you can push a new

[jira] [Created] (FLINK-3865) ExecutionConfig NullPointerException with second execution

2016-05-03 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3865: - Summary: ExecutionConfig NullPointerException with second execution Key: FLINK-3865 URL: https://issues.apache.org/jira/browse/FLINK-3865 Project: Flink Issue

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

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

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

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15269194#comment-15269194 ] 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-03 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61925324 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,178 @@ +/* + * Licensed to

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

2016-05-03 Thread IgorBerman
Github user IgorBerman commented on the pull request: https://github.com/apache/flink/pull/1953#issuecomment-216622861 @aljoscha can we rerun somehow build? I've checked it failed on flink-connector-wikiedits which isn't connected...unless I'm missing something Running

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

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

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

2016-05-03 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15269345#comment-15269345 ] Subhobrata Dey commented on FLINK-3857: --- Hello [~fhueske], I'm interested in the task & assigning

[jira] [Assigned] (FLINK-3857) Add reconnect attempt to Elasticsearch host

2016-05-03 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhobrata Dey reassigned FLINK-3857: - Assignee: Subhobrata Dey > Add reconnect attempt to Elasticsearch host >

[jira] [Assigned] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-03 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-3758: --- Assignee: Konstantin Knauf > Add possibility to register accumulators in custom

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

2016-05-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1952#issuecomment-216466422 The build now fails consistently for the wikipedia connector? Could you push another dummy commit to rerun travis tests. Let's see if it goes away. --- If your

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

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

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

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

[GitHub] flink pull request: [FLINK-1827] and small fixes in some tests

2016-05-03 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1915#issuecomment-216475737 Modulo one more inline comment, I think it looks good. --- 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-1827] and small fixes in some tests

2016-05-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1915#discussion_r61855640 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/StartupUtils.java --- @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache

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

2016-05-03 Thread smarthi
Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/1952#issuecomment-216487812 There IRC Wikimedia channel is timing out and hence the reason for Wiki test failures, nothing to do with this PR. LGTM IMO --- If your project is set up for

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

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

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

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

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

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

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

2016-05-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268379#comment-15268379 ] Maximilian Michels commented on FLINK-1984: --- Great news :) > Integrate Flink with Apache Mesos

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

2016-05-03 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1955 --- 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-3793][docs] re-organize table API and S...

2016-05-03 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1955#issuecomment-216463342 Updated and 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

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

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

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

2016-05-03 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r61853639 --- 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-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268383#comment-15268383 ] ASF GitHub Bot commented on FLINK-3650: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-1827] and small fixes in some tests

2016-05-03 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1915#issuecomment-216474116 Is this good to merge, @tillrohrmann? --- 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

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

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

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

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

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

2016-05-03 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-3793. -- Resolution: Fixed Fix Version/s: 1.1.0 > Re-organize the Table API and SQL docs >

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

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

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

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

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

2016-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268419#comment-15268419 ] Aljoscha Krettek commented on FLINK-3669: - Ok, I think it's good to merge then. :-) >

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268456#comment-15268456 ] ASF GitHub Bot commented on FLINK-3754: --- GitHub user yjshen opened a pull request:

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

2016-05-03 Thread yjshen
GitHub user yjshen opened a pull request: https://github.com/apache/flink/pull/1958 [FLINK-3754][Table]Add a validation phase before construct RelNode using TableAPI This PR aims at adding an extra phase of **validation** for plans generated from Table API, matches the

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

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

[jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

2016-05-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268472#comment-15268472 ] Chesnay Schepler commented on FLINK-3860: - this may be simply an availability issue, as the test

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

2016-05-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1957#issuecomment-216466778 It is a problem because we would be trashing the db, right. I thought about garbage collection but this would be yet another layer of complexity. --- If your project

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

2016-05-03 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/1856#discussion_r61854150 --- 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)

[GitHub] flink pull request: [FLINK-1827] and small fixes in some tests

2016-05-03 Thread stefanobortoli
Github user stefanobortoli commented on a diff in the pull request: https://github.com/apache/flink/pull/1915#discussion_r61855824 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/util/StartupUtils.java --- @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies

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

[jira] [Created] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

2016-05-03 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3860: Summary: WikipediaEditsSourceTest.testWikipediaEditsSource times out Key: FLINK-3860 URL: https://issues.apache.org/jira/browse/FLINK-3860 Project: Flink

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

2016-05-03 Thread yjshen
Github user yjshen commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-216487312 This PR substitute #1916 by squashing several previous commits into single one for easier rebase. @fhueske I've implemented eager validation here, can you take a

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

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

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

[jira] [Commented] (FLINK-3855) Upgrade Jackson version

2016-05-03 Thread Tatu Saloranta (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15269725#comment-15269725 ] Tatu Saloranta commented on FLINK-3855: --- Also: if I am not mistaken, ElasticSearch2 connector does

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

2016-05-03 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61864334 --- 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-3856] [core] Create types for java.sql....

2016-05-03 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/1959 [FLINK-3856] [core] Create types for java.sql.Date/Time/Timestamp Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

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

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268523#comment-15268523 ] ASF GitHub Bot commented on FLINK-3856: --- GitHub user twalthr opened a pull request:

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

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

[jira] [Commented] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument.

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

[jira] [Created] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2016-05-03 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3861: --- Summary: Add Scala's BigInteger and BigDecimal to Scala API Key: FLINK-3861 URL: https://issues.apache.org/jira/browse/FLINK-3861 Project: Flink Issue Type:

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

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268617#comment-15268617 ] ASF GitHub Bot commented on FLINK-1996: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request: [FLINK-1996] [tableApi] Add TableSink interfac...

2016-05-03 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/1961 [FLINK-1996] [tableApi] Add TableSink interface to emit tables to external storage. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql....

2016-05-03 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1959#issuecomment-216513630 These types would also be useful for `flink-jdbc` and possibly other modules. We can move them to a dedicated `TimeTypeInfo` or `SqlTimeTypeInfo` class, but I think

[jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

2016-05-03 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268489#comment-15268489 ] Ufuk Celebi commented on FLINK-3860: Yes, that's problematic for other reasons as well. I would like

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

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

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

[jira] [Commented] (FLINK-3825) Update CEP documentation to include Scala API

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268610#comment-15268610 ] ASF GitHub Bot commented on FLINK-3825: --- GitHub user StefanRRichter opened a pull request:

[GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql....

2016-05-03 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1959#issuecomment-216511830 Can these type infos exist independent of the BasicTypeInfo? Either in some class like SQL type infos, or even only inside the Table API / SQL project? --- If

[GitHub] flink pull request: [FLINK-3825] Documentation for CEP Scala API.

2016-05-03 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/1960 [FLINK-3825] Documentation for CEP Scala API. [FLINK-3825] Documentation for CEP Scala API. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

2016-05-03 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268637#comment-15268637 ] Stephan Ewen commented on FLINK-3860: - How about not ignoring it (that effectively means removing the

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

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268540#comment-15268540 ] 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-03 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61866752 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

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

2016-05-03 Thread yjshen
Github user yjshen closed the pull request at: https://github.com/apache/flink/pull/1916 --- 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-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268553#comment-15268553 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff in the pull

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

2016-05-03 Thread yjshen
Github user yjshen commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-216502690 @zentol OK, I've closed it. --- 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-3754][Table]Add a validation phase befo...

2016-05-03 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-216506763 That's a known issue, see FLINK-3860. No need to worry about this PR. I'll have a look soon, thanks for the update! --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

[jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

2016-05-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268494#comment-15268494 ] Chesnay Schepler commented on FLINK-3860: - i agree that we should @Ignore it. >

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

2016-05-03 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-216501884 Since this PR is a substitute, could you close the old one? Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: FLINK-3808: Refactor the whole file monitoring...

2016-05-03 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1929#issuecomment-216503327 One related test failure; the hadoop dependency could not be found for PROFILE="-Dhadoop.profile=1" --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2016-05-03 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268613#comment-15268613 ] Timo Walther commented on FLINK-3861: - [~aljoscha] you are a Scala expert. How would you implement

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

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

[jira] [Closed] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction

2016-05-03 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Ramírez closed FLINK-3784. - Resolution: Not A Problem > Unexpected results using collect() in RichMapPartitionFunction >

[jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

2016-05-03 Thread Martin Liesenberg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268522#comment-15268522 ] Martin Liesenberg commented on FLINK-3404: -- ok, I didn't realize that needed to be done first.

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

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

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

[jira] [Commented] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction

2016-05-03 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268584#comment-15268584 ] Chesnay Schepler commented on FLINK-3784: - I believe tThis Issue was resolved on the mailing-list,

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

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

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

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268524#comment-15268524 ] 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-03 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r61868075 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,194 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-3860) WikipediaEditsSourceTest.testWikipediaEditsSource times out

2016-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268555#comment-15268555 ] Aljoscha Krettek commented on FLINK-3860: - +1 > WikipediaEditsSourceTest.testWikipediaEditsSource

[jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

2016-05-03 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268558#comment-15268558 ] Aljoscha Krettek commented on FLINK-3404: - In some way, yes. > Extend Kafka consumers with

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

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

2016-05-03 Thread yjshen
Github user yjshen commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-216505284 Test failure due to irrelevant test: ``` [INFO] flink-table SUCCESS [08:03 min] [INFO]

[jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics

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

[GitHub] flink pull request: [FLINK-3229] Flink streaming consumer for AWS ...

2016-05-03 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1911#issuecomment-216512837 I'm currently working on a custom branch based on this pull request. It seems that we are running into some dependency issues when using the kinesis-connector in

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

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

[jira] [Commented] (FLINK-3784) Unexpected results using collect() in RichMapPartitionFunction

2016-05-03 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-3784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15268656#comment-15268656 ] Sergio Ramírez commented on FLINK-3784: --- Yes, it is solved. Thanks for the support. > Unexpected

[GitHub] flink pull request: Timer coalescing across keys and cleanup of un...

2016-05-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1944#issuecomment-216535365 I merged it. Thanks a lot for your work! 😃 --- 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

[jira] [Updated] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't

2016-05-03 Thread Tatu Saloranta (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tatu Saloranta updated FLINK-3866: -- Description: Looking at default `TypeSerializer` instances I noticed what looks like a minor

[jira] [Updated] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't

2016-05-03 Thread Tatu Saloranta (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tatu Saloranta updated FLINK-3866: -- Description: Looking at default `TypeSerializer` instances I noticed what looks like a minor

[jira] [Created] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't

2016-05-03 Thread Tatu Saloranta (JIRA)
Tatu Saloranta created FLINK-3866: - Summary: StringArraySerializer claims type is immutable; shouldn't Key: FLINK-3866 URL: https://issues.apache.org/jira/browse/FLINK-3866 Project: Flink

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

2016-05-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270033#comment-15270033 ] ASF GitHub Bot commented on FLINK-3857: --- GitHub user sbcd90 opened a pull request:

[GitHub] flink pull request: [FLINK-3857][Streaming Connectors]Add reconnec...

2016-05-03 Thread sbcd90
GitHub user sbcd90 opened a pull request: https://github.com/apache/flink/pull/1962 [FLINK-3857][Streaming Connectors]Add reconnect attempt to Elasticsearch host - [ ] General - The pull request references the related JIRA issue ("[FLINK-3857] Add reconnect attempt to

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

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

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

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

[jira] [Created] (FLINK-3863) Yarn Cluster shutdown may fail if leader changed recently

2016-05-03 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3863: - Summary: Yarn Cluster shutdown may fail if leader changed recently Key: FLINK-3863 URL: https://issues.apache.org/jira/browse/FLINK-3863 Project: Flink

[jira] [Updated] (FLINK-3862) Restructure community website

2016-05-03 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3862: - Summary: Restructure community website (was: Restructure community slide) > Restructure

  1   2   >