Ver código fonte

catch es error

AE86 3 anos atrás
pai
commit
58289d4710

+ 1 - 1
dbsyncer-connector/src/main/java/org/dbsyncer/connector/es/ESConnector.java

@@ -194,7 +194,7 @@ public final class ESConnector extends AbstractConnector implements Connector<ES
             if (restStatus.getStatus() != RestStatus.OK.getStatus()) {
             if (restStatus.getStatus() != RestStatus.OK.getStatus()) {
                 throw new ConnectorException(String.format("error code:%s", restStatus.getStatus()));
                 throw new ConnectorException(String.format("error code:%s", restStatus.getStatus()));
             }
             }
-        } catch (IOException e) {
+        } catch (Exception e) {
             // 记录错误数据
             // 记录错误数据
             result.getFailData().addAll(data);
             result.getFailData().addAll(data);
             result.getFail().set(data.size());
             result.getFail().set(data.size());