[jira] [Assigned] (FLINK-27241) Support DROP PARTITION statement for partitioned table

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27241: --- Assignee: dalongliu > Support DROP PARTITION statement for partitioned table >

[jira] [Assigned] (FLINK-27240) Support ADD PARTITION statement for partitioned table

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27240: --- Assignee: dalongliu > Support ADD PARTITION statement for partitioned table >

[jira] [Assigned] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22318: --- Assignee: dalongliu (was: Jark Wu) > Support RENAME column name for ALTER TABLE statement >

[jira] [Assigned] (FLINK-22732) Restrict ALTER TABLE from setting empty table options

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22732: --- Assignee: Jark Wu > Restrict ALTER TABLE from setting empty table options >

[jira] [Assigned] (FLINK-22732) Restrict ALTER TABLE from setting empty table options

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22732: --- Assignee: dalongliu (was: Jark Wu) > Restrict ALTER TABLE from setting empty table options >

[jira] [Assigned] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22318: --- Assignee: Jark Wu > Support RENAME column name for ALTER TABLE statement >

[jira] [Assigned] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22317: --- Assignee: Jark Wu (was: Aiden Gong) > Support DROP column/constraint/watermark for ALTER TABLE

[jira] [Assigned] (FLINK-22317) Support DROP column/constraint/watermark for ALTER TABLE statement

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22317: --- Assignee: Aiden Gong (was: Jark Wu) > Support DROP column/constraint/watermark for ALTER TABLE

[jira] [Assigned] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22315: --- Assignee: Jane Chan (was: Jark Wu) > Support ADD column/constraint/watermark for ALTER TABLE

[jira] [Assigned] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22315: --- Assignee: Jark Wu (was: RocMarshal) > Support ADD column/constraint/watermark for ALTER TABLE

[jira] [Assigned] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28451: --- Assignee: luoyuxia (was: Jark Wu) > HiveFunctionDefinitionFactory load udf using user classloader

[jira] [Assigned] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28451: --- Assignee: Jark Wu (was: luoyuxia) > HiveFunctionDefinitionFactory load udf using user classloader

[jira] [Assigned] (FLINK-27790) Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27790: --- Assignee: Liu (was: Jark Wu) > Port ADD JAR /SHOW JARS syntax implementation from SqlClient to >

[jira] [Assigned] (FLINK-27790) Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27790: --- Assignee: Jark Wu > Port ADD JAR /SHOW JARS syntax implementation from SqlClient to >

[jira] [Assigned] (FLINK-27660) Table API support create function using customed jar

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27660: --- Assignee: Jark Wu (was: Peter Huang) > Table API support create function using customed jar >

[jira] [Assigned] (FLINK-27660) Table API support create function using customed jar

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27660: --- Assignee: Peter Huang (was: Jark Wu) > Table API support create function using customed jar >

[jira] [Assigned] (FLINK-28343) Hive dialect fails using union map type

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28343: --- Assignee: luoyuxia > Hive dialect fails using union map type >

[jira] [Assigned] (FLINK-25641) Unexpected aggregate plan after load hive module

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25641: --- Assignee: luoyuxia > Unexpected aggregate plan after load hive module >

[jira] [Assigned] (FLINK-28342) Flink batch support for Hive StorageHandlers

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28342: --- Assignee: luoyuxia > Flink batch support for Hive StorageHandlers >

[jira] [Assigned] (FLINK-28158) Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE)

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28158: --- Assignee: luoyuxia > Flink supports all modes of Hive UDAF (PARTIAL1, PARTIAL2, FINAL, COMPLETE) >

[jira] [Assigned] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25593: --- Assignee: luoyuxia > A redundant scan could be skipped if it is an input of join and the other >

[jira] [Assigned] (FLINK-25596) Specify hash/sortmerge join in SQL hint

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25596: --- Assignee: luoyuxia > Specify hash/sortmerge join in SQL hint >

[jira] [Assigned] (FLINK-25594) Take parquet metadata into consideration when source is parquet files

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25594: --- Assignee: luoyuxia > Take parquet metadata into consideration when source is parquet files >

[jira] [Assigned] (FLINK-27858) Hive source support filter push down for parquet format

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27858: --- Assignee: luoyuxia > Hive source support filter push down for parquet format >

[jira] [Assigned] (FLINK-28306) Support get table statistic for Hive partition table

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28306: --- Assignee: luoyuxia > Support get table statistic for Hive partition table >

[jira] [Assigned] (FLINK-27857) Hive source support filter push down for orc format

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27857: --- Assignee: luoyuxia > Hive source support filter push down for orc format >

