You are viewing a plain text version of this content. The canonical link for it is here.

Posted to notifications@shardingsphere.apache.org by GitBox <gi...@apache.org> on 2022/02/16 15:32:42 UTC

[GitHub] [shardingsphere] RaigorJiang opened a new pull request #15456: [DistSQL] Make workerThread, batchSize and rateLimiter optional in sharding scaling rule.

RaigorJiang opened a new pull request #15456:
URL: https://github.com/apache/shardingsphere/pull/15456


   For #15437.
   
   `workerThread`, `batchSize` and r`ateLimiter` can be null in sharding scaling rule configuration.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@shardingsphere.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [shardingsphere] sandynz commented on pull request #15456: [DistSQL] Make workerThread, batchSize and rateLimiter optional in sharding scaling rule.

Posted by GitBox <gi...@apache.org>.

sandynz commented on pull request #15456:
URL: https://github.com/apache/shardingsphere/pull/15456#issuecomment-1042513501


   Test passed:
   
   ```
   mysql> CREATE SHARDING SCALING RULE scaling_name2(
       -> INPUT(
       ->   BATCH_SIZE=1000
       -> ),
       -> OUTPUT(
       ->   WORKER_THREAD=40
       -> ),
       -> STREAM_CHANNEL(TYPE(NAME=MEMORY, PROPERTIES("block-queue-size"=10000))),
       -> COMPLETION_DETECTOR(TYPE(NAME=IDLE, PROPERTIES("incremental-task-idle-minute-threshold"=1))),
       -> DATA_CONSISTENCY_CHECKER(TYPE(NAME=DATA_MATCH, PROPERTIES("chunk-size"=1000)))
       -> );
   Query OK, 0 rows affected (0.04 sec)
   
   mysql> CREATE SHARDING SCALING RULE scaling_name3(
       -> INPUT(
       ->   WORKER_THREAD=40,
       ->   BATCH_SIZE=1000
       -> ),
       -> OUTPUT(
       ->   WORKER_THREAD=40,
       ->   BATCH_SIZE=1000
       -> ),
       -> STREAM_CHANNEL(TYPE(NAME=MEMORY, PROPERTIES("block-queue-size"=10000)))
       -> );
   Query OK, 0 rows affected (0.05 sec)
   ```
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@shardingsphere.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [shardingsphere] sandynz merged pull request #15456: [DistSQL] Make workerThread, batchSize and rateLimiter optional in sharding scaling rule.

Posted by GitBox <gi...@apache.org>.

sandynz merged pull request #15456:
URL: https://github.com/apache/shardingsphere/pull/15456


   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@shardingsphere.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org