This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit e84812e504d44a3224eacb689646e4dc3494e280 Author: 李平 <[email protected]> AuthorDate: Tue Aug 6 14:36:04 2019 +0800 修改stop --- src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java | 3 --- src/main/java/org/apache/connect/mongo/replicator/MongoReplicator.java | 3 --- 2 files changed, 6 deletions(-) diff --git a/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java b/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java index e116cfb..40dfdd0 100644 --- a/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java +++ b/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java @@ -88,11 +88,8 @@ public class MongoSourceTask extends SourceTask { mongoReplicator.start(); }catch (Throwable throwable) { logger.info("task start error", throwable); - }finally { stop(); } - - } @Override diff --git a/src/main/java/org/apache/connect/mongo/replicator/MongoReplicator.java b/src/main/java/org/apache/connect/mongo/replicator/MongoReplicator.java index 326ba03..a14ceee 100644 --- a/src/main/java/org/apache/connect/mongo/replicator/MongoReplicator.java +++ b/src/main/java/org/apache/connect/mongo/replicator/MongoReplicator.java @@ -56,17 +56,14 @@ public class MongoReplicator { this.clientSettings = MongoClientSettings.builder().applicationName(APPLICATION_NAME) .applyConnectionString(connectionString) - .retryWrites(true) .build(); this.mongoClient = MongoClients.create(clientSettings); this.isReplicaMongo(); executorService.submit(new ReplicatorTask(this, mongoClient, mongoReplicatorConfig, filter)); }catch (Exception e) { logger.info("start replicator error", e); - }finally { shutdown(); } - }
