apache / seatunnel

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

[Bug] [Seatunnel-web] Oracle Jdbc Source/Sink Unable to fetch table fields #7985

Open shashwatsai opened 2 weeks ago

shashwatsai commented 2 weeks ago

Search before asking

What happened

While Configuring new Source for Oracle Jdbc, we are unable to fetch table fields for the table.

SeaTunnel Version

2.3.8

SeaTunnel Config

env {
"job.mode"=BATCH
"job.name"="SeaTunnel_Job"
"savemode.execute.location"=CLUSTER
}
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"
    "result_table_name"=Table15533734300256
    query="generated sql query"
    user="oracle_user"
    password=*********
    url="jdbc:oracle:thin:@//host-2:1521/ORACLEDB.visa.com"
    driver="oracle.jdbc.driver.OracleDriver"
}
}
transform {
}
sink {
Jdbc {
    "schema_save_mode"="CREATE_SCHEMA_WHEN_NOT_EXIST"
    "data_save_mode"="DROP_DATA"
    "create_index"="true"
    "connection_check_timeout_sec"="30"
    "batch_size"="1000"
    "is_exactly_once"="false"
    "max_commit_attempts"="3"
    "transaction_timeout_sec"="-1"
    "max_retries"="0"
    "auto_commit"="true"
    "support_upsert_by_query_primary_key_exist"="false"
    "multi_table_sink_replica"="1"
    "source_table_name"=Table15533734300256
    "generate_sink_sql"=true
    database="ds_test"
    table="source table"
    user=mysql_user
    driver="com.mysql.cj.jdbc.Driver"
    password="******"
    url="jdbc:mysql://hostm:3306/databaseName"
}
}

Running Command

1. Navigate to Seatunnel Web deployment
2. Create new synchronisation task.
3. Choose Oracle Jdbc as a source.

Error Exception

While fetching table Fields:
HTTP GET
http://sl73tskrapd841.visa.com:8801/seatunnel/api/v1/datasource/schema?datasourceId=15368238007488&databaseName=NLQDC&tableName=DFD_PO.TEDC_STATE_SEATUNNEL

Response:
{
    "code": -70001,
    "msg": "Datasource invalid. get table fields failed",
    "data": null,
    "failed": true,
    "success": false
}

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

image

Are you willing to submit PR?

Code of Conduct