You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by GitBox <gi...@apache.org> on 2022/11/09 07:35:32 UTC

[GitHub] [dolphinscheduler] lenian commented on pull request #12836: [Feature-9467][DataSource] add DM(达梦) data source

lenian commented on PR #12836:
URL: https://github.com/apache/dolphinscheduler/pull/12836#issuecomment-1308334041

   test case:
   ![image](https://user-images.githubusercontent.com/21359079/200766730-3ab980b7-1cee-4d06-8c01-710259e9434e.png)
   ![image](https://user-images.githubusercontent.com/21359079/200766779-d4099fb9-c6f7-49aa-892b-205bcbca8f75.png)
   ![image](https://user-images.githubusercontent.com/21359079/200766807-7ff57104-15d0-44ae-ab71-6ce272f4218d.png)
   ![image](https://user-images.githubusercontent.com/21359079/200766852-edb45fba-646c-44ab-8f7e-7a9f9d1a1b17.png)
   
   Process_instance run result log :
   [INFO] 2022-11-09 11:22:51.210 +0800 - Begin to pulling task
   [INFO] 2022-11-09 11:22:51.212 +0800 - Begin to initialize task
   [INFO] 2022-11-09 11:22:51.213 +0800 - Set task startTime: 1667964171212
   [INFO] 2022-11-09 11:22:51.217 +0800 - Set task envFile: /etc/profile
   [INFO] 2022-11-09 11:22:51.218 +0800 - Set task appId: 3_6
   [INFO] 2022-11-09 11:22:51.218 +0800 - End initialize task
   [INFO] 2022-11-09 11:22:51.232 +0800 - Set task status to TaskExecutionStatus{code=1, desc='running'}
   [INFO] 2022-11-09 11:22:55.116 +0800 - TenantCode:lenian check success
   [INFO] 2022-11-09 11:22:55.119 +0800 - ProcessExecDir:/tmp/dolphinscheduler/exec/process/lenian/7486873665920/7487072336000_2/3/6 check success
   [INFO] 2022-11-09 11:22:55.119 +0800 - Resources:{} check success
   [INFO] 2022-11-09 11:22:55.132 +0800 - Task plugin: SQL create success
   [INFO] 2022-11-09 11:22:55.132 +0800 - Success initialized task plugin instance success
   [INFO] 2022-11-09 11:22:55.132 +0800 - Success set taskVarPool: null
   [INFO] 2022-11-09 11:22:55.133 +0800 - Full sql parameters: SqlParameters{type='DM', datasource=1, sql='select * from person.person', sqlType=0, sendEmail=null, displayRows=10, limit=0, udfs='null', showType='null', connParams='null', groupId='0', title='null', preStatements=[], postStatements=[]}
   [INFO] 2022-11-09 11:22:55.133 +0800 - sql type : DM, datasource : 1, sql : select * from person.person , localParams : [],udfs : null,showType : null,connParams : null,varPool : [] ,query max result limit  0
   [INFO] 2022-11-09 11:22:55.173 +0800 - can't find udf function resource
   [INFO] 2022-11-09 11:22:55.478 +0800 - prepare statement replace sql : select * from person.person, sql parameters : {}
   [INFO] 2022-11-09 11:22:55.479 +0800 - main statement execute query, for sql: select * from person.person
   [INFO] 2022-11-09 11:22:55.488 +0800 - display sql result 10 rows as follows:
   [INFO] 2022-11-09 11:22:55.489 +0800 - row 1 : {"PERSONID":1,"SEX":"F","NAME":"李丽","EMAIL":"lily@sina.com","PHONE":"02788548562"}
   [INFO] 2022-11-09 11:22:55.489 +0800 - row 2 : {"PERSONID":2,"SEX":"M","NAME":"王刚","EMAIL":"","PHONE":"02787584562"}
   [INFO] 2022-11-09 11:22:55.489 +0800 - row 3 : {"PERSONID":3,"SEX":"M","NAME":"李勇","EMAIL":"","PHONE":"02782585462"}
   [INFO] 2022-11-09 11:22:55.489 +0800 - row 4 : {"PERSONID":4,"SEX":"F","NAME":"郭艳","EMAIL":"","PHONE":"02787785462"}
   [INFO] 2022-11-09 11:22:55.489 +0800 - row 5 : {"PERSONID":5,"SEX":"F","NAME":"孙丽","EMAIL":"","PHONE":"13055173012"}
   [INFO] 2022-11-09 11:22:55.490 +0800 - row 6 : {"PERSONID":6,"SEX":"M","NAME":"黄非","EMAIL":"","PHONE":"13355173012"}
   [INFO] 2022-11-09 11:22:55.490 +0800 - row 7 : {"PERSONID":7,"SEX":"F","NAME":"王菲","EMAIL":"","PHONE":"13255173012"}
   [INFO] 2022-11-09 11:22:55.490 +0800 - row 8 : {"PERSONID":8,"SEX":"M","NAME":"张平","EMAIL":"","PHONE":"13455173012"}
   [INFO] 2022-11-09 11:22:55.490 +0800 - row 9 : {"PERSONID":9,"SEX":"M","NAME":"张红","EMAIL":"","PHONE":"13555173012"}
   [INFO] 2022-11-09 11:22:55.490 +0800 - row 10 : {"PERSONID":10,"SEX":"F","NAME":"刘佳","EMAIL":"","PHONE":"13955173012"}
   [INFO] 2022-11-09 11:22:55.491 +0800 - The current task need to send alert, begin to send alert
   [INFO] 2022-11-09 11:22:57.534 +0800 - Success send alert
   [INFO] 2022-11-09 11:22:57.536 +0800 - Send task execute result to master, the current task status: TaskExecutionStatus{code=7, desc='success'}
   [INFO] 2022-11-09 11:22:57.536 +0800 - Remove the current task execute context from worker cache
   [INFO] 2022-11-09 11:22:57.536 +0800 - The current execute mode isn't develop mode, will clear the task execute file: /tmp/dolphinscheduler/exec/process/lenian/7486873665920/7487072336000_2/3/6
   [INFO] 2022-11-09 11:22:57.540 +0800 - Success clear the task execute file: /tmp/dolphinscheduler/exec/process/lenian/7486873665920/7487072336000_2/3/6
   
   


-- 
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@dolphinscheduler.apache.org

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