Skip to content

Commit eb9226d

Browse files
author
陈海晴(jennyhq.chen)
committed
[ISSUE-138][Feature]: Support Unit5 Test For Clickhouse Connector
1 parent 05ede51 commit eb9226d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-clickhouse-e2e-test/src/test/java/org/apache/flink/connector/clickhouse/FlinkContainerTestEnviroment.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ public void waitUntilJobRunning(Duration timeout) {
203203
if (jobStatusMessages != null && !jobStatusMessages.isEmpty()) {
204204
JobStatusMessage message = jobStatusMessages.iterator().next();
205205
JobStatus jobStatus = message.getJobState();
206-
if (jobStatus.isTerminalState()) {
206+
if (jobStatus.isTerminalState() && message.getJobState() == JobStatus.FAILED) {
207207
throw new ValidationException(
208208
String.format(
209209
"Job has been terminated! JobName: %s, JobID: %s, Status: %s",

0 commit comments

Comments
 (0)