Ignore error if setting gp_max_csv_line_length failed

wangzw · wangzw · commit 66a8a85f4d7d · 2020-03-02T14:31:38.000+08:00
diff --git a/gpdbwriter/src/main/java/cn/hashdata/datax/plugin/writer/gpdbwriter/CopyWorker.java b/gpdbwriter/src/main/java/cn/hashdata/datax/plugin/writer/gpdbwriter/CopyWorker.java
@@ -140,6 +140,11 @@ public Long call() throws Exception {
 	private void changeCsvSizelimit(Connection conn) {
 		List<String> sqls = new ArrayList<String>();
 		sqls.add("set gp_max_csv_line_length = " + Integer.toString(MaxCsvSize));
-		WriterUtil.executeSqls(conn, sqls, task.getJdbcUrl(), DataBaseType.PostgreSQL);
+
+		try {
+			WriterUtil.executeSqls(conn, sqls, task.getJdbcUrl(), DataBaseType.PostgreSQL);
+		} catch (Exception e) {
+			LOG.warn("Cannot set gp_max_csv_line_length to " + MaxCsvSize);
+		}
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -140,6 +140,11 @@ public Long call() throws Exception {`
`140`	`140`	`private void changeCsvSizelimit(Connection conn) {`
`141`	`141`	`List<String> sqls = new ArrayList<String>();`
`142`	`142`	`sqls.add("set gp_max_csv_line_length = " + Integer.toString(MaxCsvSize));`
`143`		`- WriterUtil.executeSqls(conn, sqls, task.getJdbcUrl(), DataBaseType.PostgreSQL);`
	`143`	`+`
	`144`	`+ try {`
	`145`	`+ WriterUtil.executeSqls(conn, sqls, task.getJdbcUrl(), DataBaseType.PostgreSQL);`
	`146`	`+ } catch (Exception e) {`
	`147`	`+ LOG.warn("Cannot set gp_max_csv_line_length to " + MaxCsvSize);`
	`148`	`+ }`
`144`	`149`	`}`
`145`	`150`	`}`