File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
samza-core/src/main/java/org/apache/samza/config Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 3232
3333public class JobCoordinatorConfig extends MapConfig {
3434 public static final String JOB_COORDINATOR_FACTORY = "job.coordinator.factory" ;
35- public final static String DEFAULT_COORDINATOR_UTILS_FACTORY = ZkJobCoordinatorFactory .class .getName ();
35+ public final static String DEFAULT_COORDINATOR_FACTORY = ZkJobCoordinatorFactory .class .getName ();
3636 private static final String AZURE_COORDINATION_UTILS_FACTORY = "org.apache.samza.coordinator.AzureCoordinationUtilsFactory" ;
3737 private static final String AZURE_COORDINATOR_FACTORY = "org.apache.samza.coordinator.AzureJobCoordinatorFactory" ;
3838
@@ -41,7 +41,7 @@ public JobCoordinatorConfig(Config config) {
4141 }
4242
4343 public String getJobCoordinationUtilsFactoryClassName () {
44- String coordinatorFactory = get (JOB_COORDINATOR_FACTORY , DEFAULT_COORDINATOR_UTILS_FACTORY );
44+ String coordinatorFactory = get (JOB_COORDINATOR_FACTORY , DEFAULT_COORDINATOR_FACTORY );
4545
4646 String coordinationUtilsFactory ;
4747 if (Objects .equals (coordinatorFactory , AZURE_COORDINATOR_FACTORY )) {
You can’t perform that action at this time.
0 commit comments