[jira] [Closed] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15231. -- Fix Version/s: (was: 1.11.0) 1.10.0 Resolution: Fixed master: 

[jira] [Created] (FLINK-15440) Enable savepoint support for Table & SQL program

2019-12-30 Thread Kurt Young (Jira)
Kurt Young created FLINK-15440: -- Summary: Enable savepoint support for Table & SQL program Key: FLINK-15440 URL: https://issues.apache.org/jira/browse/FLINK-15440 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-15397) Streaming and batch has different value in the case of count function

2019-12-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15397: -- Assignee: Jingsong Lee > Streaming and batch has different value in the case of count

[jira] [Assigned] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

2019-12-30 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15290: -- Assignee: Rui Li > Need a way to turn off vectorized orc reader for SQL CLI >

[jira] [Assigned] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15411: -- Assignee: Jingsong Lee (was: Rui Li) > Planner can't prune partition on DATE/TIMESTAMP

[jira] [Comment Edited] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003924#comment-17003924 ] Kurt Young edited comment on FLINK-15411 at 12/27/19 6:32 AM: -- Yeah, that

[jira] [Commented] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003924#comment-17003924 ] Kurt Young commented on FLINK-15411: Yeah, that might also be true. Even if the want to partition

[jira] [Commented] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003909#comment-17003909 ] Kurt Young commented on FLINK-15412: cc [~lirui] > LocalExecutorITCase#testParameterizedTypes

[jira] [Updated] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15412: --- Fix Version/s: 1.10.0 > LocalExecutorITCase#testParameterizedTypes failed in travis >

[jira] [Commented] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003907#comment-17003907 ] Kurt Young commented on FLINK-15409: cc [~jark] [~jinyu.zj] > Add semicolon to

[jira] [Updated] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15409: --- Affects Version/s: (was: 1.10.0) 1.9.1 > Add semicolon to

[jira] [Updated] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15409: --- Fix Version/s: (was: 1.11.0) 1.10.0 1.9.2 > Add semicolon

[jira] [Updated] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15411: --- Affects Version/s: (was: 1.11.0) > Planner can't prune partition on DATE/TIMESTAMP columns >

[jira] [Updated] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15411: --- Fix Version/s: (was: 1.11.0) > Planner can't prune partition on DATE/TIMESTAMP columns >

[jira] [Commented] (FLINK-15411) Planner can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003905#comment-17003905 ] Kurt Young commented on FLINK-15411: IMO partition with DATE field maybe the most widely used in

[jira] [Updated] (FLINK-15413) ScalarOperatorsTest failed in travis

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15413: --- Fix Version/s: 1.9.2 > ScalarOperatorsTest failed in travis >

[jira] [Updated] (FLINK-15391) DATE and TIMESTAMP partition columns don't work

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15391: --- Fix Version/s: (was: 1.11.0) > DATE and TIMESTAMP partition columns don't work >

[jira] [Commented] (FLINK-15404) How to insert hive table for different catalog

2019-12-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003597#comment-17003597 ] Kurt Young commented on FLINK-15404: try  {noformat} insert into myhive.default.hive_table select *

[jira] [Commented] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003502#comment-17003502 ] Kurt Young commented on FLINK-15395: [~zjffdu] There is no need to follow sql client, normally,

[jira] [Commented] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003499#comment-17003499 ] Kurt Young commented on FLINK-15395: Why? Can you provide more details? > No API for execute insert

[jira] [Commented] (FLINK-15381) INSERT INTO VALUES statement fails if a cast project is applied

2019-12-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003496#comment-17003496 ] Kurt Young commented on FLINK-15381: Just curious, who generated collation trait in the plan? It

[jira] [Commented] (FLINK-15395) No API for execute insert into statement

2019-12-25 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003477#comment-17003477 ] Kurt Young commented on FLINK-15395: sqlUpdate is supposed to execute `insert into`. > No API for