[jira] [Assigned] (FLINK-27597) Support get column statistic for Hive partition table

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27597: --- Assignee: luoyuxia > Support get column statistic for Hive partition table >

[jira] [Assigned] (FLINK-28628) Introduce operation execution plugin

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28628: --- Assignee: luoyuxia > Introduce operation execution plugin > >

[jira] [Assigned] (FLINK-28317) Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28317: --- Assignee: luoyuxia > Throw unsupport exception when RexSubQuery contains LogicalUnion and >

[jira] [Assigned] (FLINK-28096) Hive dialect support set variable

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28096: --- Assignee: luoyuxia > Hive dialect support set variable > - > >

[jira] [Assigned] (FLINK-28212) IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28212: --- Assignee: luoyuxia > IndexOutOfBoundsException is thrown when project contains window which >

[jira] [Assigned] (FLINK-28296) Support Hive's UDAF which implement GenericUDAFResolver

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28296: --- Assignee: luoyuxia > Support Hive's UDAF which implement GenericUDAFResolver >

[jira] [Assigned] (FLINK-27850) Hive dialect supports "add file xxx"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27850: --- Assignee: luoyuxia > Hive dialect supports "add file xxx" > >

[jira] [Assigned] (FLINK-27859) Hive dialect should support create table whose name begins with digits

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27859: --- Assignee: luoyuxia > Hive dialect should support create table whose name begins with digits >

[jira] [Assigned] (FLINK-27375) Hive dialect support "over() without order keys inside"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27375: --- Assignee: luoyuxia > Hive dialect support "over() without order keys inside" >

[jira] [Assigned] (FLINK-27603) Hive dialect supports "reload function"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27603: --- Assignee: luoyuxia > Hive dialect supports "reload function" >

[jira] [Assigned] (FLINK-27217) Support partition filter push down when there exists default_parition

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27217: --- Assignee: luoyuxia (was: Jark Wu) > Support partition filter push down when there exists

[jira] [Assigned] (FLINK-27718) Hive dialect supports to count mutiple fields

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27718: --- Assignee: luoyuxia > Hive dialect supports to count mutiple fields >

[jira] [Assigned] (FLINK-27217) Support partition filter push down when there exists default_parition

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27217: --- Assignee: Jark Wu (was: luoyuxia) > Support partition filter push down when there exists

[jira] [Assigned] (FLINK-27217) Support partition filter push down when there exists default_parition

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27217: --- Assignee: luoyuxia > Support partition filter push down when there exists default_parition >

[jira] [Assigned] (FLINK-27374) Convert Hive's void type to Flink's string type

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27374: --- Assignee: luoyuxia > Convert Hive's void type to Flink's string type >

[jira] [Assigned] (FLINK-26542) Fix "schema of both sides of union should match" exception when one side of union select multiple same coulmns

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26542: --- Assignee: luoyuxia > Fix "schema of both sides of union should match" exception when one side of

[jira] [Assigned] (FLINK-27016) Improve supporting for complex data type for Hive dialect

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27016: --- Assignee: luoyuxia > Improve supporting for complex data type for Hive dialect >

[jira] [Assigned] (FLINK-26505) Support non equality condition for left semi join in Hive dialect

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26505: --- Assignee: luoyuxia > Support non equality condition for left semi join in Hive dialect >

[jira] [Assigned] (FLINK-27014) Hive dialect support select null literal in subquery

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27014: --- Assignee: luoyuxia > Hive dialect support select null literal in subquery >

[jira] [Assigned] (FLINK-27017) Hive dialect supports divide by zero

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27017: --- Assignee: luoyuxia > Hive dialect supports divide by zero > >

[jira] [Assigned] (FLINK-27015) Hive dialect supports cast timestamp to decimal

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27015: --- Assignee: luoyuxia > Hive dialect supports cast timestamp to decimal >

[jira] [Assigned] (FLINK-27175) Fail to call Hive UDAF when the UDAF is with only one parameter with array type

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27175: --- Assignee: luoyuxia > Fail to call Hive UDAF when the UDAF is with only one parameter with array >

[jira] [Assigned] (FLINK-26426) Hive dialect support "create table like"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26426: --- Assignee: luoyuxia > Hive dialect support "create table like" >

[jira] [Assigned] (FLINK-26411) Hive dialect supports CLUSTERED BY/ SORTED BY table

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26411: --- Assignee: luoyuxia > Hive dialect supports CLUSTERED BY/ SORTED BY table >

