wsm12138 commented on issue #18870:
URL: 
https://github.com/apache/shardingsphere/issues/18870#issuecomment-1174948099

   Proxy log
   ```
   [ERROR] 2022-07-05 19:04:28.521 [nioEventLoopGroup-4-1] 
o.a.s.d.p.m.i.client.MySQLClient - protocol resolution error
   io.netty.handler.codec.DecoderException: 
java.lang.IndexOutOfBoundsException: readerIndex(6) + length(1) exceeds 
writerIndex(6): PooledSlicedByteBuf(ridx: 6, widx: 6, cap: 6/6, unwrapped: 
PooledUnsafeDirectByteBuf(ridx: 9, widx: 9, cap: 1024))
           at 
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:480)
           at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:279)
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
           at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
           at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:327)
           at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:299)
           at 
io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:103)
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
           at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
           at 
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
           at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
           at 
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
           at 
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
           at 
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:722)
           at 
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:658)
           at 
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:584)
           at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496)
           at 
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986)
           at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
           at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: java.lang.IndexOutOfBoundsException: readerIndex(6) + length(1) 
exceeds writerIndex(6): PooledSlicedByteBuf(ridx: 6, widx: 6, cap: 6/6, 
unwrapped: PooledUnsafeDirectByteBuf(ridx: 9, widx: 9, cap: 1024))
           at 
io.netty.buffer.AbstractByteBuf.checkReadableBytes0(AbstractByteBuf.java:1442)
           at io.netty.buffer.AbstractByteBuf.readByte(AbstractByteBuf.java:730)
           at 
io.netty.buffer.AbstractByteBuf.readUnsignedByte(AbstractByteBuf.java:744)
           at 
org.apache.shardingsphere.db.protocol.mysql.payload.MySQLPacketPayload.readInt1(MySQLPacketPayload.java:49)
           at 
org.apache.shardingsphere.db.protocol.mysql.packet.binlog.MySQLBinlogEventHeader.<init>(MySQLBinlogEventHeader.java:55)
           at 
org.apache.shardingsphere.data.pipeline.mysql.ingest.client.netty.MySQLBinlogEventPacketDecoder.decode(MySQLBinlogEventPacketDecoder.java:60)
           at 
io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:510)
           at 
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:449)
           ... 23 common frames omitted
   [INFO ] 2022-07-05 19:04:28.521 [nioEventLoopGroup-4-1] 
o.a.s.d.p.m.i.client.MySQLClient - reconnect mysql client.
   [WARN ] 2022-07-05 19:04:28.524 [nioEventLoopGroup-4-1] 
o.a.s.d.p.m.i.client.MySQLClient - channel inactive
   [INFO ] 2022-07-05 19:04:28.524 [nioEventLoopGroup-4-1] 
o.a.s.d.p.m.i.client.MySQLClient - reconnect mysql client.
   [INFO ] 2022-07-05 19:04:38.089 [Curator-SafeNotifyService-0] 
o.a.s.d.p.c.e.PipelineJobExecutor - UPDATED job config: 
/scaling/0130317c30317c3054317c7368617264696e675f6462/config
   [INFO ] 2022-07-05 19:04:38.091 [Curator-SafeNotifyService-0] 
o.a.s.d.p.c.e.PipelineJobExecutor - 
jobId=0130317c30317c3054317c7368617264696e675f6462, deleted=false, disabled=true
   [INFO ] 2022-07-05 19:04:38.137 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJob - stop, 
jobId=0130317c30317c3054317c7368617264696e675f6462
   [INFO ] 2022-07-05 19:04:38.137 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJobSchedulerCenter - remove and stop 
0130317c30317c3054317c7368617264696e675f6462
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop, 
jobId=0130317c30317c3054317c7368617264696e675f6462, shardingItem=0
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop inventory task 
0130317c30317c3054317c7368617264696e675f6462 - ds_2.t_order_0#0
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.core.task.InventoryTask@4891a81f
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.ingest.MySQLInventoryDumper@427fc4e4
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.importer.MySQLImporter@1f53f66d
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop inventory task 
0130317c30317c3054317c7368617264696e675f6462 - ds_2.t_order_1#0
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.core.task.InventoryTask@6bcb3dd0
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.ingest.MySQLInventoryDumper@613356a0
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.importer.MySQLImporter@103a50d0
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop incremental task 
0130317c30317c3054317c7368617264696e675f6462 - ds_2
   [INFO ] 2022-07-05 19:04:38.138 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask@7036bee8
   [INFO ] 2022-07-05 19:04:38.139 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.ingest.MySQLIncrementalDumper@5fe3abea
   [INFO ] 2022-07-05 19:04:38.139 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.importer.MySQLImporter@4c19c9c3
   [INFO ] 2022-07-05 19:04:38.139 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.importer.MySQLImporter@2a58c017
   [INFO ] 2022-07-05 19:04:38.139 [Curator-SafeNotifyService-0] 
o.a.s.d.p.a.e.AbstractLifecycleExecutor - stop lifecycle executor: 
org.apache.shardingsphere.data.pipeline.mysql.importer.MySQLImporter@22a7513c
   [INFO ] 2022-07-05 19:04:38.150 [Curator-SafeNotifyService-0] 
o.a.s.d.p.s.r.RuleAlteredJobWorker - restoreSourceWriting, 
databaseName=sharding_db
   [INFO ] 2022-07-05 19:04:38.150 [Curator-SafeNotifyService-0] 
o.a.s.d.p.c.lock.PipelineSimpleLock - releaseLock, lockName=scaling-sharding_db
   [INFO ] 2022-07-05 19:04:38.166 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-0]
 o.a.s.d.p.m.i.MySQLIncrementalDumper - incremental dump, eventCount=21
   [ERROR] 2022-07-05 19:04:40.456 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-1]
 com.zaxxer.hikari.pool.HikariPool - HikariPool-9 - Exception during pool 
initialization.
   com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link 
failure
           at 
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
           at 
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:828)
           at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:448)
           at 
com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:241)
           at 
com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198)
           at 
com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
           at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:354)
           at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
           at 
com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:473)
           at 
com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:554)
           at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
           at 
com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:98)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:90)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getProtocolType(DatabaseTypeEngine.java:57)
           at 
org.apache.shardingsphere.mode.metadata.MetaDataContextsBuilder.build(MetaDataContextsBuilder.java:59)
           at 
org.apache.shardingsphere.mode.manager.memory.MemoryContextManagerBuilder.build(MemoryContextManagerBuilder.java:49)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.createContextManager(ShardingSphereDataSource.java:86)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.<init>(ShardingSphereDataSource.java:69)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:77)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:138)
           at 
org.apache.shardingsphere.driver.data.pipeline.datasource.creator.ShardingSpherePipelineDataSourceCreator.createPipelineDataSource(ShardingSpherePipelineDataSourceCreator.java:51)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory.newInstance(PipelineDataSourceFactory.java:44)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager.getDataSource(PipelineDataSourceManager.java:52)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.write(AbstractImporter.java:88)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.doStart(AbstractImporter.java:74)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.start(AbstractLifecycleExecutor.java:41)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.run(AbstractLifecycleExecutor.java:61)
           at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications 
link failure
           at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
           at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
           at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
           at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89)
           at com.mysql.cj.NativeSession.connect(NativeSession.java:119)
           at 
com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:948)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:818)
           ... 30 common frames omitted
   Caused by: java.net.ConnectException: Connection refused (Connection refused)
           at java.net.PlainSocketImpl.socketConnect(Native Method)
           at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
           at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
           at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
           at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
           at java.net.Socket.connect(Socket.java:607)
           at 
com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:156)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63)
           ... 33 common frames omitted
   [ERROR] 2022-07-05 19:04:41.470 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 com.zaxxer.hikari.pool.HikariPool - HikariPool-10 - Exception during pool 
initialization.
   com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link 
failure
           at 
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
           at 
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:828)
           at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:448)
           at 
com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:241)
           at 
com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198)
           at 
com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
           at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:354)
           at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
           at 
com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:473)
           at 
com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:554)
           at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
           at 
com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:98)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:90)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getProtocolType(DatabaseTypeEngine.java:57)
           at 
org.apache.shardingsphere.mode.metadata.MetaDataContextsBuilder.build(MetaDataContextsBuilder.java:59)
           at 
org.apache.shardingsphere.mode.manager.memory.MemoryContextManagerBuilder.build(MemoryContextManagerBuilder.java:49)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.createContextManager(ShardingSphereDataSource.java:86)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.<init>(ShardingSphereDataSource.java:69)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:77)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:138)
           at 
org.apache.shardingsphere.driver.data.pipeline.datasource.creator.ShardingSpherePipelineDataSourceCreator.createPipelineDataSource(ShardingSpherePipelineDataSourceCreator.java:51)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory.newInstance(PipelineDataSourceFactory.java:44)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager.getDataSource(PipelineDataSourceManager.java:52)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.write(AbstractImporter.java:88)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.doStart(AbstractImporter.java:74)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.start(AbstractLifecycleExecutor.java:41)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.run(AbstractLifecycleExecutor.java:61)
           at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications 
link failure
           at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
           at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
           at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
           at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89)
           at com.mysql.cj.NativeSession.connect(NativeSession.java:119)
           at 
com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:948)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:818)
           ... 30 common frames omitted
   Caused by: java.net.ConnectException: Connection refused (Connection refused)
           at java.net.PlainSocketImpl.socketConnect(Native Method)
           at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
           at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
           at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
           at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
           at java.net.Socket.connect(Socket.java:607)
           at 
com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:156)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63)
           ... 33 common frames omitted
   [ERROR] 2022-07-05 19:04:42.485 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-2]
 com.zaxxer.hikari.pool.HikariPool - HikariPool-11 - Exception during pool 
initialization.
   com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link 
failure
           at 
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
           at 
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:828)
           at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:448)
           at 
com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:241)
           at 
com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198)
           at 
com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
           at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:354)
           at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
           at 
com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:473)
           at 
com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:554)
           at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
           at 
com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:98)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:90)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getProtocolType(DatabaseTypeEngine.java:57)
           at 
org.apache.shardingsphere.mode.metadata.MetaDataContextsBuilder.build(MetaDataContextsBuilder.java:59)
           at 
org.apache.shardingsphere.mode.manager.memory.MemoryContextManagerBuilder.build(MemoryContextManagerBuilder.java:49)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.createContextManager(ShardingSphereDataSource.java:86)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.<init>(ShardingSphereDataSource.java:69)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:77)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:138)
           at 
org.apache.shardingsphere.driver.data.pipeline.datasource.creator.ShardingSpherePipelineDataSourceCreator.createPipelineDataSource(ShardingSpherePipelineDataSourceCreator.java:51)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory.newInstance(PipelineDataSourceFactory.java:44)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager.getDataSource(PipelineDataSourceManager.java:52)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.write(AbstractImporter.java:88)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.doStart(AbstractImporter.java:74)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.start(AbstractLifecycleExecutor.java:41)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.run(AbstractLifecycleExecutor.java:61)
           at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications 
link failure
           at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
           at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
           at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
           at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89)
           at com.mysql.cj.NativeSession.connect(NativeSession.java:119)
           at 
com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:948)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:818)
           ... 30 common frames omitted
   Caused by: java.net.ConnectException: Connection refused (Connection refused)
           at java.net.PlainSocketImpl.socketConnect(Native Method)
           at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
           at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
           at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
           at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
           at java.net.Socket.connect(Socket.java:607)
           at 
com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:156)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63)
           ... 33 common frames omitted
   [ERROR] 2022-07-05 19:04:42.490 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.core.task.IncrementalTask - importer onFailure, taskId=ds_2
   java.lang.IllegalArgumentException: Communications link failure
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:101)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:90)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getProtocolType(DatabaseTypeEngine.java:57)
           at 
org.apache.shardingsphere.mode.metadata.MetaDataContextsBuilder.build(MetaDataContextsBuilder.java:59)
           at 
org.apache.shardingsphere.mode.manager.memory.MemoryContextManagerBuilder.build(MemoryContextManagerBuilder.java:49)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.createContextManager(ShardingSphereDataSource.java:86)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.<init>(ShardingSphereDataSource.java:69)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:77)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:138)
           at 
org.apache.shardingsphere.driver.data.pipeline.datasource.creator.ShardingSpherePipelineDataSourceCreator.createPipelineDataSource(ShardingSpherePipelineDataSourceCreator.java:51)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory.newInstance(PipelineDataSourceFactory.java:44)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager.getDataSource(PipelineDataSourceManager.java:52)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.write(AbstractImporter.java:88)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.doStart(AbstractImporter.java:74)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.start(AbstractLifecycleExecutor.java:41)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.run(AbstractLifecycleExecutor.java:61)
           at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: com.mysql.cj.jdbc.exceptions.CommunicationsException: 
Communications link failure
           at 
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
           at 
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:828)
           at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:448)
           at 
com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:241)
           at 
com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198)
           at 
com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
           at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:354)
           at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
           at 
com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:473)
           at 
com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:554)
           at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
           at 
com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:98)
           ... 19 common frames omitted
   Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications 
link failure
           at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
           at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
           at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
           at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89)
           at com.mysql.cj.NativeSession.connect(NativeSession.java:119)
           at 
com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:948)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:818)
           ... 30 common frames omitted
   Caused by: java.net.ConnectException: Connection refused (Connection refused)
           at java.net.PlainSocketImpl.socketConnect(Native Method)
           at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
           at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
           at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
           at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
           at java.net.Socket.connect(Socket.java:607)
           at 
com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:156)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63)
           ... 33 common frames omitted
   [ERROR] 2022-07-05 19:04:42.491 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.s.r.RuleAlteredJobScheduler - Incremental task execute failed.
   
org.apache.shardingsphere.data.pipeline.core.exception.PipelineJobExecutionException:
 Task ds_2 execute failed
           at 
org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask.waitForResult(IncrementalTask.java:129)
           at 
org.apache.shardingsphere.data.pipeline.core.task.IncrementalTask.doStart(IncrementalTask.java:86)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.start(AbstractLifecycleExecutor.java:41)
           at 
org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor.run(AbstractLifecycleExecutor.java:61)
           at 
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
           at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
           at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
           at java.lang.Thread.run(Thread.java:748)
   Caused by: java.lang.IllegalArgumentException: Communications link failure
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:101)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:90)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getProtocolType(DatabaseTypeEngine.java:57)
           at 
org.apache.shardingsphere.mode.metadata.MetaDataContextsBuilder.build(MetaDataContextsBuilder.java:59)
           at 
org.apache.shardingsphere.mode.manager.memory.MemoryContextManagerBuilder.build(MemoryContextManagerBuilder.java:49)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.createContextManager(ShardingSphereDataSource.java:86)
           at 
org.apache.shardingsphere.driver.jdbc.core.datasource.ShardingSphereDataSource.<init>(ShardingSphereDataSource.java:69)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:77)
           at 
org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory.createDataSource(ShardingSphereDataSourceFactory.java:138)
           at 
org.apache.shardingsphere.driver.data.pipeline.datasource.creator.ShardingSpherePipelineDataSourceCreator.createPipelineDataSource(ShardingSpherePipelineDataSourceCreator.java:51)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceFactory.newInstance(PipelineDataSourceFactory.java:44)
           at 
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager.getDataSource(PipelineDataSourceManager.java:52)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.write(AbstractImporter.java:88)
           at 
org.apache.shardingsphere.data.pipeline.core.importer.AbstractImporter.doStart(AbstractImporter.java:74)
           ... 6 common frames omitted
   Caused by: com.mysql.cj.jdbc.exceptions.CommunicationsException: 
Communications link failure
           at 
com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174)
           at 
com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:828)
           at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:448)
           at 
com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:241)
           at 
com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:198)
           at 
com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:138)
           at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:354)
           at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
           at 
com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:473)
           at 
com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:554)
           at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:115)
           at 
com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:112)
           at 
org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine.getDatabaseType(DatabaseTypeEngine.java:98)
           ... 19 common frames omitted
   Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications 
link failure
           at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method)
           at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
           at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
           at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151)
           at 
com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:89)
           at com.mysql.cj.NativeSession.connect(NativeSession.java:119)
           at 
com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:948)
           at 
com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:818)
           ... 30 common frames omitted
   Caused by: java.net.ConnectException: Connection refused (Connection refused)
           at java.net.PlainSocketImpl.socketConnect(Native Method)
           at 
java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
           at 
java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
           at 
java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
           at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
           at java.net.Socket.connect(Socket.java:607)
           at 
com.mysql.cj.protocol.StandardSocketFactory.connect(StandardSocketFactory.java:156)
           at 
com.mysql.cj.protocol.a.NativeSocketConnection.connect(NativeSocketConnection.java:63)
           ... 33 common frames omitted
   [INFO ] 2022-07-05 19:04:42.492 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop, 
jobId=0130317c30317c3054317c7368617264696e675f6462, shardingItem=0
   [INFO ] 2022-07-05 19:04:42.492 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop inventory task 
0130317c30317c3054317c7368617264696e675f6462 - ds_2.t_order_0#0
   [INFO ] 2022-07-05 19:04:42.492 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop inventory task 
0130317c30317c3054317c7368617264696e675f6462 - ds_2.t_order_1#0
   [INFO ] 2022-07-05 19:04:42.492 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.s.r.RuleAlteredJobScheduler - stop incremental task 
0130317c30317c3054317c7368617264696e675f6462 - ds_2
   [INFO ] 2022-07-05 19:04:42.493 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.s.r.RuleAlteredJobWorker - restoreSourceWriting, 
databaseName=sharding_db
   [INFO ] 2022-07-05 19:04:42.493 
[ShardingSphere-Scaling-Incremental-0130317c30317c3054317c7368617264696e675f6462-3]
 o.a.s.d.p.c.lock.PipelineSimpleLock - releaseLock, lockName=scaling-sharding_db
   [INFO ] 2022-07-05 19:04:43.101 [Curator-SafeNotifyService-0] 
o.a.s.d.p.c.e.PipelineJobExecutor - UPDATED job config: 
/scaling/0130317c30317c3054317c7368617264696e675f6462/config
   [INFO ] 2022-07-05 19:04:43.138 [pool-32-thread-2] 
o.a.s.d.p.c.lock.PipelineSimpleLock - tryLock, lockName=scaling-sharding_db, 
timeoutMills=3000, result=false
   [INFO ] 2022-07-05 19:04:43.138 [pool-32-thread-2] 
o.a.s.d.p.c.e.PipelineJobExecutor - tryLock failed, databaseName=sharding_db


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to