方便更快捷的说明问题,可以按需填写(可删除)
使用环境: 本地测试
场景、问题:
我现在有一张 数据量很大 然后我想在一个库上面分多张表 到时候把目标数据迁移到逻辑主表中 然后主表会存在各个分表中
已进行操作:
现状:
控制台报错 报的是
[ERROR] 2023-04-20 20:09:07.416 [Connection-8-ThreadExecutor] o.a.s.p.f.c.CommandExecutorTask - Exception occur:
java.lang.NullPointerException: null
at org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory$1.initialize(PipelineAPIFactory.java:49)
at org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory$1.initialize(PipelineAPIFactory.java:45)
at org.apache.commons.lang3.concurrent.LazyInitializer.get(LazyInitializer.java:106)
at org.apache.shardingsphere.data.pipeline.core.api.PipelineAPIFactory.getGovernanceRepositoryAPI(PipelineAPIFactory.java:60)
at org.apache.shardingsphere.data.pipeline.core.api.impl.PipelineDataSourcePersistService.load(PipelineDataSourcePersistService.java:43)
at org.apache.shardingsphere.data.pipeline.scenario.migration.api.impl.MigrationJobAPI.addMigrationSourceResources(MigrationJobAPI.java:437)
at org.apache.shardingsphere.migration.distsql.handler.update.RegisterMigrationSourceStorageUnitUpdater.executeUpdate(RegisterMigrationSourceStorageUnitUpdater.java:56)
at org.apache.shardingsphere.migration.distsql.handler.update.RegisterMigrationSourceStorageUnitUpdater.executeUpdate(RegisterMigrationSourceStorageUnitUpdater.java:41)
at org.apache.shardingsphere.proxy.backend.handler.distsql.ral.UpdatableRALBackendHandler.execute(UpdatableRALBackendHandler.java:48)
at org.apache.shardingsphere.proxy.frontend.mysql.command.query.text.query.MySQLComQueryPacketExecutor.execute(MySQLComQueryPacketExecutor.java:92)
at org.apache.shardingsphere.proxy.frontend.command.CommandExecutorTask.doExecuteCommand(CommandExecutorTask.java:114)
at org.apache.shardingsphere.proxy.frontend.command.CommandExecutorTask.executeCommand(CommandExecutorTask.java:109)
at org.apache.shardingsphere.proxy.frontend.command.CommandExecutorTask.run(CommandExecutorTask.java:77)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)