apache / seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
https://seatunnel.apache.org/
Apache License 2.0
7.83k stars 1.77k forks source link

[BUG][Zeta]job name error #6470

Closed lovezhou1990 closed 5 months ago

lovezhou1990 commented 6 months ago

Search before asking

What happened

Submit the task to the cluster using seatunnel.sh-c job.com, and then use seatunnel.sh-l to view the task. The displayed job name is incorrect and not the name of job.name in the job.com configuration file

SeaTunnel Version

2.3.4

SeaTunnel Config

env {
  # You can set flink configuration here
  execution.parallelism = 1
  job.name = "st test"
  job.mode = "STREAMING"
  checkpoint.interval = 2000
  #execution.checkpoint.interval = 10000
  #execution.checkpoint.data-uri = "hdfs://localhost:9000/checkpoint"
}

source {
  MySQL-CDC {
    result_table_name = "company"
    parallelism = 1
    username = "xx"
    password = "xx"
    startup.mode = "latest" 
    database-names =["xxx"]
    table-names = ["xxx.company"]
    base-url = "jdbc:mysql://xxx:3306/test3_bigdata?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&rewriteBatchedStatements=true&zeroDateTimeBehavior=CONVERT_TO_NULL"
  }
}

sink {

  Elasticsearch {
      source_table_name = "company"
      hosts = ["http://xxx:19200"]
      index = "changelog_companyx" 
      max_batch_size=100
    }
}

Running Command

./bin/seatunnel.sh -c job.conf

Error Exception

no

Zeta or Flink or Spark Version

Zeta

Java or Scala Version

1.8

Screenshots

No response

Are you willing to submit PR?

Code of Conduct

github-actions[bot] commented 5 months ago

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

github-actions[bot] commented 5 months ago

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.