实测有效｜用 SeaTunnel 免费实现 MySQL→Oracle 实时同步，步骤超细

./bin/seatunnel.sh -hUsage: seatunnel.sh [options]  Options:    --async                         Run the job asynchronously, when the job                                     is submitted, the client will exit                                    (default: false)    -can, --cancel-job              Cancel job by JobId    --check                         Whether check config (default: false)    -cj, --close-job                Close client the task will also be closed                                     (default: true)    -cn, --cluster                  The name of cluster    -c, --config                    Config file    --decrypt                       Decrypt config file, When both --decrypt                                     and --encrypt are specified, only                                     --encrypt will take effect (default: false)     -m, --master, -e, --deploy-mode SeaTunnel job submit master, support                                     [local, cluster] (default: cluster)    --encrypt                       Encrypt config file, when both --decrypt                                     and --encrypt are specified, only                                     --encrypt will take effect (default: false)     --get_running_job_metrics       Gets metrics for running jobs (default: false)     -h, --help                      Show the usage message    -j, --job-id                    Get job status by JobId    -l, --list                      list job status (default: false)    --metrics                       Get job metrics by JobId    -n, --name                      SeaTunnel job name (default: SeaTunnel)    -r, --restore                   restore with savepoint by jobId    -s, --savepoint                 savepoint job by jobId    --set-job-id                    Set custom job id for job    -i, --variable                  Variable substitution, such as -i                                     city=beijing, or -i date=20190318.We use ',' as separator, when inside "", ',' are                                     treated as normal characters instead of                                     delimiters. For example, -i                                     city="beijing,shanghai". If you want to                                     use dynamic parameters, you can use the                                     following format: -i date=$(date                                     +"%Y%m%d"). (default: [])

./bin/seatunnel.sh -l

./bin/seatunnel.sh -s 967714059992432641

./bin/seatunnel.sh -r 967714059992432641 -c $SEATUNNEL_HOME/config/mysql_virdb_config 

./bin/seatunnel.sh -r 967714059992432641 -c $SEATUNNEL_HOME/config/mysql_virdb_config --async -n job_mysql_virdb

./bin/seatunnel.sh -can 967714059992432641

rootLogger.appenderRef.file.ref = fileAppenderappender.file.layout.pattern = [%X{ST-JID}] %d{yyyy-MM-dd HH:mm:ss,SSS} %-5p [%-30.30c{1.}] [%t] - %m%n

rootLogger.appenderRef.file.ref = routingAppenderappender.file.layout.pattern = %d{yyyy-MM-dd HH:mm:ss,SSS} %-5p [%-30.30c{1.}] [%t] - %m%n

seatunnel:engine:history-job-expire-minutes:1440telemetry:logs:scheduled-deletion-enable:true

seatunnel:engine:http:enable-http:trueport:8080

2025-04-24 17:59:42,640 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Fatal Error, 2025-04-24 17:59:42,641 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues2025-04-24 17:59:42,641 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Reason:SeaTunnel job executed failed 2025-04-24 17:59:42,642 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed        at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228)        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)        at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a sink for identifier 'jdbc'.        at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSink(FactoryUtil.java:250)        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createSinkAction(MultipleTableJobConfigParser.java:669)        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:592)        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:240)        at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123)        at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191)        at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165)        ... 2 moreCaused by: org.apache.seatunnel.api.configuration.util.OptionValidationException: ErrorCode:[API-02], ErrorDescription:[Option item validate failed] - There are unconfigured options, the options('database') are required because ['generate_sink_sql' == true] is true.        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:200)        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:107)        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:47)        at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSink(FactoryUtil.java:239)        ... 8 more2025-04-24 17:59:42,642 ERROR [o.a.s.c.s.SeaTunnel           ] [main] - ===============================================================================Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed        at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:228)        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)        at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34)Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a sink for identifier 'jdbc'.        at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSink(FactoryUtil.java:250)        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createSinkAction(MultipleTableJobConfigParser.java:669)        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:592)        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:240)        at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:123)        at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:191)        at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:165)        ... 2 moreCaused by: org.apache.seatunnel.api.configuration.util.OptionValidationException: ErrorCode:[API-02], ErrorDescription:[Option item validate failed] - There are unconfigured options, the options('database') are required because ['generate_sink_sql' == true] is true.        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:200)        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:107)        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:47)        at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSink(FactoryUtil.java:239)        ... 8 more

[967787050499571713] 2025-04-24 22:00:16,190 ERROR [.s.e.s.c.CheckpointCoordinator] [hz.main.generic-operation.thread-14] - report error from taskorg.apache.seatunnel.common.utils.SeaTunnelException: java.lang.IllegalArgumentException: can't find field [ID]        at org.apache.seatunnel.api.table.type.SeaTunnelRowType.indexOf(SeaTunnelRowType.java:87)        at org.apache.seatunnel.api.table.type.SeaTunnelRowType.indexOf(SeaTunnelRowType.java:77)        at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSink.createWriter(JdbcSink.java:133)        at org.apache.seatunnel.connectors.seatunnel.jdbc.sink.JdbcSink.createWriter(JdbcSink.java:66)        at org.apache.seatunnel.api.sink.multitablesink.MultiTableSink.createWriter(MultiTableSink.java:82)        at org.apache.seatunnel.engine.server.task.flow.SinkFlowLifeCycle.restoreState(SinkFlowLifeCycle.java:342)        at org.apache.seatunnel.engine.server.task.SeaTunnelTask.lambda$restoreState$16(SeaTunnelTask.java:426)        at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184)        at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)        at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)        at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)        at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)        at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)        at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151)        at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174)        at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)        at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418)        at org.apache.seatunnel.engine.server.task.SeaTunnelTask.restoreState(SeaTunnelTask.java:423)        at org.apache.seatunnel.engine.server.checkpoint.operation.NotifyTaskRestoreOperation.lambda$runInternal$0(NotifyTaskRestoreOperation.java:107)        at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)        at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)        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:750)        at org.apache.seatunnel.engine.server.checkpoint.CheckpointCoordinator.reportCheckpointErrorFromTask(CheckpointCoordinator.java:391) ~[seatunnel-starter.jar:2.3.10]        at org.apache.seatunnel.engine.server.checkpoint.CheckpointManager.reportCheckpointErrorFromTask(CheckpointManager.java:182) ~[seatunnel-starter.jar:2.3.10]        at org.apache.seatunnel.engine.server.checkpoint.operation.CheckpointErrorReportOperation.runInternal(CheckpointErrorReportOperation.java:48) ~[seatunnel-starter.jar:2.3.10]        at org.apache.seatunnel.engine.server.task.operation.TracingOperation.run(TracingOperation.java:42) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationservice.Operation.call(Operation.java:189) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.call(OperationRunnerImpl.java:273) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:248) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:213) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:175) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:139) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.executeRun(OperationThread.java:123) ~[seatunnel-starter.jar:2.3.10]        at com.hazelcast.internal.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:102) ~[seatunnel-starter.jar:2.3.10]

Error Msg = ORA-00955: name is already used by an existing object        at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:530)        ... 43 more        at org.apache.seatunnel.engine.server.CoordinatorService.lambda$submitJob$6(CoordinatorService.java:656)        at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)        at java.util.concurrent.FutureTask.run(FutureTask.java:266)        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:750)