yzeng1618 opened a new issue, #9457:
URL: https://github.com/apache/seatunnel/issues/9457

   ### Search before asking
   
   - [x] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   During the synchronization process from MySQL to Iceberg, the 
synchronization is shown as successful, but the timestamp type time is found to 
differ from the source by 8 hours.
   
   ### SeaTunnel Version
   
   2.3.9
   
   ### SeaTunnel Config
   
   ```conf
   {
     env {
       execution.parallelism = 1
       job.mode = "BATCH"
       job.name = "seatunnel_batch_job"
     }
     # source配置
     source {
       JDBC {
         url = "xxxx"
         driver = "xxxxx"
         user = "xxxx"
         password = "xxxx"
         query = "xxxxx"
         split.size = 5000
         fetch_size = 2000      
       }
     }
     # sink配置
     sink {
       Iceberg {
         catalog_name= "default"
         iceberg.catalog.config={
           "type"= "xxxx"
           "uri" = "xxxx"
           "warehouse"= "xxxx"
         }
         namespace= "xxxxx"
         table= "xxxxx"
         iceberg.table.write-props={
           write.format.default="xxxx"
           write.target-file-size-bytes=536870912
           write.parquet.compression-codec="xxxx"
         }
         iceberg.hadoop-conf-path = "xxxxx"
         iceberg.table.upsert-mode-enabled = false
         iceberg.table.schema-evolution-enabled=true
         case_sensitive=true      
       }
     }
   }
   ```
   
   ### Running Command
   
   ```shell
   ./bin/start-seatunnel-flink-15-connector-v2.sh --config mysql2iceberg.conf 
--deploy-mode run-application --target yarn-application --name mysql2iceberg
   ```
   
   ### Error Exception
   
   ```log
   The value of the datetime type at the MySQL source end is 2020-06-08 
15:21:15, and after successful synchronization, the value of the corresponding 
field is 2020-06-08 23:21:15.000.
   ```
   
   ### Zeta or Flink or Spark Version
   
   flink 1.16
   
   ### Java or Scala Version
   
   java 8
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [x] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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]

Reply via email to