[jira] [Comment Edited] (PHOENIX-6494) Delete data and insert immediately cause the data inconsistently

Future.Zhang (Jira) Wed, 16 Jun 2021 06:57:04 -0700


    [ 
https://issues.apache.org/jira/browse/PHOENIX-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364313#comment-17364313
 ]


Future.Zhang edited comment on PHOENIX-6494 at 6/16/21, 1:56 PM:
-----------------------------------------------------------------

hi, Rushabh Shah , Below is my test case

expect result is ： there are 30 record in ’T16.JG_JGXW_CHECK_ACTION_44_149‘ 
table.

but after execute the script, there are nothing in  
’T16.JG_JGXW_CHECK_ACTION_44_149‘ table.

 
{code:java}
CREATE SCHEMA IF NOT EXISTS T16;


CREATE TABLE T16.JG_JGXW_CHECK_ACTION_44_149 (
        RECORD_UNIQUE_ID VARCHAR NOT NULL,
        CHECK_BATCH_NO VARCHAR,
        PK_ID VARCHAR,
        ADMINISTRATIVE_CP_CE_TYPE VARCHAR,
        CONSTRAINT JG_JGXW_CHECK_ACTION_PK PRIMARY KEY (RECORD_UNIQUE_ID)
);




UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'11-','798d440d95874ff7b342a51b59fa9d66','11','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'17-','798d440d95874ff7b342a51b59fa9d66','17','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'2-','798d440d95874ff7b342a51b59fa9d66','2','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'20-','798d440d95874ff7b342a51b59fa9d66','20','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'26-','798d440d95874ff7b342a51b59fa9d66','26','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'8-','798d440d95874ff7b342a51b59fa9d66','8','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'12-','798d440d95874ff7b342a51b59fa9d66','12','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'18-','798d440d95874ff7b342a51b59fa9d66','18','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'21-','798d440d95874ff7b342a51b59fa9d66','21','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'27-','798d440d95874ff7b342a51b59fa9d66','27','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'3-','798d440d95874ff7b342a51b59fa9d66','3','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'30-','798d440d95874ff7b342a51b59fa9d66','30','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'9-','798d440d95874ff7b342a51b59fa9d66','9','X');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'13-','798d440d95874ff7b342a51b59fa9d66','13','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'19-','798d440d95874ff7b342a51b59fa9d66','19','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'22-','798d440d95874ff7b342a51b59fa9d66','22','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'28-','798d440d95874ff7b342a51b59fa9d66','28','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'4-','798d440d95874ff7b342a51b59fa9d66','4','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'14-','798d440d95874ff7b342a51b59fa9d66','14','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'23-','798d440d95874ff7b342a51b59fa9d66','23','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'29-','798d440d95874ff7b342a51b59fa9d66','29','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'5-','798d440d95874ff7b342a51b59fa9d66','5','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'15-','798d440d95874ff7b342a51b59fa9d66','15','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'24-','798d440d95874ff7b342a51b59fa9d66','24','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'6-','798d440d95874ff7b342a51b59fa9d66','6','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'1-','798d440d95874ff7b342a51b59fa9d66','1','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'10-','798d440d95874ff7b342a51b59fa9d66','10','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'16-','798d440d95874ff7b342a51b59fa9d66','16','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'25-','798d440d95874ff7b342a51b59fa9d66','25','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'7-','798d440d95874ff7b342a51b59fa9d66','7','1');


DELETE FROM T16.JG_JGXW_CHECK_ACTION_44_149;




UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'11-','798d440d95874ff7b342a51b59fa9d66','11','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'17-','798d440d95874ff7b342a51b59fa9d66','17','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'2-','798d440d95874ff7b342a51b59fa9d66','2','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'20-','798d440d95874ff7b342a51b59fa9d66','20','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'26-','798d440d95874ff7b342a51b59fa9d66','26','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'8-','798d440d95874ff7b342a51b59fa9d66','8','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'12-','798d440d95874ff7b342a51b59fa9d66','12','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'18-','798d440d95874ff7b342a51b59fa9d66','18','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'21-','798d440d95874ff7b342a51b59fa9d66','21','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'27-','798d440d95874ff7b342a51b59fa9d66','27','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'3-','798d440d95874ff7b342a51b59fa9d66','3','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'30-','798d440d95874ff7b342a51b59fa9d66','30','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'9-','798d440d95874ff7b342a51b59fa9d66','9','X');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'13-','798d440d95874ff7b342a51b59fa9d66','13','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'19-','798d440d95874ff7b342a51b59fa9d66','19','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'22-','798d440d95874ff7b342a51b59fa9d66','22','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'28-','798d440d95874ff7b342a51b59fa9d66','28','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'4-','798d440d95874ff7b342a51b59fa9d66','4','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'14-','798d440d95874ff7b342a51b59fa9d66','14','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'23-','798d440d95874ff7b342a51b59fa9d66','23','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'29-','798d440d95874ff7b342a51b59fa9d66','29','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'5-','798d440d95874ff7b342a51b59fa9d66','5','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'15-','798d440d95874ff7b342a51b59fa9d66','15','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'24-','798d440d95874ff7b342a51b59fa9d66','24','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'6-','798d440d95874ff7b342a51b59fa9d66','6','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'1-','798d440d95874ff7b342a51b59fa9d66','1','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'10-','798d440d95874ff7b342a51b59fa9d66','10','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'16-','798d440d95874ff7b342a51b59fa9d66','16','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'25-','798d440d95874ff7b342a51b59fa9d66','25','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'7-','798d440d95874ff7b342a51b59fa9d66','7','1');










{code}


was (Author: weilai):
Below is my test case

expect result is ： there are 30 record in ’T16.JG_JGXW_CHECK_ACTION_44_149‘ 
table.

but after execute the script, there are nothing in  
’T16.JG_JGXW_CHECK_ACTION_44_149‘ table.

 
{code:java}
CREATE SCHEMA IF NOT EXISTS T16;


CREATE TABLE T16.JG_JGXW_CHECK_ACTION_44_149 (
        RECORD_UNIQUE_ID VARCHAR NOT NULL,
        CHECK_BATCH_NO VARCHAR,
        PK_ID VARCHAR,
        ADMINISTRATIVE_CP_CE_TYPE VARCHAR,
        CONSTRAINT JG_JGXW_CHECK_ACTION_PK PRIMARY KEY (RECORD_UNIQUE_ID)
);




UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'11-','798d440d95874ff7b342a51b59fa9d66','11','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'17-','798d440d95874ff7b342a51b59fa9d66','17','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'2-','798d440d95874ff7b342a51b59fa9d66','2','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'20-','798d440d95874ff7b342a51b59fa9d66','20','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'26-','798d440d95874ff7b342a51b59fa9d66','26','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'8-','798d440d95874ff7b342a51b59fa9d66','8','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'12-','798d440d95874ff7b342a51b59fa9d66','12','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'18-','798d440d95874ff7b342a51b59fa9d66','18','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'21-','798d440d95874ff7b342a51b59fa9d66','21','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'27-','798d440d95874ff7b342a51b59fa9d66','27','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'3-','798d440d95874ff7b342a51b59fa9d66','3','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'30-','798d440d95874ff7b342a51b59fa9d66','30','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'9-','798d440d95874ff7b342a51b59fa9d66','9','X');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'13-','798d440d95874ff7b342a51b59fa9d66','13','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'19-','798d440d95874ff7b342a51b59fa9d66','19','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'22-','798d440d95874ff7b342a51b59fa9d66','22','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'28-','798d440d95874ff7b342a51b59fa9d66','28','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'4-','798d440d95874ff7b342a51b59fa9d66','4','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'14-','798d440d95874ff7b342a51b59fa9d66','14','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'23-','798d440d95874ff7b342a51b59fa9d66','23','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'29-','798d440d95874ff7b342a51b59fa9d66','29','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'5-','798d440d95874ff7b342a51b59fa9d66','5','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'15-','798d440d95874ff7b342a51b59fa9d66','15','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'24-','798d440d95874ff7b342a51b59fa9d66','24','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'6-','798d440d95874ff7b342a51b59fa9d66','6','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'1-','798d440d95874ff7b342a51b59fa9d66','1','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'10-','798d440d95874ff7b342a51b59fa9d66','10','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'16-','798d440d95874ff7b342a51b59fa9d66','16','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'25-','798d440d95874ff7b342a51b59fa9d66','25','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'7-','798d440d95874ff7b342a51b59fa9d66','7','1');


