This is an automated email from the ASF dual-hosted git repository.
totalo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 5ca82aa Remove useless worker-id (#15608)
5ca82aa is described below
commit 5ca82aa030855a2818284c84d73ada4f807d3838
Author: Zhengqiang Duan <[email protected]>
AuthorDate: Thu Feb 24 17:39:46 2022 +0800
Remove useless worker-id (#15608)
---
.../src/test/resources/yaml/sharding-rule.yaml | 2 --
.../checker/ShardingRuleStatementCheckerTest.java | 2 +-
.../query/ShardingTableRuleQueryResultSetTest.java | 5 +--
...bleRulesUsedKeyGeneratorQueryResultSetTest.java | 4 +--
...AlterShardingTableRuleStatementUpdaterTest.java | 2 +-
...teShardingKeyGeneratorStatementUpdaterTest.java | 12 ++-----
...reateShardingTableRuleStatementUpdaterTest.java | 4 +--
...opShardingKeyGeneratorStatementUpdaterTest.java | 8 +----
.../src/main/resources/conf/config-sharding.yaml | 2 --
.../resources/docker/proxy/conf/config-db.yaml | 2 --
.../resources/docker/proxy/conf/config-db.yaml | 2 --
.../src/test/resources/yaml/unit/sharding.yaml | 2 --
.../src/main/resources/case/rdl/alter.xml | 30 +++-------------
.../src/main/resources/case/rdl/create.xml | 42 ++++------------------
.../src/main/resources/sql/supported/rdl/alter.xml | 10 +++---
.../main/resources/sql/supported/rdl/create.xml | 14 ++++----
16 files changed, 34 insertions(+), 109 deletions(-)
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/resources/yaml/sharding-rule.yaml
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/resources/yaml/sharding-rule.yaml
index f99310e..245bee6 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/resources/yaml/sharding-rule.yaml
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/resources/yaml/sharding-rule.yaml
@@ -102,8 +102,6 @@ rules:
keyGenerators:
snowflake:
type: SNOWFLAKE
- props:
- worker-id: 123
scalingName: default_scaling
scaling:
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/checker/ShardingRuleStatementCheckerTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/checker/ShardingRuleStatementCheckerTest.java
index d9cecfc..40000b2 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/checker/ShardingRuleStatementCheckerTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/checker/ShardingRuleStatementCheckerTest.java
@@ -207,7 +207,7 @@ public final class ShardingRuleStatementCheckerTest {
autoTableRuleConfiguration.setKeyGenerateStrategy(new
KeyGenerateStrategyConfiguration("order_item_id", "t_order_item_snowflake"));
result.getAutoTables().add(autoTableRuleConfiguration);
result.getShardingAlgorithms().put("t_order_algorithm", new
ShardingSphereAlgorithmConfiguration("hash_mod",
newProperties("sharding-count", "4")));
- result.getKeyGenerators().put("t_order_item_snowflake", new
ShardingSphereAlgorithmConfiguration("snowflake", newProperties("worker-id",
"123")));
+ result.getKeyGenerators().put("t_order_item_snowflake", new
ShardingSphereAlgorithmConfiguration("snowflake", new Properties()));
return result;
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShardingTableRuleQueryResultSetTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShardingTableRuleQueryResultSetTest.java
index 951d998..a163c73 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShardingTableRuleQueryResultSetTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShardingTableRuleQueryResultSetTest.java
@@ -64,7 +64,6 @@ public final class ShardingTableRuleQueryResultSetTest {
assertThat(actual.get(10), is("algorithm-expression=t_order_${order_id
% 2}"));
assertThat(actual.get(11), is("order_id"));
assertThat(actual.get(12), is("SNOWFLAKE"));
- assertThat(actual.get(13), is("worker-id=123"));
}
private RuleConfiguration createRuleConfiguration() {
@@ -93,8 +92,6 @@ public final class ShardingTableRuleQueryResultSetTest {
}
private ShardingSphereAlgorithmConfiguration
createKeyGeneratorConfiguration() {
- Properties props = new Properties();
- props.put("worker-id", "123");
- return new ShardingSphereAlgorithmConfiguration("SNOWFLAKE", props);
+ return new ShardingSphereAlgorithmConfiguration("SNOWFLAKE", new
Properties());
}
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShowShardingTableRulesUsedKeyGeneratorQueryResultSetTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShowShardingTableRulesUsedKeyGeneratorQueryResultS
[...]
index 17cf74c..064849e 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShowShardingTableRulesUsedKeyGeneratorQueryResultSetTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/query/ShowShardingTableRulesUsedKeyGeneratorQueryResultSetTest.java
@@ -106,8 +106,6 @@ public final class
ShowShardingTableRulesUsedKeyGeneratorQueryResultSetTest {
}
private ShardingSphereAlgorithmConfiguration
createKeyGeneratorConfiguration() {
- Properties props = new Properties();
- props.put("worker-id", "123");
- return new ShardingSphereAlgorithmConfiguration("SNOWFLAKE", props);
+ return new ShardingSphereAlgorithmConfiguration("SNOWFLAKE", new
Properties());
}
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/AlterShardingTableRuleStatementUpdaterTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/AlterShardingTableRuleStatementUpdaterTest.java
index f4bb630..f862c98 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/AlterShardingTableRuleStatementUpdaterTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/AlterShardingTableRuleStatementUpdaterTest.java
@@ -167,7 +167,7 @@ public final class
AlterShardingTableRuleStatementUpdaterTest {
result.getTables().add(createTableRuleConfiguration());
result.getAutoTables().add(createAutoTableRuleConfiguration());
result.getShardingAlgorithms().put("t_order_algorithm", new
ShardingSphereAlgorithmConfiguration("hash_mod",
newProperties("sharding-count", "4")));
- result.getKeyGenerators().put("t_order_item_snowflake", new
ShardingSphereAlgorithmConfiguration("snowflake", newProperties("worker-id",
"123")));
+ result.getKeyGenerators().put("t_order_item_snowflake", new
ShardingSphereAlgorithmConfiguration("snowflake", new Properties()));
return result;
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingKeyGeneratorStatementUpdaterTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingKeyGeneratorStatementUpdaterTest.java
index 1404a42..92dba60 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingKeyGeneratorStatementUpdaterTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingKeyGeneratorStatementUpdaterTest.java
@@ -62,7 +62,7 @@ public final class
CreateShardingKeyGeneratorStatementUpdaterTest {
public void assertExecuteWithExist() throws DistSQLException {
ShardingKeyGeneratorSegment keyGeneratorSegment =
buildShardingKeyGeneratorSegment();
ShardingRuleConfiguration shardingRuleConfiguration = new
ShardingRuleConfiguration();
- shardingRuleConfiguration.getKeyGenerators().put("uuid_key_generator",
new ShardingSphereAlgorithmConfiguration("uuid", buildProps()));
+ shardingRuleConfiguration.getKeyGenerators().put("uuid_key_generator",
new ShardingSphereAlgorithmConfiguration("uuid", new Properties()));
updater.checkSQLStatement(shardingSphereMetaData,
createSQLStatement(keyGeneratorSegment), shardingRuleConfiguration);
}
@@ -77,7 +77,7 @@ public final class
CreateShardingKeyGeneratorStatementUpdaterTest {
public void assertExecuteWithInvalidAlgorithm() throws DistSQLException {
ShardingKeyGeneratorSegment keyGeneratorSegment =
buildShardingKeyGeneratorSegment();
ShardingRuleConfiguration shardingRuleConfiguration = new
ShardingRuleConfiguration();
-
shardingRuleConfiguration.getKeyGenerators().put("snowflake_key_generator", new
ShardingSphereAlgorithmConfiguration("INVALID_ALGORITHM", buildProps()));
+
shardingRuleConfiguration.getKeyGenerators().put("snowflake_key_generator", new
ShardingSphereAlgorithmConfiguration("INVALID_ALGORITHM", new Properties()));
updater.checkSQLStatement(shardingSphereMetaData,
createSQLStatement(keyGeneratorSegment), shardingRuleConfiguration);
}
@@ -86,12 +86,6 @@ public final class
CreateShardingKeyGeneratorStatementUpdaterTest {
}
private ShardingKeyGeneratorSegment buildShardingKeyGeneratorSegment() {
- return new ShardingKeyGeneratorSegment("uuid_key_generator", new
AlgorithmSegment("uuid", buildProps()));
- }
-
- private Properties buildProps() {
- Properties result = new Properties();
- result.put("worker-id", "123");
- return result;
+ return new ShardingKeyGeneratorSegment("uuid_key_generator", new
AlgorithmSegment("uuid", new Properties()));
}
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingTableRuleStatementUpdaterTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingTableRuleStatementUpdaterTest.java
index 4898e74..9f5e5a9 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingTableRuleStatementUpdaterTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/CreateShardingTableRuleStatementUpdaterTest.java
@@ -132,7 +132,7 @@ public final class
CreateShardingTableRuleStatementUpdaterTest {
private AutoTableRuleSegment createCompleteAutoTableRule() {
AutoTableRuleSegment result = new
AutoTableRuleSegment("t_order_item_input", Arrays.asList("logic_ds"));
- result.setKeyGenerateStrategySegment(new
KeyGenerateStrategySegment("product_id", new AlgorithmSegment("snowflake_test",
newProperties("worker-id", "123"))));
+ result.setKeyGenerateStrategySegment(new
KeyGenerateStrategySegment("product_id", new AlgorithmSegment("snowflake_test",
new Properties())));
result.setShardingColumn("order_id");
result.setShardingAlgorithmSegment(new AlgorithmSegment("MOD_TEST",
newProperties("", "")));
return result;
@@ -156,7 +156,7 @@ public final class
CreateShardingTableRuleStatementUpdaterTest {
result.getTables().add(createTableRuleConfiguration());
result.getAutoTables().add(createAutoTableRuleConfiguration());
result.getShardingAlgorithms().put("t_order_algorithm", new
ShardingSphereAlgorithmConfiguration("hash_mod",
newProperties("sharding-count", "4")));
- result.getKeyGenerators().put("t_order_item_snowflake", new
ShardingSphereAlgorithmConfiguration("snowflake", newProperties("worker-id",
"123")));
+ result.getKeyGenerators().put("t_order_item_snowflake", new
ShardingSphereAlgorithmConfiguration("snowflake", new Properties()));
return result;
}
diff --git
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/DropShardingKeyGeneratorStatementUpdaterTest.java
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/DropShardingKeyGeneratorStatementUpdaterTest.java
index bc27439..1bcb21e 100644
---
a/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/DropShardingKeyGeneratorStatementUpdaterTest.java
+++
b/shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-distsql/shardingsphere-sharding-distsql-handler/src/test/java/org/apache/shardingsphere/sharding/distsql/update/DropShardingKeyGeneratorStatementUpdaterTest.java
@@ -66,7 +66,7 @@ public final class
DropShardingKeyGeneratorStatementUpdaterTest {
@Test
public void assertDropSpecifiedKeyGenerator() {
ShardingRuleConfiguration currentRuleConfig = new
ShardingRuleConfiguration();
- currentRuleConfig.getKeyGenerators().put("uuid_key_generator", new
ShardingSphereAlgorithmConfiguration("uuid", buildProps()));
+ currentRuleConfig.getKeyGenerators().put("uuid_key_generator", new
ShardingSphereAlgorithmConfiguration("uuid", new Properties()));
updater.updateCurrentRuleConfiguration(createSQLStatement("uuid_key_generator"),
currentRuleConfig);
assertTrue(currentRuleConfig.getKeyGenerators().isEmpty());
}
@@ -88,10 +88,4 @@ public final class
DropShardingKeyGeneratorStatementUpdaterTest {
private DropShardingKeyGeneratorStatement createSQLStatement(final
String... keyGeneratorNames) {
return new
DropShardingKeyGeneratorStatement(Arrays.asList(keyGeneratorNames));
}
-
- private Properties buildProps() {
- Properties result = new Properties();
- result.put("worker-id", "123");
- return result;
- }
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-bootstrap/src/main/resources/conf/config-sharding.yaml
b/shardingsphere-proxy/shardingsphere-proxy-bootstrap/src/main/resources/conf/config-sharding.yaml
index 0b6b770..d77bc17 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-bootstrap/src/main/resources/conf/config-sharding.yaml
+++
b/shardingsphere-proxy/shardingsphere-proxy-bootstrap/src/main/resources/conf/config-sharding.yaml
@@ -91,8 +91,6 @@
# keyGenerators:
# snowflake:
# type: SNOWFLAKE
-# props:
-# worker-id: 123
#
# scalingName: default_scaling
# scaling:
diff --git
a/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-metrics/src/test/resources/docker/proxy/conf/config-db.yaml
b/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-metrics/src/test/resources/docker/proxy/conf/config-db.yaml
index f7d0eb7..80ee2bd 100644
---
a/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-metrics/src/test/resources/docker/proxy/conf/config-db.yaml
+++
b/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-metrics/src/test/resources/docker/proxy/conf/config-db.yaml
@@ -68,5 +68,3 @@ rules:
keyGenerators:
snowflake:
type: SNOWFLAKE
- props:
- worker-id: 123
diff --git
a/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-opentelemetry/src/test/resources/docker/proxy/conf/config-db.yaml
b/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-opentelemetry/src/test/resources/docker/proxy/conf/config-db.yaml
index aacc280..23d5eec 100644
---
a/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-opentelemetry/src/test/resources/docker/proxy/conf/config-db.yaml
+++
b/shardingsphere-test/shardingsphere-integration-agent-test/shardingsphere-integration-agent-test-plugins/shardingsphere-integration-agent-test-opentelemetry/src/test/resources/docker/proxy/conf/config-db.yaml
@@ -68,5 +68,3 @@ rules:
keyGenerators:
snowflake:
type: SNOWFLAKE
- props:
- worker-id: 123
diff --git
a/shardingsphere-test/shardingsphere-integration-driver-test/src/test/resources/yaml/unit/sharding.yaml
b/shardingsphere-test/shardingsphere-integration-driver-test/src/test/resources/yaml/unit/sharding.yaml
index 8787582..c6b2605 100644
---
a/shardingsphere-test/shardingsphere-integration-driver-test/src/test/resources/yaml/unit/sharding.yaml
+++
b/shardingsphere-test/shardingsphere-integration-driver-test/src/test/resources/yaml/unit/sharding.yaml
@@ -93,8 +93,6 @@ rules:
keyGenerators:
snowflake:
type: SNOWFLAKE
- props:
- worker-id: 123
- !READWRITE_SPLITTING
dataSources:
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/alter.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/alter.xml
index c26e89a..ed60831 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/alter.xml
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/alter.xml
@@ -72,11 +72,7 @@
<property key="sharding-count" value="4"/>
</properties>
</table-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</alter-sharding-auto-table-rule>
@@ -88,11 +84,7 @@
<property key="sharding-count" value="4"/>
</properties>
</table-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</alter-sharding-auto-table-rule>
@@ -101,11 +93,7 @@
<data-source>ms_group_${0..1}</data-source>
<table-strategy type="standard" sharding-column="user_id"
sharding-algorithm-name="table_inline"></table-strategy>
<database-strategy type="standard" sharding-column="order_id"
sharding-algorithm-name="database_inline"></database-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</alter-sharding-table-rule>
@@ -114,11 +102,7 @@
<data-source>ms_group_${0..1}</data-source>
<table-strategy type="standard" sharding-column="user_id"
sharding-algorithm-name="table_inline"></table-strategy>
<database-strategy type="complex"
sharding-column="order_id,user_id"
sharding-algorithm-name="database_inline"></database-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</alter-sharding-table-rule>
@@ -291,11 +275,7 @@
<alter-sharding-key-generator sql-case-id="alter-sharding-key-generator">
<shardingKeyGenerator key-generator-name="uuid_key_generator">
- <algorithm algorithm-name="uuid">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </algorithm>
+ <algorithm algorithm-name="uuid" />
</shardingKeyGenerator>
</alter-sharding-key-generator>
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/create.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/create.xml
index dbb62b6..24b79d1 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/create.xml
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/case/rdl/create.xml
@@ -76,11 +76,7 @@
<property key="sharding-count" value="4"/>
</properties>
</table-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</create-sharding-auto-table-rule>
@@ -93,11 +89,7 @@
<property key="sharding-count" value="4"/>
</properties>
</table-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</create-sharding-auto-table-rule>
@@ -109,11 +101,7 @@
<property key="sharding-count" value="4"/>
</properties>
</table-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</create-sharding-auto-table-rule>
@@ -122,11 +110,7 @@
<data-source>ms_group_${0..1}</data-source>
<table-strategy type="standard" sharding-column="user_id"
sharding-algorithm-name="table_inline"></table-strategy>
<database-strategy type="standard" sharding-column="order_id"
sharding-algorithm-name="database_inline"></database-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
<rule name="t_order_item" key-generate-strategy-column="another_id">
<data-source>ms_group_${0..1}</data-source>
@@ -140,11 +124,7 @@
<data-source>ms_group_${0..1}</data-source>
<table-strategy type="standard" sharding-column="user_id"
sharding-algorithm-name="table_inline"></table-strategy>
<database-strategy type="complex"
sharding-column="order_id,user_id"
sharding-algorithm-name="database_inline"></database-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
<rule name="t_order_item" key-generate-strategy-column="another_id">
<data-source>ms_group_${0..1}</data-source>
@@ -164,11 +144,7 @@
</properties>
</algorithm-segment>
</database-strategy>
- <key-generate-strategy algorithm-name="snowflake">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </key-generate-strategy>
+ <key-generate-strategy algorithm-name="snowflake" />
</rule>
</create-sharding-table-rule>
@@ -444,11 +420,7 @@
<create-sharding-key-generator sql-case-id="create-sharding-key-generator">
<shardingKeyGenerator key-generator-name="uuid_key_generator">
- <algorithm algorithm-name="uuid">
- <properties>
- <property key="worker-id" value="123"/>
- </properties>
- </algorithm>
+ <algorithm algorithm-name="uuid" />
</shardingKeyGenerator>
</create-sharding-key-generator>
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/alter.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/alter.xml
index d8304fb..709af36 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/alter.xml
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/alter.xml
@@ -26,8 +26,8 @@
<distsql-case id="alter-resource-single-with-properties" value="ALTER
RESOURCE
ds_0(HOST=127.0.0.1,PORT=3306,DB=test0,USER=ROOT,PASSWORD=123456,PROPERTIES('maxPoolSize'=30));"
/>
<distsql-case id="alter-resource-url-single-with-empty-properties"
value="ALTER RESOURCE
ds_0(URL='jdbc:mysql://127.0.0.1:3306/test0',USER=ROOT,PROPERTIES())" />
<distsql-case id="alter-resource-url-single-with-properties" value="ALTER
RESOURCE
ds_0(URL='jdbc:mysql://127.0.0.1:3306/test0',USER=ROOT,PASSWORD=123456,PROPERTIES('maxPoolSize'=30))"
/>
- <distsql-case id="alter-sharding-auto-table-rule" value="ALTER SHARDING
TABLE RULE t_order (RESOURCES(ms_group_0,ms_group_1), SHARDING_COLUMN=order_id,
TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>
- <distsql-case id="alter-sharding-auto-table-rule-with-inline-expression"
value="ALTER SHARDING TABLE RULE t_order (RESOURCES('ms_group_${0..1}'),
SHARDING_COLUMN=order_id,
TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>
+ <distsql-case id="alter-sharding-auto-table-rule" value="ALTER SHARDING
TABLE RULE t_order (RESOURCES(ms_group_0,ms_group_1), SHARDING_COLUMN=order_id,
TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))"
/>
+ <distsql-case id="alter-sharding-auto-table-rule-with-inline-expression"
value="ALTER SHARDING TABLE RULE t_order (RESOURCES('ms_group_${0..1}'),
SHARDING_COLUMN=order_id,
TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))"
/>
<distsql-case id="alter-sharding-binding-table-rules" value="ALTER
SHARDING BINDING TABLE RULES (t_order,t_order_item), (t_1,t_2)" />
<distsql-case id="alter-sharding-broadcast-table-rules" value="ALTER
SHARDING BROADCAST TABLE RULES(t_1,t_2)" />
<distsql-case id="alter-readwrite-splitting-rule" value="ALTER
READWRITE_SPLITTING RULE ms_group_0 (AUTO_AWARE_RESOURCE=group_0,
TYPE(NAME=random,PROPERTIES(read_weight='2:1'))), ms_group_1
(WRITE_RESOURCE=primary_ds,
READ_RESOURCES(replica_ds_0,replica_ds_1),TYPE(NAME=random))" />
@@ -40,11 +40,11 @@
<distsql-case id="alter-encrypt-rule-with-query-with-cipher-column"
value="ALTER ENCRYPT RULE t_encrypt (RESOURCE=ds_1,
COLUMNS((NAME=user_id,PLAIN=user_plain,CIPHER=user_cipher,
TYPE(NAME=AES,PROPERTIES('aes-key-value'='123456abc'))), (NAME=order_id, CIPHER
=order_cipher,TYPE(NAME=MD5))), QUERY_WITH_CIPHER_COLUMN=false)" />
<distsql-case id="alter-shadow-algorithm" value="ALTER SHADOW ALGORITHM
(simple_note_algorithm, TYPE(NAME=SIMPLE_NOTE, PROPERTIES('shadow'='true',
'foo'='bar')))" />
<distsql-case id="alter-shadow-rule" value="ALTER SHADOW RULE
shadow_rule(SOURCE=demo_ds,SHADOW=demo_ds_shadow,t_order((TYPE(NAME=COLUMN_REGEX_MATCH,PROPERTIES('operation'='insert','column'='user_id','regex'='[1]'))),(simple_note_algorithm,TYPE(NAME=SIMPLE_NOTE,PROPERTIES('shadow'='true',foo='bar')))))"
/>
- <distsql-case id="alter-sharding-table-rule" value="ALTER SHARDING TABLE
RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>"
- <distsql-case id="alter-sharding-table-rule-complex" value="ALTER SHARDING
TABLE RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`complex`,sharding_columns = order_id,user_id, sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>"
+ <distsql-case id="alter-sharding-table-rule" value="ALTER SHARDING TABLE
RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))"
/>"
+ <distsql-case id="alter-sharding-table-rule-complex" value="ALTER SHARDING
TABLE RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`complex`,sharding_columns = order_id,user_id, sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))"
/>"
<distsql-case id="alter-sharding-algorithm" value="ALTER SHARDING
ALGORITHM algorithm_name(TYPE(NAME=inline,PROPERTIES('algorithm-expression' =
't_order_${order_id % 2}')))" />
<distsql-case id="alter-default-single-table" value="ALTER DEFAULT SINGLE
TABLE RULE RESOURCE = ds_0" />
- <distsql-case id="alter-sharding-key-generator" value="ALTER SHARDING KEY
GENERATOR uuid_key_generator(TYPE(NAME=uuid,PROPERTIES('worker-id' = '123')))"
/>
+ <distsql-case id="alter-sharding-key-generator" value="ALTER SHARDING KEY
GENERATOR uuid_key_generator(TYPE(NAME=uuid))" />
<distsql-case id="alter-default-sharding-strategy" value="ALTER DEFAULT
SHARDING TABLE STRATEGY(TYPE=standard, SHARDING_COLUMN=order_id,
SHARDING_ALGORITHM=algorithms_name)" />
<distsql-case id="alter-default-sharding-strategy-complex" value="ALTER
DEFAULT SHARDING TABLE STRATEGY(TYPE=complex,
SHARDING_COLUMNS=order_id,user_id, SHARDING_ALGORITHM=algorithms_name)" />
<distsql-case id="enable-sharding-scaling-rule" value="ENABLE SHARDING
SCALING RULE scalingName" />
diff --git
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/create.xml
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/create.xml
index a959ed9..2f19413 100644
---
a/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/create.xml
+++
b/shardingsphere-test/shardingsphere-parser-test/src/main/resources/sql/supported/rdl/create.xml
@@ -26,8 +26,8 @@
<distsql-case id="add-resource-single-with-properties" value="ADD RESOURCE
ds_0(HOST=127.0.0.1,PORT=3306,DB=test0,USER=ROOT,PASSWORD=123456,PROPERTIES('maxPoolSize'=30));"
/>
<distsql-case id="add-resource-url-single-with-empty-properties"
value="ADD RESOURCE
ds_0(URL='jdbc:mysql://127.0.0.1:3306/test0',USER=ROOT,PROPERTIES())" />
<distsql-case id="add-resource-url-single-with-properties" value="ADD
RESOURCE
ds_0(URL='jdbc:mysql://127.0.0.1:3306/test0',USER=ROOT,PASSWORD=123456,PROPERTIES('maxPoolSize'=30))"
/>
- <distsql-case id="create-sharding-auto-table-rule" value="CREATE SHARDING
TABLE RULE t_order (RESOURCES(ms_group_0,ms_group_1),
SHARDING_COLUMN=order_id,TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),
KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>
- <distsql-case id="create-sharding-auto-table-rule-with-inline-expression"
value="CREATE SHARDING TABLE RULE t_order (RESOURCES('ms_group_${0..1}'),
SHARDING_COLUMN=order_id,TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),
KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>
+ <distsql-case id="create-sharding-auto-table-rule" value="CREATE SHARDING
TABLE RULE t_order (RESOURCES(ms_group_0,ms_group_1),
SHARDING_COLUMN=order_id,TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),
KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))" />
+ <distsql-case id="create-sharding-auto-table-rule-with-inline-expression"
value="CREATE SHARDING TABLE RULE t_order (RESOURCES('ms_group_${0..1}'),
SHARDING_COLUMN=order_id,TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),
KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))" />
<distsql-case id="create-sharding-binding-table-rule" value="CREATE
SHARDING BINDING TABLE RULES (t_order,t_order_item), (t_1,t_2)" />
<distsql-case id="create-sharding-broadcast-table-rule" value="CREATE
SHARDING BROADCAST TABLE RULES(t_1,t_2)" />
<distsql-case id="create-static-readwrite-splitting-rule" value="CREATE
READWRITE_SPLITTING RULE ms_group_0 (WRITE_RESOURCE=primary_ds,
READ_RESOURCES(replica_ds_0,replica_ds_1), TYPE(NAME=random)))" />
@@ -44,14 +44,14 @@
<distsql-case id="create-default-sharding-table-strategy-with-lower-case"
value="create default sharding table strategy(type=standard,
sharding_column=order_id, sharding_algorithm=algorithms_name)" />
<distsql-case id="create-default-sharding-database-strategy" value="CREATE
DEFAULT SHARDING DATABASE STRATEGY(TYPE=STANDARD, SHARDING_COLUMN=ORDER_ID,
SHARDING_ALGORITHM=algorithms_name)" />
<distsql-case id="create-default-sharding-strategy-complex" value="CREATE
DEFAULT SHARDING TABLE STRATEGY(TYPE=complex,
SHARDING_COLUMNS=order_id,user_id, SHARDING_ALGORITHM=algorithms_name)" />
- <distsql-case id="create-sharding-table-rule" value="CREATE SHARDING TABLE
RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123)))),t_order_item
(DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE = `standard`,s [...]
- <distsql-case id="create-sharding-table-rule-complex" value="CREATE
SHARDING TABLE RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY(
TYPE = `complex`,sharding_columns = order_id,user_id,sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123)))),t_order_item
(DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYP [...]
- <distsql-case id="create-sharding-table-rule-with-auto-create-algorithm"
value="CREATE SHARDING TABLE RULE t_order
(DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sharding_algorithm
(TYPE(NAME=inline,PROPERTIES('algorithm-expression'='ms_group_${order_id%
2}')))),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=
[...]
+ <distsql-case id="create-sharding-table-rule" value="CREATE SHARDING TABLE
RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake))),t_order_item
(DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sh [...]
+ <distsql-case id="create-sharding-table-rule-complex" value="CREATE
SHARDING TABLE RULE t_order (DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY(
TYPE = `complex`,sharding_columns = order_id,user_id,sharding_algorithm =
database_inline),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake))),t_order_item
(DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_colu [...]
+ <distsql-case id="create-sharding-table-rule-with-auto-create-algorithm"
value="CREATE SHARDING TABLE RULE t_order
(DATANODES('ms_group_${0..1}'),DATABASE_STRATEGY( TYPE =
`standard`,sharding_column = order_id,sharding_algorithm
(TYPE(NAME=inline,PROPERTIES('algorithm-expression'='ms_group_${order_id%
2}')))),TABLE_STRATEGY(TYPE = `standard`,sharding_column =
user_id,sharding_algorithm =
table_inline),KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))"
/>"
<distsql-case id="create-shadow-algorithm" value="CREATE SHADOW ALGORITHM
(simple_note_algorithm, TYPE(NAME=HINT, PROPERTIES('shadow'='true',
'foo'='bar')))" />
<distsql-case id="create-default-single-table" value="CREATE DEFAULT
SINGLE TABLE RULE RESOURCE = ds_0" />
<distsql-case id="add-resource-with-quota" value="ADD RESOURCE
`ds_0`(HOST=127.0.0.1,PORT=3306,DB=test0,USER=ROOT);" />
- <distsql-case id="create-sharding-auto-table-rule-with-quota"
value="CREATE SHARDING TABLE RULE `t_order` (RESOURCES(ms_group_0,ms_group_1),
SHARDING_COLUMN=order_id,TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),
KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake,PROPERTIES('worker-id'=123))))"
/>
+ <distsql-case id="create-sharding-auto-table-rule-with-quota"
value="CREATE SHARDING TABLE RULE `t_order` (RESOURCES(ms_group_0,ms_group_1),
SHARDING_COLUMN=order_id,TYPE(NAME=hash_mod,PROPERTIES('sharding-count'=4)),
KEY_GENERATE_STRATEGY(COLUMN=another_id,TYPE(NAME=snowflake)))" />
<distsql-case id="create-sharding-binding-table-rule-with-quota"
value="CREATE SHARDING BINDING TABLE RULES (`t_order`,`t_order_item`),
(t_1,t_2)" />
<distsql-case id="create-sharding-broadcast-table-rule-with-quota"
value="CREATE SHARDING BROADCAST TABLE RULES(`t_1`,`t_2`)" />
<distsql-case id="create-readwrite-splitting-rule-with-quota"
value="CREATE READWRITE_SPLITTING RULE `ms_group_0` (WRITE_RESOURCE=primary_ds,
READ_RESOURCES(replica_ds_0,replica_ds_1), TYPE(NAME=random)))" />
@@ -59,7 +59,7 @@
<distsql-case id="create-encrypt-rule-with-quota" value="CREATE ENCRYPT
RULE `encrypt` (RESOURCE=ds_1,
COLUMNS((NAME=user_id,PLAIN=user_plain,CIPHER=user_cipher,TYPE(NAME=AES,PROPERTIES('aes-key-value'='123456abc'))),
(NAME=order_id, CIPHER =order_cipher,TYPE(NAME=MD5))))" />
<distsql-case id="create-encrypt-rule-with-query-with-cipher-column"
value="CREATE ENCRYPT RULE `encrypt` (RESOURCE=ds_1,
COLUMNS((NAME=user_id,PLAIN=user_plain,CIPHER=user_cipher,TYPE(NAME=AES,PROPERTIES('aes-key-value'='123456abc')))),QUERY_WITH_CIPHER_COLUMN=false)"
/>
<distsql-case id="create-shadow-rule-with-quota" value="CREATE SHADOW RULE
`shadow_rule`(SOURCE=demo_ds,SHADOW=demo_ds_shadow,t_order((TYPE(NAME=COLUMN_REGEX_MATCH,PROPERTIES('operation'='insert','column'='user_id','regex'='[1]'))),(simple_note_algorithm,TYPE(NAME=SIMPLE_NOTE,PROPERTIES('shadow'='true',foo='bar')))))"
/>
- <distsql-case id="create-sharding-key-generator" value="CREATE SHARDING
KEY GENERATOR uuid_key_generator(TYPE(NAME=uuid,PROPERTIES('worker-id'=123)))"
/>
+ <distsql-case id="create-sharding-key-generator" value="CREATE SHARDING
KEY GENERATOR uuid_key_generator(TYPE(NAME=uuid))" />
<distsql-case id="create-sharding-scaling-rule-without-configuration"
value="CREATE SHARDING SCALING RULE default_scaling" />
<distsql-case
id="create-sharding-scaling-rule-with-minimal-auto-configuration" value="CREATE
SHARDING SCALING RULE default_scaling (COMPLETION_DETECTOR
(TYPE(NAME=IDLE,PROPERTIES('incremental-task-idle-minute-threshold'=30))),DATA_CONSISTENCY_CHECKER
(TYPE(NAME=DATA_MATCH,PROPERTIES ('chunk-size'=1000))))" />
<distsql-case
id="create-sharding-scaling-rule-with-complete-auto-configuration"
value="CREATE SHARDING SCALING RULE default_scaling (INPUT
(WORKER_THREAD=40,BATCH_SIZE=1000,RATE_LIMITER (TYPE(NAME=QPS,PROPERTIES
('qps'=50)))),OUTPUT (WORKER_THREAD=40,BATCH_SIZE=1000,RATE_LIMITER
(TYPE(NAME=TPS,PROPERTIES ('tps'=2000)))),STREAM_CHANNEL (TYPE
(NAME=MEMORY,PROPERTIES ('block-queue-size'=10000))),COMPLETION_DETECTOR (TYPE
(NAME=IDLE,PROPERTIES ('incremental-task-idle-minute-threshold'=3 [...]
