fixing bug in snapshot manager (apache#204)

jerrypeng · sijie · commit 3af1d480861f · 2018-03-03T16:44:13.000-08:00
diff --git a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataSnapshotManager.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataSnapshotManager.java
@@ -160,10 +160,10 @@ List<Integer> getSnapshotTopics() {
         try {
             List<String> topics = pulsarAdmin.persistentTopics().getList(namespace);
             for (String topic : topics) {
-                if (topic.startsWith(snapshotTopicPath)) {
+                String prefix = String.format("%s/snapshot-", snapshotTopicPath);
+                if (topic.startsWith(prefix)) {
                     ret.add(Integer.parseInt(
-                            topic.replace(
-                                    String.format("%s/snapshot-", snapshotTopicPath, snapshotsTopicPath), "")));
+                            topic.replace(prefix, "")));
                 }
             }
         } catch (PulsarAdminException e) {

Original file line number	Diff line number	Diff line change
`@@ -160,10 +160,10 @@ List<Integer> getSnapshotTopics() {`
`160`	`160`	`try {`
`161`	`161`	`List<String> topics = pulsarAdmin.persistentTopics().getList(namespace);`
`162`	`162`	`for (String topic : topics) {`
`163`		`- if (topic.startsWith(snapshotTopicPath)) {`
	`163`	`+ String prefix = String.format("%s/snapshot-", snapshotTopicPath);`
	`164`	`+ if (topic.startsWith(prefix)) {`
`164`	`165`	`ret.add(Integer.parseInt(`
`165`		`- topic.replace(`
`166`		`- String.format("%s/snapshot-", snapshotTopicPath, snapshotsTopicPath), "")));`
	`166`	`+ topic.replace(prefix, "")));`
`167`	`167`	`}`
`168`	`168`	`}`
`169`	`169`	`} catch (PulsarAdminException e) {`