[jira] [Updated] (FLINK-16568) Cannot call Hive UDAF that requires constant arguments

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16568: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Cannot call Hive UDAF that requires con

[jira] [Updated] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16531: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add full integration tests for "GROUPIN

[jira] [Updated] (FLINK-16688) Hive-connector should set SessionState for hive

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16688: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Hive-connector should set SessionState

[jira] [Commented] (FLINK-15801) Timestamp extractor created from properties does not work for some physical fields

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233223#comment-17233223 ] Leonard Xu commented on FLINK-15801: cc [~dwysakowicz] do you have plan to fix this

[jira] [Updated] (FLINK-16032) Depends on core classifier hive-exec in hive connector

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16032: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Depends on core classifier hive-exec in

[jira] [Updated] (FLINK-15595) Entirely implement resolution order as FLIP-68 concept

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15595: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Entirely implement resolution order as

[jira] [Updated] (FLINK-15732) Add config option to close Hash window agg since hash will lead to OOM

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15732: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add config option to close Hash window

[jira] [Updated] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-11-16 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15992: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Incorrect classloader when finding Tabl

[jira] [Created] (FLINK-20184) update hive streaming read and temporal table documents

2020-11-16 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20184: -- Summary: update hive streaming read and temporal table documents Key: FLINK-20184 URL: https://issues.apache.org/jira/browse/FLINK-20184 Project: Flink Issue Typ

[jira] [Commented] (FLINK-20151) Test SQL Hive integration

2020-11-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233530#comment-17233530 ] Leonard Xu commented on FLINK-20151: [~rmetzger] +1 from my side > Test SQL Hive in

[jira] [Comment Edited] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-11-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233629#comment-17233629 ] Leonard Xu edited comment on FLINK-19635 at 11/17/20, 2:35 PM: ---

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-11-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233629#comment-17233629 ] Leonard Xu commented on FLINK-19635:   {code:java}  {code} 04:35:14,975 [hbase-upser

[jira] [Comment Edited] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-11-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233629#comment-17233629 ] Leonard Xu edited comment on FLINK-19635 at 11/17/20, 2:38 PM: ---

[jira] [Resolved] (FLINK-17045) If multiple views are based on tables not defined in the yaml config file, dropping one of the views will throw exception

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-17045. Fix Version/s: 1.11.0 Resolution: Fixed > If multiple views are based on tables not defined

[jira] [Commented] (FLINK-16919) Parameter 'jobName' does not take effect in BatchTableEnvUtil

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149503#comment-17149503 ] Leonard Xu commented on FLINK-16919: Hi,  [~Dillon.] The  function JobExecutionResul

[jira] [Closed] (FLINK-17312) Support sql client start with restore savepoint

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-17312. -- Resolution: Duplicate > Support sql client start with restore savepoint >

[jira] [Commented] (FLINK-17312) Support sql client start with restore savepoint

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149526#comment-17149526 ] Leonard Xu commented on FLINK-17312: I found this issue should duplicate with FLINK-

[jira] [Updated] (FLINK-16309) ElasticSearch 7 connector is missing in SQL connector list

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16309: --- Affects Version/s: 1.10.0 > ElasticSearch 7 connector is missing in SQL connector list > ---

[jira] [Updated] (FLINK-16309) ElasticSearch 7 connector is missing in SQL connector list

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16309: --- Fix Version/s: 1.10.2 > ElasticSearch 7 connector is missing in SQL connector list > ---

[jira] [Commented] (FLINK-16309) ElasticSearch 7 connector is missing in SQL connector list

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149535#comment-17149535 ] Leonard Xu commented on FLINK-16309: Hello, [~fhueske] I update the fix version to

[jira] [Resolved] (FLINK-15699) FirstValueAggFunctionWithoutOrderTest failed on Traivs

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-15699. Fix Version/s: 1.11.0 Resolution: Fixed > FirstValueAggFunctionWithoutOrderTest failed on T

[jira] [Commented] (FLINK-16309) ElasticSearch 7 connector is missing in SQL connector list

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149795#comment-17149795 ] Leonard Xu commented on FLINK-16309: Thanks Jingsong very much, but the fix it in re

