You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2022/05/26 11:20:06 UTC
[shardingsphere] branch master updated: Add preconditions of scaling IT (#17969)
This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng 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 1edd573cddf Add preconditions of scaling IT (#17969)
1edd573cddf is described below
commit 1edd573cddf11eca33b8c8f726e801c30c6d6309
Author: azexcy <10...@users.noreply.github.com>
AuthorDate: Thu May 26 19:19:58 2022 +0800
Add preconditions of scaling IT (#17969)
* Add watcher of scaling it
* Multiple checks of metadata
* Fix codestyle
* Code optimize
---
.../data/pipeline/cases/base/BaseITCase.java | 82 ++++++++++++++--------
.../pipeline/cases/command/CommonSQLCommand.java | 4 +-
.../cases/general/MySQLGeneralScalingIT.java | 3 +-
.../cases/general/PostgreSQLGeneralScalingIT.java | 1 -
.../cases/primarykey/TextPrimaryKeyScalingIT.java | 3 +-
.../pipeline/framework/watcher/ScalingWatcher.java | 54 ++++++++++++++
.../src/test/resources/env/common/command.xml | 4 +-
.../src/test/resources/logback-test.xml | 3 -
8 files changed, 113 insertions(+), 41 deletions(-)
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/base/BaseITCase.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/base/BaseITCase.java
index 58189d4406a..a07ce91d290 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/base/BaseITCase.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/base/BaseITCase.java
@@ -37,9 +37,10 @@ import org.apache.shardingsphere.integration.data.pipeline.framework.container.c
import org.apache.shardingsphere.integration.data.pipeline.framework.container.database.DockerDatabaseContainer;
import org.apache.shardingsphere.integration.data.pipeline.framework.helper.ScalingCaseHelper;
import org.apache.shardingsphere.integration.data.pipeline.framework.param.ScalingParameterized;
+import org.apache.shardingsphere.integration.data.pipeline.framework.watcher.ScalingWatcher;
import org.apache.shardingsphere.integration.data.pipeline.util.DatabaseTypeUtil;
import org.apache.shardingsphere.test.integration.env.DataSourceEnvironment;
-import org.junit.After;
+import org.junit.Rule;
import org.springframework.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
@@ -48,6 +49,7 @@ import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Arrays;
+import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
@@ -71,6 +73,10 @@ public abstract class BaseITCase {
private static final IntegrationTestEnvironment ENV = IntegrationTestEnvironment.getInstance();
+ @Rule
+ @Getter(AccessLevel.NONE)
+ public ScalingWatcher scalingWatcher;
+
private final BaseComposedContainer composedContainer;
private final CommonSQLCommand commonSQLCommand;
@@ -92,6 +98,7 @@ public abstract class BaseITCase {
composedContainer.start();
commonSQLCommand = JAXB.unmarshal(BaseITCase.class.getClassLoader().getResource("env/common/command.xml"), CommonSQLCommand.class);
createProxyDatabase(parameterized.getDatabaseType());
+ scalingWatcher = new ScalingWatcher(composedContainer, jdbcTemplate);
}
@SneakyThrows
@@ -145,6 +152,8 @@ public abstract class BaseITCase {
addSourceResource0(connection);
}
}
+ List<Map<String, Object>> resources = queryForListWithLog("SHOW SCHEMA RESOURCES from sharding_db");
+ assertThat(resources.size(), is(2));
}
private void addSourceResource0(final Connection connection) throws SQLException {
@@ -164,7 +173,9 @@ public abstract class BaseITCase {
.replace("${ds2}", JDBC_URL_APPENDER.appendQueryProperties(getActualJdbcUrlTemplate("ds_2"), queryProps))
.replace("${ds3}", JDBC_URL_APPENDER.appendQueryProperties(getActualJdbcUrlTemplate("ds_3"), queryProps))
.replace("${ds4}", JDBC_URL_APPENDER.appendQueryProperties(getActualJdbcUrlTemplate("ds_4"), queryProps));
- getJdbcTemplate().execute(addTargetResource);
+ executeWithLog(addTargetResource);
+ List<Map<String, Object>> resources = queryForListWithLog("SHOW SCHEMA RESOURCES from sharding_db");
+ assertThat(resources.size(), is(5));
}
private String getActualJdbcUrlTemplate(final String databaseName) {
@@ -177,31 +188,41 @@ public abstract class BaseITCase {
}
protected void initShardingAlgorithm() throws InterruptedException {
- jdbcTemplate.execute(getCommonSQLCommand().getCreateDatabaseShardingAlgorithm());
+ executeWithLog(getCommonSQLCommand().getCreateDatabaseShardingAlgorithm());
TimeUnit.SECONDS.sleep(2);
- jdbcTemplate.execute(getCommonSQLCommand().getCreateOrderShardingAlgorithm());
+ executeWithLog(getCommonSQLCommand().getCreateOrderShardingAlgorithm());
TimeUnit.SECONDS.sleep(2);
- jdbcTemplate.execute(getCommonSQLCommand().getCreateOrderItemShardingAlgorithm());
+ executeWithLog(getCommonSQLCommand().getCreateOrderItemShardingAlgorithm());
}
protected void createAllSharingTableRule() {
- jdbcTemplate.execute(commonSQLCommand.getCreateAllSharingTableRule());
+ executeWithLog(commonSQLCommand.getCreateOrderWithItemSharingTableRule());
}
protected void createOrderSharingTableRule() {
- jdbcTemplate.execute(commonSQLCommand.getCreateOrderShardingTableRule());
+ executeWithLog(commonSQLCommand.getCreateOrderShardingTableRule());
}
protected void bindingShardingRule() {
- jdbcTemplate.execute("CREATE SHARDING BINDING TABLE RULES (t_order,t_order_item)");
+ executeWithLog("CREATE SHARDING BINDING TABLE RULES (t_order,t_order_item)");
}
protected void createScalingRule() {
- jdbcTemplate.execute("CREATE SHARDING SCALING RULE scaling_manual (INPUT(SHARDING_SIZE=1000), DATA_CONSISTENCY_CHECKER(TYPE(NAME=DATA_MATCH)))");
+ executeWithLog("CREATE SHARDING SCALING RULE scaling_manual (INPUT(SHARDING_SIZE=1000), DATA_CONSISTENCY_CHECKER(TYPE(NAME=DATA_MATCH)))");
}
protected void createSchema(final String schemaName) {
- jdbcTemplate.execute(String.format("CREATE SCHEMA %s", schemaName));
+ executeWithLog(String.format("CREATE SCHEMA %s", schemaName));
+ }
+
+ protected void executeWithLog(final String sql) {
+ log.info("jdbcTemplate execute:{}", sql);
+ jdbcTemplate.execute(sql);
+ }
+
+ protected List<Map<String, Object>> queryForListWithLog(final String sql) {
+ log.info("jdbcTemplate queryForMap:{}", sql);
+ return jdbcTemplate.queryForList(sql);
}
protected void startIncrementTask(final BaseIncrementTask baseIncrementTask) {
@@ -209,10 +230,11 @@ public abstract class BaseITCase {
getIncreaseTaskThread().start();
}
- protected void assertOriginalSourceSuccess() {
- List<Map<String, Object>> previewResults = getJdbcTemplate().queryForList("PREVIEW SELECT COUNT(1) FROM t_order");
- Set<Object> originalSources = previewResults.stream().map(each -> each.get("data_source_name")).collect(Collectors.toSet());
- assertThat(originalSources, is(new HashSet<>(Arrays.asList("ds_0", "ds_1"))));
+ protected void assertBeforeApplyScalingMetadataCorrectly() {
+ List<Map<String, Object>> previewResults = queryForListWithLog("PREVIEW SELECT COUNT(1) FROM t_order");
+ Set<Object> actualSources = previewResults.stream().map(each -> each.get("actual_sql")).collect(Collectors.toSet());
+ assertThat(previewResults.stream().map(each -> each.get("data_source_name")).collect(Collectors.toSet()), is(new HashSet<>(Arrays.asList("ds_0", "ds_1"))));
+ assertThat(actualSources, is(new HashSet<>(Collections.singletonList("SELECT COUNT(1) FROM t_order_0 UNION ALL SELECT COUNT(1) FROM t_order_1"))));
}
/**
@@ -221,18 +243,20 @@ public abstract class BaseITCase {
* @throws InterruptedException interrupted exception
*/
protected void assertCheckMatchConsistencySuccess() throws InterruptedException {
+ assertBeforeApplyScalingMetadataCorrectly();
if (null != increaseTaskThread) {
increaseTaskThread.join(60 * 1000L);
}
- TimeUnit.SECONDS.sleep(2);
- List<Map<String, Object>> scalingListMap = getJdbcTemplate().queryForList("SHOW SCALING LIST");
+ TimeUnit.SECONDS.sleep(4);
+ List<Map<String, Object>> scalingListMap = queryForListWithLog("SHOW SCALING LIST");
assertThat(scalingListMap.size(), is(1));
Object jobId = scalingListMap.get(0).get("id");
log.info("jobId: {}", jobId);
Map<String, String> actualStatusMap = new HashMap<>(2, 1);
+ String showScalingStatus = String.format("SHOW SCALING STATUS %s", jobId);
for (int i = 0; i < 15; i++) {
- List<Map<String, Object>> showScalingStatusResMap = jdbcTemplate.queryForList(String.format("SHOW SCALING STATUS %s", jobId));
- log.info("actualStatusMap: {}", actualStatusMap);
+ List<Map<String, Object>> showScalingStatusResMap = queryForListWithLog(showScalingStatus);
+ log.info("{}: {}", showScalingStatus, showScalingStatusResMap);
boolean finished = true;
for (Map<String, Object> entry : showScalingStatusResMap) {
String status = entry.get("status").toString();
@@ -249,25 +273,25 @@ public abstract class BaseITCase {
if (finished) {
break;
}
+ assertBeforeApplyScalingMetadataCorrectly();
TimeUnit.SECONDS.sleep(2);
}
assertThat(actualStatusMap.values().stream().filter(StringUtils::isNotBlank).collect(Collectors.toSet()).size(), is(1));
- jdbcTemplate.execute(String.format("STOP SCALING SOURCE WRITING %s", jobId));
- List<Map<String, Object>> checkScalingResults = jdbcTemplate.queryForList(String.format("CHECK SCALING %s BY TYPE (NAME=DATA_MATCH)", jobId));
+ executeWithLog(String.format("STOP SCALING SOURCE WRITING %s", jobId));
+ assertBeforeApplyScalingMetadataCorrectly();
+ List<Map<String, Object>> checkScalingResults = queryForListWithLog(String.format("CHECK SCALING %s BY TYPE (NAME=DATA_MATCH)", jobId));
log.info("checkScalingResults: {}", checkScalingResults);
for (Map<String, Object> entry : checkScalingResults) {
assertTrue(Boolean.parseBoolean(entry.get("records_content_matched").toString()));
}
- jdbcTemplate.execute(String.format("APPLY SCALING %s", jobId));
+ assertBeforeApplyScalingMetadataCorrectly();
+ executeWithLog(String.format("APPLY SCALING %s", jobId));
// TODO make sure the scaling job was applied
TimeUnit.SECONDS.sleep(2);
- List<Map<String, Object>> previewResults = jdbcTemplate.queryForList("PREVIEW SELECT COUNT(1) FROM t_order");
- Set<Object> targetSources = previewResults.stream().map(each -> each.get("data_source_name")).collect(Collectors.toSet());
- assertThat(targetSources, is(new HashSet<>(Arrays.asList("ds_2", "ds_3", "ds_4"))));
- }
-
- @After
- public void stopContainer() {
- composedContainer.stop();
+ List<Map<String, Object>> previewResults = queryForListWithLog("PREVIEW SELECT COUNT(1) FROM t_order");
+ Set<Object> targetSources = previewResults.stream().map(each -> each.get("actual_sql")).collect(Collectors.toSet());
+ assertThat(previewResults.stream().map(each -> each.get("data_source_name")).collect(Collectors.toSet()), is(new HashSet<>(Arrays.asList("ds_2", "ds_3", "ds_4"))));
+ assertThat(targetSources, is(new HashSet<>(Arrays.asList("SELECT COUNT(1) FROM t_order_0 UNION ALL SELECT COUNT(1) FROM t_order_3",
+ "SELECT COUNT(1) FROM t_order_1 UNION ALL SELECT COUNT(1) FROM t_order_4", "SELECT COUNT(1) FROM t_order_2 UNION ALL SELECT COUNT(1) FROM t_order_5"))));
}
}
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/command/CommonSQLCommand.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/command/CommonSQLCommand.java
index 5c132e4cda1..67abf9253bd 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/command/CommonSQLCommand.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/command/CommonSQLCommand.java
@@ -38,8 +38,8 @@ public final class CommonSQLCommand {
@XmlElement(name = "create-order-item-sharding-algorithm")
private String createOrderItemShardingAlgorithm;
- @XmlElement(name = "create-all-sharding-table-rule")
- private String createAllSharingTableRule;
+ @XmlElement(name = "create-order-with-item-sharding-table-rule")
+ private String createOrderWithItemSharingTableRule;
@XmlElement(name = "create-order-sharding-table-rule")
private String createOrderShardingTableRule;
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/MySQLGeneralScalingIT.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/MySQLGeneralScalingIT.java
index 1625f0a7ff1..1bc0cbae853 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/MySQLGeneralScalingIT.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/MySQLGeneralScalingIT.java
@@ -78,9 +78,8 @@ public final class MySQLGeneralScalingIT extends BaseExtraSQLITCase {
getJdbcTemplate().batchUpdate(getExtraSQLCommand().getFullInsertOrder(), dataPair.getLeft());
getJdbcTemplate().batchUpdate(getExtraSQLCommand().getFullInsertOrderItem(), dataPair.getRight());
startIncrementTask(new MySQLIncrementTask(getJdbcTemplate(), keyGenerateAlgorithm, true));
- assertOriginalSourceSuccess();
addTargetResource();
- getJdbcTemplate().execute(getCommonSQLCommand().getAutoAlterOrderWithItemShardingTableRule());
+ executeWithLog(getCommonSQLCommand().getAutoAlterOrderWithItemShardingTableRule());
assertCheckMatchConsistencySuccess();
}
}
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/PostgreSQLGeneralScalingIT.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/PostgreSQLGeneralScalingIT.java
index 0ebb764c4f0..cba6dc767df 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/PostgreSQLGeneralScalingIT.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/general/PostgreSQLGeneralScalingIT.java
@@ -82,7 +82,6 @@ public final class PostgreSQLGeneralScalingIT extends BaseExtraSQLITCase {
getJdbcTemplate().batchUpdate(getExtraSQLCommand().getFullInsertOrder(), dataPair.getLeft());
getJdbcTemplate().batchUpdate(getExtraSQLCommand().getFullInsertOrderItem(), dataPair.getRight());
startIncrementTask(new PostgreSQLIncrementTask(getJdbcTemplate(), new SnowflakeKeyGenerateAlgorithm(), "test", true));
- assertOriginalSourceSuccess();
addTargetResource();
getJdbcTemplate().execute(getCommonSQLCommand().getAutoAlterOrderWithItemShardingTableRule());
assertCheckMatchConsistencySuccess();
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/primarykey/TextPrimaryKeyScalingIT.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/primarykey/TextPrimaryKeyScalingIT.java
index 4e5a6c25a26..898f9a23957 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/primarykey/TextPrimaryKeyScalingIT.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/primarykey/TextPrimaryKeyScalingIT.java
@@ -73,9 +73,8 @@ public class TextPrimaryKeyScalingIT extends BaseExtraSQLITCase {
createOrderSharingTableRule();
createOrderTable();
batchInsertOrder();
- assertOriginalSourceSuccess();
addTargetResource();
- getJdbcTemplate().execute(getCommonSQLCommand().getAutoAlterOrderShardingTableRule());
+ executeWithLog(getCommonSQLCommand().getAutoAlterOrderShardingTableRule());
assertCheckMatchConsistencySuccess();
}
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java
new file mode 100644
index 00000000000..bd97b865009
--- /dev/null
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/framework/watcher/ScalingWatcher.java
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.shardingsphere.integration.data.pipeline.framework.watcher;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.shardingsphere.integration.data.pipeline.framework.container.compose.BaseComposedContainer;
+import org.apache.shardingsphere.integration.data.pipeline.framework.container.compose.NativeComposedContainer;
+import org.junit.rules.TestWatcher;
+import org.junit.runner.Description;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+import java.util.List;
+import java.util.Map;
+
+@RequiredArgsConstructor
+@Slf4j
+public class ScalingWatcher extends TestWatcher {
+
+ private final BaseComposedContainer composedContainer;
+
+ private final JdbcTemplate jdbcTemplate;
+
+ @Override
+ protected void failed(final Throwable e, final Description description) {
+ if (composedContainer instanceof NativeComposedContainer) {
+ super.failed(e, description);
+ return;
+ }
+ List<Map<String, Object>> previewList = jdbcTemplate.queryForList("preview select * from t_order");
+ List<Map<String, Object>> shardingAlgorithms = jdbcTemplate.queryForList("SHOW SHARDING ALGORITHMS");
+ log.warn("watcher failed, preview:{}, shardingAlgorithms:{}", previewList, shardingAlgorithms);
+ }
+
+ @Override
+ protected void finished(final Description description) {
+ composedContainer.close();
+ }
+}
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/env/common/command.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/env/common/command.xml
index 4aaa74c549a..3e7bb611090 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/env/common/command.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/env/common/command.xml
@@ -31,7 +31,7 @@
TYPE(NAME=INLINE,PROPERTIES("algorithm-expression"="t_order_item_${order_id % 2}")))
</create-order-item-sharding-algorithm>
- <create-all-sharding-table-rule>
+ <create-order-with-item-sharding-table-rule>
CREATE SHARDING TABLE RULE t_order (
DATANODES("ds_${0..1}.t_order_${0..1}"),
DATABASE_STRATEGY(TYPE=standard,SHARDING_COLUMN=user_id,SHARDING_ALGORITHM=database_inline),
@@ -43,7 +43,7 @@
TABLE_STRATEGY(TYPE=standard,SHARDING_COLUMN=order_id,SHARDING_ALGORITHM=t_order_item_inline),
KEY_GENERATE_STRATEGY(COLUMN=order_id,TYPE(NAME=snowflake))
)
- </create-all-sharding-table-rule>
+ </create-order-with-item-sharding-table-rule>
<create-order-sharding-table-rule>
CREATE SHARDING TABLE RULE t_order (
diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/logback-test.xml b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/logback-test.xml
index 200d454e788..3037e476734 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/logback-test.xml
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/resources/logback-test.xml
@@ -22,9 +22,6 @@
<pattern>[%-5level] %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
</encoder>
</appender>
- <logger name="org.springframework.jdbc.core.JdbcTemplate" level="DEBUG" additivity="false">
- <appender-ref ref="console" />
- </logger>
<logger name="org.apache.shardingsphere.test.integration.framework.container.atomic.DockerITContainer" level="WARN" />
<logger name="com.zaxxer.hikari.pool.ProxyConnection" level="OFF" />
<root level="INFO">