[jira] [Created] (FLINK-11969) Add end2end stream sql test for unbounded operators

Hequn Cheng created FLINK-11969: --- Summary: Add end2end stream sql test for unbounded operators Key: FLINK-11969 URL: https://issues.apache.org/jira/browse/FLINK-11969 Project: Flink Issue

[jira] [Created] (FLINK-11934) Remove the deprecate methods in TableEnvironment

Hequn Cheng created FLINK-11934: --- Summary: Remove the deprecate methods in TableEnvironment Key: FLINK-11934 URL: https://issues.apache.org/jira/browse/FLINK-11934 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

[ https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11918: --- Assignee: Hequn Cheng > Deprecated Window and Rename it to GroupWindow >

[jira] [Updated] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

[ https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11918: Issue Type: Sub-task (was: Improvement) Parent: FLINK-11068 > Deprecated Window and

[jira] [Commented] (FLINK-11890) Replace Table API string-based expressions by a Java DSL

[ https://issues.apache.org/jira/browse/FLINK-11890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792393#comment-16792393 ] Hequn Cheng commented on FLINK-11890: - Cool, looking forward to the proposal. > Replace Table API

[jira] [Updated] (FLINK-11908) Port window classes into flink-api-java

[ https://issues.apache.org/jira/browse/FLINK-11908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11908: Issue Type: Sub-task (was: Improvement) Parent: FLINK-11068 > Port window classes into

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792326#comment-16792326 ] Hequn Cheng commented on FLINK-11068: - [~sunjincheng121] Thanks for your suggestions. I think it

[jira] [Created] (FLINK-11916) Join with a Temporal Table should throw exception for left join

Hequn Cheng created FLINK-11916: --- Summary: Join with a Temporal Table should throw exception for left join Key: FLINK-11916 URL: https://issues.apache.org/jira/browse/FLINK-11916 Project: Flink

[jira] [Commented] (FLINK-11908) Port window classes into flink-api-java

[ https://issues.apache.org/jira/browse/FLINK-11908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791812#comment-16791812 ] Hequn Cheng commented on FLINK-11908: - Hi [~twalthr], One thing need to confirm with you is I find

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791806#comment-16791806 ] Hequn Cheng commented on FLINK-11068: - I have created FLINK-11908 for porting window classes and we

[jira] [Created] (FLINK-11908) Port window classes into flink-api-java

Hequn Cheng created FLINK-11908: --- Summary: Port window classes into flink-api-java Key: FLINK-11908 URL: https://issues.apache.org/jira/browse/FLINK-11908 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791790#comment-16791790 ] Hequn Cheng commented on FLINK-11068: - Hi [~twalthr], Great to have your suggestions. Thanks for

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790378#comment-16790378 ] Hequn Cheng commented on FLINK-11068: - [~dawidwys] Thanks for your valuable suggestions. I think you

[jira] [Commented] (FLINK-11824) Event-time attribute cannot have same name as in original format

[ https://issues.apache.org/jira/browse/FLINK-11824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16788860#comment-16788860 ] Hequn Cheng commented on FLINK-11824: - +1. Would be better to be able to have the same name as the

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787669#comment-16787669 ] Hequn Cheng commented on FLINK-11068: - [~twalthr] Hi, I have almost finished this issue. I think

[jira] [Commented] (FLINK-11819) Additional attribute for order by not support by flink sql, but told supported in doc

[ https://issues.apache.org/jira/browse/FLINK-11819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787428#comment-16787428 ] Hequn Cheng commented on FLINK-11819: - [~hustclf] Thanks for bringing up the discussion.

[jira] [Commented] (FLINK-11818) Provide pipe transformation function for DataSet API

[ https://issues.apache.org/jira/browse/FLINK-11818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785163#comment-16785163 ] Hequn Cheng commented on FLINK-11818: - [~yanghua] It's an interesting feature! Do you have any ideas

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778819#comment-16778819 ] Hequn Cheng commented on FLINK-11067: - [~twalthr] [~sunjincheng121] Thanks for your suggestions. I

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778782#comment-16778782 ] Hequn Cheng commented on FLINK-11068: - [~twalthr] [~yanghua] Thank you a lot for helping to

[jira] [Assigned] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11068: --- Assignee: Hequn Cheng > Convert the API classes *Table, *Window to interfaces >

[jira] [Comment Edited] (FLINK-11067) Convert TableEnvironments to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777857#comment-16777857 ] Hequn Cheng edited comment on FLINK-11067 at 2/26/19 12:08 PM: --- Hi

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16777857#comment-16777857 ] Hequn Cheng commented on FLINK-11067: - Hi [~twalthr], I have invested deeper into this issue and

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772725#comment-16772725 ] Hequn Cheng commented on FLINK-11067: - Hi, [~twalthr] Thank you for your reply. I like your ideas.

[jira] [Assigned] (FLINK-11067) Convert TableEnvironments to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11067: --- Assignee: Hequn Cheng (was: Yuzhao Chen) > Convert TableEnvironments to interfaces >

[jira] [Commented] (FLINK-11067) Convert TableEnvironments to interfaces

[ https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771015#comment-16771015 ] Hequn Cheng commented on FLINK-11067: - [~twalthr] Thanks for updating this issue according to the

[jira] [Commented] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770716#comment-16770716 ] Hequn Cheng commented on FLINK-11200: - [~twalthr] Hi, Would you be ok if I port all these DataView

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759825#comment-16759825 ] Hequn Cheng commented on FLINK-11447: - Hi all, thank you all for your valuable suggestions.

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16758307#comment-16758307 ] Hequn Cheng commented on FLINK-11447: - Hi, [~twalthr]. I agree that we don't need to complete in

[jira] [Commented] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757923#comment-16757923 ] Hequn Cheng commented on FLINK-11451: - Hi, [~xueyu] I think [~twalthr]'s suggestion is good. I don't

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757178#comment-16757178 ] Hequn Cheng commented on FLINK-11445: - [~twalthr] Oops, forgot it. Thanks for the reminder. (y) >

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757099#comment-16757099 ] Hequn Cheng commented on FLINK-11445: - [~dawidwys] Great to have your suggestions.(y) Will give a PR

[jira] [Commented] (FLINK-11447) Deprecate "new Table(TableEnvironment, String)"

[ https://issues.apache.org/jira/browse/FLINK-11447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757095#comment-16757095 ] Hequn Cheng commented on FLINK-11447: - Hi all, thanks for the nice discussion! I would like to share

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757035#comment-16757035 ] Hequn Cheng commented on FLINK-11445: - Hi [~twalthr] [~sunjincheng121], will implement this issue

[jira] [Commented] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756078#comment-16756078 ] Hequn Cheng commented on FLINK-11451: - [~xueyu] Great, thank you! Looking forward to your answer or

[jira] [Commented] (FLINK-11451) Move *QueryConfig and TableDescriptor to flink-table-api-java

[ https://issues.apache.org/jira/browse/FLINK-11451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16756011#comment-16756011 ] Hequn Cheng commented on FLINK-11451: - [~xueyu] Hi, thanks a lot for willing to solve this issue.

[jira] [Commented] (FLINK-11445) Deprecate static methods in TableEnvironments

[ https://issues.apache.org/jira/browse/FLINK-11445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754924#comment-16754924 ] Hequn Cheng commented on FLINK-11445: - [~twalthr] Thanks for creating the issue. [~sunjincheng121]

[jira] [Commented] (FLINK-11439) INSERT INTO flink_sql SELECT * FROM blink_sql

[ https://issues.apache.org/jira/browse/FLINK-11439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754500#comment-16754500 ] Hequn Cheng commented on FLINK-11439: - [~twalthr] A nice title (y) > INSERT INTO flink_sql SELECT *

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16751059#comment-16751059 ] Hequn Cheng commented on FLINK-11301: - [~Zentol] Sounds good. We can observe it a bit longer. If

[jira] [Updated] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11301: Attachment: error.log > Travis failed: No output has been received in the last 10m0s >

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750659#comment-16750659 ] Hequn Cheng commented on FLINK-11301: - I encountered the same error in my last PR.  Log link has

[jira] [Updated] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11301: Description: -[https://api.travis-ci.org/v3/job/47082/log.txt]- new log link: 

[jira] [Reopened] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reopened FLINK-11301: - > Travis failed: No output has been received in the last 10m0s >

[jira] [Commented] (FLINK-11416) DISTINCT on a JOIN inside of an UNION is not working

[ https://issues.apache.org/jira/browse/FLINK-11416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16750611#comment-16750611 ] Hequn Cheng commented on FLINK-11416: - Hi [~lordon], Thanks for reporting the issue. It is probably

[jira] [Updated] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

[ https://issues.apache.org/jira/browse/FLINK-11398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11398: Description: As discussed

[jira] [Created] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

Hequn Cheng created FLINK-11398: --- Summary: Add a dedicated phase to materialize time indicators for nodes produce updates Key: FLINK-11398 URL: https://issues.apache.org/jira/browse/FLINK-11398

[jira] [Commented] (FLINK-11342) Add example for every built-In TableAPI Function

[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745170#comment-16745170 ] Hequn Cheng commented on FLINK-11342: - Great, I will create sub-tasks in the next few days. Thank

[jira] [Updated] (FLINK-11342) Add example for every built-In TableAPI Function

[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11342: Component/s: Documentation > Add example for every built-In TableAPI Function >

[jira] [Commented] (FLINK-11342) Add example for every built-In TableAPI Function

[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745053#comment-16745053 ] Hequn Cheng commented on FLINK-11342: - Hi [~StephanEwen], great to have your attention. I suggest

[jira] [Updated] (FLINK-11342) Add example for every built-In TableAPI Function

[ https://issues.apache.org/jira/browse/FLINK-11342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11342: Description: There are a lot of built-in tableApi functions:

[jira] [Created] (FLINK-11342) Add example for every built-In TableAPI Function

Hequn Cheng created FLINK-11342: --- Summary: Add example for every built-In TableAPI Function Key: FLINK-11342 URL: https://issues.apache.org/jira/browse/FLINK-11342 Project: Flink Issue Type:

[jira] [Created] (FLINK-11331) Fix errors in tableApi.md and functions.md

Hequn Cheng created FLINK-11331: --- Summary: Fix errors in tableApi.md and functions.md Key: FLINK-11331 URL: https://issues.apache.org/jira/browse/FLINK-11331 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

[ https://issues.apache.org/jira/browse/FLINK-11310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11310: Description: In FLINK-10474, we force translate IN into a predicate to avoid translating to a

[jira] [Created] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

Hequn Cheng created FLINK-11310: --- Summary: Convert predicates to IN or NOT_IN for Project Key: FLINK-11310 URL: https://issues.apache.org/jira/browse/FLINK-11310 Project: Flink Issue Type:

[jira] [Closed] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-11301. --- Resolution: Fixed > Travis failed: No output has been received in the last 10m0s >

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740321#comment-16740321 ] Hequn Cheng commented on FLINK-11301: - Sorry, it seems travis will overwrite the log when restart

[jira] [Created] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

Hequn Cheng created FLINK-11301: --- Summary: Travis failed: No output has been received in the last 10m0s Key: FLINK-11301 URL: https://issues.apache.org/jira/browse/FLINK-11301 Project: Flink

[jira] [Commented] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream for createHarnessTester in HarnessTestBase

[ https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732989#comment-16732989 ] Hequn Cheng commented on FLINK-11222: - [~aljoscha] Great to have your suggestions! > Change

[jira] [Commented] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large.

[ https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732986#comment-16732986 ] Hequn Cheng commented on FLINK-11230: - [~jiweiautohome] The bottom aggregate after window will still

[jira] [Comment Edited] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large.

[ https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732637#comment-16732637 ] Hequn Cheng edited comment on FLINK-11230 at 1/3/19 3:52 AM: -

[jira] [Commented] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large.

[ https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732637#comment-16732637 ] Hequn Cheng commented on FLINK-11230: - [~jiweiautohome] Have you change the code of Flink. It should

[jira] [Commented] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large.

[ https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731981#comment-16731981 ] Hequn Cheng commented on FLINK-11230: - [~jiweiautohome] It is wired that the global window outputs

[jira] [Commented] (FLINK-11229) Support ScalarFunction for the where/filter clause.

[ https://issues.apache.org/jira/browse/FLINK-11229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16731360#comment-16731360 ] Hequn Cheng commented on FLINK-11229: - [~yanghua] It seems TableApi has already supported scalar

[jira] [Commented] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large.

[ https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730969#comment-16730969 ] Hequn Cheng commented on FLINK-11230: - Hi [~jiweiautohome] , I can't figure out the reason with the

[jira] [Commented] (FLINK-11229) Support ScalarFunction for the where/filter clause.

[ https://issues.apache.org/jira/browse/FLINK-11229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730964#comment-16730964 ] Hequn Cheng commented on FLINK-11229: - [~yanghua] Could you be more specific about what you are

[jira] [Commented] (FLINK-11226) Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729620#comment-16729620 ] Hequn Cheng commented on FLINK-11226: - [~albert.bik...@gmail.com] Thanks for reporting the issue. As

[jira] [Commented] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream for createHarnessTester in HarnessTestBase

[ https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729310#comment-16729310 ] Hequn Cheng commented on FLINK-11222: - [~zjffdu] good point. I agree with you that we should be

[jira] [Updated] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream for createHarnessTester in HarnessTestBase

[ https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11222: Summary: Change api.scala.DataStream to api.datastream.DataStream for createHarnessTester in

[jira] [Created] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase

Hequn Cheng created FLINK-11222: --- Summary: Change api.scala.DataStream to api.datastream.DataStream in HarnessTestBase Key: FLINK-11222 URL: https://issues.apache.org/jira/browse/FLINK-11222 Project:

[jira] [Created] (FLINK-11221) Support delimited identifiers in TableAPI

Hequn Cheng created FLINK-11221: --- Summary: Support delimited identifiers in TableAPI Key: FLINK-11221 URL: https://issues.apache.org/jira/browse/FLINK-11221 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727431#comment-16727431 ] Hequn Cheng edited comment on FLINK-11188 at 12/22/18 1:41 PM: --- [~fhueske]

[jira] [Created] (FLINK-11210) Enable auto state cleanup strategy for RANGE OVER

Hequn Cheng created FLINK-11210: --- Summary: Enable auto state cleanup strategy for RANGE OVER Key: FLINK-11210 URL: https://issues.apache.org/jira/browse/FLINK-11210 Project: Flink Issue Type:

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727431#comment-16727431 ] Hequn Cheng commented on FLINK-11188: - [~fhueske] Thanks for your suggestions. I will close this

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727261#comment-16727261 ] Hequn Cheng commented on FLINK-10473: - [~karmagyz]  Thank you for sharing your ideas that I never

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727258#comment-16727258 ] Hequn Cheng commented on FLINK-11139: - [~fhueske] Thanks for the reminder. Yes it will add 8 bytes

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727251#comment-16727251 ] Hequn Cheng commented on FLINK-11188: - [~fhueske] Hi, thanks for your reply. I think you are right.

[jira] [Commented] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727187#comment-16727187 ] Hequn Cheng commented on FLINK-11142: - Hi all, thanks for the discussion and valuable

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725897#comment-16725897 ] Hequn Cheng commented on FLINK-10473: - Hi [~karmagyz] The problem raised in FLINK-11172 is expired

[jira] [Commented] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725040#comment-16725040 ] Hequn Cheng commented on FLINK-11200: - [~twalthr] Make sense, I will try to follow your idea. >

[jira] [Created] (FLINK-11203) FunctionContext of AggregateFunction will not be initialized for window GroupBy

Hequn Cheng created FLINK-11203: --- Summary: FunctionContext of AggregateFunction will not be initialized for window GroupBy Key: FLINK-11203 URL: https://issues.apache.org/jira/browse/FLINK-11203

[jira] [Commented] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724959#comment-16724959 ] Hequn Cheng commented on FLINK-11198: - [~chiggi_dev] Thanks for opening the issue. It would be nice

[jira] [Assigned] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11198: --- Assignee: Hequn Cheng > Access to MetricGroup in an AggregateFunction(Non Rich) >

[jira] [Commented] (FLINK-11197) Improve migration test comments about how to generate snapshots

[ https://issues.apache.org/jira/browse/FLINK-11197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724845#comment-16724845 ] Hequn Cheng commented on FLINK-11197: - The ASF GitHub Bot haven't left a comment after my pull

[jira] [Commented] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724822#comment-16724822 ] Hequn Cheng commented on FLINK-11200: - [~twalthr] Thanks for the notice. Start with

[jira] [Assigned] (FLINK-11200) Port DataView classes to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-11200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11200: --- Assignee: Hequn Cheng > Port DataView classes to flink-table-common >

[jira] [Created] (FLINK-11197) Improve migration test comments about how to generate snapshots

Hequn Cheng created FLINK-11197: --- Summary: Improve migration test comments about how to generate snapshots Key: FLINK-11197 URL: https://issues.apache.org/jira/browse/FLINK-11197 Project: Flink

[jira] [Commented] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-11180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723864#comment-16723864 ] Hequn Cheng commented on FLINK-11180: - [~sunjincheng121]  Thanks for providing the information. I

[jira] [Commented] (FLINK-11181) SimpleRecoveryITCaseBase test error

[ https://issues.apache.org/jira/browse/FLINK-11181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723753#comment-16723753 ] Hequn Cheng commented on FLINK-11181: - This is not a release blocker as it is a bug of the test.  >

[jira] [Commented] (FLINK-11172) Remove the max retention time in StreamQueryConfig

[ https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16723586#comment-16723586 ] Hequn Cheng commented on FLINK-11172: - Hi all, thanks for your discussion and suggestions.

[jira] [Created] (FLINK-11188) Bounded over should not enable state retention time

Hequn Cheng created FLINK-11188: --- Summary: Bounded over should not enable state retention time Key: FLINK-11188 URL: https://issues.apache.org/jira/browse/FLINK-11188 Project: Flink Issue

[jira] [Assigned] (FLINK-11181) SimpleRecoveryITCaseBase test error

[ https://issues.apache.org/jira/browse/FLINK-11181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11181: --- Assignee: Hequn Cheng > SimpleRecoveryITCaseBase test error >

[jira] [Assigned] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-11180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11180: --- Assignee: Hequn Cheng > ProcessFailureCancelingITCase#testCancelingOnProcessFailure >

[jira] [Commented] (FLINK-11172) Remove the max retention time in StreamQueryConfig

[ https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722668#comment-16722668 ] Hequn Cheng commented on FLINK-11172: - [~karmagyz] Good catch! It would be nice if we can ensure the

[jira] [Assigned] (FLINK-11170) Support DISTINCT aggregates in MATCH_RECOGNIZE

[ https://issues.apache.org/jira/browse/FLINK-11170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-11170: --- Assignee: Hequn Cheng > Support DISTINCT aggregates in MATCH_RECOGNIZE >

[jira] [Commented] (FLINK-11120) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720843#comment-16720843 ] Hequn Cheng commented on FLINK-11120: - [~x1q1j1] Hi, thanks for reporting the problem. Could you add

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720833#comment-16720833 ] Hequn Cheng commented on FLINK-11139: - [~zhaoshijie] Do you mean you have already switched to state

[jira] [Created] (FLINK-11150) Check exception messages in ValidationTest of flink-table

Hequn Cheng created FLINK-11150: --- Summary: Check exception messages in ValidationTest of flink-table Key: FLINK-11150 URL: https://issues.apache.org/jira/browse/FLINK-11150 Project: Flink

[jira] [Commented] (FLINK-11128) Methods of org.apache.flink.table.expressions.Expression are private[flink]

[ https://issues.apache.org/jira/browse/FLINK-11128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16719959#comment-16719959 ] Hequn Cheng commented on FLINK-11128: - [~dfakhritdinov] Hi, could you share more about your problem?

[jira] [Created] (FLINK-11147) Add document for TableAggregate Function

Hequn Cheng created FLINK-11147: --- Summary: Add document for TableAggregate Function Key: FLINK-11147 URL: https://issues.apache.org/jira/browse/FLINK-11147 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16719728#comment-16719728 ] Hequn Cheng commented on FLINK-11139: - [~zhaoshijie] Hi, thanks for reporting and trying to fix the

[jira] [Commented] (FLINK-11142) Undefined behavior in the conversion from DataStream/DataSet to Table

[ https://issues.apache.org/jira/browse/FLINK-11142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16718957#comment-16718957 ] Hequn Cheng commented on FLINK-11142: - [~karmagyz] Hi, thanks for reporting the problem. It is true

<    4   5   6   7   8   9   10   11   12   13   >