Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
jacktengg committed Nov 19, 2024
1 parent 6528d41 commit a710160
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ public class WorkloadGroup implements Writable, GsonPostProcessable {
// later more type and workload may be included in the future.
public static final String INTERNAL_TYPE = "internal_type";

// deprecated
// deprecated, use MEMORY_LOW_WATERMARK and MEMORY_HIGH_WATERMARK instead.
public static final String SPILL_THRESHOLD_LOW_WATERMARK = "spill_threshold_low_watermark";
public static final String SPILL_THRESHOLD_HIGH_WATERMARK = "spill_threshold_high_watermark";

Expand Down Expand Up @@ -128,8 +128,8 @@ public class WorkloadGroup implements Writable, GsonPostProcessable {
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(SCAN_THREAD_NUM, "-1");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(MAX_REMOTE_SCAN_THREAD_NUM, "-1");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(MIN_REMOTE_SCAN_THREAD_NUM, "-1");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(SPILL_THRESHOLD_LOW_WATERMARK, "50%");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(SPILL_THRESHOLD_HIGH_WATERMARK, "80%");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(MEMORY_LOW_WATERMARK, "50%");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(MEMORY_HIGH_WATERMARK, "80%");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(TAG, "");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(READ_BYTES_PER_SECOND, "-1");
ALL_PROPERTIES_DEFAULT_VALUE_MAP.put(REMOTE_READ_BYTES_PER_SECOND, "-1");
Expand Down Expand Up @@ -561,8 +561,8 @@ public void getProcNodeData(BaseProcResult result, QueryQueue qq) {
if (StringUtils.isEmpty(val)) {
row.add(ALL_PROPERTIES_DEFAULT_VALUE_MAP.get(key));
} else if ((CPU_HARD_LIMIT.equals(key) && !"-1".equals(val))
|| SPILL_THRESHOLD_LOW_WATERMARK.equals(key)
|| SPILL_THRESHOLD_HIGH_WATERMARK.equals(key)) {
|| MEMORY_LOW_WATERMARK.equals(key)
|| MEMORY_HIGH_WATERMARK.equals(key)) {
row.add(val + "%");
} else {
row.add(val);
Expand Down

0 comments on commit a710160

Please sign in to comment.