DBZ-7517 Remove the unused 'connector' parameter in the createSourceTask method in EmbeddedEngine.java
This commit is contained in:
parent
ae802f5642
commit
86c1dac16a
@ -584,3 +584,4 @@ Artem Shubovych
|
|||||||
leoloel
|
leoloel
|
||||||
Clifford Cheefoon
|
Clifford Cheefoon
|
||||||
Fr0z3Nn
|
Fr0z3Nn
|
||||||
|
Xianming Zhou
|
@ -441,7 +441,7 @@ public void run() {
|
|||||||
// Create source connector task
|
// Create source connector task
|
||||||
final List<Map<String, String>> taskConfigs = connector.taskConfigs(1);
|
final List<Map<String, String>> taskConfigs = connector.taskConfigs(1);
|
||||||
final Class<? extends Task> taskClass = connector.taskClass();
|
final Class<? extends Task> taskClass = connector.taskClass();
|
||||||
task = createSourceTask(connector, taskConfigs, taskClass);
|
task = createSourceTask(taskConfigs, taskClass);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// start source task
|
// start source task
|
||||||
@ -594,7 +594,7 @@ public OffsetStorageReader offsetStorageReader() {
|
|||||||
connector.initialize(context);
|
connector.initialize(context);
|
||||||
}
|
}
|
||||||
|
|
||||||
private SourceTask createSourceTask(final SourceConnector connector, final List<Map<String, String>> taskConfigs, final Class<? extends Task> taskClass)
|
private SourceTask createSourceTask(final List<Map<String, String>> taskConfigs, final Class<? extends Task> taskClass)
|
||||||
throws EmbeddedEngineRuntimeException, NoSuchMethodException, InvocationTargetException {
|
throws EmbeddedEngineRuntimeException, NoSuchMethodException, InvocationTargetException {
|
||||||
if (taskConfigs.isEmpty()) {
|
if (taskConfigs.isEmpty()) {
|
||||||
String msg = "Unable to start connector's task class '" + taskClass.getName() + "' with no task configuration";
|
String msg = "Unable to start connector's task class '" + taskClass.getName() + "' with no task configuration";
|
||||||
|
@ -253,3 +253,4 @@ Liaoyuxing,leoloel
|
|||||||
iankko,Jan Lieskovsky
|
iankko,Jan Lieskovsky
|
||||||
CliffordCheefoon,Clifford Cheefoon
|
CliffordCheefoon,Clifford Cheefoon
|
||||||
Fr0z3Nn,Ivanov Sergey Vasilevich
|
Fr0z3Nn,Ivanov Sergey Vasilevich
|
||||||
|
Xianming Zhou
|
Loading…
Reference in New Issue
Block a user