[jira] [Comment Edited] (FLINK-16309) ElasticSearch 7 connector is missing in SQL connector list

2020-07-01 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17149795#comment-17149795 ] Leonard Xu edited comment on FLINK-16309 at 7/2/20, 4:05 AM: -

[jira] [Commented] (FLINK-18509) add ignite jdbc dialect

2020-07-06 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152457#comment-17152457 ] Leonard Xu commented on FLINK-18509: Supporting ignite is an interesting feature. +1

[jira] [Commented] (FLINK-18510) Job Listener接口不生效

2020-07-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152522#comment-17152522 ] Leonard Xu commented on FLINK-18510: Hi, [~linweilun]  Could you describe this issu

[jira] [Commented] (FLINK-18509) add ignite jdbc dialect

2020-07-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17152551#comment-17152551 ] Leonard Xu commented on FLINK-18509: Hi,[~ChaseDream] As I know, community have a p

[jira] [Commented] (FLINK-18410) Flink SQL filesystem connector class name correct

2020-07-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154286#comment-17154286 ] Leonard Xu commented on FLINK-18410: Nice catch, I think we should correct the typo.

[jira] [Updated] (FLINK-17967) Could not find document *** in docs

2020-07-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17967: --- Affects Version/s: (was: 1.11.1) 1.11.0 > Could not find document *** in

[jira] [Created] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-09 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18548: -- Summary: Improve FlinkCalcMergeRule to merge calc nodes better Key: FLINK-18548 URL: https://issues.apache.org/jira/browse/FLINK-18548 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Labels: pull-request-available (was: ) > Improve FlinkCalcMergeRule to merge calc nodes better > --

[jira] [Created] (FLINK-18585) Dynamic index can not work in new DynamicTableSink

2020-07-13 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18585: -- Summary: Dynamic index can not work in new DynamicTableSink Key: FLINK-18585 URL: https://issues.apache.org/jira/browse/FLINK-18585 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

2020-07-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157082#comment-17157082 ] Leonard Xu commented on FLINK-18583: Hi, [~dian.fu] This issue will lead loss data

[jira] [Updated] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

2020-07-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18583: --- Fix Version/s: 1.12.0 > The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

[jira] [Commented] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

2020-07-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157085#comment-17157085 ] Leonard Xu commented on FLINK-18583: [~karmagyz]  Are you still working on this, and

[jira] [Comment Edited] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

2020-07-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157085#comment-17157085 ] Leonard Xu edited comment on FLINK-18583 at 7/14/20, 2:31 AM:

[jira] [Commented] (FLINK-18594) The link is broken in kafka doc

2020-07-13 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157176#comment-17157176 ] Leonard Xu commented on FLINK-18594: Hi, [~dian.fu]  I'd like to fix this, could you

[jira] [Created] (FLINK-18604) HBase Descriptor can not work in Table API

2020-07-15 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18604: -- Summary: HBase Descriptor can not work in Table API Key: FLINK-18604 URL: https://issues.apache.org/jira/browse/FLINK-18604 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

