alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2768 Throw Debezium Exception.

Browse Source
This commit is contained in:
Bingqin Zhou 2020-11-30 15:27:17 -08:00 committed by Gunnar Morling
parent ccea21da51
commit db7c71f86b
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CassandraConnectorTask.java
View File

@ -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);
}
}