This is an automated email from the ASF dual-hosted git repository.
yuchenhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new a647b9a feat(bulk-load): add table-level bulk load reject count (#805)
a647b9a is described below
commit a647b9a3b44ca3dd5cbc660840f15c0a5dd494bc
Author: HeYuchen <[email protected]>
AuthorDate: Tue Aug 31 14:38:05 2021 +0800
feat(bulk-load): add table-level bulk load reject count (#805)
---
rdsn | 2 +-
src/server/info_collector.cpp | 1 +
src/server/info_collector.h | 3 +++
src/shell/command_helper.h | 5 +++++
src/shell/commands/table_management.cpp | 2 ++
5 files changed, 12 insertions(+), 1 deletion(-)
diff --git a/rdsn b/rdsn
index 6135e45..a63f453 160000
--- a/rdsn
+++ b/rdsn
@@ -1 +1 @@
-Subproject commit 6135e4596a36bb7d303a8703f6c4ab15a14fedb8
+Subproject commit a63f4531c2d654e36298586dcf993ad64a49f65f
diff --git a/src/server/info_collector.cpp b/src/server/info_collector.cpp
index 601bf51..ec46d15 100644
--- a/src/server/info_collector.cpp
+++ b/src/server/info_collector.cpp
@@ -222,6 +222,7 @@ info_collector::app_stat_counters
*info_collector::get_app_counters(const std::s
INIT_COUNTER(recent_backup_request_throttling_reject_count);
INIT_COUNTER(recent_write_splitting_reject_count);
INIT_COUNTER(recent_read_splitting_reject_count);
+ INIT_COUNTER(recent_write_bulk_load_ingestion_reject_count);
INIT_COUNTER(storage_mb);
INIT_COUNTER(storage_count);
INIT_COUNTER(rdb_block_cache_hit_rate);
diff --git a/src/server/info_collector.h b/src/server/info_collector.h
index a077cd4..c812ed2 100644
--- a/src/server/info_collector.h
+++ b/src/server/info_collector.h
@@ -82,6 +82,8 @@ public:
row_stats.recent_backup_request_throttling_reject_count);
recent_write_splitting_reject_count->set(row_stats.recent_write_splitting_reject_count);
recent_read_splitting_reject_count->set(row_stats.recent_read_splitting_reject_count);
+ recent_write_bulk_load_ingestion_reject_count->set(
+ row_stats.recent_write_bulk_load_ingestion_reject_count);
storage_mb->set(row_stats.storage_mb);
storage_count->set(row_stats.storage_count);
rdb_block_cache_hit_rate->set(convert_to_1M_ratio(
@@ -153,6 +155,7 @@ public:
::dsn::perf_counter_wrapper
recent_backup_request_throttling_reject_count;
::dsn::perf_counter_wrapper recent_write_splitting_reject_count;
::dsn::perf_counter_wrapper recent_read_splitting_reject_count;
+ ::dsn::perf_counter_wrapper
recent_write_bulk_load_ingestion_reject_count;
::dsn::perf_counter_wrapper storage_mb;
::dsn::perf_counter_wrapper storage_count;
::dsn::perf_counter_wrapper rdb_block_cache_hit_rate;
diff --git a/src/shell/command_helper.h b/src/shell/command_helper.h
index fd80f1d..c075d50 100644
--- a/src/shell/command_helper.h
+++ b/src/shell/command_helper.h
@@ -629,6 +629,8 @@ struct row_data
row.recent_backup_request_throttling_reject_count;
recent_write_splitting_reject_count +=
row.recent_write_splitting_reject_count;
recent_read_splitting_reject_count +=
row.recent_read_splitting_reject_count;
+ recent_write_bulk_load_ingestion_reject_count +=
+ row.recent_write_bulk_load_ingestion_reject_count;
storage_mb += row.storage_mb;
storage_count += row.storage_count;
rdb_block_cache_hit_count += row.rdb_block_cache_hit_count;
@@ -688,6 +690,7 @@ struct row_data
double recent_backup_request_throttling_reject_count = 0;
double recent_write_splitting_reject_count = 0;
double recent_read_splitting_reject_count = 0;
+ double recent_write_bulk_load_ingestion_reject_count = 0;
double storage_mb = 0;
double storage_count = 0;
double rdb_block_cache_hit_count = 0;
@@ -774,6 +777,8 @@ update_app_pegasus_perf_counter(row_data &row, const
std::string &counter_name,
row.recent_write_splitting_reject_count += value;
else if (counter_name == "recent.read.splitting.reject.count")
row.recent_read_splitting_reject_count += value;
+ else if (counter_name == "recent.write.bulk.load.ingestion.reject.count")
+ row.recent_write_bulk_load_ingestion_reject_count += value;
else if (counter_name == "disk.storage.sst(MB)")
row.storage_mb += value;
else if (counter_name == "disk.storage.sst.count")
diff --git a/src/shell/commands/table_management.cpp
b/src/shell/commands/table_management.cpp
index 1c74649..e4d16c2 100644
--- a/src/shell/commands/table_management.cpp
+++ b/src/shell/commands/table_management.cpp
@@ -513,6 +513,8 @@ bool app_stat(command_executor *e, shell_context *sc,
arguments args)
row.recent_backup_request_throttling_reject_count;
sum.recent_write_splitting_reject_count +=
row.recent_write_splitting_reject_count;
sum.recent_read_splitting_reject_count +=
row.recent_read_splitting_reject_count;
+ sum.recent_write_bulk_load_ingestion_reject_count +=
+ row.recent_write_bulk_load_ingestion_reject_count;
sum.storage_mb += row.storage_mb;
sum.storage_count += row.storage_count;
sum.rdb_block_cache_hit_count += row.rdb_block_cache_hit_count;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
