[jira] [Created] (FLINK-6266) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6266: -- Summary: Remove the useless import in FlinkRelBuilder Key: FLINK-6266 URL: https://issues.apache.org/jira/browse/FLINK-6266 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-6267) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6267: -- Summary: Remove the useless import in FlinkRelBuilder Key: FLINK-6267 URL: https://issues.apache.org/jira/browse/FLINK-6267 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-6267) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956419#comment-15956419 ] ASF GitHub Bot commented on FLINK-6267: --- GitHub user sunjincheng121 opened a pull re

[GitHub] flink pull request #3671: [FLINK-6267][table]Remove the useless import in Fl...

2017-04-05 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/3671 [FLINK-6267][table]Remove the useless import in FlinkRelBuilder Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considera

[jira] [Commented] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956452#comment-15956452 ] ASF GitHub Bot commented on FLINK-6020: --- Github user WangTaoTheTonic commented on th

[GitHub] flink issue #3525: [FLINK-6020]add a random integer suffix to blob key to av...

2017-04-05 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3525 hi stephan, could you help review? @StephanEwen --- 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 issue #913: [FLINK-2363] [docs] First part of internals - complete job...

2017-04-05 Thread coveralls
Github user coveralls commented on the issue: https://github.com/apache/flink/pull/913 [![Coverage Status](https://coveralls.io/builds/10937729/badge)](https://coveralls.io/builds/10937729) Changes Unknown when pulling **e80aa842fbaab611cd889ae35b6c117e54a2e80d on Stepha

[jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956470#comment-15956470 ] ASF GitHub Bot commented on FLINK-2363: --- Github user coveralls commented on the issu

[GitHub] flink issue #3656: [FLINK-5994][table] Add Janino to flink-dist JAR file

2017-04-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3656 Thanks @sunjincheng121. I think you can close this PR. I also proposed to close FLINK-5994, because I think Janino shouldn't be added to the default artifact but to the jar-with-dependencies inste

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956495#comment-15956495 ] ASF GitHub Bot commented on FLINK-5994: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

2017-04-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956498#comment-15956498 ] ramkrishna.s.vasudevan commented on FLINK-5752: --- Started working on this. Wi

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956501#comment-15956501 ] Fabian Hueske commented on FLINK-6249: -- Thanks @radu, I saw your question on the Calc

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956504#comment-15956504 ] Fabian Hueske commented on FLINK-6261: -- Hi [~wheat9], I've already implemented this f

[GitHub] flink pull request #3665: [FLINK-6011] Support TUMBLE, HOP, SESSION window i...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3665#discussion_r109856293 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/LogicalWindowAggregateRule.scala --- @@ -117,46 +119,86 @@

[GitHub] flink issue #3656: [FLINK-5994][table] Add Janino to flink-dist JAR file

2017-04-05 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/3656 Thanks,@fhueske, I also think add `Janino` to `jar-with-dependencies` can solve the user's problem which mentioned in this JIRA.That is why at the beginning I am in this PR I did not add `Jan

[jira] [Commented] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

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

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956508#comment-15956508 ] ASF GitHub Bot commented on FLINK-5994: --- Github user sunjincheng121 commented on the

[GitHub] flink pull request #3656: [FLINK-5994][table] Add Janino to flink-dist JAR f...

2017-04-05 Thread sunjincheng121
Github user sunjincheng121 closed the pull request at: https://github.com/apache/flink/pull/3656 --- 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

[jira] [Commented] (FLINK-5994) Add Janino to flink-table JAR file

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956509#comment-15956509 ] ASF GitHub Bot commented on FLINK-5994: --- Github user sunjincheng121 closed the pull

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

2017-04-05 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956510#comment-15956510 ] Haohui Mai commented on FLINK-6261: --- That's even better -- looking forward to the PR :-)

[jira] [Updated] (FLINK-6257) Post-pass OVER windows

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6257: - Description: The OVER windows have been implemented by several contributors. We should do a post p

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956513#comment-15956513 ] Fabian Hueske commented on FLINK-6257: -- I'd do the check in the {{DataStreamOverAggre

[GitHub] flink pull request #3665: [FLINK-6011] Support TUMBLE, HOP, SESSION window i...

2017-04-05 Thread haohui
Github user haohui commented on a diff in the pull request: https://github.com/apache/flink/pull/3665#discussion_r109857875 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/LogicalWindowAggregateRule.scala --- @@ -117,46 +119,86 @@

[jira] [Commented] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956518#comment-15956518 ] ASF GitHub Bot commented on FLINK-6011: --- Github user haohui commented on a diff in t

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956524#comment-15956524 ] sunjincheng commented on FLINK-6257: Yes [~fhueske] I am glad to do it if you can spl

[jira] [Commented] (FLINK-6257) Post-pass OVER windows

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956529#comment-15956529 ] Fabian Hueske commented on FLINK-6257: -- Just noticed, this is already a subissue. We

[jira] [Assigned] (FLINK-6257) Post-pass OVER windows

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-6257: -- Assignee: sunjincheng > Post-pass OVER windows > -- > > Key

[GitHub] flink issue #3671: [FLINK-6267][table]Remove the useless import in FlinkRelB...

2017-04-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3671 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6267) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956543#comment-15956543 ] ASF GitHub Bot commented on FLINK-6267: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956550#comment-15956550 ] Fabian Hueske commented on FLINK-6228: -- Hi [~sunjincheng121], yes. I would handle tha

