Describe the bug
In LoadingTaskPlanner#Plan(): OlapTableSink olapTableSink = new OlapTableSink(table, tupleDesc, partitionIds); If the table does not has any partition, Preconditions.checkState will throw IllegalStateException, but the funtion only cath UserException, that will cause load job status can not be updated。
To Reproduce
Steps to reproduce the behavior:
- create a table without partition:
CREATE TABLE table1
(
event_day DATE,
siteid INT DEFAULT '10',
citycode SMALLINT,
username VARCHAR(32) DEFAULT '',
pv BIGINT SUM DEFAULT '0'
)
AGGREGATE KEY(event_day, siteid, citycode, username)
PARTITION BY RANGE(event_day)()
DISTRIBUTED BY HASH(siteid) BUCKETS 10
PROPERTIES("replication_num" = "1"); - broker load job:
LOAD LABEL db1.label1
(
DATA INFILE("hdfs://abc.com:8888/user/palo/test/ml/file1")
INTO TABLE tbl1
COLUMNS TERMINATED BY ","
(event_date,siteid,citycode,username,pv)
SET
(
date=event_date,
id=siteid,
code=citycode,
name=username
count=pv
),
)
WITH BROKER 'broker'
(
"username"="user",
"password"="pass"
)
PROPERTIES
(
"timeout" = "3600"
); - error log:
- job status not be updated
Expected behavior
when IllegalStateException happed, job status should be updated to "CANCELLED"
Screenshots
If applicable, add screenshots to help explain your problem.
Desktop (please complete the following information):
- OS: [e.g. iOS]
- Browser [e.g. chrome, safari]
- Version [e.g. 22]
Smartphone (please complete the following information):
- Device: [e.g. iPhone6]
- OS: [e.g. iOS8.1]
- Browser [e.g. stock browser, safari]
- Version [e.g. 22]
Additional context
Add any other context about the problem here.
暂无答案!
目前还没有任何答案,快来回答吧!