[jira] [Assigned] (FLINK-26474) Fail to call hive udf when secondary parameter required constant but pass value like "-1"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26474: --- Assignee: luoyuxia > Fail to call hive udf when secondary parameter required constant but pass >

[jira] [Assigned] (FLINK-26413) Hive dialect support "LOAD DATA INPATH"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26413: --- Assignee: luoyuxia > Hive dialect support "LOAD DATA INPATH" >

[jira] [Assigned] (FLINK-26415) support partitioned view in hive dialect

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26415: --- Assignee: luoyuxia > support partitioned view in hive dialect >

[jira] [Assigned] (FLINK-26412) Hive dialect supports "CREATE FUNCTION USING xxx.jar"

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26412: --- Assignee: luoyuxia > Hive dialect supports "CREATE FUNCTION USING xxx.jar" >

[jira] [Assigned] (FLINK-26410) support hive transform

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26410: --- Assignee: luoyuxia > support hive transform > -- > > Key:

[jira] [Assigned] (FLINK-26371) Support read hive variables using the syntax like select ${hiveconf:select_time}

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26371: --- Assignee: luoyuxia > Support read hive variables using the syntax like select >

[jira] [Assigned] (FLINK-26362) "IndexOutOfBoundsException" when subquery select all field from using hive dialect

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26362: --- Assignee: luoyuxia > "IndexOutOfBoundsException" when subquery select all field from using hive >

[jira] [Updated] (FLINK-27996) Hive dialect support INTERVAL type

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27996: Summary: Hive dialect support INTERVAL type (was: Hive dialect support interval) > Hive dialect support

[jira] [Closed] (FLINK-27996) Hive dialect support interval

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27996. --- Fix Version/s: 1.16.0 Assignee: luoyuxia Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28451: --- Assignee: luoyuxia > HiveFunctionDefinitionFactory load udf using user classloader instead of >

[jira] [Created] (FLINK-28620) SQL Client doesn't properly print values of INTERVAL type

2022-07-21 Thread Jark Wu (Jira)
Jark Wu created FLINK-28620: --- Summary: SQL Client doesn't properly print values of INTERVAL type Key: FLINK-28620 URL: https://issues.apache.org/jira/browse/FLINK-28620 Project: Flink Issue Type:

[jira] [Updated] (FLINK-28089) Hive dialect support "tablesample (xx rows)"

2022-07-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28089: Component/s: Connectors / Hive > Hive dialect support "tablesample (xx rows)" >

[jira] [Closed] (FLINK-28089) Hive dialect support "tablesample (xx rows)"

2022-07-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28089. --- Fix Version/s: 1.16.0 Assignee: luoyuxia Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

2022-07-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15289: --- Assignee: Jark Wu > Run sql appear error of "Zero-length character strings have no serializable >

[jira] [Updated] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

2022-07-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15289: Fix Version/s: 1.16.0 > Run sql appear error of "Zero-length character strings have no serializable >

[jira] [Closed] (FLINK-27013) Hive dialect supports IS_DISTINCT_FROM

2022-07-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27013. --- Fix Version/s: 1.16.0 Assignee: luoyuxia Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page

2022-07-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28122: --- Assignee: hunter > Translate "Overview " and "Project Configuration" in "User-defined Sources & >

[jira] [Commented] (FLINK-28524) Translate "User-defined Sources & Sinks"

2022-07-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566111#comment-17566111 ] Jark Wu commented on FLINK-28524: - Sorry, there is already an issue for this. FLINK-16105 > Translate

[jira] [Closed] (FLINK-28524) Translate "User-defined Sources & Sinks"

2022-07-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28524. --- Resolution: Duplicate > Translate "User-defined Sources & Sinks" >

[jira] [Commented] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

2022-07-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565282#comment-17565282 ] Jark Wu commented on FLINK-27142: - Hi [~twalthr], I also don't understand the two major cases you

[jira] [Closed] (FLINK-26414) Hive dialect supports "MACRO"

2022-07-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26414. --- Fix Version/s: 1.16.0 Assignee: luoyuxia Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-27244) Support subdirectories with Hive tables

2022-07-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27244. --- Fix Version/s: 1.16.0 Assignee: luoyuxia Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-15855) Use the new type inference for hive udaf

2022-07-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15855. --- Fix Version/s: 1.16.0 Resolution: Fixed Resolved in master: bcd619f43dab85c5920e6a15bc1f2db133904421

[jira] [Updated] (FLINK-26414) Hive dialect supports "MACRO"

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26414: Summary: Hive dialect supports "MACRO" (was: Hive dialect supports "Marco") > Hive dialect supports

