[jira] [Updated] (FLINK-28922) Translate "ORDER BY clause" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-28922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28922: Component/s: Documentation > Translate "ORDER BY clause" page into Chinese >

[jira] [Closed] (FLINK-28924) Translate "LIMIT clause" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-28924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28924. --- Assignee: Zhuang Liu Resolution: Fixed Fixed in master: ae7f325a358574be6ce1e3c37aabff71214c857b > T

[jira] [Closed] (FLINK-28922) Translate "ORDER BY clause" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-28922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28922. --- Assignee: Zhuang Liu Resolution: Fixed Fixed in master: 3930014433915af0ea9d16714f21a6b55aa6dd61 > T

[jira] [Closed] (FLINK-28780) function docs of dayofmonth is not correct

[ https://issues.apache.org/jira/browse/FLINK-28780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28780. --- Assignee: jackylau Resolution: Fixed FIxed in master: 59843ae275ceb64d8429aea1426c829e1d562c26 > func

[jira] [Closed] (FLINK-27015) Fix exception for casting timestamp to decimal in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27015. --- Resolution: Fixed Fixed in master: 435dab64f6171dacdf90c759554dc3ef085d4ad5 > Fix exception for casting ti

[jira] [Closed] (FLINK-26505) Fix IndexOutOfBoundsException for non equality condition exists in left semi join in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26505. --- Resolution: Fixed Fixed in master: 479ddeaa02a5c571b252612205a92e3265c2435e > Fix IndexOutOfBoundsException

[jira] [Closed] (FLINK-27386) throw NPE if multi MAPJOIN hint union all

[ https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27386. --- Resolution: Fixed Fixed in master: 24ac1215883a5121e2f714277c56eaa8152c7e9b > throw NPE if multi MAPJOIN hi

[jira] [Assigned] (FLINK-28954) Release Testing: Verify FLIP-223 HiveServer2 Endpoint

[ https://issues.apache.org/jira/browse/FLINK-28954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28954: --- Assignee: luoyuxia > Release Testing: Verify FLIP-223 HiveServer2 Endpoint > --

[jira] [Assigned] (FLINK-28952) Release Testing: Veify Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28952: --- Assignee: Shengkai Fang > Release Testing: Veify Hive dialect > --

[jira] [Assigned] (FLINK-28965) Should create empty partition when it's for dynamic partition

[ https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28965: --- Assignee: tartarus > Should create empty partition when it's for dynamic partition > --

[jira] [Closed] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-28548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28548. --- Assignee: Liu Resolution: Fixed Fixed in master: f2abb51ac91c8b0e9bdd261de791d3aa1ba033dd > The commi

[jira] [Closed] (FLINK-28003) Hive sql is wrongly modified by SqlCompleter in SQL client when using -f {file}

[ https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28003. --- Resolution: Fixed Fixed in master: 226f1602c047092cc1997f6e861aa37858df21f7 > Hive sql is wrongly modified

[jira] [Closed] (FLINK-28773) Fix Hive sink not write a success file after finish writing in batch mode

[ https://issues.apache.org/jira/browse/FLINK-28773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28773. --- Assignee: tartarus Resolution: Fixed Fixed in master: 00cded670753e2795c774c159facb801bbeb9927 to b66

[jira] [Updated] (FLINK-27386) throw NPE if multi MAPJOIN hint union all

[ https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27386: Priority: Critical (was: Major) > throw NPE if multi MAPJOIN hint union all > ---

[jira] [Updated] (FLINK-28003) Hive sql is wrongly modified by SqlCompleter in SQL client when using -f {file}

[ https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28003: Fix Version/s: 1.16.0 > Hive sql is wrongly modified by SqlCompleter in SQL client when using -f > {file}

[jira] [Assigned] (FLINK-28883) Fix HiveTableSink failed to report metrics to hive metastore

[ https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28883: --- Assignee: luoyuxia > Fix HiveTableSink failed to report metrics to hive metastore > ---

[jira] [Updated] (FLINK-28003) Hive sql is wrongly modified by SqlCompleter in SQL client when using -f {file}

[ https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28003: Priority: Critical (was: Major) > Hive sql is wrongly modified by SqlCompleter in SQL client when using -

[jira] [Updated] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-28548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28548: Priority: Critical (was: Major) > The commit partition base path is not created when no data is sent whic

[jira] [Updated] (FLINK-28548) The commit partition base path is not created when no data is sent which may cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-28548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28548: Fix Version/s: 1.16.0 > The commit partition base path is not created when no data is sent which may > ca

[jira] [Updated] (FLINK-27015) Fix exception for casting timestamp to decimal in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27015: Summary: Fix exception for casting timestamp to decimal in Hive dialect (was: Fix exception for casting

[jira] [Closed] (FLINK-28913) Fix fail to open HiveCatalog when it's for hive3

[ https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28913. --- Assignee: luoyuxia Resolution: Fixed Fixed in master: cb4ead75d594e351dfe81af42e52db88faae356a > Fix

[jira] [Closed] (FLINK-28916) Add e2e test for create function using jar syntax

[ https://issues.apache.org/jira/browse/FLINK-28916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28916. --- Resolution: Fixed Fixed in master: 7661af066f5830f8dc7fae62b67df31ac7fc2e45 > Add e2e test for create funct

[jira] [Closed] (FLINK-28208) The method createBatchSink in class HiveTableSink should setParallelism for map operator

[ https://issues.apache.org/jira/browse/FLINK-28208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28208. --- Fix Version/s: 1.16.0 Assignee: Liu Resolution: Fixed Fixed in master: 15c422b483ee0c5084eb2

[jira] [Closed] (FLINK-26771) Fix incomparable exception between boolean type and numeric type in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26771. --- Resolution: Fixed Fixed in master: 1455e51c7cd64264f5ddebd0b768efc109fab74f > Fix incomparable exception be

[jira] [Assigned] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28897: --- Assignee: dalongliu > Fail to use udf in added jar when enabling checkpoint > -

[jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27492: Priority: Major (was: Critical) > Flink table scala example does not including the scala-api jars > -

[jira] [Updated] (FLINK-28774) Allow user to configure whether to enable sort or not when it's for dynamic parition writing for HiveSource

[ https://issues.apache.org/jira/browse/FLINK-28774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28774: Component/s: Connectors / Hive > Allow user to configure whether to enable sort or not when it's for dynam

[jira] [Closed] (FLINK-28774) Allow user to configure whether to enable sort or not when it's for dynamic parition writing for HiveSource

[ https://issues.apache.org/jira/browse/FLINK-28774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28774. --- Fix Version/s: 1.16.0 Assignee: luoyuxia Resolution: Fixed Fixed in master: 22dba69f16d69e82

[jira] [Updated] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28897: Priority: Critical (was: Major) > Fail to use udf in added jar when enabling checkpoint > ---

[jira] [Updated] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28897: Fix Version/s: 1.16.0 > Fail to use udf in added jar when enabling checkpoint > --

[jira] [Updated] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28897: Component/s: Table SQL / Client > Fail to use udf in added jar when enabling checkpoint >

[jira] [Closed] (FLINK-26929) Introduce adaptive hash join for batch sql optimization

[ https://issues.apache.org/jira/browse/FLINK-26929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26929. --- Resolution: Fixed Fixed in master: 10acb641a036ae9d171452695b660c46d97c865a > Introduce adaptive hash join

[jira] [Commented] (FLINK-26929) Introduce adaptive hash join for batch sql optimization

[ https://issues.apache.org/jira/browse/FLINK-26929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577710#comment-17577710 ] Jark Wu commented on FLINK-26929: - [~Runking], yes, you are right. > Introduce adaptiv

[jira] [Closed] (FLINK-28797) Hive source should also support verctor reading for complex data type when with parquet format

[ https://issues.apache.org/jira/browse/FLINK-28797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28797. --- Assignee: luoyuxia Resolution: Fixed Fixed in master: 43eda5d3fe23de1aa95e73475dfb4792d36d4490 to 923

[jira] [Updated] (FLINK-28773) Fix Hive sink not write a success file after finish writing in batch mode

[ https://issues.apache.org/jira/browse/FLINK-28773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28773: Summary: Fix Hive sink not write a success file after finish writing in batch mode (was: Allow to write a

[jira] [Updated] (FLINK-28883) Fix HiveTableSink failed to report metrics to hive metastore

[ https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28883: Summary: Fix HiveTableSink failed to report metrics to hive metastore (was: HiveTableSink supports to rep

[jira] [Updated] (FLINK-28883) Fix HiveTableSink failed to report metrics to hive metastore

[ https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28883: Description: Currently, HiveTableSink is failed to report metrics to metastores, like file number, total l

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

[ https://issues.apache.org/jira/browse/FLINK-26413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26413. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 6c91cc5999828f0a61f8a54498bc71a581a05dd8 >

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

[ https://issues.apache.org/jira/browse/FLINK-26413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26413: Component/s: Connectors / Hive > Hive dialect support "LOAD DATA INPATH" > --

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25592: Fix Version/s: (was: 1.16.0) > Improvement of parser, optimizer and execution for Flink Batch SQL > --

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

[ https://issues.apache.org/jira/browse/FLINK-27660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-27660: Fix Version/s: (was: 1.16.0) > Table API support create function using customed jar >

[jira] [Closed] (FLINK-24614) Add array,map,row types support for parquet vectorized reader

[ https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24614. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 5c731a37e1a8f71f9c9e813f6c741a1e203fa1a3 >

[jira] [Updated] (FLINK-28420) Support partial lookup caching in lookup join runners

[ https://issues.apache.org/jira/browse/FLINK-28420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28420: Fix Version/s: 1.16.0 > Support partial lookup caching in lookup join runners > --

[jira] [Closed] (FLINK-28420) Support partial lookup caching in lookup join runners

[ https://issues.apache.org/jira/browse/FLINK-28420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28420. --- Resolution: Fixed Fixed in master: bc76a93239e159fba7277da96336c3796887e6c5 > Support partial lookup cachin

[jira] [Commented] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576499#comment-17576499 ] Jark Wu commented on FLINK-28844: - https://dev.azure.com/apache-flink/apache-flink/_buil

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

[ https://issues.apache.org/jira/browse/FLINK-27790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27790. --- Resolution: Fixed Fixed in master: c5c66af680eaf3aae6fbcb6dc48e8d6b66ade8c9 to fe9c726ac1ac09c719b2769e7b73

[jira] [Closed] (FLINK-28834) Add TemporalJoin example and ITCase

[ https://issues.apache.org/jira/browse/FLINK-28834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28834. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 62786320eb555e36fe9fb82168fe97855dc54056 >

[jira] [Updated] (FLINK-28834) Add TemporalJoin example and ITCase

[ https://issues.apache.org/jira/browse/FLINK-28834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28834: Component/s: Examples > Add TemporalJoin example and ITCase > --- > >

[jira] [Updated] (FLINK-28834) Add TemporalJoin example and ITCase

[ https://issues.apache.org/jira/browse/FLINK-28834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28834: Component/s: Table SQL / API > Add TemporalJoin example and ITCase > --- >

[jira] [Closed] (FLINK-28772) Hive dialect supports add jar

[ https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28772. --- Resolution: Fixed Fixed in master: 6d06cdaa1633035c127483af1dc4b45e57cbc035 and 1a094eb3619e9696759eaf1a5a0

[jira] [Commented] (FLINK-28789) TPC-DS tests failed due to release input gate for task failure

[ https://issues.apache.org/jira/browse/FLINK-28789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576251#comment-17576251 ] Jark Wu commented on FLINK-28789: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Assigned] (FLINK-27617) Add more analysis functions for Flink batch

[ https://issues.apache.org/jira/browse/FLINK-27617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-27617: --- Assignee: luoyuxia > Add more analysis functions for Flink batch > ---

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

[ https://issues.apache.org/jira/browse/FLINK-27619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27619. --- Resolution: Fixed Fixed in master: 3e1018e0cbc6d28d59f2d0658c6a94b044484f67 and 8ac7e9724a60d9f90ede81b8e1b

[jira] [Closed] (FLINK-27617) Add more analysis functions for Flink batch

[ https://issues.apache.org/jira/browse/FLINK-27617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27617. --- Resolution: Fixed > Add more analysis functions for Flink batch > -

[jira] [Updated] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28844: Description: This is keep failing on master since the commit of https://github.com/flink-ci/flink-mirror/

[jira] [Commented] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576201#comment-17576201 ] Jark Wu commented on FLINK-28844: - [~chesnay], could you help to take a look? > YARNHig

[jira] [Created] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

Jark Wu created FLINK-28844: --- Summary: YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator Key: FLINK-28844 URL: https://issues.apache.org/jira/browse/FLINK-28844 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-27217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27217. --- Resolution: Fixed Fixed in master: c54eaf51aad662dcfd187f370792edf15bb80b3c and 01d31f6ed30d2f1ed37eaaad705

[jira] [Closed] (FLINK-25645) UnsupportedOperationException would thrown out when hash shuffle by a field with array type

[ https://issues.apache.org/jira/browse/FLINK-25645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25645. --- Resolution: Fixed Fixed in master: f806bb79950202256358988684964761ebe2a05b > UnsupportedOperationException

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575976#comment-17575976 ] Jark Wu commented on FLINK-26721: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-28772) Hive dialect supports add jar

[ https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28772: Fix Version/s: 1.16.0 > Hive dialect supports add jar > -- > >

[jira] [Updated] (FLINK-28772) Hive dialect supports add jar

[ https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28772: Component/s: Connectors / Hive > Hive dialect supports add jar > -- > >

[jira] [Assigned] (FLINK-28772) Hive dialect supports add jar

[ https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28772: --- Assignee: luoyuxia (was: Jark Wu) > Hive dialect supports add jar > -

[jira] [Assigned] (FLINK-28772) Hive dialect supports add jar

[ https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28772: --- Assignee: Jark Wu > Hive dialect supports add jar > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-27620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27620. --- Resolution: Fixed Fixed in master: b4df097513be1ec0b82b5a110f93606388747765 > Support percent_rank > --

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

[ https://issues.apache.org/jira/browse/FLINK-28296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28296: Component/s: Connectors / Hive > Support Hive's UDAF which implement GenericUDAFResolver > ---

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

[ https://issues.apache.org/jira/browse/FLINK-28296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28296. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: f9bd7d2f553174c2ae25da63e3d5be156649cf27 >

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

[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26362: Component/s: Connectors / Hive > "IndexOutOfBoundsException" when subquery select all field from using hiv

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

[ https://issues.apache.org/jira/browse/FLINK-26362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26362. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 9b9a0bc10da78a15b0144a1fa7bfb41e4f31a295 >

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

[ https://issues.apache.org/jira/browse/FLINK-26371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26371: Component/s: Connectors / Hive > Support read hive variables using the syntax like select > ${hiveconf:se

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

[ https://issues.apache.org/jira/browse/FLINK-26371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26371. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: abba1d7c853c8f198e65dd2dd073b51a19f133a4 >

[jira] [Updated] (FLINK-28459) Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS)

[ https://issues.apache.org/jira/browse/FLINK-28459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28459: Component/s: Table SQL / Planner > Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS) > --

[jira] [Closed] (FLINK-28459) Flink SQL supports non-atomic CREATE TABLE AS SELECT(CTAS)

[ https://issues.apache.org/jira/browse/FLINK-28459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28459. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: bc29e574105a2e635f8f8b9a4ad8f251dfb89321 >

[jira] [Closed] (FLINK-28720) Add Hive partition when flink has no data to write

[ https://issues.apache.org/jira/browse/FLINK-28720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28720. --- Fix Version/s: 1.16.0 Assignee: tartarus Resolution: Fixed Fixed in master: 6fe0d1dbfc58b803

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

[ https://issues.apache.org/jira/browse/FLINK-28212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28212. --- Resolution: Fixed Fixed in master: 42287b399f7ca74a419cee0385a84e7859fc7628 > IndexOutOfBoundsException i

[jira] [Closed] (FLINK-28776) RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream WatermarkAssignerOperator

[ https://issues.apache.org/jira/browse/FLINK-28776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28776. --- Assignee: jackylau Resolution: Fixed Fixed in master: 2a7fe42d5069a7f9d0d7c531011aaf622893064e > RowT

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

[ https://issues.apache.org/jira/browse/FLINK-27016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27016. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 5ce10c9493ff23ef3dbc3eedc9d6d283d0798d96 >

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

[ https://issues.apache.org/jira/browse/FLINK-26542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26542. --- Resolution: Fixed Fixed in master: 6670feaef40b022e4caf32f1db10e03b8e374d7a > Fix "schema of both sides of

[jira] [Updated] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

[ https://issues.apache.org/jira/browse/FLINK-28764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28764: Fix Version/s: 1.16.0 > Support more than 64 distinct aggregate function calls in one aggregate SQL > que

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

[ https://issues.apache.org/jira/browse/FLINK-28096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28096. --- Resolution: Fixed Fixed in master: a6a7063cfafd8cd5c1b04169839b92373bf96fde > Hive dialect support set vari

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

[ https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26412: Component/s: Connectors / Hive > Hive dialect supports "CREATE FUNCTION USING xxx.jar" > -

[jira] [Updated] (FLINK-26366) Support "insert directory"

[ https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26366: Component/s: Connectors / Hive > Support "insert directory" > -- > >

[jira] [Closed] (FLINK-26366) Support "insert directory"

[ https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26366. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: a42c0041fc37595d07010c2077b2f806b2b34ef9 >

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

[ https://issues.apache.org/jira/browse/FLINK-26412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26412. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: b0d2b2aeb28329d48ee0b89259dbb067175c545a >

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

[ https://issues.apache.org/jira/browse/FLINK-26410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26410. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: faf37ebb2bbf385fbb9b6163bbf7a09353a0e39d >

[jira] [Updated] (FLINK-26410) support hive transform using syntax

[ https://issues.apache.org/jira/browse/FLINK-26410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26410: Summary: support hive transform using syntax (was: support hive transform) > support hive transform using

[jira] [Closed] (FLINK-27387) Support Insert Multi-Table

[ https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27387. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: bed7993aaf9838efdd254c8140c36d4ae1f80a56 >

[jira] [Closed] (FLINK-25142) The user-defined hive udtf initialize exception in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-25142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25142. --- Fix Version/s: 1.16.0 Assignee: xiangqiao Resolution: Fixed Fixed in master: 541c66b7b71b396

[jira] [Closed] (FLINK-28471) Translate hive_read_write.md into Chinese

[ https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28471. --- Fix Version/s: 1.16.0 Assignee: eyys Resolution: Fixed Resolved in master: a1ba512e70538dab0

[jira] [Assigned] (FLINK-28679) HiveServer2Endpoint compile failed

[ https://issues.apache.org/jira/browse/FLINK-28679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-28679: --- Assignee: Shengkai Fang > HiveServer2Endpoint compile failed > -- >

[jira] [Updated] (FLINK-28679) HiveServer2 Endpoint supports to build with Hive3

[ https://issues.apache.org/jira/browse/FLINK-28679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28679: Summary: HiveServer2 Endpoint supports to build with Hive3 (was: HiveServer2Endpoint compile failed) >

[jira] [Closed] (FLINK-28679) HiveServer2Endpoint compile failed

[ https://issues.apache.org/jira/browse/FLINK-28679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28679. --- Resolution: Fixed Fixed in master: aa624025dce378da3c11fc3ab6e8cf91fc94c30e > HiveServer2Endpoint compile f

[jira] [Closed] (FLINK-28463) Flink SQL syntax support CREATE TABLE AS SELECT(CTAS)

[ https://issues.apache.org/jira/browse/FLINK-28463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28463. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: ed8d3acf454e62edae458496473a6cf9c20daa24 >

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

[ https://issues.apache.org/jira/browse/FLINK-28628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28628. --- Resolution: Fixed Fixed in master: c7af66be7cb5c8148dd8bd258267bb7d2550f10e > Introduce operation execution

[jira] [Updated] (FLINK-28650) Flink SQL Parsing bug for METADATA

[ https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28650: Component/s: Table SQL / API > Flink SQL Parsing bug for METADATA > -- > >

[jira] [Updated] (FLINK-28650) Flink SQL Parsing bug for METADATA

[ https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28650: Fix Version/s: 1.16.0 > Flink SQL Parsing bug for METADATA > -- > >

[jira] [Commented] (FLINK-28650) Flink SQL Parsing bug for METADATA

[ https://issues.apache.org/jira/browse/FLINK-28650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570803#comment-17570803 ] Jark Wu commented on FLINK-28650: - Yes. I think this is a bug in partial insert (insert

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

[ https://issues.apache.org/jira/browse/FLINK-27618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-27618. --- Resolution: Fixed Fixed in master: 8017a417515cb87b1d15ef1295ecac73126b40f8 > Support CumeDist > --

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

[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-28451. --- Resolution: Fixed Fixed in master: e13ae26e806eff403787d5b75e90008bcc13d8dc and 9a4fd227a5824e707f4dbe52773

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

[ https://issues.apache.org/jira/browse/FLINK-28628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-28628: Fix Version/s: 1.16.0 > Introduce operation execution plugin > > >

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