[ https://issues.apache.org/jira/browse/FLINK-34651 ]
shizhengchao deleted comment on FLINK-34651:
--
was (Author: tinny):
a
> The HiveTableSink of Flink does not support writing to S3
> -
[
https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828226#comment-17828226
]
shizhengchao commented on FLINK-34651:
--
a
> The HiveTableSink of Flink does not su
[
https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828225#comment-17828225
]
shizhengchao commented on FLINK-34651:
--
[~easonqin] It won't take effect because t
[
https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-34651:
-
Priority: Blocker (was: Major)
> The HiveTableSink of Flink does not support writing to S3
> --
[
https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-34651:
-
Affects Version/s: 1.18.1
1.17.2
1.15.4
[
https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-34651:
-
Affects Version/s: 1.16.3
(was: 1.13.6)
> The HiveTableSink of Flink
shizhengchao created FLINK-34651:
Summary: The HiveTableSink of Flink does not support writing to S3
Key: FLINK-34651
URL: https://issues.apache.org/jira/browse/FLINK-34651
Project: Flink
Iss
[ https://issues.apache.org/jira/browse/FLINK-26541 ]
shizhengchao deleted comment on FLINK-26541:
--
was (Author: tinny):
Why do not use session mode？If application mode supports sql, then I think
there is no different whith session mode.
> SQ
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747428#comment-17747428
]
shizhengchao commented on FLINK-26541:
--
Why do not use session mode？If application
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624836#comment-17624836
]
shizhengchao commented on FLINK-29772:
--
my case is kafka interval join，deadlock occ
[ https://issues.apache.org/jira/browse/FLINK-29772 ]
shizhengchao deleted comment on FLINK-29772:
--
was (Author: tinny):
kafka interval join, deadlock occurs when using rocksdb
> Kafka table source scan blocked
> --
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624834#comment-17624834
]
shizhengchao commented on FLINK-29772:
--
kafka interval join, deadlock occurs when u
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-29772:
-
Description:
{code:java}
//
"Source: TableSourceScan(table=[[ostream, user_mart, dwd_ads_isms_ms
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-29772:
-
Description:
{code:java}
//
"Source: TableSourceScan(table=[[ostream, user_mart, dwd_ads_isms_ms
shizhengchao created FLINK-29772:
Summary: Kafka table source scan blocked
Key: FLINK-29772
URL: https://issues.apache.org/jira/browse/FLINK-29772
Project: Flink
Issue Type: Bug
Com
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514050#comment-17514050
]
shizhengchao edited comment on FLINK-26033 at 3/30/22, 3:06 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514050#comment-17514050
]
shizhengchao edited comment on FLINK-26033 at 3/30/22, 2:24 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17514050#comment-17514050
]
shizhengchao commented on FLINK-26033:
--
master: 2049f849a130e738759001c5a6b9d85834d
[
https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502790#comment-17502790
]
shizhengchao commented on FLINK-26527:
--
[~martijnvisser] Thanks, I've got it, it's
[
https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-26527:
-
Description:
When I try to run sql using flink's classloader, I get the following exception：
{co
[
https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-26527:
-
Description:
When I try to run sql using flink's classloader, I get the following exception：
{co
[
https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-26527:
-
Description:
When I try to run sql using flink's classloader, I get the following exception：
{co
shizhengchao created FLINK-26527:
Summary: ClassCastException in TemporaryClassLoaderContext
Key: FLINK-26527
URL: https://issues.apache.org/jira/browse/FLINK-26527
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17500479#comment-17500479
]
shizhengchao edited comment on FLINK-26033 at 3/3/22, 3:36 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17500479#comment-17500479
]
shizhengchao commented on FLINK-26033:
--
[~MartijnVisser] [~renqs] I got through t
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494327#comment-17494327
]
shizhengchao commented on FLINK-26033:
--
[~renqs] I plan to add a robin class that
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17494323#comment-17494323
]
shizhengchao commented on FLINK-26033:
--
[~renqs] I 'm interested in fix this bug, p
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489345#comment-17489345
]
shizhengchao commented on FLINK-26033:
--
[~MartijnVisser] This is not a problem, but
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489342#comment-17489342
]
shizhengchao commented on FLINK-26033:
--
[~MartijnVisser] I made a mistake,I re-chec
[
https://issues.apache.org/jira/browse/FLINK-26033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489298#comment-17489298
]
shizhengchao commented on FLINK-26033:
--
[~jark] [~libenchao] Can you check this que
shizhengchao created FLINK-26033:
Summary: In KafkaConnector, when 'sink.partitioner' is configured
as 'round-robin', it does not take effect
Key: FLINK-26033
URL: https://issues.apache.org/jira/browse/FLINK-26033
shizhengchao created FLINK-25703:
Summary: In Batch, I think .stagingPath should be created when the
task is running to prevent permission issues caused by inconsistency of hadoop
usernames
Key: FLINK-25703
URL:
shizhengchao created FLINK-25124:
Summary: A deadlock occurs when the jdbc sink uses two consecutive
dimension tables to associate
Key: FLINK-25124
URL: https://issues.apache.org/jira/browse/FLINK-25124
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367969#comment-17367969
]
shizhengchao commented on FLINK-23096:
--
The *clearSessionState* method catches IOE
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367832#comment-17367832
]
shizhengchao edited comment on FLINK-23096 at 6/23/21, 3:29 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367832#comment-17367832
]
shizhengchao edited comment on FLINK-23096 at 6/23/21, 3:10 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367832#comment-17367832
]
shizhengchao edited comment on FLINK-23096 at 6/23/21, 3:09 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367832#comment-17367832
]
shizhengchao edited comment on FLINK-23096 at 6/23/21, 3:07 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367832#comment-17367832
]
shizhengchao commented on FLINK-23096:
--
[~Leonard Xu] [~lirui]
> HiveParser could
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367327#comment-17367327
]
shizhengchao commented on FLINK-23096:
--
This is the location of the code exception
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-23096:
-
Description:
My sql code is as follows：
{code:java}
//代码占位符
CREATE CATALOG myhive WITH (
'ty
[
https://issues.apache.org/jira/browse/FLINK-23096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-23096:
-
Description:
My sql code is as follows：
{code:java}
//代码占位符
CREATE CATALOG myhive WITH (
'ty
shizhengchao created FLINK-23096:
Summary: HiveParser could not attach the sessionstate of hive
Key: FLINK-23096
URL: https://issues.apache.org/jira/browse/FLINK-23096
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268342#comment-17268342
]
shizhengchao commented on FLINK-19446:
--
[~Balro]，i think your patch would be work w
[
https://issues.apache.org/jira/browse/FLINK-20995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267996#comment-17267996
]
shizhengchao commented on FLINK-20995:
--
Did you submit the task through the web int
[
https://issues.apache.org/jira/browse/FLINK-20660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251616#comment-17251616
]
shizhengchao commented on FLINK-20660:
--
[~sujun1020], i think the problem is the lo
[
https://issues.apache.org/jira/browse/FLINK-20660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251616#comment-17251616
]
shizhengchao edited comment on FLINK-20660 at 12/18/20, 9:08 AM:
-
shizhengchao created FLINK-20607:
Summary: a wrong example in udfs page.
Key: FLINK-20607
URL: https://issues.apache.org/jira/browse/FLINK-20607
Project: Flink
Issue Type: Bug
Compo
[
https://issues.apache.org/jira/browse/FLINK-20570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-20570:
-
Description:
in `/docs/stream/operators/process_function.md`, line 252. The `NOTE` css
style i
shizhengchao created FLINK-20570:
Summary: `/docs/stream/operators/process_function.md`, line 252.
The `NOTE tip` css style is different from the others.
Key: FLINK-20570
URL: https://issues.apache.org/jira/brows
shizhengchao created FLINK-20200:
Summary: SQL Hints are not supported in "Create View" syntax
Key: FLINK-20200
URL: https://issues.apache.org/jira/browse/FLINK-20200
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222726#comment-17222726
]
shizhengchao commented on FLINK-19723:
--
Hi [~jark], after testing, this is not a bu
[
https://issues.apache.org/jira/browse/FLINK-19818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19818:
-
Description:
I get an *ArrayIndexOutOfBoundsException* , when my table source have nest
json. a
[
https://issues.apache.org/jira/browse/FLINK-19818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19818:
-
Description:
I get an *ArrayIndexOutOfBoundsException* , when my table source have nest
json. a
[
https://issues.apache.org/jira/browse/FLINK-19818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19818:
-
Summary: ArrayIndexOutOfBoundsException occus when the source table have
nest json (was: Array
[
https://issues.apache.org/jira/browse/FLINK-19818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221118#comment-17221118
]
shizhengchao commented on FLINK-19818:
--
After my test, only `select * from Orders`
shizhengchao created FLINK-19818:
Summary: ArrayIndexOutOfBoundsException occus in 'Interval Joins'
when the source table have nest json
Key: FLINK-19818
URL: https://issues.apache.org/jira/browse/FLINK-19818
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218199#comment-17218199
]
shizhengchao commented on FLINK-19629:
--
Hi, [~jark] Can you help me review the code
[
https://issues.apache.org/jira/browse/FLINK-19735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217535#comment-17217535
]
shizhengchao commented on FLINK-19735:
--
Hi [~jark], my flink version is 1.11.1, I f
[
https://issues.apache.org/jira/browse/FLINK-19735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19735:
-
Description:
TableFunction can't be work in Flink Sql. Here is my code：
{code:sql}
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-19735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19735:
-
Description:
TableFunction can't be work in Flink Sql. Here is my code：
{code:sql}
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-19735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217527#comment-17217527
]
shizhengchao commented on FLINK-19735:
--
Hi, [~jark] , currently, TableFunction only
shizhengchao created FLINK-19735:
Summary: TableFunction can not work in Flink View
Key: FLINK-19735
URL: https://issues.apache.org/jira/browse/FLINK-19735
Project: Flink
Issue Type: Bug
shizhengchao created FLINK-19723:
Summary: The retry mechanism of jdbc connector has the risk of
data duplication
Key: FLINK-19723
URL: https://issues.apache.org/jira/browse/FLINK-19723
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17214576#comment-17214576
]
shizhengchao commented on FLINK-18545:
--
How about adding a tableoptions, for exampl
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19629:
-
Comment: was deleted
(was: Avro union(something, null) spelled incorrectly, should be Avro
uni
[
https://issues.apache.org/jira/browse/FLINK-19638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213777#comment-17213777
]
shizhengchao commented on FLINK-19638:
--
[~dwysakowicz] thank you , i change avro-to
[
https://issues.apache.org/jira/browse/FLINK-19638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213774#comment-17213774
]
shizhengchao commented on FLINK-19638:
--
Flink version is 1.12-SNAPSHOT.
I generate
shizhengchao created FLINK-19638:
Summary: AvroUnionLogicalSerializerTest class compile error
Key: FLINK-19638
URL: https://issues.apache.org/jira/browse/FLINK-19638
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213667#comment-17213667
]
shizhengchao commented on FLINK-19629:
--
This is a duplicate of FLINK-19622
> Avro
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19629:
-
Description:
create table tableA (
name STRING,
hobly MAP,
phone STRING
) with (
'conne
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19629:
-
Component/s: (was: Documentation)
Formats (JSON, Avro, Parquet, ORC, Sequenc
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-19629:
-
Summary: Avro format cause NullPointException，as null value in MAP type's
value type (was: Eng
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213633#comment-17213633
]
shizhengchao edited comment on FLINK-19629 at 10/14/20, 6:00 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213633#comment-17213633
]
shizhengchao commented on FLINK-19629:
--
[~jark] Thank you for reminding me that fou
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213569#comment-17213569
]
shizhengchao commented on FLINK-19629:
--
Avro union(something, null) spelled incorr
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213561#comment-17213561
]
shizhengchao commented on FLINK-19629:
--
[~jark], i can complete this work, could yo
shizhengchao created FLINK-19629:
Summary: English words are spelled incorrectly and an example is
not provided
Key: FLINK-19629
URL: https://issues.apache.org/jira/browse/FLINK-19629
Project: Flink
78 matches
Mail list logo
