luoyuxia created FLINK-29077:
Summary: Add doc for creeate statement of Hive dialect
Key: FLINK-29077
URL: https://issues.apache.org/jira/browse/FLINK-29077
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29077:
-
Summary: Add doc for create statement of Hive dialect (was: Add doc for
creeate statement of Hive diale
[
https://issues.apache.org/jira/browse/FLINK-29076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29076:
-
Summary: Add doc for alter statement of Hive dialect (was: Add alter doc
for Hive dialect)
> Add doc f
[
https://issues.apache.org/jira/browse/FLINK-29025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29025:
-
Summary: Add overview doc for Hive Dialect (was: Add overview docs for
Hive Dialect)
> Add overview do
[
https://issues.apache.org/jira/browse/FLINK-29025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29025:
-
Summary: Add overview docs for Hive Dialect (was: Add docs for Hive
Dialect)
> Add overview docs for H
luoyuxia created FLINK-29076:
Summary: Add alter doc for Hive dialect
Key: FLINK-29076
URL: https://issues.apache.org/jira/browse/FLINK-29076
Project: Flink
Issue Type: Sub-task
Compone
[
https://issues.apache.org/jira/browse/FLINK-29024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29024:
-
Summary: Add an overview page for Hive Compatibility (was: Add basic doc
structure for Hive Compatibili
[
https://issues.apache.org/jira/browse/FLINK-29013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582715#comment-17582715
]
luoyuxia commented on FLINK-29013:
--
To fix it, we should first call RecordReader#create
[
https://issues.apache.org/jira/browse/FLINK-28618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581811#comment-17581811
]
luoyuxia commented on FLINK-28618:
--
[~liubox123] I think the current master has fixed t
[
https://issues.apache.org/jira/browse/FLINK-29045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29045:
-
Fix Version/s: 1.16.0
> Optimize error message in Flink SQL Client when try to switch Hive Dialect
> ---
[
https://issues.apache.org/jira/browse/FLINK-29045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29045:
-
Description:
Since Flink 1.15 , if users want to use HiveDialect, they have to swap
flink-table-planner
luoyuxia created FLINK-29045:
Summary: Optimize error message in Flink SQL Client when try to
switch Hive Dialect
Key: FLINK-29045
URL: https://issues.apache.org/jira/browse/FLINK-29045
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581257#comment-17581257
]
luoyuxia commented on FLINK-19957:
--
Although the question is asked one year ago. But st
luoyuxia created FLINK-29027:
Summary: Fix HiveTableSink failed to report statistic to hive
metastore in stream mode
Key: FLINK-29027
URL: https://issues.apache.org/jira/browse/FLINK-29027
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28956:
-
Affects Version/s: 1.16.0
> FIx non-multi insert statement fall into multi insert logic in Hive dialect
[
https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28956:
-
Fix Version/s: 1.16.0
> FIx non-multi insert statement fall into multi insert logic in Hive dialect
> -
[
https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28956:
-
Priority: Critical (was: Major)
> FIx non-multi insert statement fall into multi insert logic in Hive
luoyuxia created FLINK-29025:
Summary: Add docs for Hive Dialect
Key: FLINK-29025
URL: https://issues.apache.org/jira/browse/FLINK-29025
Project: Flink
Issue Type: Sub-task
Components:
luoyuxia created FLINK-29026:
Summary: Add docs for HiveServer2 integration
Key: FLINK-29026
URL: https://issues.apache.org/jira/browse/FLINK-29026
Project: Flink
Issue Type: Sub-task
luoyuxia created FLINK-29024:
Summary: Add basic doc structure for Hive Compatibility
Key: FLINK-29024
URL: https://issues.apache.org/jira/browse/FLINK-29024
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29021:
-
Description:
This Jira is for adding some docs for Hive Compatibility.
Expect to add a new section belo
[
https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29021:
-
Description:
This Jira is for adding some docs for Hive Compatibility.
Expect to put it in , includin
[
https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29021:
-
Description:
Expect to put it in , including three part:
1: Overview
2: Hive Dialect
3: HiveServe
[
https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29021:
-
Labels: documentation (was: )
> [Umbrella] Add docs for Hive Compatibility
> --
luoyuxia created FLINK-29021:
Summary: [Umbrella] Add docs for Hive Compatibility
Key: FLINK-29021
URL: https://issues.apache.org/jira/browse/FLINK-29021
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29013:
-
Description:
It'll cause NPE when using following code:
{code:java}
tableEnv.executeSql(
[
https://issues.apache.org/jira/browse/FLINK-29013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29013:
-
Description:
It'll cause NPE when using following code:
{code:java}
tableEnv.executeSql(
[
https://issues.apache.org/jira/browse/FLINK-29013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29013:
-
Description:
It'll cause NPE when using following code:
{code:java}
tableEnv.executeSql(
luoyuxia created FLINK-29013:
Summary: Fail to use "transform using" when record reader is
binary record reader in Hive dialect
Key: FLINK-29013
URL: https://issues.apache.org/jira/browse/FLINK-29013
Pro
[
https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28965:
-
Summary: Shouldn't create empty partition when it's for dynamic partition
(was: Should create empty par
[
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580544#comment-17580544
]
luoyuxia commented on FLINK-22827:
--
[~aidenma] Thanks for your attention. If you have a
[
https://issues.apache.org/jira/browse/FLINK-26411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-26411.
--
Resolution: Duplicate
> Hive dialect supports CLUSTERED BY/ SORTED BY table
> ---
[
https://issues.apache.org/jira/browse/FLINK-26411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26411:
-
Fix Version/s: 1.16.0
> Hive dialect supports CLUSTERED BY/ SORTED BY table
> -
[
https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-22827.
--
Resolution: Duplicate
> Hive dialect supports CLUSTERED BY clause of CREATE TABLE DDL
> --
[
https://issues.apache.org/jira/browse/FLINK-26474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26474:
-
Priority: Critical (was: Major)
> Fail to call hive udf when secondary parameter required constant but
[
https://issues.apache.org/jira/browse/FLINK-27175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27175:
-
Fix Version/s: 1.16.0
> Fail to call Hive UDAF when the UDAF is with only one parameter with array
> ty
[
https://issues.apache.org/jira/browse/FLINK-27175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27175:
-
Priority: Critical (was: Major)
> Fail to call Hive UDAF when the UDAF is with only one parameter with
[
https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26505:
-
Priority: Critical (was: Major)
> Fix IndexOutOfBoundsException for non equality condition exists in l
[
https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579551#comment-17579551
]
luoyuxia commented on FLINK-28965:
--
[~tartarus] Could you please have a look?
> Should
[
https://issues.apache.org/jira/browse/FLINK-28965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28965:
-
Description:
Can be reproduced by the following code in HiveDialectTest:
{code:java}
tableEnv.execute
luoyuxia created FLINK-28965:
Summary: Should create empty partition when it's for dynamic
partition
Key: FLINK-28965
URL: https://issues.apache.org/jira/browse/FLINK-28965
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Summary: Fix fail to open HiveCatalog when it's for hive3 (was: Fix fail
to open HiveCatalog in hive3)
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Summary: Fix fail to open HiveCatalog in hive3 (was: Fix fail to open
HiveCatalog when it's for hive3)
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Fix Version/s: 1.16.0
> Fix exception for casting timestam to decimal in Hive dialect
> ---
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Component/s: Connectors / Hive
> Fix exception for casting timestam to decimal in Hive dialect
> --
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Affects Version/s: 1.16.0
> Fix exception for casting timestam to decimal in Hive dialect
> ---
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Priority: Critical (was: Major)
> Fix exception for casting timestam to decimal in Hive dialect
>
[
https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579501#comment-17579501
]
luoyuxia commented on FLINK-28956:
--
To fix it, we need a more strict check.
> FIx non-
[
https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28956:
-
Description:
In [FLINK-27387|https://issues.apache.org/jira/browse/FLINK-27387], we support
multi inser
luoyuxia created FLINK-28956:
Summary: FIx non-multi insert statement fall into multi insert
logic in Hive dialect
Key: FLINK-28956
URL: https://issues.apache.org/jira/browse/FLINK-28956
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28952:
-
Fix Version/s: 1.16.0
> Release Testing: Veify Hive dialect
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-28952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28952:
-
Component/s: Connectors / Hive
Table SQL / API
> Release Testing: Veify Hive dialect
>
luoyuxia created FLINK-28952:
Summary: Release Testing: Veify Hive dialect
Key: FLINK-28952
URL: https://issues.apache.org/jira/browse/FLINK-28952
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578245#comment-17578245
]
luoyuxia edited comment on FLINK-28883 at 8/11/22 4:28 AM:
---
I'
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578245#comment-17578245
]
luoyuxia commented on FLINK-28883:
--
I'll try to fix it.
> Fix HiveTableSink failed to
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578226#comment-17578226
]
luoyuxia edited comment on FLINK-28913 at 8/11/22 3:32 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26771:
-
Priority: Critical (was: Major)
> Fix incomparable exception between boolean type and numeric type in H
[
https://issues.apache.org/jira/browse/FLINK-28883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28883:
-
Fix Version/s: 1.16.0
> 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
]
luoyuxia updated FLINK-28883:
-
Priority: Critical (was: Major)
> Fix HiveTableSink failed to report metrics to hive metastore
> --
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578226#comment-17578226
]
luoyuxia commented on FLINK-28913:
--
The workaround way is to swap `opt/flink-table-plan
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Priority: Critical (was: Major)
> 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
]
luoyuxia updated FLINK-28913:
-
Fix Version/s: 1.16.0
> 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
]
luoyuxia updated FLINK-28913:
-
Description:
When use HiveCatalog for hive3, it will throw such exception:
{code:java}
java.lang.NoClass
luoyuxia created FLINK-28913:
Summary: Fix fail to open HiveCatalog when it's for hive3
Key: FLINK-28913
URL: https://issues.apache.org/jira/browse/FLINK-28913
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-28913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28913:
-
Component/s: Connectors / Hive
> Fix fail to open HiveCatalog when it's for hive3
>
[
https://issues.apache.org/jira/browse/FLINK-28905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28905:
-
Summary: Fix HiveCatalog can't get statistic for Hive timestamp partition
column (was: Fix HiveCatalog
[
https://issues.apache.org/jira/browse/FLINK-28905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28905:
-
Description:
Hive's timestamp type will be mapped to Flink's `TIMESTAMP_WITHOUT_TIME_ZONE`,
but
in met
luoyuxia created FLINK-28905:
Summary: Fix HiveCatalog use wrong Flink type when get statistic
for Hive timestamp partition column
Key: FLINK-28905
URL: https://issues.apache.org/jira/browse/FLINK-28905
P
[
https://issues.apache.org/jira/browse/FLINK-28767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577765#comment-17577765
]
luoyuxia commented on FLINK-28767:
--
[https://dev.azure.com/leonardBang/Azure_CI/_build/
[
https://issues.apache.org/jira/browse/FLINK-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27338:
-
Summary: Improve spliting file for Hive table with orc format (was:
Improve spliting file for Hive sour
[
https://issues.apache.org/jira/browse/FLINK-27338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27338:
-
Description:
Currently, for hive source, it'll use the hdfs block size configured with key
dfs.block.si
[
https://issues.apache.org/jira/browse/FLINK-27597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-27597.
--
Resolution: Fixed
> Support get column statistic for Hive partition table
> --
[
https://issues.apache.org/jira/browse/FLINK-28306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-28306.
--
Resolution: Fixed
> Support get table statistic for Hive partition table
> ---
[
https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27374:
-
Summary: Fix using wrong Flink type for Hive's void type (was: Convert
Hive's void type to Flink's str
[
https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27014:
-
Summary: Fix exception when select null literal in subquery for Hive
dialect (was: Fix select null lit
[
https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27014:
-
Summary: Fix select null literal in subquery for Hive dialect (was: Fix
select null literal in subque
[
https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27014:
-
Summary: Fix select null literal in subquery Hive dialect (was: Hive
dialect support select null liter
[
https://issues.apache.org/jira/browse/FLINK-27718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27718:
-
Summary: Fix fail to count mutiple fields excpetion in Hive dialect (was:
Hive dialect supports to coun
[
https://issues.apache.org/jira/browse/FLINK-27375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27375:
-
Summary: Fix exception when no order keys exists in over() in Hive Dialect
(was: Hive dialect support "
[
https://issues.apache.org/jira/browse/FLINK-27017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27017:
-
Summary: Fix divide by zero exception in Hive dialect (was: Hive dialect
supports divide by zero)
> F
[
https://issues.apache.org/jira/browse/FLINK-27015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27015:
-
Summary: Fix exception for casting timestam to decimal in Hive dialect
(was: Hive dialect supports cas
[
https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26771:
-
Summary: Fix ecompare between boolean type with numeric type in Hive
dialect (was: Hive dialect support
[
https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26771:
-
Summary: Fix incomparable exception between boolean type and numeric type
in Hive dialect (was: Fix eco
[
https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26505:
-
Summary: Fix IndexOutOfBoundsException for non equality condition exists
in left semi join in Hive dial
[
https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26505:
-
Summary: Fix non equality condition for left semi join in Hive dialect
(was: Support non equality condi
[
https://issues.apache.org/jira/browse/FLINK-28789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575120#comment-17575120
]
luoyuxia commented on FLINK-28789:
--
[https://dev.azure.com/apache-flink/apache-flink/_b
[
https://issues.apache.org/jira/browse/FLINK-28797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17575067#comment-17575067
]
luoyuxia commented on FLINK-28797:
--
Can move on after https://issues.apache.org/jira/br
luoyuxia created FLINK-28797:
Summary: Hive source should also support verctor reading for
complex data type when with parquet format
Key: FLINK-28797
URL: https://issues.apache.org/jira/browse/FLINK-28797
luoyuxia created FLINK-28795:
Summary: Unstable test for
HiveDialectQueryITCase#testInsertDirectory
Key: FLINK-28795
URL: https://issues.apache.org/jira/browse/FLINK-28795
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-27217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17574525#comment-17574525
]
luoyuxia commented on FLINK-27217:
--
When the filter expressions contains some expressio
luoyuxia created FLINK-28774:
Summary: Allow user to configure whether to enable sort or not
when it's for dynamic parition writing for HiveSource
Key: FLINK-28774
URL: https://issues.apache.org/jira/browse/FLINK-2877
[
https://issues.apache.org/jira/browse/FLINK-16568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-16568.
--
Resolution: Resolved
> Cannot call Hive UDAF that requires constant arguments
> --
luoyuxia created FLINK-28773:
Summary: Allow to write a success file after finish writing for
Hive sink in batch mode
Key: FLINK-28773
URL: https://issues.apache.org/jira/browse/FLINK-28773
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28772:
-
Summary: Hive dialect supports add jar (was: Port AddJarOperation to Hive
dialect)
> Hive dialect sup
luoyuxia created FLINK-28772:
Summary: Port AddJarOperation to Hive dialect
Key: FLINK-28772
URL: https://issues.apache.org/jira/browse/FLINK-28772
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17574026#comment-17574026
]
luoyuxia commented on FLINK-28741:
--
[~jingzhang] Just another quick question. Should th
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572881#comment-17572881
]
luoyuxia commented on FLINK-28741:
--
Thanks for reporting. Yes, you're right. It'll tre
[
https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28741:
-
Parent: FLINK-26360
Issue Type: Sub-task (was: Bug)
> Unexpected result if insert 'false' to bo
[
https://issues.apache.org/jira/browse/FLINK-28729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572469#comment-17572469
]
luoyuxia commented on FLINK-28729:
--
[~jeff-zou] There's a fix for it in Hive community
[
https://issues.apache.org/jira/browse/FLINK-28430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-28430.
--
Resolution: Duplicate
Will be fixed in https://issues.apache.org/jira/browse/FLINK-28451
> HiveFuncti
701 - 800 of 1100 matches
Mail list logo
