DBZ-2199 Avoid IndexOutOfBoundsException when no task configuration is available
This commit is contained in:
parent
a45bb4b9f3
commit
2b501c6df1
@ -725,6 +725,11 @@ public void raiseError(Exception e) {
|
|||||||
connectorCallback.ifPresent(DebeziumEngine.ConnectorCallback::connectorStarted);
|
connectorCallback.ifPresent(DebeziumEngine.ConnectorCallback::connectorStarted);
|
||||||
List<Map<String, String>> taskConfigs = connector.taskConfigs(1);
|
List<Map<String, String>> taskConfigs = connector.taskConfigs(1);
|
||||||
Class<? extends Task> taskClass = connector.taskClass();
|
Class<? extends Task> taskClass = connector.taskClass();
|
||||||
|
if (taskConfigs.isEmpty()) {
|
||||||
|
String msg = "Unable to start connector's task class '" + taskClass.getName() + "' with no task configuration";
|
||||||
|
fail(msg);
|
||||||
|
return;
|
||||||
|
}
|
||||||
task = null;
|
task = null;
|
||||||
try {
|
try {
|
||||||
task = (SourceTask) taskClass.getDeclaredConstructor().newInstance();
|
task = (SourceTask) taskClass.getDeclaredConstructor().newInstance();
|
||||||
|
Loading…
Reference in New Issue
Block a user