From 390a2dd550fb8a531e3ea9642e8be93b83678d80 Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Tue, 16 Jan 2024 14:30:10 +0800 Subject: [PATCH] =?UTF-8?q?chore(test):=20=E6=9D=82=E9=A1=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/httpRequests/http-requests-log.http | 536 +++++++----------- .../test/java/com/test/SqlBuilderTests.java | 8 +- test/test.http | 4 + 3 files changed, 223 insertions(+), 325 deletions(-) diff --git a/.idea/httpRequests/http-requests-log.http b/.idea/httpRequests/http-requests-log.http index 740c315..8840189 100644 --- a/.idea/httpRequests/http-requests-log.http +++ b/.idea/httpRequests/http-requests-log.http @@ -1,3 +1,218 @@ +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/sync_checkpoint_state?flink_job_id=1542097996099055616&alias=acct_acct_item_zs&message_id=861976:46933:-1&publish_time=1705373846898 +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=360A7282DB9D80CB6448B7D777A775FB +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T105935.500.txt + +### + +GET http://132.126.207.145:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=7432549068B8B97C4262AFE16E441540 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T104830.200.txt + +### + +GET http://132.126.207.145:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=7432549068B8B97C4262AFE16E441540 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T104829.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.145:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=BE997A6F6AEFD1CA4146698ABD496B48 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102430.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.145:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=72054C37516102EEB06EF5A0F5A83AAE +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102428.200.txt + +### + +GET http://132.126.207.145:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=330A8B0CAC7A15CC36A88B55CF2C407B +Accept-Encoding: br,deflate,gzip,x-gzip + +### + +GET http://132.126.207.145:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Accept-Encoding: br,deflate,gzip,x-gzip + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=5A77D0A2402762309BD5AFB2BA404BB2 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102147.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=EA64044D10F310CC0A1B6E012024D447 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102146-1.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=C020506E0113E19848006BB9D635C746 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102146.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=C5B4C74D1DE66BB79AB7BCADA0ADD3FC +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102145.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=D2D689EF3A3C0A9E31655761139EB782 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102144.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=1C1D8E27BC4DC259CCBDA3AB68267606 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102143.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=5929B1C5B9A5A06F6B77E0474252C681 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102141.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=49AF67BCEE7F58FBFD8CE3044D8FADDF +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102140.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=F8554BC0AF2786BECA1F227B65A8B994 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102139.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=58BC6FDDD752F5DD2A7F2302B3044527 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102137.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=FD0B0DA39AE3B3424550036F0244CA59 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102136.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=C4E2078745A32624F43385AF531E6FE7 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102135.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=4F0B9200F7662735BB78070F3B29B814 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T102132.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1597126971674021888&alias=psr_dep_tb_im_work_data +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=09EED47A2E9B899F8F2B7E6E691ED278 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T101417.200.txt + +### + +GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/hudi_api/api/message_id?flink_job_id=1542097993662164992&alias=acct_bal_repayment_sz +Connection: Keep-Alive +User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) +Cookie: JSESSIONID=7B52A1524EBCC8A7F128BC99DDDB97B1 +Accept-Encoding: br,deflate,gzip,x-gzip + +<> 2024-01-16T101234.200.txt + +### + GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.126.207.130:35690/hudi_services/service_scheduler/schedule/schedule_times Connection: Keep-Alive User-Agent: Apache-HttpClient/4.5.14 (Java/17.0.9) @@ -269,324 +484,3 @@ Accept-Encoding: br,deflate,gzip,x-gzip ### -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14041/queue/poll/compaction-queue -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=98CC709B9ED7F9CC70C5138E6350AB73 -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T174734.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14041/queue/poll/compaction-queue -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=98CC709B9ED7F9CC70C5138E6350AB73 -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T174722.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14041/queue/take/compaction-queue -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=98CC709B9ED7F9CC70C5138E6350AB73 -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T174331.404.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14041/queue/add/compaction-queue -Content-Type: application/json -Content-Length: 223 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=1A204579800593D4EFCFCED156E43CB7 -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123456", - "priority": 1, - "data": { - "id": "37171d34-25cf-409d-b408-4b329dc009e9", - "flinkJobId": 1683450773883, - "alias": "acct_item", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T174248.200.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:23167/queue/add/compaction-queue -Content-Type: application/json -Content-Length: 225 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=1A204579800593D4EFCFCED156E43CB7 -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123456", - "priority": 150, - "data": { - "id": "37171d34-25cf-409d-b408-4b329dc009e9", - "flinkJobId": 1683450773883, - "alias": "acct_item", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T171445.200.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:23167/queue/add/compaction-queue -Content-Type: application/json -Content-Length: 224 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=1A204579800593D4EFCFCED156E43CB7 -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123456", - "priority": 15, - "data": { - "id": "37171d34-25cf-409d-b408-4b329dc009e9", - "flinkJobId": 1683450773883, - "alias": "acct_item", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T171436.200.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:23167/queue/add/compaction-queue -Content-Type: application/json -Content-Length: 225 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=1A204579800593D4EFCFCED156E43CB7 -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123456", - "priority": 100, - "data": { - "id": "37171d34-25cf-409d-b408-4b329dc009e9", - "flinkJobId": 1683450773883, - "alias": "acct_item", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T171404.200.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:23167/queue/add/compaction-queue -Content-Type: application/json -Content-Length: 206 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=1A204579800593D4EFCFCED156E43CB7 -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123456", - "data": { - "id": "37171d34-25cf-409d-b408-4b329dc009e9", - "flinkJobId": 1683450773883, - "alias": "acct_item", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T171323.200.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:23167/queue/add/compaction-queue -Content-Type: application/json -Content-Length: 158 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=1A204579800593D4EFCFCED156E43CB7 -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123", - "data": { - "id": "123", - "flinkJobId": 123456, - "alias": "test", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T171200.200.json - -### - -POST http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:23167/queue/push/compaction-queue -Content-Type: application/json -Content-Length: 158 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -{ - "id": "123", - "data": { - "id": "123", - "flinkJobId": 123456, - "alias": "test", - "batch": "123", - "status": "", - "comment": "text" - } -} - -<> 2023-05-07T171115.404.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@b5s119.hdp.dc:38000/queue/names -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=11609263D43A89047BEC8B5EA721A2B7 -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T165612.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@b5s119.hdp.dc:38000/queue/names -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=11609263D43A89047BEC8B5EA721A2B7 -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T165521.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@b5s119.hdp.dc:38000/queue/all?name=compaction-queue -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=936E036BAFFA0EEDD94D0007972E841A -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T165512.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@b5s119.hdp.dc:38000/queue/all?name=compaction-queue -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=936E036BAFFA0EEDD94D0007972E841A -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T165150.500.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@b5s119.hdp.dc:38000/queue/names -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=7D592F9B097946A2B42570B66A67399C -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-07T165118.200.json - -### - -GET http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814/v1/jobs/320c6e7438afebea43fa0f0160319717 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-06T104152.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14986/flink/task_manager?url=http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814&vertex_id=320c6e7438afebea43fa0f0160319717&checkpoint_id=2793&task_manager_id=container_1672368973318_1814_01_000002 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-05T165913.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14986/flink/task_manager_overview?url=http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814&vertex_id=320c6e7438afebea43fa0f0160319717&checkpoint_id=2793 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-05T165848.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14986/flink/checkpoint_config?url=http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814&vertex_id=320c6e7438afebea43fa0f0160319717&checkpoint_id=2793 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-05T165841.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14986/flink/checkpoint?url=http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814&vertex_id=320c6e7438afebea43fa0f0160319717&checkpoint_id=2793 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-05T165831.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14986/flink/checkpoint_overview?url=http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814&vertex_id=320c6e7438afebea43fa0f0160319717 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-05T165806.200.json - -### - -GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.142:14986/flink/vertex_config?url=http://b5s120.hdp.dc:8088/proxy/application_1672368973318_1814&vertex_id=320c6e7438afebea43fa0f0160319717 -Connection: Keep-Alive -User-Agent: Apache-HttpClient/4.5.13 (Java/17.0.5) -Cookie: JSESSIONID=EF34D16868A55ED34A46AB1C4C0CD38E -Accept-Encoding: br,deflate,gzip,x-gzip - -<> 2023-05-05T165758.200.json - -### - diff --git a/service-info-query/src/test/java/com/test/SqlBuilderTests.java b/service-info-query/src/test/java/com/test/SqlBuilderTests.java index 7747d7b..10b14b8 100644 --- a/service-info-query/src/test/java/com/test/SqlBuilderTests.java +++ b/service-info-query/src/test/java/com/test/SqlBuilderTests.java @@ -21,10 +21,10 @@ public class SqlBuilderTests { String STATUS_Y = "y"; String STATUS_N = "n"; System.out.println(SqlUtil.formatSql( - SqlBuilder.update(TbAppCollectTableInfo._origin_) - .set(TbAppCollectTableInfo.STATUS_O, STATUS_N) - .whereEq(TbAppCollectTableInfo.FLINK_JOB_ID_O, "Q") - .andEq(TbAppCollectTableInfo.ALIAS_O, "Q") + SqlBuilder + .select(TbAppHudiSyncState.MESSAGE_ID_A) + .from(TbAppHudiSyncState._alias_) + .whereEq(TbAppHudiSyncState.ID_A, null) .precompileSql() )); } diff --git a/test/test.http b/test/test.http index 06c5f1d..18af4a8 100644 --- a/test/test.http +++ b/test/test.http @@ -8,6 +8,7 @@ @scheduler-url = {{url}}/hudi_services/service_scheduler @web-url = {{url}}/hudi_services/service_web @services-url = {{url}}/hudi_services/service_cloud_query +@api-url = {{url}}/hudi_services/hudi_api ### 队列名称 GET {{queue-url}}/queue/names @@ -79,3 +80,6 @@ GET {{web-url}}/overview/sync_running_status ### Get schedule_times GET {{scheduler-url}}/schedule/schedule_times + +### Get message id +GET {{api-url}}/api/sync_checkpoint_state?flink_job_id=1542097996099055616&alias=acct_acct_item_zs&message_id=861976:46933:-1&publish_time=1705373846898