[jira] [Assigned] (FLINK-28363) Support drop savepoint statement in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28363: --- Assignee: (was: Paul Lin) > Support drop savepoint statement in SQL client >

[jira] [Assigned] (FLINK-28362) Support savepoint statements in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28362: --- Assignee: Paul Lin > Support savepoint statements in SQL client >

[jira] [Assigned] (FLINK-28362) Support savepoint statements in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28362: --- Assignee: (was: Paul Lin) > Support savepoint statements in SQL client >

[jira] [Assigned] (FLINK-28361) Support show jobs statement in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28361: --- Assignee: (was: Paul Lin) > Support show jobs statement in SQL client >

[jira] [Updated] (FLINK-28361) Support show jobs statement in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28361: Component/s: Table SQL / Client > Support show jobs statement in SQL client >

[jira] [Assigned] (FLINK-28363) Support drop savepoint statement in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28363: --- Assignee: Paul Lin > Support drop savepoint statement in SQL client >

[jira] [Assigned] (FLINK-28360) Support stop job statement in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28360: --- Assignee: Paul Lin > Support stop job statement in SQL client >

[jira] [Assigned] (FLINK-28361) Support show jobs statement in SQL client

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28361: --- Assignee: Paul Lin > Support show jobs statement in SQL client >

[jira] [Comment Edited] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562047#comment-17562047 ] Jark Wu edited comment on FLINK-26764 at 7/5/22 7:57 AM: - I checked some

[jira] [Assigned] (FLINK-27620) Support percent_rank

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27620: --- Assignee: luoyuxia > Support percent_rank > > > Key:

[jira] [Updated] (FLINK-27620) Support percent_rank

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27620: Component/s: Table SQL / API > Support percent_rank > > > Key:

[jira] [Updated] (FLINK-27620) Support percent_rank

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27620: Fix Version/s: 1.16.0 > Support percent_rank > > > Key: FLINK-27620

[jira] [Assigned] (FLINK-27619) Support NTILE

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27619: --- Assignee: luoyuxia > Support NTILE > - > > Key: FLINK-27619 >

[jira] [Updated] (FLINK-27619) Support NTILE

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27619: Component/s: Table SQL / API > Support NTILE > - > > Key: FLINK-27619 >

[jira] [Updated] (FLINK-27619) Support NTILE

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27619: Fix Version/s: 1.16.0 > Support NTILE > - > > Key: FLINK-27619 >

[jira] [Updated] (FLINK-27618) Support CumeDist

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27618: Fix Version/s: 1.16.0 > Support CumeDist > > > Key: FLINK-27618 >

[jira] [Updated] (FLINK-27618) Suuport CumeDist

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27618: Component/s: Table SQL / API > Suuport CumeDist > > > Key: FLINK-27618 >

[jira] [Updated] (FLINK-27618) Support CumeDist

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27618: Summary: Support CumeDist (was: Suuport CumeDist) > Support CumeDist > > >

[jira] [Assigned] (FLINK-27618) Suuport CumeDist

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27618: --- Assignee: luoyuxia > Suuport CumeDist > > > Key: FLINK-27618 >

[jira] [Commented] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE

2022-07-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562047#comment-17562047 ] Jark Wu commented on FLINK-26764: - I checked some resources[1][2][3], and it seems the default behavior

[jira] [Commented] (FLINK-28368) Get field type return result problem

2022-07-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561985#comment-17561985 ] Jark Wu commented on FLINK-28368: - It's by design. Nullability is a part of data type in Flink. > Get

[jira] [Closed] (FLINK-28368) Get field type return result problem

2022-07-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28368. --- Resolution: Not A Problem > Get field type return result problem > > >

[jira] [Assigned] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option

2022-06-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28213: --- Assignee: dalongliu > StreamExecutionEnvironment configure method support override pipeline.jars

[jira] [Commented] (FLINK-28053) Introduce queue to execute request in sequence

2022-06-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557329#comment-17557329 ] Jark Wu commented on FLINK-28053: - Similar issue in HiveServer: HIVE-11402 > Introduce queue to execute

[jira] [Assigned] (FLINK-28121) Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page

2022-06-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28121: --- Assignee: Chengkai Yang > Translate "Extension Points" and "Full Stack Example" in "User-defined

[jira] [Closed] (FLINK-27861) Introduce UserResourceManager to manage user defined resource

2022-06-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27861. --- Assignee: dalongliu Resolution: Fixed Fixed in master: 7032ce386d7e765ad9a295732f2f909db97dce1b >

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