@@ -262,14 +262,18 @@ public void updateLimiter(JobMeta jobMeta) {
262262 DLMJobReq .class );
263263 params = dlmJobReq .getRateLimit ();
264264 }
265- setClusterLimitConfig (jobMeta .getSourceCluster (), params .getDataSizeLimit ());
266- setClusterLimitConfig (jobMeta .getTargetCluster (), params .getDataSizeLimit ());
267- setTenantLimitConfig (jobMeta .getSourceTenant (), params .getDataSizeLimit ());
268- setTenantLimitConfig (jobMeta .getTargetTenant (), params .getDataSizeLimit ());
269- setTableLimitConfig (jobMeta .getTargetTableMeta (), params .getRowLimit ());
270- setTableLimitConfig (jobMeta .getSourceTableMeta (), params .getRowLimit ());
271-
272- log .info ("Update rate limit to {}" , params );
265+ if (params .getDataSizeLimit () != null ) {
266+ setClusterLimitConfig (jobMeta .getSourceCluster (), params .getDataSizeLimit ());
267+ setClusterLimitConfig (jobMeta .getTargetCluster (), params .getDataSizeLimit ());
268+ setTenantLimitConfig (jobMeta .getSourceTenant (), params .getDataSizeLimit ());
269+ setTenantLimitConfig (jobMeta .getTargetTenant (), params .getDataSizeLimit ());
270+ log .info ("Update rate limit success,dataSizeLimit={}" , params .getDataSizeLimit ());
271+ }
272+ if (params .getRowLimit () != null ) {
273+ setTableLimitConfig (jobMeta .getTargetTableMeta (), params .getRowLimit ());
274+ setTableLimitConfig (jobMeta .getSourceTableMeta (), params .getRowLimit ());
275+ log .info ("Update rate limit success,rowLimit={}" , params .getRowLimit ());
276+ }
273277 } catch (Exception e ) {
274278 log .warn ("Update rate limit failed,errorMsg={}" , e .getMessage ());
275279 setClusterLimitConfig (jobMeta .getSourceCluster (), 1024 );
0 commit comments