2020-07-15 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18604: --- Summary: HBase ConnectorDescriptor can not work in Table API (was: HBase Descriptor can not work

[jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE

2020-07-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18624: --- Fix Version/s: (was: 1.11.1) 1.11.2 > Document CREATE TEMPORARY TABLE > -

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161003#comment-17161003 ] Leonard Xu commented on FLINK-18640: I agree with [~lzljs3620320], and the latest co

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161018#comment-17161018 ] Leonard Xu commented on FLINK-18640: Hi,[~良]  {quote} The quote need to deal with t

[jira] [Comment Edited] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161003#comment-17161003 ] Leonard Xu edited comment on FLINK-18640 at 7/20/20, 8:28 AM:

[jira] [Commented] (FLINK-18640) Flink jdbc not support postgresql with schema

2020-07-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161049#comment-17161049 ] Leonard Xu commented on FLINK-18640: {quote}So the most correct way is spiliting the

[jira] [Closed] (FLINK-18653) flink-storm中可以根据TopologyBuilder转换成DataStream,但是,在现实使用的时候,我们只能从Storm jar中获得StormTopolgoy。

2020-07-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-18653. -- Resolution: Not A Problem > flink-storm中可以根据TopologyBuilder转换成DataStream,但是,在现实使用的时候,我们只能从Storm > jar

[jira] [Commented] (FLINK-18653) flink-storm中可以根据TopologyBuilder转换成DataStream,但是,在现实使用的时候,我们只能从Storm jar中获得StormTopolgoy。

2020-07-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161691#comment-17161691 ] Leonard Xu commented on FLINK-18653: Hello, [~empcl] Please use English when you re

[jira] [Commented] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns

2020-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162105#comment-17162105 ] Leonard Xu commented on FLINK-18665: [~jark] I'd like to fix this, could you assign

[jira] [Comment Edited] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns

2020-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162105#comment-17162105 ] Leonard Xu edited comment on FLINK-18665 at 7/21/20, 3:13 PM:

[jira] [Updated] (FLINK-18667) Data Types documentation misunderstand users

2020-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18667: --- Labels: starter (was: ) > Data Types documentation misunderstand users > --

[jira] [Commented] (FLINK-18667) Data Types documentation misunderstand users

2020-07-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162462#comment-17162462 ] Leonard Xu commented on FLINK-18667: [~lzljs3620320]  I add `starter` label as reco

[jira] [Commented] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns

2020-07-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17162552#comment-17162552 ] Leonard Xu commented on FLINK-18665: [~klion26] This issue affects 1.11.0 and 1.11.

[jira] [Closed] (FLINK-18693) AvroSerializationSchema does not work with types generated by avrohugger

2020-07-23 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-18693. -- Resolution: Duplicate Hi, [~aljoscha]  I close this one, looks like it's a duplicate issue with FLINK-

[jira] [Created] (FLINK-18700) Debezium-json format throws Exception when PG table's IDENTITY config is not FULL

2020-07-24 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18700: -- Summary: Debezium-json format throws Exception when PG table's IDENTITY config is not FULL Key: FLINK-18700 URL: https://issues.apache.org/jira/browse/FLINK-18700 Project

[jira] [Commented] (FLINK-18729) kafka

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165587#comment-17165587 ] Leonard Xu commented on FLINK-18729: Hello, [~shengjk1]  Could you add more detail a

[jira] [Updated] (FLINK-18730) Remove Beta tag from SQL Client docs

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18730: --- Labels: starter (was: ) > Remove Beta tag from SQL Client docs > --

[jira] [Updated] (FLINK-15366) Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15366: --- Summary: Improve FlinkCalcMergeRule to merge calc nodes better (was: Dimension table do not support

[jira] [Updated] (FLINK-15366) Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15366: --- Description: FlinkCalcMergeRule should merge calc nodes when outer calc do not contains inner calc'

[jira] [Updated] (FLINK-18548) Dimension table do not support computed column

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Summary: Dimension table do not support computed column (was: Improve FlinkCalcMergeRule to merge c

[jira] [Updated] (FLINK-18548) Improve FlinkCalcMergeRule to merge calc nodes better

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Description: In Flink 1.10, we bring computed column feature, but I found dimension table do not su

[jira] [Commented] (FLINK-18548) Dimension table do not support computed column

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166098#comment-17166098 ] Leonard Xu commented on FLINK-18548: After FLINK-15366, Flink should support compu

[jira] [Comment Edited] (FLINK-18548) Dimension table do not support computed column

2020-07-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17166098#comment-17166098 ] Leonard Xu edited comment on FLINK-18548 at 7/28/20, 2:57 AM:

[jira] [Created] (FLINK-18758) Support debezium data type in debezium format

2020-07-29 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18758: -- Summary: Support debezium data type in debezium format Key: FLINK-18758 URL: https://issues.apache.org/jira/browse/FLINK-18758 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-18759) Add readme.md for TPC-DS tools

2020-07-29 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18759: -- Summary: Add readme.md for TPC-DS tools Key: FLINK-18759 URL: https://issues.apache.org/jira/browse/FLINK-18759 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-18758) Support debezium data type in debezium format

2020-07-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18758: --- Description: Currently debezium json format  wrapper the json format to serialize/deserialize the d

[jira] [Commented] (FLINK-18758) Support debezium data type in debezium format

2020-07-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167683#comment-17167683 ] Leonard Xu commented on FLINK-18758: I agree that schema part is optional, maybe we

[jira] [Created] (FLINK-18768) Imporve SQL kafka connector docs about passing kafka properties

2020-07-30 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18768: -- Summary: Imporve SQL kafka connector docs about passing kafka properties Key: FLINK-18768 URL: https://issues.apache.org/jira/browse/FLINK-18768 Project: Flink

[jira] [Commented] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-07-30 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167941#comment-17167941 ] Leonard Xu commented on FLINK-18756: I'd like to work for this ticket. > Support IF

[jira] [Commented] (FLINK-16824) Creating Temporal Table Function via DDL

2020-08-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170524#comment-17170524 ] Leonard Xu commented on FLINK-16824: I'd like to support this feature, [~jark] could

[jira] [Commented] (FLINK-16579) Upgrade Calcite version to 1.23 for Flink SQL

2020-08-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17170525#comment-17170525 ] Leonard Xu commented on FLINK-16579: +1 for this. > Upgrade Calcite version to 1.23

[jira] [Updated] (FLINK-18548) Dimension table do not support computed column

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Parent: FLINK-16824 Issue Type: Sub-task (was: Improvement) > Dimension table do not suppor

[jira] [Updated] (FLINK-15366) Improve FlinkCalcMergeRule to merge calc nodes better

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15366: --- Parent: FLINK-16824 Issue Type: Sub-task (was: Bug) > Improve FlinkCalcMergeRule to merge c

[jira] [Updated] (FLINK-18548) support flexible syntax for Temporal table

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Summary: support flexible syntax for Temporal table (was: Dimension table do not support computed c

[jira] [Updated] (FLINK-18548) support flexible syntax for Temporal table

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Description: The reason why Flink does not support computed column in dimension(temporal) table is

[jira] [Updated] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

2020-08-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17183: --- Fix Version/s: (was: 1.11.0) 1.12.0 > the 'create table [if not exists]' synt

[jira] [Commented] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

2020-08-07 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172968#comment-17172968 ] Leonard Xu commented on FLINK-17183: Hi, [~muzimusi] This issue has implemented in

[jira] [Commented] (FLINK-18862) sql 中agg算子的 count(1) 的结果强转成String类型再经过一次agg的操作就不能成功

2020-08-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174015#comment-17174015 ] Leonard Xu commented on FLINK-18862: Hi, [~YUJIANBO]  Thanks for creating this issu

[jira] [Commented] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175341#comment-17175341 ] Leonard Xu commented on FLINK-18333: I'd like to take this ticket. > UnsignedTypeCo

[jira] [Commented] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-11 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175340#comment-17175340 ] Leonard Xu commented on FLINK-18333: It seems a mariadb4j's unstable issue bu have n

[jira] [Created] (FLINK-18976) Support user defined query in JDBC Source

2020-08-17 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18976: -- Summary: Support user defined query in JDBC Source Key: FLINK-18976 URL: https://issues.apache.org/jira/browse/FLINK-18976 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-18976) Support user defined query in JDBC Source

2020-08-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-18976. -- Resolution: Duplicate > Support user defined query in JDBC Source > --

[jira] [Commented] (FLINK-18976) Support user defined query in JDBC Source

2020-08-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179288#comment-17179288 ] Leonard Xu commented on FLINK-18976: [~jark] Yes > Support user defined query in JD

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-08-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17179289#comment-17179289 ] Leonard Xu commented on FLINK-17826: Hi, [~f.pompermaier] Are you still working for

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-08-18 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180216#comment-17180216 ] Leonard Xu commented on FLINK-17826: [~f.pompermaier] okay, I'll take this and open

[jira] [Commented] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program"

2020-08-25 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183820#comment-17183820 ] Leonard Xu commented on FLINK-18333: [~jark] Thanks for the reminder, I'll open the

[jira] [Created] (FLINK-19063) Support join late event from dimension table side in temporal table join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19063: -- Summary: Support join late event from dimension table side in temporal table join Key: FLINK-19063 URL: https://issues.apache.org/jira/browse/FLINK-19063 Project: Flink

[jira] [Updated] (FLINK-19063) Support join late event from dimension table side in temporal table join

2020-08-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19063: --- Description: To join late event from dimension table side in temporal table join is a common user c

[jira] [Updated] (FLINK-16824) FLIP-132 Temporal Table DDL and Temporal Table Join

2020-08-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16824: --- Summary: FLIP-132 Temporal Table DDL and Temporal Table Join (was: Creating Temporal Table Function

[jira] [Created] (FLINK-19072) Import Temporal Table join rule

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19072: -- Summary: Import Temporal Table join rule Key: FLINK-19072 URL: https://issues.apache.org/jira/browse/FLINK-19072 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19073) Improve streamExecTemporalJoinRule

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19073: -- Summary: Improve streamExecTemporalJoinRule Key: FLINK-19073 URL: https://issues.apache.org/jira/browse/FLINK-19073 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19074) Materialize timeindicator in the right input of temporal join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19074: -- Summary: Materialize timeindicator in the right input of temporal join Key: FLINK-19074 URL: https://issues.apache.org/jira/browse/FLINK-19074 Project: Flink Is

[jira] [Created] (FLINK-19075) Infer changelog trait for temporal join node

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19075: -- Summary: Infer changelog trait for temporal join node Key: FLINK-19075 URL: https://issues.apache.org/jira/browse/FLINK-19075 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19077) Improve process time temporal join operator

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19077: -- Summary: Improve process time temporal join operator Key: FLINK-19077 URL: https://issues.apache.org/jira/browse/FLINK-19077 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19078) Import rowtime join temporal operator

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19078: -- Summary: Import rowtime join temporal operator Key: FLINK-19078 URL: https://issues.apache.org/jira/browse/FLINK-19078 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19076) Import rule to deal Temporal Join condition

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19076: -- Summary: Import rule to deal Temporal Join condition Key: FLINK-19076 URL: https://issues.apache.org/jira/browse/FLINK-19076 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19079) Support row time deduplicate operator

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19079: -- Summary: Support row time deduplicate operator Key: FLINK-19079 URL: https://issues.apache.org/jira/browse/FLINK-19079 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19080) Materialize timeindicator data type in the right input of temporal join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19080: -- Summary: Materialize timeindicator data type in the right input of temporal join Key: FLINK-19080 URL: https://issues.apache.org/jira/browse/FLINK-19080 Project: Flink

[jira] [Created] (FLINK-19081) Deprecate TemporalTableFunction and Table$createTemporalTableFunction()

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19081: -- Summary: Deprecate TemporalTableFunction and Table$createTemporalTableFunction() Key: FLINK-19081 URL: https://issues.apache.org/jira/browse/FLINK-19081 Project: Flink

[jira] [Created] (FLINK-19082) Add docs for temporal table and temporal table join

2020-08-27 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19082: -- Summary: Add docs for temporal table and temporal table join Key: FLINK-19082 URL: https://issues.apache.org/jira/browse/FLINK-19082 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-19081) Deprecate TemporalTableFunction and Table#createTemporalTableFunction()

2020-08-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19081: --- Summary: Deprecate TemporalTableFunction and Table#createTemporalTableFunction() (was: Deprecate Te

[jira] [Commented] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

2020-08-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17186336#comment-17186336 ] Leonard Xu commented on FLINK-18604: Sure, I have not the assign priority too,  but

[jira] [Created] (FLINK-19092) Parse comment on computed column failed

2020-08-29 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-19092: -- Summary: Parse comment on computed column failed Key: FLINK-19092 URL: https://issues.apache.org/jira/browse/FLINK-19092 Project: Flink Issue Type: Bug

<    1   2   3   4   5   6   7   8   9   10   >