Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a sink for identifier 'StarRocks' #6862

Open
3 tasks done
asdj07 opened this issue May 15, 2024 · 1 comment
Labels

Comments

@asdj07
Copy link

asdj07 commented May 15, 2024

Search before asking

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

What happened

mysql-cdc sink to starrocks,work error

SeaTunnel Version

2.3.5

SeaTunnel Config

env {
  parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 10000
}

source {
  MySQL-CDC {
    base-url = "jdbc:mysql://112.108.1.60:3306/test"
    username = "xx"
    password = "xx"
    table-names = ["test.test"]
    startup.mode = "initial"
  }
}


sink {
  StarRocks {
    nodeUrls = ["192.168.66.243:8030"]
    username = xx
    password = "xx"
    database = "test"
    table = "test1"
    #enable_upsert_delete = true
  }
}

Running Command

../bin/seatunnel.sh --config ./source_mysql_cdc_sr.conf -e local

Error Exception

Caused by: org.apache.seatunnel.api.table.factory.FactoryException: ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a sink for identifier 'StarRocks'.
        at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSink(FactoryUtil.java:130)
        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.createSinkAction(MultipleTableJobConfigParser.java:622)
        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSink(MultipleTableJobConfigParser.java:553)
        at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:200)
        at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88)
        at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:156)
        at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:149)
        ... 2 more
Caused by: org.apache.seatunnel.api.configuration.util.OptionValidationException: ErrorCode:[API-02], ErrorDescription:[Option item validate failed] - There are unconfigured options, the options('base-url') are required.
        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:134)
        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:95)
        at org.apache.seatunnel.api.configuration.util.ConfigValidator.validate(ConfigValidator.java:47)
        at org.apache.seatunnel.api.table.factory.FactoryUtil.createAndPrepareSink(FactoryUtil.java:126)
        ... 8 more

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

@asdj07 asdj07 added the bug label May 15, 2024
@liunaijie
Copy link
Contributor

ErrorDescription:[Option item validate failed] - There are unconfigured options, the options('base-url') are required.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants