with "xdb.use_load_for_step=true" (default config) config in stado.config.
Stado -> select count(*) from sf_commercerecord; +----------+ | count(*) | +----------+ | 3000000 | +----------+ 1 row(s).
Stado -> select count(*) from sf_wofcust201205; +----------+ | count(*) | +----------+ | 25009727 | +----------+ 1 row(s).
Stado -> update sf_commercerecord set status=integraltype where exists ( select * from sf_wofcust201205 where sf_commercerecord.mobileno=sf_wofcust201205.mobileno and sf_commercerecord.feecode=sf_wofcust201205.feecode ); SQLException: ERROR: UNEXPECTED_MESSAGE_RECIEVED (GOT, EXPECTED) :(1 , 41 )
For small tables, there seems to be no problem:
Stado -> select count(*) from sf_commercerecord; +----------+ | count(*) | +----------+ | 2 | +----------+ 1 row(s).
Stado -> select count(*) from sf_wofcust201205; +----------+ | count(*) | +----------+ | 82 | +----------+ 1 row(s).
Stado -> update sf_commercerecord set status=integraltype where exists ( select * from sf_wofcust201205 where sf_commercerecord.mobileno=sf_wofcust201205.mobileno and sf_commercerecord.feecode=sf_wofcust201205.feecode); 1 row(s) affected
with "xdb.use_ load_for_ step=true" (default config) config in stado.config.
Stado -> select count(*) from sf_commercerecord;
+----------+
| count(*) |
+----------+
| 3000000 |
+----------+
1 row(s).
Stado -> select count(*) from sf_wofcust201205;
+----------+
| count(*) |
+----------+
| 25009727 |
+----------+
1 row(s).
Stado -> update sf_commercerecord set status=integraltype where exists ( select * from sf_wofcust201205 where sf_commercereco rd.mobileno= sf_wofcust20120 5.mobileno and sf_commercereco rd.feecode= sf_wofcust20120 5.feecode ); MESSAGE_ RECIEVED (GOT, EXPECTED) :(1 , 41 )
SQLException: ERROR: UNEXPECTED_
For small tables, there seems to be no problem:
Stado -> select count(*) from sf_commercerecord;
+----------+
| count(*) |
+----------+
| 2 |
+----------+
1 row(s).
Stado -> select count(*) from sf_wofcust201205;
+----------+
| count(*) |
+----------+
| 82 |
+----------+
1 row(s).
Stado -> update sf_commercerecord set status=integraltype where exists ( select * from sf_wofcust201205 where sf_commercereco rd.mobileno= sf_wofcust20120 5.mobileno and sf_commercereco rd.feecode= sf_wofcust20120 5.feecode) ;
1 row(s) affected