DELETE FROM T16.JG_JGXW_CHECK_ACTION_44_149;




UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'11-','798d440d95874ff7b342a51b59fa9d66','11','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'17-','798d440d95874ff7b342a51b59fa9d66','17','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'2-','798d440d95874ff7b342a51b59fa9d66','2','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'20-','798d440d95874ff7b342a51b59fa9d66','20','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'26-','798d440d95874ff7b342a51b59fa9d66','26','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'8-','798d440d95874ff7b342a51b59fa9d66','8','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'12-','798d440d95874ff7b342a51b59fa9d66','12','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'18-','798d440d95874ff7b342a51b59fa9d66','18','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'21-','798d440d95874ff7b342a51b59fa9d66','21','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'27-','798d440d95874ff7b342a51b59fa9d66','27','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'3-','798d440d95874ff7b342a51b59fa9d66','3','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'30-','798d440d95874ff7b342a51b59fa9d66','30','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'9-','798d440d95874ff7b342a51b59fa9d66','9','X');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'13-','798d440d95874ff7b342a51b59fa9d66','13','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'19-','798d440d95874ff7b342a51b59fa9d66','19','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'22-','798d440d95874ff7b342a51b59fa9d66','22','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'28-','798d440d95874ff7b342a51b59fa9d66','28','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'4-','798d440d95874ff7b342a51b59fa9d66','4','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'14-','798d440d95874ff7b342a51b59fa9d66','14','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'23-','798d440d95874ff7b342a51b59fa9d66','23','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'29-','798d440d95874ff7b342a51b59fa9d66','29','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'5-','798d440d95874ff7b342a51b59fa9d66','5','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'15-','798d440d95874ff7b342a51b59fa9d66','15','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'24-','798d440d95874ff7b342a51b59fa9d66','24','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'6-','798d440d95874ff7b342a51b59fa9d66','6','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'1-','798d440d95874ff7b342a51b59fa9d66','1','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'10-','798d440d95874ff7b342a51b59fa9d66','10','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'16-','798d440d95874ff7b342a51b59fa9d66','16','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'25-','798d440d95874ff7b342a51b59fa9d66','25','1');
UPSERT INTO T16.JG_JGXW_CHECK_ACTION_44_149 
(RECORD_UNIQUE_ID,CHECK_BATCH_NO,PK_ID,ADMINISTRATIVE_CP_CE_TYPE) VALUES (
'7-','798d440d95874ff7b342a51b59fa9d66','7','1');










{code}

> Delete data and insert immediately cause the data inconsistently
> ----------------------------------------------------------------
>
>                 Key: PHOENIX-6494
>                 URL: https://issues.apache.org/jira/browse/PHOENIX-6494
>             Project: Phoenix
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 5.1.1
>         Environment: Phoenix 5.1.1
> Hbase 2.3.5
> Hadoop 2.10.1
>            Reporter: Future.Zhang
>            Priority: Major
>
> I have a table named “TEST1”, it contain 30 record. 
> I use SpringJDBC to connect phoenix.
>  
> My Java code like below
> {code:java}
> //代码占位符
> //First, Delete all data
> phoenixJdbcTemplate.execute("DELETE FROM TEST1");
> //Second, use alibaba datax to sync data (30 record) into "TEST1" table. 
> JavaRemoteShell.execute("python /opt/data/bin/datax sync_data.json");
> {code}
> after, i query 'TEST1' table, it only 19 record into the table.
>  
> Is it a phoenix bug? 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Comment Edited] (PHOENIX-6494) Delete data and insert immediately cause the data inconsistently

Reply via email to