first commit
This commit is contained in:
parent
f4c85f40dc
commit
ae15a1d746
|
@ -848,7 +848,7 @@ closeSession(session_dest);
|
||||||
for (Row row: rows){
|
for (Row row: rows){
|
||||||
boolean flag = false;
|
boolean flag = false;
|
||||||
while (!flag) {
|
while (!flag) {
|
||||||
session_dest.execute(getWriteStatementNotification(session_dest, row)).wasApplied();
|
flag = session_dest.execute(getWriteStatementNotification(session_dest, row)).wasApplied();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
|
@ -917,7 +917,7 @@ closeSession(session_dest);
|
||||||
for (Row row: rows){
|
for (Row row: rows){
|
||||||
boolean flag = false;
|
boolean flag = false;
|
||||||
while (!flag) {
|
while (!flag) {
|
||||||
session_dest.execute(getWriteStatementPost(session_dest, row)).wasApplied();
|
flag = session_dest.execute(getWriteStatementPost(session_dest, row)).wasApplied();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
|
|
Loading…
Reference in New Issue