[GitHub] flink pull request #4076: [FLINK-6811][table] Add TIMESTAMPADD supported in ...

2017-06-05 Thread sunjincheng121
GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4076 [FLINK-6811][table] Add TIMESTAMPADD supported in SQL In this PR I have add `TIMESTAMPADD` supported in SQL. (the semantics keep consistent with calcite) - [x] General - The pu

[jira] [Commented] (FLINK-6811) Add TIMESTAMPADD supported in SQL

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

[jira] [Commented] (FLINK-6602) Table source with defined time attributes allows empty string

2017-06-05 Thread Zhe Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16036675#comment-16036675 ] Zhe Li commented on FLINK-6602: --- Checking the rowtime and proctime are not allowed empty str

[GitHub] flink pull request #4070: [FLINK-6834] [table] Support scalar functions on O...

2017-06-05 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4070#discussion_r120078093 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -226,30 +226,69 @@ object Projecti

[jira] [Created] (FLINK-6849) Refactor operator state backend and internal operator state hierarchy

2017-06-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6849: -- Summary: Refactor operator state backend and internal operator state hierarchy Key: FLINK-6849 URL: https://issues.apache.org/jira/browse/FLINK-6849 Proje

[jira] [Commented] (FLINK-6834) Over window doesn't support complex calculation

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

[GitHub] flink pull request #4070: [FLINK-6834] [table] Support scalar functions on O...

2017-06-05 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4070#discussion_r120081629 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala --- @@ -226,30 +226,69 @@ object Projecti

[jira] [Commented] (FLINK-6834) Over window doesn't support complex calculation

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

[jira] [Commented] (FLINK-6697) Add batch multi-window support

2017-06-05 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16036840#comment-16036840 ] Jark Wu commented on FLINK-6697: Hi [~twalthr], do you think 'w.rowtime should be supporte

[jira] [Created] (FLINK-6850) Links on "Powered by Flink" page not rendered correctly

2017-06-05 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-6850: --- Summary: Links on "Powered by Flink" page not rendered correctly Key: FLINK-6850 URL: https://issues.apache.org/jira/browse/FLINK-6850 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6788) Remove unused GenericFlatTypePostPass/AbstractSchema class

2017-06-05 Thread Miao Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16037251#comment-16037251 ] Miao Wang commented on FLINK-6788: -- Great! I am looking forward to working my first FLINK

[jira] [Assigned] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions

2017-06-05 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-5252: - Assignee: Haohui Mai > Migrate all YARN related configurations to ConfigOptions > ---

[jira] [Updated] (FLINK-6838) RescalingITCase fails in master branch

2017-06-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6838: Component/s: Tests State Backends, Checkpointing > RescalingITCase fails in

[jira] [Commented] (FLINK-6838) RescalingITCase fails in master branch

2017-06-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16037484#comment-16037484 ] Aljoscha Krettek commented on FLINK-6838: - [~srichter], could you please have a lo

[jira] [Commented] (FLINK-6810) Add Some built-in Scalar Function supported

2017-06-05 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16037492#comment-16037492 ] Haohui Mai commented on FLINK-6810: --- Thanks for creating these jira. They are quite usef

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

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

[GitHub] flink issue #3712: [FLINK-6281] Create TableSink for JDBC.

2017-06-05 Thread haohui
Github user haohui commented on the issue: https://github.com/apache/flink/pull/3712 @fhueske @zentol can you please take another look? Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Updated] (FLINK-6811) Add TIMESTAMPADD supported in SQL

2017-06-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6811: --- Description: * Syntax timestampAdd (datepart SqlTypeFamily.ANY, number:SqlTypeFamily.INTEGER, date:Sq

[jira] [Created] (FLINK-6851) Improve built-in scalar function when upgrade calcite version to 1.13

2017-06-05 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6851: -- Summary: Improve built-in scalar function when upgrade calcite version to 1.13 Key: FLINK-6851 URL: https://issues.apache.org/jira/browse/FLINK-6851 Project: Flink

[jira] [Updated] (FLINK-6811) Add TIMESTAMPADD supported in SQL

2017-06-05 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-6811: --- Description: * Syntax timestampAdd (datepart SqlTypeFamily.ANY, number:SqlTypeFamily.INTEGER, date:Sq

[jira] [Commented] (FLINK-6844) TraversableSerializer should implement compatibility methods

2017-06-05 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16037942#comment-16037942 ] mingleizhang commented on FLINK-6844: - I will look into this issue those days. > Trav

[jira] [Updated] (FLINK-6493) Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equals()

2017-06-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-6493: -- Description: {code} && ((partitionStateSerializer == null && ((Snapshot) obj).getPartitionStateSerializ

[jira] [Created] (FLINK-6852) Fix misuse of GCD

2017-06-05 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-6852: - Summary: Fix misuse of GCD Key: FLINK-6852 URL: https://issues.apache.org/jira/browse/FLINK-6852 Project: Flink Issue Type: Improvement Reporter: Ruido

[GitHub] flink pull request #4077: [FLINK-6852] Fix misuse of GCD

2017-06-05 Thread Xpray
GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/4077 [FLINK-6852] Fix misuse of GCD Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the

[jira] [Commented] (FLINK-6852) Fix misuse of GCD

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

[jira] [Updated] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

2017-06-05 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai updated FLINK-6693: -- Summary: Support DATE_FORMAT function in the Table / SQL API (was: Support DATE_FORMAT function in the

[GitHub] flink pull request #4078: [FLINK-6693] [table] Support DATE_FORMAT function ...

2017-06-05 Thread haohui
GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/4078 [FLINK-6693] [table] Support DATE_FORMAT function in the Table / SQL API. You can merge this pull request into a Git repository by running: $ git pull https://github.com/haohui/flink FLINK-6693

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the Table / SQL API

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

[jira] [Assigned] (FLINK-6418) Support for dynamic state changes in CEP patterns

2017-06-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6418: --- Assignee: Dawid Wysakowicz > Support for dynamic state changes in CEP patterns >