diff --git a/helm/templates/grafana/dashboard-config-map.yaml b/helm/templates/grafana/dashboard-config-map.yaml index cc9ec623f3ef71459ccad65128bf8cd65f0d6eb6..459021213c1d4c746819ddabac790800b9a6ed09 100644 --- a/helm/templates/grafana/dashboard-config-map.yaml +++ b/helm/templates/grafana/dashboard-config-map.yaml @@ -527,7 +527,7 @@ data: "steppedLine": false, "targets": [ { - "expr": "sum by(topic) (kafka_topic_partitions >= 0)", + "expr": "kafka_topic_partitions", "format": "time_series", "intervalFactor": 1, "legendFormat": "{{topic}}", diff --git a/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/DocumentMapper.java b/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/DocumentMapper.java index f0a99ece6cb7f7a1d6063ee1e389472dbe84bab2..1abf847250779150bb48b45c162afaeac1130044 100644 --- a/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/DocumentMapper.java +++ b/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/DocumentMapper.java @@ -34,7 +34,7 @@ final class DocumentMapper extends SimpleFunction<ActivePowerRecord, Document> { private String createDocumentName(final String documentId) { this.initFirestoreConfig(); return "projects/" + this.firestoreConfig.getProjectId() - + "/databases/" + this.firestoreConfig.getDatabaseDdlRequest() + + "/databases/" + this.firestoreConfig.getDatabase() + "/documents/" + this.collection + "/" + documentId; } diff --git a/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/FirestoreConfig.java b/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/FirestoreConfig.java index 1f5adfcdf5606bc508c59f12846bf773a01264fc..143387d0e15fc778721e026f1c7fdb3b01fc15ef 100644 --- a/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/FirestoreConfig.java +++ b/theodolite-benchmarks/uc1-beam/src/main/java/rocks/theodolite/benchmarks/uc1/beam/firestore/FirestoreConfig.java @@ -16,8 +16,8 @@ final class FirestoreConfig { return this.firestoreOptions.getProjectId(); } - public String getDatabaseDdlRequest() { - return this.firestoreOptions.getProjectId(); + public String getDatabase() { + return this.firestoreOptions.getDatabaseId(); } public static FirestoreConfig createFromDefaults() throws IOException {