update dashboard

Author: kwannoel

docker/dashboards/risingwave-dev-dashboard.json

@@ -139,8 +139,8 @@ def _(outer_panels: Panels):
                             "clean {{fragment_id}} {{relation}}",
                         ),
                         panels.target(
-                            f"sum({metric('sync_kv_log_store_unclean_state')}) - sum({metric('sync_kv_log_store_clean_state')}) by (fragment_id, relation)",
-                            "current {{fragment_id}} {{relation}}",
+                            f"sum({metric('sync_kv_log_store_unclean_state')}) by (fragment_id, relation) - sum({metric('sync_kv_log_store_clean_state')}) by (fragment_id, relation)",
+                            "current state {{fragment_id}} {{relation}}",
                         ),
                     ]
                 ),

grafana/dashboard/dev/sync_logstore_metrics.py

@@ -533,11 +533,7 @@ impl<S: StateStore> SyncedKvLogStoreExecutor<S> {
 
             let mut log_store_stream = tokio_stream::StreamExt::peekable(log_store_stream);
             let mut clean_state = log_store_stream.peek().await.is_none();
-            if clean_state {
-                self.metrics.clean_state.inc();
-            } else {
-                self.metrics.unclean_state.inc();
-            }
+
 
             let mut read_future_state = ReadFuture::ReadingPersistedStream(log_store_stream);