You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by GitBox <gi...@apache.org> on 2022/03/28 11:14:48 UTC

[GitHub] [incubator-seatunnel] 2416210017 opened a new issue #1599: seatunnel oracle to hive error?

2416210017 opened a new issue #1599:
URL: https://github.com/apache/incubator-seatunnel/issues/1599


   Hi, I'm a novice. I'm trying Oracle JDBC to hive, and I encounter an error. Is there a problem with my configuration?Can someone help take a look?
   
   `spark 2.4.8`
   `SEATUNNEL-1.5.7.5`
   
   ![image](https://user-images.githubusercontent.com/52597892/160386124-80c26b54-ccad-4d7e-a947-4749d8f7d1eb.png)
   ![image](https://user-images.githubusercontent.com/52597892/160386214-a592c08a-46fd-4fc7-a02b-a4f1ed53063f.png)
   


-- 
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: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [incubator-seatunnel] 2416210017 commented on issue #1599: seatunnel oracle to hive error?

Posted by GitBox <gi...@apache.org>.
2416210017 commented on issue #1599:
URL: https://github.com/apache/incubator-seatunnel/issues/1599#issuecomment-1084015382


   Oh, my God, it has been solved. Here is an example for those who need it later !
   
   `spark {
       spark.app.name = "seatunnel_oracle"
       spark.default.parallelism = 4
       spark.executor.instances = 5
       spark.executor.cores = 4
       spark.executor.memory = "5g"
       spark.sql.catalogImplementation = "hive"
   }
   
   input {
   jdbc {
       driver = "oracle.jdbc.driver.OracleDriver"
       url = "jdbc:oracle:thin:@//10.10.223.18:1521/ora11g"
       table = "(SELECT id,name,'2022-03-28' AS partition_date FROM SYSTEM.PLAYER) as A"
       result_table_name = "player_oracle"
       user = "system"
       password = "belle#2020BELLE"
   }
   }
   
   filter {
   }
   
   output {
       Hive {
           sql = "insert overwrite table test.player partition(partition_date) select id,name from player_oracle"
       }
   }
   `


-- 
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: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [incubator-seatunnel] 2416210017 closed issue #1599: seatunnel oracle to hive error?

Posted by GitBox <gi...@apache.org>.
2416210017 closed issue #1599:
URL: https://github.com/apache/incubator-seatunnel/issues/1599


   


-- 
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: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [incubator-seatunnel] 2416210017 edited a comment on issue #1599: seatunnel oracle to hive error?

Posted by GitBox <gi...@apache.org>.
2416210017 edited a comment on issue #1599:
URL: https://github.com/apache/incubator-seatunnel/issues/1599#issuecomment-1084015382


   Oh, my God, it has been solved. Here is an example for those who need it later !
   
   spark {
       spark.app.name = "seatunnel_oracle"
       spark.default.parallelism = 4
       spark.executor.instances = 5
       spark.executor.cores = 4
       spark.executor.memory = "5g"
       spark.sql.catalogImplementation = "hive"
   }
   
   input {
   jdbc {
       driver = "oracle.jdbc.driver.OracleDriver"
       url = "jdbc:oracle:thin:@//10.10.11.110:1521/ora11g"
       table = "(SELECT id,name,'2022-03-28' AS partition_date FROM SYSTEM.PLAYER) as A"
       result_table_name = "player_oracle"
       user = "system"
       password = "123456"
   }
   }
   
   filter {
   }
   
   output {
       Hive {
           sql = "insert overwrite table ods_commodity.player partition(partition_date) select id,name from player_oracle"
       }
   }
   


-- 
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: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [incubator-seatunnel] 2416210017 commented on issue #1599: seatunnel oracle to hive error?

Posted by GitBox <gi...@apache.org>.
2416210017 commented on issue #1599:
URL: https://github.com/apache/incubator-seatunnel/issues/1599#issuecomment-1080523206


   According to the introduction of the official website of seatunnel, I have no problem from Mysql to hive, but Oracle error. Is there an example of Oracle to hive? thank you?


-- 
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: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org