You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:22:26 UTC
[rocketmq-connect] 03/13: 修改stop
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: 李平 <lp...@alibaba-inc.com>
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();
}
-
}