[jira] [Created] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

["Phil Chen (Jira)" <ji...@apache.org>]

Phil Chen created FLINK-22189:
---------------------------------

             Summary: 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
         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)