[
https://issues.apache.org/jira/browse/FLINK-22189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-22189:
-------------------------------
Priority: Major (was: Blocker)
> Flink SQL Client Hudi batch write crashes JobManager
> ----------------------------------------------------
>
> Key: FLINK-22189
> URL: https://issues.apache.org/jira/browse/FLINK-22189
> Project: Flink
> Issue Type: Bug
> Components: Client / Job Submission
> Affects Versions: 1.11.3
> Reporter: Phil Chen
> Priority: Major
> Attachments:
> flink-pchen-standalonesession-0-Phils-MBP.fios-router.home.log
>
>
> Flink SQL> create table t2(
> > uuid varchar(20),
> > name varchar(10),
> > age int,
> > ts timestamp(3),
> > `partition` varchar(20)
> > )
> > PARTITIONED BY (`partition`)
> > with (
> > 'connector' = 'hudi',
> > 'path' = 'file:///tmp/hudi/t2'
> > );
> [INFO] Table has been created.
> Flink SQL> insert into t2 values
> > ('id1','Danny',23,TIMESTAMP '1970-01-01 00:00:01','par1'),
> > ('id2','Stephen',33,TIMESTAMP '1970-01-01 00:00:02','par1'),
> > ('id3','Julian',53,TIMESTAMP '1970-01-01 00:00:03','par2'),
> > ('id4','Fabian',31,TIMESTAMP '1970-01-01 00:00:04','par2'),
> > ('id5','Sophia',18,TIMESTAMP '1970-01-01 00:00:05','par3'),
> > ('id6','Emma',20,TIMESTAMP '1970-01-01 00:00:06','par3'),
> > ('id7','Bob',44,TIMESTAMP '1970-01-01 00:00:07','par4'),
> > ('id8','Han',56,TIMESTAMP '1970-01-01 00:00:08','par4');
> [INFO] Submitting SQL update statement to the cluster...
> [INFO] Table update statement has been successfully submitted to the cluster:
> Job ID: f5828dfb80550b82f9a2f15afe2439a0
>
> Check flink dashboard at [http://localhost:8081|http://localhost:8081/]
> JM crashed.
>
> Hadoop version: 3.2.2
> Apache Hudi version:
> lib/hudi-flink-bundle_2.11-0.8.0.jar
> See attached JobManager log.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
