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

[ 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] [Closed] (FLINK-15284) Sql error (Failed to push project into table source!)

[ 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] [Assigned] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1

[ 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

[ 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-15245) Flink running in one cluster cannot write data to Hive tables in another cluster

[ 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-15185) Hive sink can not run in standalone mode

[ 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-15185) Hive sink can not run in standalone mode

[ 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] [Closed] (FLINK-15073) sql client fails to run same query multiple times

[ 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] [Commented] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

[ 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] [Updated] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ?

[ 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-15019) publish blog and document Flink-Hive benchmark v.s. Hive on MR/Tez

[ 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] [Commented] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ 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] [Assigned] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ 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] [Comment Edited] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries

[ 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] [Closed] (FLINK-14965) CatalogTableStatistics UNKNOWN should be consistent with TableStats UNKNOWN

[ https://issues.apache.org/jira/browse/FLINK-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14965. -- Resolution: Fixed master: c20697e149f6fd97b6514c870a3b3f19de145421 > CatalogTableStatistics UNKNOWN

[jira] [Closed] (FLINK-15026) Support database DDLs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15026. -- Resolution: Fixed master: 5973508e6cb00f7e9b04325207bfa6b46f51606a > Support database DDLs in SQL

[jira] [Closed] (FLINK-14692) Support alter/rename table through `sqlUpdate` in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14692. -- Fix Version/s: 1.10.0 Resolution: Fixed master: ca1bf97c611fc070099058f21a00cb86429e2f35 >

[jira] [Assigned] (FLINK-14686) Flink SQL DDL Enhancement

[ https://issues.apache.org/jira/browse/FLINK-14686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14686: -- Assignee: Terry Wang > Flink SQL DDL Enhancement > - > >

[jira] [Closed] (FLINK-14552) Enable partition statistics in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14552. -- Fix Version/s: 1.10.0 Resolution: Fixed master: 0d6b43959bb6a576c95549e845f7db5e51229740 >

[jira] [Created] (FLINK-15091) JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis

Kurt Young created FLINK-15091: -- Summary: JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis Key: FLINK-15091 URL: https://issues.apache.org/jira/browse/FLINK-15091 Project: Flink

[jira] [Updated] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13943: --- Component/s: (was: Table SQL / API) Table SQL / Planner > Provide api to

[jira] [Updated] (FLINK-13943) Provide api to convert flink table to java List (blink planner)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13943: --- Summary: Provide api to convert flink table to java List (blink planner) (was: Provide api to

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989499#comment-16989499 ] Kurt Young commented on FLINK-13943: Eventually we added a util to blink planner only, due to some

[jira] [Closed] (FLINK-13943) Provide api to convert flink table to java List (blink planner)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13943. -- Fix Version/s: 1.10.0 Resolution: Fixed master: cda7ab32413bba57532f61faced32230b5ffd8a9 >

[jira] [Commented] (FLINK-15092) Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException

[ https://issues.apache.org/jira/browse/FLINK-15092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989536#comment-16989536 ] Kurt Young commented on FLINK-15092: Thanks for reporting this [~xiaojin.wy], I can also reproduce

[jira] [Updated] (FLINK-15092) Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException

[ https://issues.apache.org/jira/browse/FLINK-15092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15092: --- Priority: Blocker (was: Major) > Using sql-client excute sql(select sum(cast(null as int)) from

[jira] [Commented] (FLINK-15093) FLINK-13708 still exist in StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989540#comment-16989540 ] Kurt Young commented on FLINK-15093: cc [~kkloudas]  > FLINK-13708 still exist in

[jira] [Commented] (FLINK-15093) FLINK-13708 still exist in StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989543#comment-16989543 ] Kurt Young commented on FLINK-15093: It's similar with FLINK-13708, but I don't think it's the same

[jira] [Closed] (FLINK-15091) JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis

[ https://issues.apache.org/jira/browse/FLINK-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15091. -- Resolution: Fixed master: a4072efb809680aa0f0a5f696e186634624f21b0 >

[jira] [Updated] (FLINK-15092) Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException

[ https://issues.apache.org/jira/browse/FLINK-15092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15092: --- Fix Version/s: 1.10.0 > Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a

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

[ https://issues.apache.org/jira/browse/FLINK-15095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15095: -- Assignee: godfrey he > bridge table schema's primary key to metadata handler in blink

[jira] [Commented] (FLINK-15093) FLINK-13708 still exist in StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989609#comment-16989609 ] Kurt Young commented on FLINK-15093: We also met similar problem in sql client: FLINK-15052 I think

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

[ https://issues.apache.org/jira/browse/FLINK-14970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14970: --- Fix Version/s: (was: 1.10.0) > Doomed test for equality to NaN >

[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

[ 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 >

[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

[ 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-14847) Support retrieving Hive PK constraints

[ 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] [Closed] (FLINK-15108) SQL-CLI can not execute same query multiple times

[ 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-14512) Introduce listPartitionsByFilter to Catalog

[ 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] [Assigned] (FLINK-15060) Add aarch64 support for tpcds e2e test

[ https://issues.apache.org/jira/browse/FLINK-15060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15060: -- Assignee: wangxiyuan > Add aarch64 support for tpcds e2e test >

[jira] [Closed] (FLINK-15060) Add aarch64 support for tpcds e2e test

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

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

Kurt Young created FLINK-15066: -- Summary: Cannot run multiple `insert into csvTable values ()` Key: FLINK-15066 URL: https://issues.apache.org/jira/browse/FLINK-15066 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-15062) Orc reader should use java.sql.Timestamp to read for respecting time zone

[ https://issues.apache.org/jira/browse/FLINK-15062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15062: -- Assignee: Jingsong Lee > Orc reader should use java.sql.Timestamp to read for respecting

[jira] [Assigned] (FLINK-14965) CatalogTableStatistics UNKNOWN should be consistent with TableStats UNKNOWN

[ https://issues.apache.org/jira/browse/FLINK-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14965: -- Assignee: godfrey he > CatalogTableStatistics UNKNOWN should be consistent with TableStats

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

[ 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-15107) SQL-CLI can not execute insert into statement with lowercase "INSERT INTO" keyword

[ 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-15020) Support timestamp type in hive

[ 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

[ 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] [Created] (FLINK-15124) types with precision can't be executed in sql client with blink planner

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

[ 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-14970) Doomed test for equality to NaN

[ 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-15073) sql client fails to run same query multiple times

Kurt Young created FLINK-15073: -- Summary: sql client fails to run same query multiple times Key: FLINK-15073 URL: https://issues.apache.org/jira/browse/FLINK-15073 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-15073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15073: --- Fix Version/s: 1.10.0 > sql client fails to run same query multiple times >

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

[ https://issues.apache.org/jira/browse/FLINK-15073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15073: --- Affects Version/s: 1.10.0 > sql client fails to run same query multiple times >

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

[ 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

[ 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] [Assigned] (FLINK-15093) StreamExecutionEnvironment does not clear transformations when executing

[ 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

[ 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

[ 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] [Closed] (FLINK-14691) Support database related DDLs (don't need return values) through sqlUpdate() method in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14691. -- Fix Version/s: 1.10.0 Assignee: Terry Wang Resolution: Fixed master: 

[jira] [Closed] (FLINK-13502) CatalogTableStatisticsConverter & TreeNode should be in correct package

[ https://issues.apache.org/jira/browse/FLINK-13502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13502. -- Resolution: Fixed master: d59c3171dee21ea89c366deb5e700d2d9055770e > CatalogTableStatisticsConverter

[jira] [Commented] (FLINK-14987) JDBCTableSource can't support DataTypes.DECIMAL

[ https://issues.apache.org/jira/browse/FLINK-14987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987437#comment-16987437 ] Kurt Young commented on FLINK-14987: Sorry, looks like this issue is already covered by FLINK-14645

[jira] [Updated] (FLINK-13502) CatalogTableStatisticsConverter & TreeNode should be in correct package

[ https://issues.apache.org/jira/browse/FLINK-13502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13502: --- Priority: Major (was: Critical) > CatalogTableStatisticsConverter & TreeNode should be in correct

[jira] [Commented] (FLINK-14645) Data types defined in DDL will lose precision and nullability when converting to properties

[ https://issues.apache.org/jira/browse/FLINK-14645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987439#comment-16987439 ] Kurt Young commented on FLINK-14645: Please check whether this issues covers FLINK-14987 > Data

[jira] [Assigned] (FLINK-15022) E2E View support in FLINK SQL

[ https://issues.apache.org/jira/browse/FLINK-15022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-15022: -- Assignee: Zhenghua Gao > E2E View support in FLINK SQL > - > >

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

[ 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] [Comment Edited] (FLINK-15017) add a thrift server for Flink

[ 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-11899) Introduce vectorized parquet InputFormat for blink runtime

[ 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] [Assigned] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ 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] [Closed] (FLINK-14381) Partition field names should be got from CatalogTable instead of source/sink

[ https://issues.apache.org/jira/browse/FLINK-14381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14381. -- Resolution: Fixed merged in 1.10: ad4fd63fc917641963e507ad030ce3806baeb0f0

[jira] [Closed] (FLINK-14446) Design a Java end to end test framework for supporting more external system

[ https://issues.apache.org/jira/browse/FLINK-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14446. -- Resolution: Duplicate > Design a Java end to end test framework for supporting more external system >

[jira] [Closed] (FLINK-14053) blink planner dense_rank corner case bug

[ https://issues.apache.org/jira/browse/FLINK-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14053. -- Resolution: Fixed Fixed in master: 37f67b7d394ccb3355ebc995af1c3fee04ce060f > blink planner

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953685#comment-16953685 ] Kurt Young commented on FLINK-11491: You can also further merge 1 and 2 into 2. > Support all

[jira] [Assigned] (FLINK-13867) Write file only once when doing blocking broadcast shuffle

[ https://issues.apache.org/jira/browse/FLINK-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13867: -- Assignee: Yun Gao > Write file only once when doing blocking broadcast shuffle >

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16953478#comment-16953478 ] Kurt Young commented on FLINK-11491: I think sub-task-4 is unnecessary. For sub-task-3, it's better

[jira] [Closed] (FLINK-12399) FilterableTableSource does not use filters on job run

[ https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12399. -- Fix Version/s: 1.10.0 Resolution: Fixed merged to 1.10: 

[jira] [Comment Edited] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957541#comment-16957541 ] Kurt Young edited comment on FLINK-11491 at 10/23/19 4:29 AM: -- I think we

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957541#comment-16957541 ] Kurt Young commented on FLINK-11491: I think we need a solution that can make all tpc-ds queries

[jira] [Updated] (FLINK-14848) BaseRowSerializer.toBinaryRow wrongly process null for objects with variable-length part

[ https://issues.apache.org/jira/browse/FLINK-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14848: --- Affects Version/s: (was: 1.10.0) 1.9.1 > BaseRowSerializer.toBinaryRow

[jira] [Updated] (FLINK-14855) travis-ci error.

[ https://issues.apache.org/jira/browse/FLINK-14855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14855: --- Priority: Blocker (was: Major) > travis-ci error. > > > Key:

[jira] [Updated] (FLINK-14855) travis-ci error.

[ https://issues.apache.org/jira/browse/FLINK-14855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14855: --- Fix Version/s: (was: 1.11.0) 1.10.0 > travis-ci error. > >

[jira] [Updated] (FLINK-14855) travis-ci error.

[ https://issues.apache.org/jira/browse/FLINK-14855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14855: --- Affects Version/s: (was: 1.11.0) > travis-ci error. > > > Key:

[jira] [Updated] (FLINK-14386) Support computed column for create table statement

[ https://issues.apache.org/jira/browse/FLINK-14386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14386: --- Description: Support syntax like: {code:sql} create table t( a int, b as a + 1, c as

[jira] [Closed] (FLINK-14664) Support to reference user defined functions of external catalog in computed columns

[ https://issues.apache.org/jira/browse/FLINK-14664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14664. -- Resolution: Fixed > Support to reference user defined functions of external catalog in computed >

[jira] [Closed] (FLINK-14858) Wrong "if" statement in SqlToOperationConverter

[ https://issues.apache.org/jira/browse/FLINK-14858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14858. -- Resolution: Fixed merged to 1.10.0: 0e4e60517231967b4caf6695e5a606595a9ca088 > Wrong "if" statement

[jira] [Commented] (FLINK-14845) Introduce data compression to blocking shuffle.

[ https://issues.apache.org/jira/browse/FLINK-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977982#comment-16977982 ] Kurt Young commented on FLINK-14845: [~sewen] Currently we set all shuffle type to `BLOCKING` in

[jira] [Updated] (FLINK-14789) extends max/min type in ColumnStats from Number to Comparable

[ https://issues.apache.org/jira/browse/FLINK-14789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14789: --- Component/s: (was: Table SQL / Planner) Table SQL / API > extends max/min type

[jira] [Closed] (FLINK-14789) extends max/min type in ColumnStats from Number to Comparable

[ https://issues.apache.org/jira/browse/FLINK-14789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14789. -- Resolution: Fixed fixed in 1.10.0: 7b64ebf56c6141ef9922a2bf94b96f978e51428c > extends max/min type

[jira] [Updated] (FLINK-14874) add local aggregate to solve data skew for ROLLUP/CUBE case

[ https://issues.apache.org/jira/browse/FLINK-14874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14874: --- Affects Version/s: (was: 1.9.0) > add local aggregate to solve data skew for ROLLUP/CUBE case >

[jira] [Updated] (FLINK-14868) Provides the ability for multiple sinks to write data serially

[ https://issues.apache.org/jira/browse/FLINK-14868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14868: --- Fix Version/s: (was: 1.9.2) > Provides the ability for multiple sinks to write data serially >

[jira] [Assigned] (FLINK-14845) Introduce data compression to blocking shuffle.

[ https://issues.apache.org/jira/browse/FLINK-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14845: -- Assignee: Yingjie Cao > Introduce data compression to blocking shuffle. >

[jira] [Commented] (FLINK-13943) Provide api to convert flink table to java List (e.g. Table#collect)

[ https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978255#comment-16978255 ] Kurt Young commented on FLINK-13943: +1 to Aljoscha's proposal. Most of the time this feature only

[jira] [Closed] (FLINK-14806) Introduce setTimestamp/getTimestamp interface to TypeGetterSetters/VectorizedColumnBatch and writeTimestamp interface to BinaryWriter

[ https://issues.apache.org/jira/browse/FLINK-14806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14806. -- Assignee: Zhenghua Gao Resolution: Fixed merged in 1.10.0: 

[jira] [Assigned] (FLINK-14721) HiveTableSource should implement LimitableTableSource interface

[ https://issues.apache.org/jira/browse/FLINK-14721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14721: -- Assignee: Terry Wang > HiveTableSource should implement LimitableTableSource interface >

[jira] [Commented] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983161#comment-16983161 ] Kurt Young commented on FLINK-14566: I think memory weight is not required for now, we can revisit

[jira] [Commented] (FLINK-14956) MemoryMappedBoundedData Compressed Buffer Slicer

[ https://issues.apache.org/jira/browse/FLINK-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983085#comment-16983085 ] Kurt Young commented on FLINK-14956: Hi [~nicholasjiang], is this the same as FLINK-14845? >

[jira] [Closed] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11491. -- Resolution: Fixed merged to master: 20c983c26262057c4d59bd591aed89969a8ff525 > Support all TPC-DS

[jira] [Updated] (FLINK-14079) Full data type support in planner

[ https://issues.apache.org/jira/browse/FLINK-14079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-14079: --- Fix Version/s: (was: 1.10.0) > Full data type support in planner >

[jira] [Commented] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985899#comment-16985899 ] Kurt Young commented on FLINK-14364: Hi [~wind_ljy], are you still working on this? > Allow

[jira] [Closed] (FLINK-14743) Optimize BaseRowSerializer to use Projection instead of switch

[ https://issues.apache.org/jira/browse/FLINK-14743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14743. -- Resolution: Won't Fix close this item for now, feel free to reopen it when necessary > Optimize

[jira] [Assigned] (FLINK-14743) Optimize BaseRowSerializer to use Projection instead of switch

[ https://issues.apache.org/jira/browse/FLINK-14743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14743: -- Assignee: (was: Jingsong Lee) > Optimize BaseRowSerializer to use Projection instead of

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