申请单数据清洗test

dedaaf8b · data爬虫-冯军凯 · 68b8d343 · dedaaf8b
Commit dedaaf8b authored Sep 05, 2019 by data爬虫-冯军凯
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 2 deletions

ApplyListExportToBizFlowMain.java ...oup/dbc/spark/applyList/ApplyListExportToBizFlowMain.java +1 -2

No files found.
--- a/src/main/java/cn/quantgroup/dbc/spark/applyList/ApplyListExportToBizFlowMain.java
+++ b/src/main/java/cn/quantgroup/dbc/spark/applyList/ApplyListExportToBizFlowMain.java
@@ -112,9 +112,8 @@ public class ApplyListExportToBizFlowMain {
                    applyListRow.setApplySubmitTime(receive_at.compareTo(new Timestamp(parse.getTime())) == 0 ? null : receive_at);
                    applyListRows.add(applyListRow);

-                    System.out.println("list"+JSON.toJSONString(applyListRows));

-                    if (applyListRows.size() != 0 && applyListRows.size() % 1000 == 0) {
+                    if (applyListRows.size() != 0 && applyListRows.size() % 200 == 0) {
                        JdbcExecuters.prepareBatchUpdateExecuteApply(sql, applyListRows);
                        applyListRows.clear();
                    }