Skip to content

Commit ae2aaf9

Browse files
committed
[opt] use copyOnWriteList replace ArrayList because of concurrent modification exception
1 parent c4ab92c commit ae2aaf9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
import java.util.LinkedList;
4848
import java.util.List;
4949
import java.util.Map;
50+
import java.util.concurrent.CopyOnWriteArrayList;
5051
import java.util.concurrent.Executors;
5152
import java.util.concurrent.ScheduledExecutorService;
5253
import java.util.concurrent.ScheduledFuture;
@@ -92,7 +93,7 @@ public class HbaseOutputFormat extends AbstractDtRichOutputFormat<Tuple2> {
9293
private transient ScheduledExecutorService executor;
9394
private transient ScheduledFuture scheduledFuture;
9495

95-
private final List<Row> records = new ArrayList<>();
96+
private final List<Row> records = new CopyOnWriteArrayList<>();
9697

9798

9899
@Override

0 commit comments

Comments
 (0)