seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

Published 20 hours ago • verified publisher icon apache

[Bug] 数据库名称中含有点号“.”时报错

Open FakeTrader opened this issue 4 months ago • 1 comments

Search before asking

  • [x] I had searched in the issues and found no similar issues.

What happened

数据库名称中含有点号“.”时报错，Cannot get split 'dev1.4.2.data_zone' to get databaseName and tableName

SeaTunnel Version

2.3.9

SeaTunnel Config

source {
Jdbc {
    "connection_check_timeout_sec"="30"
    "fetch_size"="0"
    "use_select_count"="false"
    "skip_analyze"="false"
    "split.size"="8096"
    "split.even-distribution.factor.upper-bound"="100.0"
    "split.even-distribution.factor.lower-bound"="0.05"
    "split.sample-sharding.threshold"="1000"
    "split.inverse-sampling.rate"="1000"
    parallelism="1"
    "plugin_output"=Table979
    query="SELECT `id`, `zone_name`, `zone_logo`, `create_at`, `update_at`, `is_deleted` FROM `dev1.4.2`.`data_zone`"
    url="jdbc:mysql://******/dev1.4.2"
    driver="com.mysql.cj.jdbc.Driver"
    user=******
    password=******
}
}

Running Command

REST

Error Exception

[] 2025-06-05 12:51:46,789 ERROR [.s.r.f.ExceptionHandlingFilter] [qtp1906635841-108] - Error occurred while processing request
java.lang.IllegalArgumentException: Cannot get split 'dev1.4.2.data_zone' to get databaseName and tableName
        at org.apache.seatunnel.api.table.catalog.TablePath.of(TablePath.java:69) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.api.table.catalog.TablePath.of(TablePath.java:50) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.engine.server.rest.service.BaseService.lambda$getJobMetrics$5(BaseService.java:281) ~[seatunnel-starter.jar:2.3.9]
        at java.util.Iterator.forEachRemaining(Iterator.java:133) ~[?:?]
        at org.apache.seatunnel.engine.server.rest.service.BaseService.getJobMetrics(BaseService.java:277) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.engine.server.rest.service.BaseService.convertToJson(BaseService.java:203) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.engine.server.rest.service.JobInfoService.lambda$getRunningJobsJson$2(JobInfoService.java:133) ~[seatunnel-starter.jar:2.3.9]
        at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?]
        at java.util.Iterator.forEachRemaining(Iterator.java:133) ~[?:?]
        at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1845) ~[?:?]
        at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
        at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
        at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?]
        at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
        at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:693) ~[?:?]
        at org.apache.seatunnel.engine.server.rest.service.JobInfoService.getRunningJobsJson(JobInfoService.java:134) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.engine.server.rest.servlet.RunningJobsServlet.doGet(RunningJobsServlet.java:45) ~[seatunnel-starter.jar:2.3.9]
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:687) ~[seatunnel-hadoop3-3.1.4-uber.jar:2.3.9]
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[seatunnel-hadoop3-3.1.4-uber.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1656) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.engine.server.rest.filter.ExceptionHandlingFilter.doFilter(ExceptionHandlingFilter.java:50) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:552) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.Server.handle(Server.java:516) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) ~[seatunnel-starter.jar:2.3.9]
        at org.apache.seatunnel.shade.org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) ~[seatunnel-starter.jar:2.3.9]
        at java.lang.Thread.run(Thread.java:833) [?:?]

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

  • [ ] Yes I am willing to submit a PR!

Code of Conduct

FakeTrader avatar Jun 05 '25 05:06 FakeTrader