shashwatsai commented on issue #9113:
URL: https://github.com/apache/seatunnel/issues/9113#issuecomment-2789745040
In Hive, column names starting with digits are not valid identifiers,
quoting with backticks might work, as hive follows Hive follows SQL identifier
rules loosely. You can try the following, ideally if possible, we should follow
the naming convention and not name columns starting with digits.
```
env {
parallelism = 1
job.mode = "BATCH"
}
source {
Hive {
table_name = "ads.table"
metastore_uri = "thrift://localhost:7004"
hive.hadoop.conf-path = "/app/hadoop/etc/hadoop/"
read_columns = [shelf_id,`7_work_day_gmv`]
read_partitions = ["dt=20250402"]
compress_codec = "parquet"
}
}
sink {
jdbc {
url =
"jdbc:mysql://locahost:3306/fe_dm?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
user = "xx"
password = "xx"
batch_size = 50000
query = "insert into xxx (shelf_id,7_work_day_gmv) values (?,?)"
enable_upsert = "false"
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
