seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

[Bug] [Oracle-CDC] SeaTunnel Job status is cancelling not cancelled

Open kingxeros opened this issue 1 month ago • 1 comments

Search before asking

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

What happened

Sometimes when I use seatunnel.sh -can jobid to cancel streaming jobs, the job status shows cancelling not cancelled。This state will always exist and the task will not disappear

SeaTunnel Version

2.3.10

SeaTunnel Config

env {
  # You can set SeaTunnel environment configuration here
  parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 180000
}

source {
    
   Oracle-CDC {
    plugin_output = "doss_owdoss_all_tables"
    username = ""
    password = ""
    database-names = ["PR043"]
    schema-names = ["OWDOSS"]
    table-names = ["PR043.OWDOSS.TM_SL_RETAIL_ORDER","PR043.OWDOSS.TM_SERIES","PR043.OWDOSS.TM_DEALER","PR043.OWDOSS.TM_SL_SND_LVL_RETAILER","PR043.OWDOSS.TM_MK_ONLINE_ORDER"]
    base-url = ""
    source.reader.close.timeout = 120000
    startup.mode = "latest"
    decimal_type_narrowing = "false"
    table-names-config = [
      {
        table = "PR043.OWDOSS.TM_SL_RETAIL_ORDER"
        primaryKeys = ["ID"]
      },
      {
        table = "PR043.OWDOSS.TM_SERIES"
        primaryKeys = ["ID"]
      },
      {
        table = "PR043.OWDOSS.TM_DEALER"
        primaryKeys = ["ID"]
      },
      {
        table = "PR043.OWDOSS.TM_SL_SND_LVL_RETAILER"
        primaryKeys = ["ID"]
      },
      {
        table = "PR043.OWDOSS.TM_MK_ONLINE_ORDER"
        primaryKeys = ["ID"]
      }
    ]
    debezium {
        log.mining.strategy = "online_catalog"
        log.mining.transaction.retention.hours = "1"
        database.history.store.only.captured.tables.ddl = "true"
        table.include.list = "OWDOSS.TM_SL_RETAIL_ORDER,OWDOSS.TM_SERIES,OWDOSS.TM_DEALER,OWDOSS.TM_SL_SND_LVL_RETAILER,OWDOSS.TM_MK_ONLINE_ORDER"
        heartbeat.interval.ms = "30000"
    }
  }

}

sink {
  StarRocks {
    plugin_input  = "doss_owdoss_all_tables"
    nodeUrls = [""]
    base-url = ""
    username = ""
    password = ""
    database = ""
    table = "S_DOSS_${schema_name}_${table_name}"
    # 支持upsert/delete事件同步(需要将选项参数enable_upsert_delete设置为true),仅支持表引擎为主键模型
    enable_upsert_delete = true
    }
}

Running Command

seatunnel.sh -can jobid

Error Exception

none

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

kingxeros avatar Nov 25 '25 06:11 kingxeros

This issue is related to #9995. If you happen to know the root cause of why it gets stuck in the CANCELING state, or if you have any related logs, please share them. They would be very helpful for investigating the problem.

dybyte avatar Nov 25 '25 11:11 dybyte