[GitHub] flink issue #3665: [FLINK-6011] Support TUMBLE, HOP, SESSION window in strea...

2017-04-05 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3665 Thanks for the update @haohui! Will merge this PR. --- 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 th

[jira] [Commented] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956552#comment-15956552 ] ASF GitHub Bot commented on FLINK-6011: --- Github user fhueske commented on the issue:

[GitHub] flink pull request #3672: [Flink-6072] TestCase CheckpointStateRestoreTest::...

2017-04-05 Thread guoweiM
GitHub user guoweiM opened a pull request: https://github.com/apache/flink/pull/3672 [Flink-6072] TestCase CheckpointStateRestoreTest::testSetState should be fail This case should be fail because three `KeyGroupStateHandles` which have same `KeyGroupRange[0,0]` are received by `Che

[GitHub] flink pull request #3673: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-04-05 Thread DmytroShkvyra
GitHub user DmytroShkvyra opened a pull request: https://github.com/apache/flink/pull/3673 [FLINK-5256] Extend DataSetSingleRowJoin to support Left and Right joins Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into c

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956576#comment-15956576 ] ASF GitHub Bot commented on FLINK-5256: --- GitHub user DmytroShkvyra opened a pull req

[GitHub] flink issue #3110: [FLINK-2184] Cannot get last element with maxBy/minBy.

2017-04-05 Thread gallenvara
Github user gallenvara commented on the issue: https://github.com/apache/flink/pull/3110 @fhueske @twalthr . Can you help with reviewing this PR? --- 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 h

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956614#comment-15956614 ] ASF GitHub Bot commented on FLINK-2184: --- Github user gallenvara commented on the iss

[GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2017-04-05 Thread ex00
Github user ex00 closed the pull request at: https://github.com/apache/flink/pull/3033 --- 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 enable

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956625#comment-15956625 ] ASF GitHub Bot commented on FLINK-5256: --- Github user ex00 closed the pull request at

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956630#comment-15956630 ] sunjincheng commented on FLINK-6228: That's great [~fhueske]. :) Here I have a questi

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956630#comment-15956630 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 10:21 AM: -

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956630#comment-15956630 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 10:23 AM: -

[GitHub] flink pull request #2870: [FLINK-4565] Support for SQL IN operator

2017-04-05 Thread NickolayVasilishin
Github user NickolayVasilishin closed the pull request at: https://github.com/apache/flink/pull/2870 --- 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 fea

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956640#comment-15956640 ] Fabian Hueske commented on FLINK-6228: -- I think that use case is not supported yet (b

[jira] [Closed] (FLINK-6266) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6266. - Resolution: Duplicate > Remove the useless import in FlinkRelBuilder > ---

[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER...

2017-04-05 Thread godfreyhe
Github user godfreyhe commented on a diff in the pull request: https://github.com/apache/flink/pull/3660#discussion_r109898654 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/SqlExpressionTest.scala --- @@ -168,6 +168,18 @@ class SqlExpressi

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956757#comment-15956757 ] ASF GitHub Bot commented on FLINK-6237: --- Github user godfreyhe commented on a diff i

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956761#comment-15956761 ] ASF GitHub Bot commented on FLINK-6237: --- Github user godfreyhe commented on the issu

[GitHub] flink issue #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER on SQL

2017-04-05 Thread godfreyhe
Github user godfreyhe commented on the issue: https://github.com/apache/flink/pull/3660 thanks for your advice @fhueske @twalthr. I had update the PR. I will implement rand and rand_integer functions for the Scala and Java Table API next immediately, or should I submit a new PR ?

[jira] [Assigned] (FLINK-6248) Make the optional() available to all offered patterns.

2017-04-05 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6248: - Assignee: Kostas Kloudas > Make the optional() available to all offered patterns. > -

[GitHub] flink pull request #3674: [FLINK-6265] [cep] Fix consecutive() for times()

2017-04-05 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/3674 [FLINK-6265] [cep] Fix consecutive() for times() You can merge this pull request into a Git repository by running: $ git pull https://github.com/kl0u/flink cep-times-fix Alternatively you can re

[jira] [Commented] (FLINK-6265) Fix consecutive() for times() pattern.

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956765#comment-15956765 ] ASF GitHub Bot commented on FLINK-6265: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request #3665: [FLINK-6011] Support TUMBLE, HOP, SESSION window i...

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

[GitHub] flink pull request #3671: [FLINK-6267][table]Remove the useless import in Fl...

2017-04-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3671 --- 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-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

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

[jira] [Commented] (FLINK-6267) Remove the useless import in FlinkRelBuilder

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

[GitHub] flink pull request #3660: [FLINK-6237] [table] support RAND and RAND_INTEGER...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3660#discussion_r109908139 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/SqlExpressionTest.scala --- @@ -168,6 +168,18 @@ class SqlExpression

[jira] [Commented] (FLINK-6237) support RAND and RAND_INTEGER on SQL

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

[GitHub] flink pull request #3675: [FLINK-6261] [table] Support TUMBLE, HOP, SESSION ...

2017-04-05 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/3675 [FLINK-6261] [table] Support TUMBLE, HOP, SESSION group window functions for SQL queries on batch tables You can merge this pull request into a Git repository by running: $ git pull https://g

[jira] [Commented] (FLINK-6261) Add support for TUMBLE, HOP, SESSION to batch SQL

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

[jira] [Closed] (FLINK-6267) Remove the useless import in FlinkRelBuilder

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6267. Resolution: Fixed Fix Version/s: 1.3.0 Fixed with 1649f35200705111a155962af33829f24acefd11 >

[jira] [Closed] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6011. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with 876107698aa2d601d5f398ea56fd93e

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956630#comment-15956630 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 1:15 PM: Th

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956640#comment-15956640 ] Fabian Hueske edited comment on FLINK-6228 at 4/5/17 1:28 PM: --

[jira] [Created] (FLINK-6268) Object reuse for Either type

2017-04-05 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6268: - Summary: Object reuse for Either type Key: FLINK-6268 URL: https://issues.apache.org/jira/browse/FLINK-6268 Project: Flink Issue Type: Improvement Compon

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956888#comment-15956888 ] sunjincheng commented on FLINK-6228: IMO.The definition of the tableAPI window can be

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956888#comment-15956888 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 1:54 PM: IM

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956888#comment-15956888 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 1:54 PM: IM

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956904#comment-15956904 ] Fabian Hueske commented on FLINK-6228: -- I'm not sure whether each window type is usef

[GitHub] flink pull request #3676: [FLINK-6241] [table] codeGen dataStream aggregates...

2017-04-05 Thread shaoxuan-wang
GitHub user shaoxuan-wang opened a pull request: https://github.com/apache/flink/pull/3676 [FLINK-6241] [table] codeGen dataStream aggregates that use ProcessFunction Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check lis

[jira] [Commented] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

2017-04-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956953#comment-15956953 ] ASF GitHub Bot commented on FLINK-6241: --- GitHub user shaoxuan-wang opened a pull req

[jira] [Commented] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956964#comment-15956964 ] sunjincheng commented on FLINK-6228: Yes, Your right In SQL we should be consistent wi

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956964#comment-15956964 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 2:47 PM: Ye

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956964#comment-15956964 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 2:47 PM: Ye

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956964#comment-15956964 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 2:51 PM: Ye

[jira] [Comment Edited] (FLINK-6228) Integrating the OVER windows in the Table API

2017-04-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956964#comment-15956964 ] sunjincheng edited comment on FLINK-6228 at 4/5/17 2:51 PM: Ye

[GitHub] flink pull request #3674: [FLINK-6265] [cep] Fix consecutive() for times()

2017-04-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3674 --- 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-6265) Fix consecutive() for times() pattern.

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

[jira] [Resolved] (FLINK-6265) Fix consecutive() for times() pattern.

2017-04-05 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas resolved FLINK-6265. --- Resolution: Fixed Merged at ffca0e76eaaefe6251a7664b93c4ec007e4305e9 > Fix consecutive() for

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109926548 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala --- @@ -131,8 +129,14 @@ abstract class TableFunct

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109931352 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunction.scala --- @@ -0,0 +1,55 @@ +/* + * Licens

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109955213 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -358,4 +366,120 @@ object

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109939331 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -358,4 +366,120 @@ object

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109965960 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedTableFunctions.scala --- @@ -109,6 +110,133 @@ class TableFunc3

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109929426 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/TableSqlFunction.scala --- @@ -53,22 +54,9 @@ class TableSqlFunc

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109963175 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedTableFunctions.scala --- @@ -109,6 +110,133 @@ class TableFunc3

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109964147 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedTableFunctions.scala --- @@ -109,6 +110,133 @@ class TableFunc3

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109931036 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/FlinkTableFunction.scala --- @@ -0,0 +1,55 @@ +/* + * Licens

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109933183 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala --- @@ -209,22 +216,23 @@ object

[GitHub] flink pull request #3623: [FLINK-6196] [table] Support dynamic schema in Tab...

2017-04-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3623#discussion_r109957441 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/TypedFlinkTableFunction.scala --- @@ -0,0 +1,52 @@ +/* + * L

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

[jira] [Commented] (FLINK-6196) Support dynamic schema in Table Function

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

  1   2   3   >