fix bug in scheduler (apache#260)

sijie · Mar 4, 2018 · dc8f39c · dc8f39c
1 parent 7370fbc
commit dc8f39c
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/pulsar-functions/conf/function_worker.yml b/pulsar-functions/conf/function_worker.yml
@@ -23,7 +23,6 @@ workerPort: 6750
 functionMetadataTopicName: metadata
 functionMetadataSnapshotsTopicPath: snapshots
 clusterCoordinationTopicName: coordinate
-snapshotFreqMs: 600000
 pulsarFunctionsNamespace: sample/standalone/functions
 pulsarServiceUrl: pulsar://localhost:6650
 pulsarWebServiceUrl: http://localhost:8080

diff --git a/...r-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java b/...r-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
@@ -132,9 +132,6 @@ private void invokeScheduler() {
                 .flatMap(stringMapEntry -> stringMapEntry.getValue().values().stream()).collect(Collectors.toList());
 
         List<Function.Instance> needsAssignment = this.getUnassignedFunctionInstances(workerIdToAssignments, allInstances);
-        if (needsAssignment.isEmpty()) {
-            return;
-        }
 
         List<Assignment> assignments = this.scheduler.schedule(
                 needsAssignment, currentAssignments, currentMembership);