|
|
@@ -16,6 +16,7 @@ import org.apache.commons.collections4.MapUtils;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.Iterator;
|
|
|
import java.util.Map;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
@Slf4j
|
|
|
public class TableStoreService {
|
|
|
@@ -52,6 +53,10 @@ public class TableStoreService {
|
|
|
if (batch.size() >= 200) {
|
|
|
this.batchWrite(batch);
|
|
|
batch.clear();
|
|
|
+ try {
|
|
|
+ TimeUnit.SECONDS.sleep(2);
|
|
|
+ } catch (Exception ignore) {
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -62,7 +67,6 @@ public class TableStoreService {
|
|
|
}
|
|
|
|
|
|
private void batchWrite(Map<String, String> data) {
|
|
|
- log.info("batchWrite data.size: {}", data.size());
|
|
|
try {
|
|
|
|
|
|
BatchWriteRowRequest request = new BatchWriteRowRequest();
|