luoyuxia created FLINK-32117:
Summary: Add more test for update statement
Key: FLINK-32117
URL: https://issues.apache.org/jira/browse/FLINK-32117
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-32232:
Summary: Supports parse support truncate table statement
Key: FLINK-32232
URL: https://issues.apache.org/jira/browse/FLINK-32232
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32233:
Summary: Introduce SupportsTruncate interface
Key: FLINK-32233
URL: https://issues.apache.org/jira/browse/FLINK-32233
Project: Flink
Issue Type: Sub-task
C
luoyuxia created FLINK-32234:
Summary: Support execute truncate table statement
Key: FLINK-32234
URL: https://issues.apache.org/jira/browse/FLINK-32234
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32286:
Summary: Align the shade pattern that Hive connector using for
calcite related class with flink-table-planner
Key: FLINK-32286
URL: https://issues.apache.org/jira/browse/FLINK-32286
luoyuxia created FLINK-32287:
Summary: Add doc for truncate table statement
Key: FLINK-32287
URL: https://issues.apache.org/jira/browse/FLINK-32287
Project: Flink
Issue Type: Sub-task
C
luoyuxia created FLINK-32350:
Summary: FLIP-311: Support Call Stored Procedure
Key: FLINK-32350
URL: https://issues.apache.org/jira/browse/FLINK-32350
Project: Flink
Issue Type: New Feature
luoyuxia created FLINK-32351:
Summary: Introduce base interfaces for call procedure
Key: FLINK-32351
URL: https://issues.apache.org/jira/browse/FLINK-32351
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32352:
Summary: Support convert call procedure statement to correpsonding
operation
Key: FLINK-32352
URL: https://issues.apache.org/jira/browse/FLINK-32352
Project: Flink
luoyuxia created FLINK-32354:
Summary: Support to execute the call procedure operation
Key: FLINK-32354
URL: https://issues.apache.org/jira/browse/FLINK-32354
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32355:
Summary: Support to list procedure
Key: FLINK-32355
URL: https://issues.apache.org/jira/browse/FLINK-32355
Project: Flink
Issue Type: Sub-task
Components:
luoyuxia created FLINK-32356:
Summary: Add document for calling procedure
Key: FLINK-32356
URL: https://issues.apache.org/jira/browse/FLINK-32356
Project: Flink
Issue Type: Sub-task
Com
luoyuxia created FLINK-32397:
Summary: Add doc for add/drop/show partition
Key: FLINK-32397
URL: https://issues.apache.org/jira/browse/FLINK-32397
Project: Flink
Issue Type: Sub-task
Co
luoyuxia created FLINK-32460:
Summary: Add doc for list procedures
Key: FLINK-32460
URL: https://issues.apache.org/jira/browse/FLINK-32460
Project: Flink
Issue Type: Sub-task
Components
luoyuxia created FLINK-32481:
Summary: Support type inference for procedure
Key: FLINK-32481
URL: https://issues.apache.org/jira/browse/FLINK-32481
Project: Flink
Issue Type: Sub-task
C
luoyuxia created FLINK-32515:
Summary: FLIP-303: Support REPLACE TABLE AS SELECT statement
Key: FLINK-32515
URL: https://issues.apache.org/jira/browse/FLINK-32515
Project: Flink
Issue Type: New F
luoyuxia created FLINK-32516:
Summary: Support to parse REPLACE TABLE AS statement
Key: FLINK-32516
URL: https://issues.apache.org/jira/browse/FLINK-32516
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-32517:
Summary: Support to execute [CREATE OR] REPLACE TABLE AS statement
Key: FLINK-32517
URL: https://issues.apache.org/jira/browse/FLINK-32517
Project: Flink
Issue Type:
luoyuxia created FLINK-32519:
Summary: Add doc for [CREATE OR] REPLACE TABLE AS statement
Key: FLINK-32519
URL: https://issues.apache.org/jira/browse/FLINK-32519
Project: Flink
Issue Type: Sub-ta
luoyuxia created FLINK-32518:
Summary: Enable atomicity for [CREATE OR] REPLACE table as
statement
Key: FLINK-32518
URL: https://issues.apache.org/jira/browse/FLINK-32518
Project: Flink
Issue Ty
luoyuxia created FLINK-32596:
Summary: The partition key will be wrong when use Flink dialect to
create Hive table
Key: FLINK-32596
URL: https://issues.apache.org/jira/browse/FLINK-32596
Project: Flink
luoyuxia created FLINK-32982:
Summary: Don't need to suggest to swap for using Hive dialect
Key: FLINK-32982
URL: https://issues.apache.org/jira/browse/FLINK-32982
Project: Flink
Issue Type: Impr
luoyuxia created FLINK-33119:
Summary: The pojo result returned be procedure should be Row of
fields in the pojo instead of the whole pojo object
Key: FLINK-33119
URL: https://issues.apache.org/jira/browse/FLINK-33119
luoyuxia created FLINK-33549:
Summary: Exception "Factory does not implement interface
YieldingOperatorFactory" thrown in batch mode
Key: FLINK-33549
URL: https://issues.apache.org/jira/browse/FLINK-33549
luoyuxia created FLINK-34014:
Summary: Jdbc connector can avoid send empty insert to database
when there's no buffer data
Key: FLINK-34014
URL: https://issues.apache.org/jira/browse/FLINK-34014
Project: F
luoyuxia created FLINK-30335:
Summary: [Umbrella] Improvement for Hive Query Syntax
Compatibility-Part2
Key: FLINK-30335
URL: https://issues.apache.org/jira/browse/FLINK-30335
Project: Flink
Iss
luoyuxia created FLINK-30432:
Summary: HiveSoure doesn't need to maintain all splits when it's
for parallelism inference
Key: FLINK-30432
URL: https://issues.apache.org/jira/browse/FLINK-30432
Project: Fl
luoyuxia created FLINK-30452:
Summary: Wrong argument type is used when call Hive's function
Key: FLINK-30452
URL: https://issues.apache.org/jira/browse/FLINK-30452
Project: Flink
Issue Type: Bug
luoyuxia created FLINK-30556:
Summary: Improve the logic for enumerating splits for Hive source
to avoid potential OOM
Key: FLINK-30556
URL: https://issues.apache.org/jira/browse/FLINK-30556
Project: Flin
luoyuxia created FLINK-30559:
Summary: May get wrong result for `if` expression if it's string
data type
Key: FLINK-30559
URL: https://issues.apache.org/jira/browse/FLINK-30559
Project: Flink
Is
luoyuxia created FLINK-30567:
Summary: Wrong insert overwrite behavior when the table contains
uppercase character with Hive dialect
Key: FLINK-30567
URL: https://issues.apache.org/jira/browse/FLINK-30567
luoyuxia created FLINK-30617:
Summary: Wrong data type for null literal in Hive dialect
Key: FLINK-30617
URL: https://issues.apache.org/jira/browse/FLINK-30617
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-30635:
Summary: Fail to recover for row-format when writing to OSS using
FileSystemTable connector
Key: FLINK-30635
URL: https://issues.apache.org/jira/browse/FLINK-30635
Project: F
luoyuxia created FLINK-30648:
Summary: [Umbrella]FLIP-282 Introduce Delete/Update API
Key: FLINK-30648
URL: https://issues.apache.org/jira/browse/FLINK-30648
Project: Flink
Issue Type: New Featur
luoyuxia created FLINK-30661:
Summary: Introduce interfaces fro Delete/Update
Key: FLINK-30661
URL: https://issues.apache.org/jira/browse/FLINK-30661
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-30662:
Summary: Add implementation for SupportsDeletePushDown
Key: FLINK-30662
URL: https://issues.apache.org/jira/browse/FLINK-30662
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-30663:
Summary: Add implementation for RowLevelDelete
Key: FLINK-30663
URL: https://issues.apache.org/jira/browse/FLINK-30663
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-30665:
Summary: Add implementation for SupportsRowLevelUpdate
Key: FLINK-30665
URL: https://issues.apache.org/jira/browse/FLINK-30665
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-30666:
Summary: Add document for Delete/Update API
Key: FLINK-30666
URL: https://issues.apache.org/jira/browse/FLINK-30666
Project: Flink
Issue Type: Sub-task
Com
luoyuxia created FLINK-30695:
Summary: Support to set parallelism for compact operator according
to the number of files in AQE.
Key: FLINK-30695
URL: https://issues.apache.org/jira/browse/FLINK-30695
Proj
luoyuxia created FLINK-30919:
Summary: Fix typo in the document of User-defined Sources & Sinks
Key: FLINK-30919
URL: https://issues.apache.org/jira/browse/FLINK-30919
Project: Flink
Issue Type:
luoyuxia created FLINK-30951:
Summary: Release Testing: Verify FLINK-29635 Hive sink should
support merge files in batch mode
Key: FLINK-30951
URL: https://issues.apache.org/jira/browse/FLINK-30951
Projec
luoyuxia created FLINK-31090:
Summary: Flink fail to select INTERVAL
Key: FLINK-31090
URL: https://issues.apache.org/jira/browse/FLINK-31090
Project: Flink
Issue Type: Bug
Components:
luoyuxia created FLINK-31130:
Summary: Improve version info for the doc of SQL Gateway
Key: FLINK-31130
URL: https://issues.apache.org/jira/browse/FLINK-31130
Project: Flink
Issue Type: Improveme
luoyuxia created FLINK-31334:
Summary: E2e ci fail with unsupported file exception
Key: FLINK-31334
URL: https://issues.apache.org/jira/browse/FLINK-31334
Project: Flink
Issue Type: Bug
luoyuxia created FLINK-31344:
Summary: Support to update nested columns in update statement
Key: FLINK-31344
URL: https://issues.apache.org/jira/browse/FLINK-31344
Project: Flink
Issue Type: Impr
luoyuxia created FLINK-31398:
Summary: Don't wrap with TemporaryClassLoaderContext in
OperationExecutor
Key: FLINK-31398
URL: https://issues.apache.org/jira/browse/FLINK-31398
Project: Flink
Iss
luoyuxia created FLINK-31409:
Summary: Hive connector should use public interfaces for Hive
dialct
Key: FLINK-31409
URL: https://issues.apache.org/jira/browse/FLINK-31409
Project: Flink
Issue Ty
luoyuxia created FLINK-31413:
Summary: Remove provided dependency tabl in Hive connector
Key: FLINK-31413
URL: https://issues.apache.org/jira/browse/FLINK-31413
Project: Flink
Issue Type: Sub-tas
luoyuxia created FLINK-31464:
Summary: Move SqlNode convert logic out from
SqlToOperationConverter
Key: FLINK-31464
URL: https://issues.apache.org/jira/browse/FLINK-31464
Project: Flink
Issue Ty
luoyuxia created FLINK-31533:
Summary: CREATE TABLE AS SELECT should support to define partition
Key: FLINK-31533
URL: https://issues.apache.org/jira/browse/FLINK-31533
Project: Flink
Issue Type:
luoyuxia created FLINK-31534:
Summary: CREATE TABLE AS SELECT should support to define primary
key
Key: FLINK-31534
URL: https://issues.apache.org/jira/browse/FLINK-31534
Project: Flink
Issue Ty
luoyuxia created FLINK-31575:
Summary: Don't swap table-planner-loader and table-planner to use
hive dialect
Key: FLINK-31575
URL: https://issues.apache.org/jira/browse/FLINK-31575
Project: Flink
luoyuxia created FLINK-31607:
Summary: Refactor the logic for HiveExecutableOperation
Key: FLINK-31607
URL: https://issues.apache.org/jira/browse/FLINK-31607
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-31633:
Summary: Hive dialect can't order by an unselected column
Key: FLINK-31633
URL: https://issues.apache.org/jira/browse/FLINK-31633
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-31663:
Summary: Add ARRAY_EXCEPT supported in SQL & Table API
Key: FLINK-31663
URL: https://issues.apache.org/jira/browse/FLINK-31663
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-31874:
Summary: Support truncate table statement in batch mode
Key: FLINK-31874
URL: https://issues.apache.org/jira/browse/FLINK-31874
Project: Flink
Issue Type: New Featur
luoyuxia created FLINK-26603:
Summary: [Umbrella] Decouple Hive with Flink itself
Key: FLINK-26603
URL: https://issues.apache.org/jira/browse/FLINK-26603
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-26681:
Summary: Remove possbile semicolon in the end of SQL statemnt in
HiveParser
Key: FLINK-26681
URL: https://issues.apache.org/jira/browse/FLINK-26681
Project: Flink
I
luoyuxia created FLINK-26764:
Summary: Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE
Key: FLINK-26764
URL: https://issues.apache.org/jira/browse/FLINK-26764
Project: Flink
Issue Type: New Fea
luoyuxia created FLINK-26771:
Summary: Hive dialect supports to compare boolean type with
numeric type
Key: FLINK-26771
URL: https://issues.apache.org/jira/browse/FLINK-26771
Project: Flink
Issu
luoyuxia created FLINK-26829:
Summary: ClassCastException will be thrown when the second
operand of divide is a function call
Key: FLINK-26829
URL: https://issues.apache.org/jira/browse/FLINK-26829
Proje
luoyuxia created FLINK-27006:
Summary: Support SingleValueAggFunction for Char data type
Key: FLINK-27006
URL: https://issues.apache.org/jira/browse/FLINK-27006
Project: Flink
Issue Type: Improve
luoyuxia created FLINK-27013:
Summary: Hive dialect supports IS_DISTINCT_FROM
Key: FLINK-27013
URL: https://issues.apache.org/jira/browse/FLINK-27013
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-27014:
Summary: Hive dialect support select null literal in subquery
Key: FLINK-27014
URL: https://issues.apache.org/jira/browse/FLINK-27014
Project: Flink
Issue Type: Impr
luoyuxia created FLINK-27015:
Summary: Hive dialect supports cast timestamp to decimal
implicitly while inserting
Key: FLINK-27015
URL: https://issues.apache.org/jira/browse/FLINK-27015
Project: Flink
luoyuxia created FLINK-27016:
Summary: Improve supporting for complex data type for Hive dialect
Key: FLINK-27016
URL: https://issues.apache.org/jira/browse/FLINK-27016
Project: Flink
Issue Type:
luoyuxia created FLINK-27017:
Summary: Hive dialect supports divide by zero
Key: FLINK-27017
URL: https://issues.apache.org/jira/browse/FLINK-27017
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27116:
Summary: Supports Hive table partitioned by decimal
Key: FLINK-27116
URL: https://issues.apache.org/jira/browse/FLINK-27116
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27145:
Summary: The code generated for agg function accepts empty
parameters can't be compiled
Key: FLINK-27145
URL: https://issues.apache.org/jira/browse/FLINK-27145
Project: Flink
luoyuxia created FLINK-27175:
Summary: Fail to call Hive UDAF when the UDAF is with only one
parameter with array type
Key: FLINK-27175
URL: https://issues.apache.org/jira/browse/FLINK-27175
Project: Flin
luoyuxia created FLINK-27191:
Summary: Support multi kerberos-enabled Hive clusters
Key: FLINK-27191
URL: https://issues.apache.org/jira/browse/FLINK-27191
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-27217:
Summary: Support partition filter push down when there exists
default_parition
Key: FLINK-27217
URL: https://issues.apache.org/jira/browse/FLINK-27217
Project: Flink
luoyuxia created FLINK-27244:
Summary: Support subdirectories with Hive tables
Key: FLINK-27244
URL: https://issues.apache.org/jira/browse/FLINK-27244
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27338:
Summary: Improve spliting file for Hive soure
Key: FLINK-27338
URL: https://issues.apache.org/jira/browse/FLINK-27338
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-27374:
Summary: Convert Hive's void type to Flink's string type
Key: FLINK-27374
URL: https://issues.apache.org/jira/browse/FLINK-27374
Project: Flink
Issue Type: Improveme
luoyuxia created FLINK-27375:
Summary: Hive dialect support "over() without order keys inside"
Key: FLINK-27375
URL: https://issues.apache.org/jira/browse/FLINK-27375
Project: Flink
Issue Type: S
luoyuxia created FLINK-27376:
Summary: Hive dialect supports "select current_database()"
Key: FLINK-27376
URL: https://issues.apache.org/jira/browse/FLINK-27376
Project: Flink
Issue Type: Sub-tas
luoyuxia created FLINK-27402:
Summary: Unexpected boolean expression simplification for AND
expression
Key: FLINK-27402
URL: https://issues.apache.org/jira/browse/FLINK-27402
Project: Flink
Is
luoyuxia created FLINK-27407:
Summary: Exception of "unable to find common type of Boolean and
Char(4)" will be thrown when RexSarg contains "Boolean" and "Char(4)"
Key: FLINK-27407
URL: https://issues.apache.org/jira
luoyuxia created FLINK-27525:
Summary: Add a demo for using kafka sink via Flink SQL
Key: FLINK-27525
URL: https://issues.apache.org/jira/browse/FLINK-27525
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-27596:
Summary: [Umbrella] Optimize Hive source
Key: FLINK-27596
URL: https://issues.apache.org/jira/browse/FLINK-27596
Project: Flink
Issue Type: Improvement
Co
luoyuxia created FLINK-27597:
Summary: Get statistic for Hive paritioned table
Key: FLINK-27597
URL: https://issues.apache.org/jira/browse/FLINK-27597
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27603:
Summary: Hive dialect support "reload function"
Key: FLINK-27603
URL: https://issues.apache.org/jira/browse/FLINK-27603
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27617:
Summary: Add more analysis functions for Flink batch
Key: FLINK-27617
URL: https://issues.apache.org/jira/browse/FLINK-27617
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-27618:
Summary: Suuport CumeDist
Key: FLINK-27618
URL: https://issues.apache.org/jira/browse/FLINK-27618
Project: Flink
Issue Type: Sub-task
Reporter: luoyuxia
luoyuxia created FLINK-27619:
Summary: Support NTIE
Key: FLINK-27619
URL: https://issues.apache.org/jira/browse/FLINK-27619
Project: Flink
Issue Type: Sub-task
Reporter: luoyuxia
luoyuxia created FLINK-27620:
Summary: Support percent_rank
Key: FLINK-27620
URL: https://issues.apache.org/jira/browse/FLINK-27620
Project: Flink
Issue Type: Sub-task
Reporter: luoyu
luoyuxia created FLINK-27718:
Summary: Hive dialect supports to count mutiple fields
Key: FLINK-27718
URL: https://issues.apache.org/jira/browse/FLINK-27718
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27801:
Summary: Disable flushing stream when call Jackson's writeValue()
method for CsvBulkWriter
Key: FLINK-27801
URL: https://issues.apache.org/jira/browse/FLINK-27801
Project: Fl
luoyuxia created FLINK-27850:
Summary: Hive dialect supports "add file xxx"
Key: FLINK-27850
URL: https://issues.apache.org/jira/browse/FLINK-27850
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-27857:
Summary: Hive source support filter push down for orc format
Key: FLINK-27857
URL: https://issues.apache.org/jira/browse/FLINK-27857
Project: Flink
Issue Type: Sub-t
luoyuxia created FLINK-27858:
Summary: Hive source support filter push down for parquet format
Key: FLINK-27858
URL: https://issues.apache.org/jira/browse/FLINK-27858
Project: Flink
Issue Type: S
luoyuxia created FLINK-27859:
Summary: Hive dialect should support create table that begins with
digits
Key: FLINK-27859
URL: https://issues.apache.org/jira/browse/FLINK-27859
Project: Flink
Is
luoyuxia created FLINK-27895:
Summary: Enable the CI test for Hive's 3.x
Key: FLINK-27895
URL: https://issues.apache.org/jira/browse/FLINK-27895
Project: Flink
Issue Type: Improvement
luoyuxia created FLINK-27996:
Summary: Hive dialect support interval
Key: FLINK-27996
URL: https://issues.apache.org/jira/browse/FLINK-27996
Project: Flink
Issue Type: Sub-task
Report
luoyuxia created FLINK-27999:
Summary: Fix test failure for Hive3
Key: FLINK-27999
URL: https://issues.apache.org/jira/browse/FLINK-27999
Project: Flink
Issue Type: Improvement
Report
luoyuxia created FLINK-28011:
Summary: Optimize getAllPartitions in HiveSource
Key: FLINK-28011
URL: https://issues.apache.org/jira/browse/FLINK-28011
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-28036:
Summary: Use correct writable type to creaet
ConstantObjectInspector
Key: FLINK-28036
URL: https://issues.apache.org/jira/browse/FLINK-28036
Project: Flink
Issue Ty
luoyuxia created FLINK-26343:
Summary: IndexOutOfBoundsException when subquery select all field
from using hive dialect
Key: FLINK-26343
URL: https://issues.apache.org/jira/browse/FLINK-26343
Project: Fl
1 - 100 of 180 matches
Mail list logo