[jira] [Commented] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

2019-12-24 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003045#comment-17003045 ] Kurt Young commented on FLINK-15384: Can't you use

[jira] [Assigned] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2019-12-23 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15066: -- Assignee: Jingsong Lee (was: Danny Chen) > Cannot run multiple `insert into csvTable values

[jira] [Closed] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

2019-12-23 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15175. -- Fix Version/s: 1.10.0 Resolution: Fixed master: fc4927e41989be75866218c2a60aa914e1eedcd3

[jira] [Commented] (FLINK-15331) Create a table from a changelog

2019-12-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000543#comment-17000543 ] Kurt Young commented on FLINK-15331: +10086 > Create a table from a changelog >

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

2019-12-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997990#comment-16997990 ] Kurt Young commented on FLINK-15290: We already have this in `HiveOptions`, the config name is 

[jira] [Updated] (FLINK-15266) NPE in blink planner code gen

2019-12-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15266: --- Fix Version/s: 1.9.2 > NPE in blink planner code gen > - > >

[jira] [Closed] (FLINK-15245) Flink running in one cluster cannot write data to Hive tables in another cluster

2019-12-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15245. -- Assignee: Rui Li Resolution: Fixed master: b0783b50cb1610611f9442d456501160322b5028 1.10.0: 

[jira] [Assigned] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

2019-12-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15287: -- Assignee: Jingsong Lee > Vectorized orc reader fails with Hive 2.0.1 >

[jira] [Updated] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

2019-12-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15287: --- Affects Version/s: 1.10.0 > Vectorized orc reader fails with Hive 2.0.1 >

[jira] [Closed] (FLINK-15284) Sql error (Failed to push project into table source!)

2019-12-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15284. -- Resolution: Duplicate > Sql error (Failed to push project into table source!) >

[jira] [Updated] (FLINK-15246) Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL] not equal to TableSink schema: [EXPR$0: TIMESTAMP(3)]

2019-12-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15246: --- Component/s: (was: Table SQL / Client) Table SQL / Planner > Query result

[jira] [Updated] (FLINK-15246) Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL] not equal to TableSink schema: [EXPR$0: TIMESTAMP(3)]

2019-12-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15246: --- Fix Version/s: 1.10.0 > Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL] not equal to

[jira] [Closed] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

2019-12-13 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15167. -- Resolution: Fixed master: cd4c3ddf 1.10.0: 5a43907e   > SQL CLI library option doesn't work for

[jira] [Updated] (FLINK-15238) A sql can't generate a valid execution plan

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15238: --- Component/s: (was: Table SQL / Client) Table SQL / Planner > A sql can't

[jira] [Commented] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995376#comment-16995376 ] Kurt Young commented on FLINK-15066: [~danny0405] I'm not sure if this issue relates to INSERT

[jira] [Updated] (FLINK-15190) add documentation for DDL in FLIP-69

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15190: --- Priority: Blocker (was: Major) > add documentation for DDL in FLIP-69 >

[jira] [Updated] (FLINK-15189) add documentation for catalog view and hive view

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15189: --- Priority: Blocker (was: Major) > add documentation for catalog view and hive view >

[jira] [Updated] (FLINK-15223) Csv connector should unescape delimiter parameter characters

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15223: --- Priority: Blocker (was: Major) > Csv connector should unescape delimiter parameter characters >

[jira] [Updated] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15001: --- Fix Version/s: (was: 1.11.0) > The digest of sub-plan reuse should contain retraction traits

[jira] [Closed] (FLINK-15185) Hive sink can not run in standalone mode

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15185. -- Resolution: Fixed master: 3a30e29043351e749df928b2bf86c578bb0f1bdb 1.10: 

[jira] [Assigned] (FLINK-15185) Hive sink can not run in standalone mode

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15185: -- Assignee: Jingsong Lee > Hive sink can not run in standalone mode >

[jira] [Closed] (FLINK-15073) sql client fails to run same query multiple times

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15073. -- Resolution: Fixed 1.10.0: 4a5a720024992c12bbfd4fb316d04f24d23a109e  > sql client fails to run same

[jira] [Updated] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

2019-12-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15212: --- Component/s: (was: Table SQL / API) Table SQL / Legacy Planner > PROCTIME

[jira] [Commented] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

2019-12-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994282#comment-16994282 ] Kurt Young commented on FLINK-15212: [~docete] Do we have a chance to first fix it in Flink? >

[jira] [Commented] (FLINK-15019) publish blog and document Flink-Hive benchmark v.s. Hive on MR/Tez

2019-12-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993588#comment-16993588 ] Kurt Young commented on FLINK-15019: Sounds great, thanks! [~phoenixjiangnan] > publish blog and

[jira] [Comment Edited] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

2019-12-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993584#comment-16993584 ] Kurt Young edited comment on FLINK-15175 at 12/11/19 2:18 PM: -- The final

[jira] [Assigned] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

2019-12-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15175: -- Assignee: liupengcheng > syntax not supported in SQLClient for TPCDS queries >

[jira] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

2019-12-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993584#comment-16993584 ] Kurt Young commented on FLINK-15175: The final plan would be FLINK-14671 > syntax not supported in

[jira] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

2019-12-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992490#comment-16992490 ] Kurt Young commented on FLINK-15175: Hi [~liupengcheng], thanks for reporting this. We will look

[jira] [Closed] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

2019-12-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14953. -- Resolution: Fixed 1.10.0: b6801d50ade388b28d349711fdf75e9f75b562da 1.9.2: 

[jira] [Assigned] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13437: -- Assignee: Terry Wang (was: Jingsong Lee) > Add Hive SQL E2E test > - >

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992208#comment-16992208 ] Kurt Young commented on FLINK-13437: [~liyu] We will try to do this in 1.10 > Add Hive SQL E2E test

[jira] [Assigned] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13437: -- Assignee: Jingsong Lee > Add Hive SQL E2E test > - > >

[jira] [Updated] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13437: --- Fix Version/s: 1.10.0 > Add Hive SQL E2E test > - > > Key:

[jira] [Commented] (FLINK-15017) add a thrift server for Flink

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992202#comment-16992202 ] Kurt Young commented on FLINK-15017: cc [~godfreyhe]  [~docete] > add a thrift server for Flink >

[jira] [Updated] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13437: --- Fix Version/s: (was: 1.10.0) > Add Hive SQL E2E test > - > >

[jira] [Assigned] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-11899: -- Assignee: Zhenqiu Huang (was: Jingsong Lee) > Introduce vectorized parquet InputFormat for

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992136#comment-16992136 ] Kurt Young commented on FLINK-11899: Thanks [~ZhenqiuHuang], will assign to you. BTW we have already

[jira] [Comment Edited] (FLINK-15017) add a thrift server for Flink

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992126#comment-16992126 ] Kurt Young edited comment on FLINK-15017 at 12/10/19 2:31 AM: -- I think this

[jira] [Commented] (FLINK-15017) add a thrift server for Flink

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992126#comment-16992126 ] Kurt Young commented on FLINK-15017: I think this is a good addition to Flink SQL. We have to take

[jira] [Updated] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14649: --- Release Note: {{PlaceHolder}} > Flatten all the connector properties keys to make it easy to

[jira] [Closed] (FLINK-13438) Support date type in Hive

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13438. -- Resolution: Fixed master: 2994f0e44b53c85535f2f29fb43d320ace91f6f8 > Support date type in Hive >

[jira] [Commented] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991469#comment-16991469 ] Kurt Young commented on FLINK-14649: Needs to attach some release notes to this jira > Flatten all

[jira] [Updated] (FLINK-15147) Add doc for alter table set properties and rename table ddl

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15147: --- Fix Version/s: 1.10.0 > Add doc for alter table set properties and rename table ddl >

[jira] [Updated] (FLINK-15147) Add doc for alter table set properties and rename table ddl

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15147: --- Priority: Blocker (was: Major) > Add doc for alter table set properties and rename table ddl >

[jira] [Updated] (FLINK-15148) Add doc for create/drop/alter database ddl

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15148: --- Fix Version/s: 1.10.0 > Add doc for create/drop/alter database ddl >

[jira] [Updated] (FLINK-15148) Add doc for create/drop/alter database ddl

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15148: --- Priority: Blocker (was: Major) > Add doc for create/drop/alter database ddl >

[jira] [Closed] (FLINK-14513) Implement listPartitionsByFilter to HiveCatalog

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14513. -- Assignee: Rui Li Resolution: Fixed master: 47f29391cf4c0c856e2401289c06658471508654 >

[jira] [Updated] (FLINK-15004) Choose two-phase Aggregate if the statistics is unknown

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15004: --- Affects Version/s: (was: 1.9.0) 1.10.0 > Choose two-phase Aggregate if

[jira] [Closed] (FLINK-14133) Improve batch sql and hive integrate performance milestone-1

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14133. -- Assignee: Jingsong Lee Resolution: Fixed > Improve batch sql and hive integrate performance

[jira] [Updated] (FLINK-15004) Choose two-phase Aggregate if the statistics is unknown

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15004: --- Parent: (was: FLINK-14133) Issue Type: Improvement (was: Sub-task) > Choose two-phase

[jira] [Commented] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991228#comment-16991228 ] Kurt Young commented on FLINK-15141: I think it's highly possible the same issue with FLINK-15124,

[jira] [Assigned] (FLINK-13438) Hive source/sink/udx should respect the conversion class of DataType

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13438: -- Assignee: Rui Li (was: Caizhi Weng) > Hive source/sink/udx should respect the conversion

[jira] [Assigned] (FLINK-15093) StreamExecutionEnvironment does not clear transformations when executing

2019-12-08 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15093: -- Assignee: Danny Chen > StreamExecutionEnvironment does not clear transformations when

[jira] [Updated] (FLINK-15093) StreamExecutionEnvironment does not clear transformations when executing

2019-12-08 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15093: --- Priority: Blocker (was: Critical) > StreamExecutionEnvironment does not clear transformations when

[jira] [Updated] (FLINK-15093) StreamExecutionEnvironment does not clear transformations when executing

2019-12-08 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15093: --- Affects Version/s: (was: 1.9.1) > StreamExecutionEnvironment does not clear transformations

[jira] [Updated] (FLINK-15128) Document support for Hive timestamp type

2019-12-08 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15128: --- Priority: Blocker (was: Major) > Document support for Hive timestamp type >

[jira] [Updated] (FLINK-15128) Document support for Hive timestamp type

2019-12-08 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15128: --- Fix Version/s: 1.10.0 > Document support for Hive timestamp type >

[jira] [Closed] (FLINK-15020) Support timestamp type in hive

2019-12-07 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15020. -- Assignee: Rui Li Resolution: Fixed master: 57bb952e3a1732caa5acb640a1712bcdd55d813d > Support

[jira] [Closed] (FLINK-15095) bridge table schema's primary key to metadata handler in blink planner

2019-12-07 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15095. -- Resolution: Fixed master: d4bd2d6ee64ba83c42981e4e62374fb962bb71bf > bridge table schema's primary

[jira] [Closed] (FLINK-14970) Doomed test for equality to NaN

2019-12-07 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14970. -- Fix Version/s: 1.10.0 Resolution: Fixed master: 3e28aedbaa85710aab34c0abb3a3973d73f7f805 >

[jira] [Created] (FLINK-15124) types with precision can't be executed in sql client with blink planner

2019-12-07 Thread Kurt Young (Jira)
Kurt Young created FLINK-15124: -- Summary: types with precision can't be executed in sql client with blink planner Key: FLINK-15124 URL: https://issues.apache.org/jira/browse/FLINK-15124 Project: Flink

[jira] [Updated] (FLINK-15124) types with precision can't be executed in sql client with blink planner

2019-12-07 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15124: --- Fix Version/s: 1.10.0 > types with precision can't be executed in sql client with blink planner >

[jira] [Closed] (FLINK-15107) SQL-CLI can not execute insert into statement with lowercase "INSERT INTO" keyword

2019-12-07 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15107. -- Assignee: Terry Wang Resolution: Fixed master: 6b389ebef0751d54f53f5fa59a359283e29586ae >

[jira] [Closed] (FLINK-15035) Introduce unknown memory setting to table in blink planner

2019-12-07 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15035. -- Resolution: Fixed master: d5853467fd70f22a119ed00166e4523a4907bfeb > Introduce unknown memory

[jira] [Closed] (FLINK-13195) Add create table support for SqlClient

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13195. -- Fix Version/s: 1.10.0 Resolution: Fixed master: caff2ed21d548996c89843a23ee216689616c961 >

[jira] [Closed] (FLINK-15117) JoinITCase.testFullJoinWithLeftLocalPred fails

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15117. -- Resolution: Duplicate > JoinITCase.testFullJoinWithLeftLocalPred fails >

[jira] [Updated] (FLINK-15114) Add execute result info for alter/create/drop database in sql client.

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15114: --- Issue Type: Improvement (was: Bug) > Add execute result info for alter/create/drop database in sql

[jira] [Closed] (FLINK-15114) Add execute result info for alter/create/drop database in sql client.

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15114. -- Resolution: Fixed master: 26431ec71bb65bd9a80d7674ec573aa0a71e901d > Add execute result info for

[jira] [Updated] (FLINK-15114) Add execute result info for alter/create/drop database in sql client.

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15114: --- Priority: Minor (was: Major) > Add execute result info for alter/create/drop database in sql

[jira] [Closed] (FLINK-15027) Support alter table DDLs in SQL CLI

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15027. -- Resolution: Fixed master: 7af523dd130756b0bc1da38246d2daba44880a05 > Support alter table DDLs in SQL

[jira] [Assigned] (FLINK-15114) Add execute result info for alter/create/drop database in sql client.

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15114: -- Assignee: Terry Wang > Add execute result info for alter/create/drop database in sql client.

[jira] [Closed] (FLINK-14959) Support precision of LocalZonedTimestampType in blink planner

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14959. -- Resolution: Fixed master:  fc2ef35b5fff94e822d4219e5d2022c4b5d55a03

[jira] [Closed] (FLINK-14512) Introduce listPartitionsByFilter to Catalog

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14512. -- Resolution: Fixed master: 393a34fd760dbdba567dc98c8e52802d1dcbbcd5 > Introduce

[jira] [Closed] (FLINK-15108) SQL-CLI can not execute same query multiple times

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15108. -- Resolution: Duplicate > SQL-CLI can not execute same query multiple times >

[jira] [Closed] (FLINK-14847) Support retrieving Hive PK constraints

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14847. -- Resolution: Fixed master: 4cfe3ddd1ca1ad4b6d9158356d343fc47dbdb23d > Support retrieving Hive PK

[jira] [Commented] (FLINK-15098) CsvTableSink has no properties of a OVERWRITE mode to write, but the exception hint the user use it when a file or directory already exists

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989757#comment-16989757 ] Kurt Young commented on FLINK-15098: I think this is the same issue which I was encountered:

[jira] [Closed] (FLINK-15098) CsvTableSink has no properties of a OVERWRITE mode to write, but the exception hint the user use it when a file or directory already exists

2019-12-06 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15098. -- Resolution: Duplicate > CsvTableSink has no properties of a OVERWRITE mode to write, but the >

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