[GitHub] flink issue #2664: [FLINK-4861] [build] Package optional project artifacts

2016-11-22 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2664 I tried out the change and I like the idea. One issue I found is that transitive dependencies are not properly added: Kafka 0.10 depends on the Kafka 0.9 code, but that one (and its dependencies)

[jira] [Commented] (FLINK-4861) Package optional project artifacts

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686017#comment-15686017 ] ASF GitHub Bot commented on FLINK-4861: --- Github user rmetzger commented on the issue

[GitHub] flink issue #2319: [FLINK-4294] [table] Allow access of composite type field...

2016-11-22 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2319 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 enabled and wishes so, or if the

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686033#comment-15686033 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on the issue:

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

2016-11-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2319 --- 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-4294) Allow access of composite type fields

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

[jira] [Resolved] (FLINK-4294) Allow access of composite type fields

2016-11-22 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4294. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in e45096867a9542a756443310a535a971a6a29695.

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-11-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686075#comment-15686075 ] Flavio Pompermaier commented on FLINK-5122: --- Can you try and see if our pull req

[GitHub] flink issue #2816: [backport] [FLINK-5073] Use Executor to run ZooKeeper cal...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2816 Build passed locally: https://travis-ci.org/tillrohrmann/flink/builds/177725509. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink issue #2826: [backport] [FLINK-5085] Execute CheckpointCoordinator's s...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2826 Build passed locally: https://travis-ci.org/tillrohrmann/flink/builds/177725509. Merging the PR. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686097#comment-15686097 ] ASF GitHub Bot commented on FLINK-5085: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686099#comment-15686099 ] ASF GitHub Bot commented on FLINK-5073: --- Github user tillrohrmann commented on the i

[GitHub] flink pull request #2826: [backport] [FLINK-5085] Execute CheckpointCoordina...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2826 --- 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 i

[GitHub] flink pull request #2816: [backport] [FLINK-5073] Use Executor to run ZooKee...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2816 --- 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 i

[jira] [Commented] (FLINK-5073) ZooKeeperCompleteCheckpointStore executes blocking delete operation in ZooKeeper client thread

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686104#comment-15686104 ] ASF GitHub Bot commented on FLINK-5073: --- Github user tillrohrmann closed the pull re

[jira] [Commented] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686105#comment-15686105 ] ASF GitHub Bot commented on FLINK-5085: --- Github user tillrohrmann closed the pull re

[jira] [Commented] (FLINK-5057) Cancellation timeouts are picked from wrong config

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686230#comment-15686230 ] ASF GitHub Bot commented on FLINK-5057: --- Github user uce closed the pull request at:

[jira] [Assigned] (FLINK-4895) Drop support for Hadoop 1

2016-11-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4895: - Assignee: Robert Metzger > Drop support for Hadoop 1 > - > >

[GitHub] flink pull request #2794: [backport] [FLINK-5057] [task] Pick cancellation t...

2016-11-22 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/2794 --- 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 enabled

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686236#comment-15686236 ] ASF GitHub Bot commented on FLINK-4913: --- Github user uce commented on the issue:

[GitHub] flink issue #2795: Revert "[FLINK-4913][yarn] include user jars in system cl...

2016-11-22 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2795 Rebased this on latest release branch and going to merge later today after Travis. --- 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] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686299#comment-15686299 ] ASF GitHub Bot commented on FLINK-3848: --- Github user tonycox commented on the issue:

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-11-22 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 > In addition, the TableSource should know project information (including order) not just fieldIncluded. So maybe we should also adapt RowCsvInputFormat. Do you mean we need to shuffle field

[GitHub] flink issue #2825: [FLINK-5085] Execute CheckpointCoordinator's state discar...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2825 @StefanRRichter reviewed the backport #2826 of this PR which simply uses a different state discarding method and gave a +1. Since Travis passes as well, I'll merge the PR. --- If your project

[jira] [Commented] (FLINK-5085) Execute CheckpointCoodinator's state discard calls asynchronously

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686312#comment-15686312 ] ASF GitHub Bot commented on FLINK-5085: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

2016-11-22 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686321#comment-15686321 ] Till Rohrmann commented on FLINK-5114: -- The failing {{TimestampITCase}} seems to be r

[GitHub] flink issue #2846: [FLINK-5112] [ExecutionGraph] Remove unused accumulator a...

