[
https://issues.apache.org/jira/browse/FLINK-13181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882608#comment-16882608
]
hehuiyuan commented on FLINK-13181:
---
Using `Builder` is more convenient.
> Add a constructor
[
https://issues.apache.org/jira/browse/FLINK-13181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882608#comment-16882608
]
hehuiyuan edited comment on FLINK-13181 at 7/11/19 2:46 AM:
Good idea. Using
hehuiyuan created FLINK-13756:
-
Summary: Modify Code Annotations for findAndCreateTableSource in
TableFactoryUtil
Key: FLINK-13756
URL: https://issues.apache.org/jira/browse/FLINK-13756
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-13757:
--
Description:
hehuiyuan created FLINK-13757:
-
Summary: Document error for `logical functions`
Key: FLINK-13757
URL: https://issues.apache.org/jira/browse/FLINK-13757
Project: Flink
Issue Type: Wish
hehuiyuan created FLINK-13810:
-
Summary: Update `Elasticsearch Connector` label
Key: FLINK-13810
URL: https://issues.apache.org/jira/browse/FLINK-13810
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-13810:
--
Description:
For document:
[
https://issues.apache.org/jira/browse/FLINK-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-13810:
--
Attachment: image-2019-08-21-16-54-51-666.png
> Update `Elasticsearch Connector` label
>
[
https://issues.apache.org/jira/browse/FLINK-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-13810:
--
Description:
For document:
[
https://issues.apache.org/jira/browse/FLINK-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-13810:
--
Description:
For document:
[
https://issues.apache.org/jira/browse/FLINK-13181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881773#comment-16881773
]
hehuiyuan commented on FLINK-13181:
---
@[~jark] Thanks, i got it.
> Add a constructor function to
hehuiyuan created FLINK-13183:
-
Summary: Add PrintTableSink for Table & SQL APi
Key: FLINK-13183
URL: https://issues.apache.org/jira/browse/FLINK-13183
Project: Flink
Issue Type: Wish
hehuiyuan created FLINK-13180:
-
Summary: Add a constructor function to CsvTableSink
Key: FLINK-13180
URL: https://issues.apache.org/jira/browse/FLINK-13180
Project: Flink
Issue Type: Improvement
hehuiyuan created FLINK-13181:
-
Summary: Add a constructor function to CsvTableSink
Key: FLINK-13181
URL: https://issues.apache.org/jira/browse/FLINK-13181
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963598#comment-16963598
]
hehuiyuan commented on FLINK-14550:
---
Hi，[~jark] ，
# Flink version 1.8.1
# use
[
https://issues.apache.org/jira/browse/FLINK-14732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972979#comment-16972979
]
hehuiyuan commented on FLINK-14732:
---
Hi , you can compile by yourself for this
[
https://issues.apache.org/jira/browse/FLINK-14732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972979#comment-16972979
]
hehuiyuan edited comment on FLINK-14732 at 11/13/19 3:21 AM:
-
Hi , you can
[
https://issues.apache.org/jira/browse/FLINK-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-14639:
--
Environment: (was: Hi , i think it should be
`MetricGroup{{#addGroup(String key, String
hehuiyuan created FLINK-14639:
-
Summary: Fix the document of Metircs that has an error for `User
Scope`
Key: FLINK-14639
URL: https://issues.apache.org/jira/browse/FLINK-14639
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-14639:
--
Description:
Hi , i think it should be `MetricGroup\{{#addGroup(String key, String value)}}`
[
https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15146:
--
Description:
Hi , the value of cleanupSize is grater than or equal 0. Whether that the value
is
hehuiyuan created FLINK-15146:
-
Summary: The value of `cleanupSize` should be grater than 0 for
`IncrementalCleanupStrategy`
Key: FLINK-15146
URL: https://issues.apache.org/jira/browse/FLINK-15146
hehuiyuan created FLINK-15158:
-
Summary: Why convert integer to bigdecimal for formart-json when
kafka is used
Key: FLINK-15158
URL: https://issues.apache.org/jira/browse/FLINK-15158
Project: Flink
hehuiyuan created FLINK-15159:
-
Summary: the string of json is mapped to VARCHAR or STRING?
Key: FLINK-15159
URL: https://issues.apache.org/jira/browse/FLINK-15159
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-15159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996223#comment-16996223
]
hehuiyuan commented on FLINK-15159:
---
Hi [~jark] , i think the string type in the json schema is mapped
[
https://issues.apache.org/jira/browse/FLINK-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996940#comment-16996940
]
hehuiyuan edited comment on FLINK-13810 at 12/16/19 3:24 AM:
-
Hi ,[~tison] ,
[
https://issues.apache.org/jira/browse/FLINK-13810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996940#comment-16996940
]
hehuiyuan commented on FLINK-13810:
---
Hi ,[~tison] , this issue may be wrong. The description of
[
https://issues.apache.org/jira/browse/FLINK-15158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15158:
--
Attachment: image-2019-12-16-10-47-23-565.png
> Why convert integer to bigdecimal for formart-json
[
https://issues.apache.org/jira/browse/FLINK-15158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15158:
--
Attachment: image-2019-12-16-10-47-43-437.png
> Why convert integer to bigdecimal for formart-json
[
https://issues.apache.org/jira/browse/FLINK-15158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15158:
--
Description:
For example ,
I have a table `table1` :
root
|– name: STRING|
|– age: INT|
|– sex:
[
https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-14550:
--
Summary: Can't use proctime attribute when register datastream to flink
table which uses some
[
https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-14550:
--
Description:
*_The data schame :_*
final String schemaString =
"
[
https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-14550:
--
Description:
*_The data schame :_*
final String schemaString =
"
hehuiyuan created FLINK-14550:
-
Summary: can't use proctime attribute when register datastream for
table and exist nested fields
Key: FLINK-14550
URL: https://issues.apache.org/jira/browse/FLINK-14550
[
https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15146:
--
Summary: Fix check that incremental cleanup size must be greater than zero
(was: Fix the value of
[
https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15146:
--
Summary: Fix the value of that should be strictly greater than zero (was:
The value of `cleanupSize`
[
https://issues.apache.org/jira/browse/FLINK-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999722#comment-16999722
]
hehuiyuan edited comment on FLINK-15321 at 12/19/19 3:58 AM:
-
You can try
[
https://issues.apache.org/jira/browse/FLINK-15321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999722#comment-16999722
]
hehuiyuan commented on FLINK-15321:
---
You can try
{{CONCAT_WS(string1, string2, string3,...)}}
> The
hehuiyuan created FLINK-15326:
-
Summary: Add document description for DECIMAL(38, 18) when the
sink table uses json schema
Key: FLINK-15326
URL: https://issues.apache.org/jira/browse/FLINK-15326
[
https://issues.apache.org/jira/browse/FLINK-15326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15326:
--
Description:
Env :
Flink 1.9.1
table-planner-blink
Question:
If i have a
[
https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992218#comment-16992218
]
hehuiyuan commented on FLINK-15146:
---
Hi [~azagrebin] , I am pleasure to do this.
> The value of
hehuiyuan created FLINK-16463:
-
Summary: CodeGenUtils generates code that has two semicolons for
GroupingWindowAggsHandler in blink
Key: FLINK-16463
URL: https://issues.apache.org/jira/browse/FLINK-16463
hehuiyuan created FLINK-16465:
-
Summary: Add more detailed instructions for TableSink
Key: FLINK-16465
URL: https://issues.apache.org/jira/browse/FLINK-16465
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Description:
!image-2020-01-15-13-58-00-535.png|width=732,height=570!
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Summary: Support key-value messages for KafkaTableSink for flink SQL
\Table (was: Support
hehuiyuan created FLINK-15596:
-
Summary: Support key-value messages for kafka producer for flink
SQL \Tbale
Key: FLINK-15596
URL: https://issues.apache.org/jira/browse/FLINK-15596
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Attachment: image-2020-01-15-13-58-00-535.png
> Support key-value messages for KafkaTableSink for
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Attachment: image-2020-01-15-13-58-39-073.png
> Support key-value messages for KafkaTableSink for
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Description:
!image-2020-01-15-13-58-00-535.png|width=732,height=570!
[
https://issues.apache.org/jira/browse/FLINK-15596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15596:
--
Attachment: image-2020-01-15-13-59-05-399.png
> Support key-value messages for KafkaTableSink for
hehuiyuan created FLINK-15610:
-
Summary: How to achieve the udf that the number of return column
is uncertain
Key: FLINK-15610
URL: https://issues.apache.org/jira/browse/FLINK-15610
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15610:
--
Description:
For
[
https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016693#comment-17016693
]
hehuiyuan commented on FLINK-15610:
---
[~jark]
> How to achieve the udf that the number of return
[
https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016716#comment-17016716
]
hehuiyuan commented on FLINK-15610:
---
[~lzljs3620320] thx.
> How to achieve the udf that the number of
[
https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017677#comment-17017677
]
hehuiyuan commented on FLINK-15610:
---
Thx
> How to achieve the udf that the number of return column is
[
https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016808#comment-17016808
]
hehuiyuan commented on FLINK-15610:
---
I have achieved by constructor， but it is't convenient.
If the
[
https://issues.apache.org/jira/browse/FLINK-15610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016808#comment-17016808
]
hehuiyuan edited comment on FLINK-15610 at 1/16/20 11:00 AM:
-
hehuiyuan created FLINK-15404:
-
Summary: How to insert hive table for different catalog
Key: FLINK-15404
URL: https://issues.apache.org/jira/browse/FLINK-15404
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003606#comment-17003606
]
hehuiyuan commented on FLINK-15404:
---
try
{code:java}
insert into myhive.default.hive_table select
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003617#comment-17003617
]
hehuiyuan commented on FLINK-15404:
---
Using the {{HiveCatalog}} and Flink’s connector to Hive, Flink
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003604#comment-17003604
]
hehuiyuan commented on FLINK-15404:
---
Hi [~ykt836] , hive catalog only be used in batch table env?
>
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003873#comment-17003873
]
hehuiyuan commented on FLINK-15404:
---
Hi [~lzljs3620320] , that is not ok. My usage may be wrong.
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003899#comment-17003899
]
hehuiyuan commented on FLINK-15404:
---
Hi [~lzljs3620320] , thanks , I ingore to invoke the
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003994#comment-17003994
]
hehuiyuan commented on FLINK-15404:
---
{code:java}
org.apache.flink.table.api.TableException: Stream
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003994#comment-17003994
]
hehuiyuan edited comment on FLINK-15404 at 12/27/19 8:16 AM:
-
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15404:
--
Summary: How to insert hive table in streaming mode and blink planner
(was: How to insert hive table
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15404:
--
Description:
I have a hive catalog :
{code:java}
catalog name : myhive
database : default
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-15404:
--
Description:
I have a hive catalog :
{code:java}
catalog name : myhive
database : default
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003994#comment-17003994
]
hehuiyuan edited comment on FLINK-15404 at 12/27/19 8:26 AM:
-
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-15404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004043#comment-17004043
]
hehuiyuan commented on FLINK-15404:
---
{code:java}
// execute SQL
tableEnv.sqlUpdate("insert into
[
https://issues.apache.org/jira/browse/FLINK-16463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053871#comment-17053871
]
hehuiyuan commented on FLINK-16463:
---
Hi [~ykt836] , I'd love to fix it
> CodeGenUtils generates code
hehuiyuan created FLINK-16584:
-
Summary: Whether to support the long type field in table planner
when the source is kafka and event time field's type is long
Key: FLINK-16584
URL:
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084014#comment-17084014
]
hehuiyuan commented on FLINK-17117:
---
Hi [~ykt836] , [~jark] , I want to fix it .
> There are an
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092504#comment-17092504
]
hehuiyuan edited comment on FLINK-17117 at 4/26/20, 5:40 AM:
-
This method is
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092504#comment-17092504
]
hehuiyuan edited comment on FLINK-17117 at 4/26/20, 5:33 AM:
-
This method is
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092504#comment-17092504
]
hehuiyuan commented on FLINK-17117:
---
This method is also called elsewhere.
For the following code
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092504#comment-17092504
]
hehuiyuan edited comment on FLINK-17117 at 4/26/20, 5:39 AM:
-
This method is
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092504#comment-17092504
]
hehuiyuan edited comment on FLINK-17117 at 4/26/20, 5:32 AM:
-
This method is
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095266#comment-17095266
]
hehuiyuan commented on FLINK-17117:
---
Hi [~ykt836] , I have fixed it for [PR
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095266#comment-17095266
]
hehuiyuan edited comment on FLINK-17117 at 4/29/20, 9:12 AM:
-
Hi [~ykt836] ,
hehuiyuan created FLINK-17117:
-
Summary: There are an useless cast operation for sql on blink
when generate code
Key: FLINK-17117
URL: https://issues.apache.org/jira/browse/FLINK-17117
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110117#comment-17110117
]
hehuiyuan commented on FLINK-16704:
---
[~jark] , understand.
> Document has some error for connect.md
hehuiyuan created FLINK-16704:
-
Summary: Document has some error for connect.md
Key: FLINK-16704
URL: https://issues.apache.org/jira/browse/FLINK-16704
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100712#comment-17100712
]
hehuiyuan commented on FLINK-17117:
---
[~ykt836] , :D
> There are an useless cast operation for sql on
hehuiyuan created FLINK-19686:
-
Summary: Cast question for data | time
Key: FLINK-19686
URL: https://issues.apache.org/jira/browse/FLINK-19686
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-19686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-19686:
--
Description:
ERROR:
{code:java}
java.lang.ClassCastException: java.time.LocalDate cannot be cast to
[
https://issues.apache.org/jira/browse/FLINK-19686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-19686:
--
Description:
ERROR:
{code:java}
java.lang.ClassCastException: java.time.LocalDate cannot be cast to
[
https://issues.apache.org/jira/browse/FLINK-19686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-19686:
--
Summary: Cast question for data | time |timestamp type (was: Cast
question for data | time )
>
[
https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179334#comment-17179334
]
hehuiyuan commented on FLINK-16584:
---
Hi [~jark] , what is the name of this function?
> Whether to
[
https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179336#comment-17179336
]
hehuiyuan commented on FLINK-16584:
---
Hi [~jark] , what is the name of this function?
> Whether to
[
https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-16584:
--
Comment: was deleted
(was: Hi [~jark] , what is the name of this function?)
> Whether to support
[
https://issues.apache.org/jira/browse/FLINK-18145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157929#comment-17157929
]
hehuiyuan commented on FLINK-18145:
---
Hi [~godfreyhe] , thx.
> Segment optimization does not work in
hehuiyuan created FLINK-18339:
-
Summary: ValidationException exception that field typeinformation
in TableSchema and in TableSource return type for blink
Key: FLINK-18339
URL:
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-18339:
--
Component/s: (was: Formats (JSON, Avro, Parquet, ORC, SequenceFile))
> ValidationException
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138175#comment-17138175
]
hehuiyuan commented on FLINK-18339:
---
[~jark] , It is not useful, OBJECT_ARRAY is mapped to
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-18339:
--
Attachment: image-2020-06-17-15-24-24-093.png
> ValidationException exception that field
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-18339:
--
Attachment: image-2020-06-17-15-24-16-290.png
> ValidationException exception that field
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138175#comment-17138175
]
hehuiyuan edited comment on FLINK-18339 at 6/17/20, 7:26 AM:
-
[~jark] , It
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-18339:
--
Description:
The type of `datatime` field is OBJECT_ARRAY.
Exception:
{code:java}
Exception
[
https://issues.apache.org/jira/browse/FLINK-18339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138281#comment-17138281
]
hehuiyuan commented on FLINK-18339:
---
Looks similar problem.
Opposite position:
FLINK-16622
1 - 100 of 317 matches
Mail list logo
