[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&focusedCommentId=15270061#comment-15270061 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff

[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 th

[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&focusedCommentId=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 Elastic

[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 fl

[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 fl

[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 Iss

[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&focusedCommentId=15269725#comment-15269725 ] Tatu Saloranta commented on FLINK-3855: --- Also: if I am not mistaken, ElasticSearch2

[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 @@ public

[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 Type

[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 trigg

[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&focusedCommentId=15269345#comment-15269345 ] Subhobrata Dey commented on FLINK-3857: --- Hello [~fhueske], I'm interested in the ta

[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] [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&focusedCommentId=15269335#comment-15269335 ] ASF GitHub Bot commented on FLINK-3854: --- Github user aljoscha commented on the pull

[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 (po

[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 org.a

[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&focusedCommentId=15269314#comment-15269314 ] ASF GitHub Bot commented on FLINK-3854: --- Github user IgorBerman commented on the pul

[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&focusedCommentId=15269194#comment-15269194 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff i

[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 the

[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&focusedCommentId=15269116#comment-15269116 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on a diff

[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_r61918711 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala --- @@ -1599,7 +1601,77 @@ class DataSet[T: ClassTag](set: JavaDataSet[T]) {

[jira] [Created] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

2016-05-03 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3864: - Summary: Yarn tests don't check for prohibited strings in log output Key: FLINK-3864 URL: https://issues.apache.org/jira/browse/FLINK-3864 Project: Flink

[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&focusedCommentId=15269019#comment-15269019 ] ASF GitHub Bot commented on FLINK-1996: --- Github user fhueske commented on the pull r

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

2016-05-03 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1961#issuecomment-216588444 Thanks for the feedback @yjshen. The motivation of the `TableSink` interface is to support very different storage systems (JDBC, Cassandra, Kafka, HBase, ...) a

[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] [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&focusedCommentId=15268940#comment-15268940 ] ASF GitHub Bot commented on FLINK-1996: --- Github user yjshen commented on the pull re

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

2016-05-03 Thread yjshen
Github user yjshen commented on the pull request: https://github.com/apache/flink/pull/1961#issuecomment-216575391 Hi @fhueske , I've read through this PR and find a little wired of the current API design. Please correct me if I take something wrong: Since we are output `Table

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

2016-05-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268920#comment-15268920 ] Fabian Hueske commented on FLINK-3862: -- +1 for moving the third party packages and co

[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 community

[jira] [Created] (FLINK-3862) Restructure community slide

2016-05-03 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3862: Summary: Restructure community slide Key: FLINK-3862 URL: https://issues.apache.org/jira/browse/FLINK-3862 Project: Flink Issue Type: Task Componen

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

2016-05-03 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1929#issuecomment-216545948 Ah man, you're right, the test needs to be moved to the `flink-fs-tests` package, I think. --- If your project is set up for it, you can reply to this email and have y

[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&focusedCommentId=15268790#comment-15268790 ] ASF GitHub Bot commented on FLINK-3808: --- Github user aljoscha commented on the pull

[jira] [Resolved] (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:all-tabpanel ] Aljoscha Krettek resolved FLINK-3669. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed in https://github.com/apache/flink/co

[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 p

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-05-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268703#comment-15268703 ] Robert Metzger commented on FLINK-2821: --- [~mxm], are you okay with me taking over th

[jira] [Assigned] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x

2016-05-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3662: - Assignee: Robert Metzger (was: Maximilian Michels) > Bump Akka version to 2.4.x for Scal

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-05-03 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268708#comment-15268708 ] Maximilian Michels commented on FLINK-2821: --- Sure, go ahead! > Change Akka conf

[jira] [Assigned] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-05-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2821: - Assignee: Robert Metzger (was: Maximilian Michels) > Change Akka configuration to allow

[jira] [Assigned] (FLINK-3661) Make Scala 2.11.x the default Scala version

2016-05-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3661: - Assignee: Robert Metzger (was: Maximilian Michels) > Make Scala 2.11.x the default Scala

[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&focusedCommentId=15268691#comment-15268691 ] ASF GitHub Bot commented on FLINK-1827: --- Github user zentol commented on the pull re

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

2016-05-03 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1915#issuecomment-216525073 @stefanobortoli yes. --- 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 fe

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

2016-05-03 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15268685#comment-15268685 ] Greg Hogan commented on FLINK-3772: --- [~vkalavri], I implemented the degree functions fro

[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&focusedCommentId=15268666#comment-15268666 ] ASF GitHub Bot commented on FLINK-1827: --- Github user stefanobortoli commented on the

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

2016-05-03 Thread stefanobortoli
Github user stefanobortoli commented on the pull request: https://github.com/apache/flink/pull/1915#issuecomment-216521677 @tillrohrmann, I see the conflicts. How should I deal with this? rebase? --- If your project is set up for it, you can reply to this email and have your reply ap

[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&focusedCommentId=15268656#comment-15268656 ] Sergio Ramírez commented on FLINK-3784: --- Yes, it is solved. Thanks for the support.

[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-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&focusedCommentId=15268637#comment-15268637 ] Stephan Ewen commented on FLINK-3860: - How about not ignoring it (that effectively mea

[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&focusedCommentId=15268625#comment-15268625 ] ASF GitHub Bot commented on FLINK-3856: --- Github user fhueske commented on the pull r

[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 they

[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&focusedCommentId=15268620#comment-15268620 ] ASF GitHub Bot commented on FLINK-3229: --- Github user rmetzger commented on the pull

[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 AWS

[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&focusedCommentId=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

[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&focusedCommentId=15268613#comment-15268613 ] Timo Walther commented on FLINK-3861: - [~aljoscha] you are a Scala expert. How would y

[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&focusedCommentId=15268612#comment-15268612 ] ASF GitHub Bot commented on FLINK-3856: --- Github user StephanEwen commented on the pu

[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 y

[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&focusedCommentId=15268610#comment-15268610 ] ASF GitHub Bot commented on FLINK-3825: --- GitHub user StefanRRichter opened a pull re

[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 https://github.c

[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: Ne

[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&focusedCommentId=15268584#comment-15268584 ] Chesnay Schepler commented on FLINK-3784: - I believe tThis Issue was resolved on t

[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 re

[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&focusedCommentId=15268580#comment-15268580 ] ASF GitHub Bot commented on FLINK-3754: --- Github user fhueske commented on the pull r

[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&focusedCommentId=15268572#comment-15268572 ] ASF GitHub Bot commented on FLINK-3754: --- Github user yjshen commented on the pull re

[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] flink-connector-wikied

[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&focusedCommentId=15268567#comment-15268567 ] ASF GitHub Bot commented on FLINK-3808: --- Github user zentol commented on the pull re

[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 and

[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&focusedCommentId=15268560#comment-15268560 ] ASF GitHub Bot commented on FLINK-3754: --- Github user yjshen commented on the pull re

[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&focusedCommentId=15268553#comment-15268553 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff

[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&focusedCommentId=15268558#comment-15268558 ] Aljoscha Krettek commented on FLINK-3404: - In some way, yes. > Extend Kafka consu

[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

[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&focusedCommentId=15268555#comment-15268555 ] Aljoscha Krettek commented on FLINK-3860: - +1 > WikipediaEditsSourceTest.testWiki

[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 th

[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&focusedCommentId=15268552#comment-15268552 ] ASF GitHub Bot commented on FLINK-3754: --- Github user yjshen closed the pull request

[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 enab

[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&focusedCommentId=15268551#comment-15268551 ] ASF GitHub Bot commented on FLINK-3754: --- Github user zentol commented on the pull re

[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

[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&focusedCommentId=15268540#comment-15268540 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff

[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 th

[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&focusedCommentId=15268535#comment-15268535 ] ASF GitHub Bot commented on FLINK-2044: --- Github user vasia commented on a diff in th

[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 Apa

[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&focusedCommentId=15268524#comment-15268524 ] ASF GitHub Bot commented on FLINK-2044: --- Github user gallenvara commented on a diff

[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 th

[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&focusedCommentId=15268523#comment-15268523 ] ASF GitHub Bot commented on FLINK-3856: --- GitHub user twalthr opened a pull request:

[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 consideration.

[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&focusedCommentId=15268522#comment-15268522 ] Martin Liesenberg commented on FLINK-3404: -- ok, I didn't realize that needed to b

[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&focusedCommentId=15268518#comment-15268518 ] ASF GitHub Bot commented on FLINK-2044: --- Github user greghogan commented on a diff i

[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 the

[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&focusedCommentId=15268494#comment-15268494 ] Chesnay Schepler commented on FLINK-3860: - i agree that we should @Ignore it. > W

[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&focusedCommentId=15268489#comment-15268489 ] Ufuk Celebi commented on FLINK-3860: Yes, that's problematic for other reasons as well

[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&focusedCommentId=15268472#comment-15268472 ] Chesnay Schepler commented on FLINK-3860: - this may be simply an availability issu

[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 i

[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&focusedCommentId=15268465#comment-15268465 ] ASF GitHub Bot commented on FLINK-3754: --- Github user yjshen commented on the pull re

[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&focusedCommentId=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 functionalit

[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 Is

[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&focusedCommentId=15268419#comment-15268419 ] Aljoscha Krettek commented on FLINK-3669: - Ok, I think it's good to merge then. :-

[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&focusedCommentId=15268410#comment-15268410 ] ASF GitHub Bot commented on FLINK-1827: --- Github user stefanobortoli commented on a d

[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 Softw

[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&focusedCommentId=15268408#comment-15268408 ] ASF GitHub Bot commented on FLINK-1827: --- Github user tillrohrmann commented on the p

  1   2   >