2016-11-22 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2846 Thanks for the review @zentol and the 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-5112) Remove unused accumulator code from ArchivedExecutionJobVertex

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686328#comment-15686328 ] ASF GitHub Bot commented on FLINK-5112: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-11-22 Thread static-max (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686338#comment-15686338 ] static-max commented on FLINK-5122: --- Your PR does not handle single failed bulk requests

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

2016-11-22 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686354#comment-15686354 ] Flavio Pompermaier commented on FLINK-5122: --- Actually the current ES sink implem

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686404#comment-15686404 ] ASF GitHub Bot commented on FLINK-3848: --- Github user wuchong commented on a diff in

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686406#comment-15686406 ] ASF GitHub Bot commented on FLINK-3848: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

2016-11-22 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r89091052 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sources/ProjectableTableSource.scala --- @@ -0,0 +1,32 @@ +/* + * Lic

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

2016-11-22 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r89090976 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableProject.scala --- @@ -0,0 +1,67 @@ +/* +

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686433#comment-15686433 ] ASF GitHub Bot commented on FLINK-4832: --- Github user ex00 commented on the issue:

[GitHub] flink issue #2840: [FLINK-4832] Count/Sum 0 elements

2016-11-22 Thread ex00
Github user ex00 commented on the issue: https://github.com/apache/flink/pull/2840 Hi @fhueske >Actually, I think implementing the fix as an optimizer rule would be the nicer solution. In that case we could transform one of the ITCases into a test that extends the TableTestBase.

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-11-22 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2810 Hi @tonycox , the [`RowCsvInputFormat`](https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/io/RowCsvInputFormat.scala#L100) rea

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686458#comment-15686458 ] ASF GitHub Bot commented on FLINK-3848: --- Github user wuchong commented on the issue:

[jira] [Created] (FLINK-5123) Add description how to do proper shading to Flink docs.

2016-11-22 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5123: --- Summary: Add description how to do proper shading to Flink docs. Key: FLINK-5123 URL: https://issues.apache.org/jira/browse/FLINK-5123 Project: Flink Issue Typ

[jira] [Closed] (FLINK-5123) Add description how to do proper shading to Flink docs.

2016-11-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5123. --- > Add description how to do proper shading to Flink docs. > --

[jira] [Resolved] (FLINK-5123) Add description how to do proper shading to Flink docs.

2016-11-22 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5123. - Resolution: Fixed Fixed in - 1.1.4 via a79290c28aed1d39588524cf873957c141c67a21 - 1.2.0 via a4

[jira] [Created] (FLINK-5124) Support more temporal arithmetic

2016-11-22 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5124: --- Summary: Support more temporal arithmetic Key: FLINK-5124 URL: https://issues.apache.org/jira/browse/FLINK-5124 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686551#comment-15686551 ] ASF GitHub Bot commented on FLINK-5075: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-...

2016-11-22 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2822#discussion_r89100942 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@ -

[jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

2016-11-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1568#comment-1568 ] Robert Metzger commented on FLINK-5049: --- Another instance of the issue: https://api

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89088443 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89086106 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object Aggregat

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89088166 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object Aggregat

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89089242 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89102066 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89101806 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89101873 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89090109 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89088819 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object Aggregat

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89086247 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object Aggregat

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89088322 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -39,66 +45,69 @@ object Aggregat

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89089095 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink pull request #2792: [FLINK-4937] [Table] Add incremental group window ...

2016-11-22 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2792#discussion_r89101976 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala --- @@ -115,14 +124,210 @@ object Aggre

[jira] [Commented] (FLINK-4937) Add incremental group window aggregation for streaming Table API

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

[GitHub] flink issue #2842: [FLINK-5097][gelly] Add missing input type information to...

2016-11-22 Thread vasia
Github user vasia commented on the issue: https://github.com/apache/flink/pull/2842 Hi @greghogan, I was able to fix the problem in `fromDataSet()` and `groupReduceOnEdges()` with `EdgesFunction`. In the rest of the uses, I don't seem to find a way to pass all the input types corr

[jira] [Commented] (FLINK-5097) The TypeExtractor is missing input type information in some Graph methods

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686757#comment-15686757 ] ASF GitHub Bot commented on FLINK-5097: --- Github user vasia commented on the issue:

[GitHub] flink issue #2740: [FLINK-4964] [ml]

2016-11-22 Thread tfournier314
Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2740 Hello @thvasilo @greghogan Ok I've updated documentation. I stay tuned for updating code. Regards Thomas --- If your project is set up for it, you can reply to this emai

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686760#comment-15686760 ] ASF GitHub Bot commented on FLINK-4964: --- Github user tfournier314 commented on the i

[jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger

2016-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686800#comment-15686800 ] Aljoscha Krettek commented on FLINK-5061: - We can also leave it in since it's not

[GitHub] flink issue #2681: [FLINK-4155] [kafka] Move partition list fetching to open...

2016-11-22 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2681 Thanks for the review @rmetzger. No, actually I haven't refactored the table tests yet. I'll file up the follow-up JIRAs mentioned in the comments, and merge the PR as is. --- If your proj

[jira] [Commented] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686810#comment-15686810 ] ASF GitHub Bot commented on FLINK-4155: --- Github user tzulitai commented on the issue

[GitHub] flink pull request #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-...

2016-11-22 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2822#discussion_r89119126 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java --- @@ -283

[jira] [Commented] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686816#comment-15686816 ] ASF GitHub Bot commented on FLINK-5075: --- Github user tzulitai commented on a diff in

[GitHub] flink issue #2822: [FLINK-5075] [kinesis] Make Kinesis consumer fail-proof t...

2016-11-22 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2822 Thanks for the review @StephanEwen. I'm pretty sure this doesn't affect the normal Kinesis shard discovery. I'll give it some final tests before merging (would like to get this in before the next 1.

[jira] [Commented] (FLINK-5075) Kinesis consumer incorrectly determines shards as newly discovered when tested against Kinesalite

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686823#comment-15686823 ] ASF GitHub Bot commented on FLINK-5075: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

2016-11-22 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686845#comment-15686845 ] Anton Mushin commented on FLINK-4604: - what if do try return the type of source column

[jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2016-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5125: Description: This is the travis log: https://api.travis-ci.org/jobs/177402367/log.txt?deans

[jira] [Created] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2016-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5125: --- Summary: ContinuousFileProcessingCheckpointITCase is Flaky Key: FLINK-5125 URL: https://issues.apache.org/jira/browse/FLINK-5125 Project: Flink Issue T

[jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2016-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5125: Labels: test-stability (was: ) > ContinuousFileProcessingCheckpointITCase is Flaky > --

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686872#comment-15686872 ] ASF GitHub Bot commented on FLINK-4469: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ...

2016-11-22 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2653#discussion_r89124491 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -162,24 +191,107 @@ obj

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686877#comment-15686877 ] ASF GitHub Bot commented on FLINK-4469: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #2653: [FLINK-4469] [table] Add support for user defined ...

2016-11-22 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/2653#discussion_r89124951 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -162,24 +191,107 @@ obj

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-11-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686881#comment-15686881 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4905 at 11/22/16 2:28 PM: --

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-11-22 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686881#comment-15686881 ] Tzu-Li (Gordon) Tai commented on FLINK-4905: Hi [~Andrew Efimov], Thanks for

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

2016-11-22 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686870#comment-15686870 ] Vasia Kalavri commented on FLINK-1536: -- This issue does not refer to bipartite graphs

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686898#comment-15686898 ] ASF GitHub Bot commented on FLINK-4964: --- Github user thvasilo commented on the issue

[GitHub] flink issue #2740: [FLINK-4964] [ml]

2016-11-22 Thread thvasilo
Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/2740 Hello @tfournier314, I should have clarified for documentation I meant apart from the docstrings you have added now, we also have to include documentation in the Flink [docs](https://github.com/apa

[GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f...

2016-11-22 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2653 Regarding to the mixing parser Expression and Logical Node, how about to create a `LogicalParser` which is used to parse string to LogicalNode ? This can separate expressions and logical nodes, and k

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-11-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686902#comment-15686902 ] ASF GitHub Bot commented on FLINK-4469: --- Github user wuchong commented on the issue:

[jira] [Commented] (FLINK-5121) Integrate YARN application ID with web interface

2016-11-22 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686901#comment-15686901 ] Maximilian Michels commented on FLINK-5121: --- The application id is already part

[jira] [Created] (FLINK-5126) Remove Checked Exceptions from State Interfaces

2016-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5126: --- Summary: Remove Checked Exceptions from State Interfaces Key: FLINK-5126 URL: https://issues.apache.org/jira/browse/FLINK-5126 Project: Flink Issue Typ

[GitHub] flink pull request #2836: [FLINK-5092] Add maven profile with code coverage ...

2016-11-22 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2836#discussion_r89129818 --- Diff: pom.xml --- @@ -955,9 +996,10 @@ under the License. ${flink.reuseForks}

  1   2   3   4   >