From db7c71f86b387e12b7efff22733c282092591e14 Mon Sep 17 00:00:00 2001 From: Bingqin Zhou Date: Mon, 30 Nov 2020 15:27:17 -0800 Subject: [PATCH] DBZ-2768 Throw Debezium Exception. --- .../connector/cassandra/CassandraConnectorTask.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CassandraConnectorTask.java b/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CassandraConnectorTask.java index e937dd2aa..dfaea31e1 100644 --- a/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CassandraConnectorTask.java +++ b/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CassandraConnectorTask.java @@ -27,6 +27,7 @@ import com.codahale.metrics.servlets.MetricsServlet; import com.codahale.metrics.servlets.PingServlet; +import io.debezium.DebeziumException; import io.debezium.config.Configuration; import io.debezium.connector.cassandra.exceptions.CassandraConnectorConfigException; import io.debezium.connector.cassandra.network.BuildInfoServlet; @@ -130,7 +131,7 @@ private void initHttpServer() { contextHandler.addServlet(new ServletHolder(new HealthCheckServlet(registerHealthCheck())), "/health"); } - private void initProcessorGroup() throws Exception { + private void initProcessorGroup() { try { processorGroup = new ProcessorGroup(); processorGroup.addProcessor(new SchemaProcessor(taskContext)); @@ -142,8 +143,7 @@ private void initProcessorGroup() throws Exception { } } catch (Exception e) { - LOGGER.error("Failed to initiate Processor Group.", e); - throw e; + throw new DebeziumException("Failed to initiate Processor Group.", e); } LOGGER.info("Initiated Processor Group."); } @@ -214,7 +214,7 @@ void start() { } } - void terminate() throws Exception { + void terminate() { LOGGER.info("Terminating processor group ..."); try { stopProcessors(); @@ -226,8 +226,7 @@ void terminate() throws Exception { } } catch (Exception e) { - LOGGER.error("Failed to terminate processor group.", e); - throw e; + throw new DebeziumException("Failed to terminate processor group.", e); } }