search

apache / doris-flink-connector

Flink Connector for Apache Doris
https://doris.apache.org/
Apache License 2.0
292 stars 201 forks source link

(Fix)[case] Fix unstable cases #415

Closed JNSimba closed 6 days ago

JNSimba commented 6 days ago

Proposed changes

Issue Number: close #xxx

Problem Summary:

[INFO] Running org.apache.doris.flink.sink.copy.TestDorisCopyWriter
02:12:37,489 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - restore checkpointId 0
02:12:37,490 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - labelPrefix doris
02:12:37,492 INFO  org.apache.doris.flink.sink.copy.BatchStageLoad              [pool-2-copy-executor-1]  - StageLoadAsyncExecutor start
02:12:37,493 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - checkpoint arrived, upload buffer to storage
02:12:37,494 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - checkpoint flush triggered.
02:12:37,497 INFO  org.apache.doris.flink.sink.copy.BatchStageLoad              [pool-1-copy-executor-1]  - StageLoadAsyncExecutor start
02:12:37,501 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - restore checkpointId 0
02:12:37,501 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - labelPrefix doris
02:12:37,503 INFO  org.apache.doris.flink.sink.copy.BatchStageLoad              [pool-3-copy-executor-1]  - StageLoadAsyncExecutor start
02:12:37,503 INFO  org.apache.doris.flink.sink.copy.DorisCopyWriter             [main]  - DorisBatchWriter Close
02:12:37,503 INFO  org.apache.doris.flink.sink.copy.BatchStageLoad              [pool-4-copy-executor-1]  - StageLoadAsyncExecutor start
Error:  Tests run: 2, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.018 s <<< FAILURE! - in org.apache.doris.flink.sink.copy.TestDorisCopyWriter
Error:  testPrepareCommit  Time elapsed: 0.015 s  <<< ERROR!
java.lang.RuntimeException: load thread already exit, write was interrupted
    at org.apache.doris.flink.sink.copy.TestDorisCopyWriter.testPrepareCommit(TestDorisCopyWriter.java:93)

02:12:37,504 INFO  org.apache.doris.flink.sink.copy.BatchStageLoad              [pool-4-copy-executor-1]  - StageLoadAsyncExecutor stop
[INFO] Running org.apache.doris.flink.sink.copy.TestCopyCommittableSerializer

Checklist(Required)

  1. Does it affect the original behavior: (Yes/No/I Don't know)
  2. Has unit tests been added: (Yes/No/No Need)
  3. Has document been added or modified: (Yes/No/No Need)
  4. Does it need to update dependencies: (Yes/No)
  5. Are there any changes that cannot be rolled back: (Yes/No)

Further comments

If this is a relatively large or complex change, kick off the discussion at dev@doris.apache.org by explaining why you chose the solution you did and what alternatives you considered, etc...