You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
To determine whether writes are switched, we check the route for t1. If it is pointing to target it is considered that writes have been switched.
The problem comes the same table exists in different source keyspaces. For example if there are two workflows one from source1=>target1 and another from source2=>target2, both with a table t1.
Now if one workflow's writes are switched we end up with the route for t1 pointing to target1.t1. When the next workflow's writes are switched we now overwrite that rule so that it points to target2.t1. The logic now assumes writes for the first workflow have not been switched.
Reproduction Steps
.
Binary Version
c768b626575aa06025b347ea265d5cd4f3805fab
Operating System and Environment details
.
Log Fragments
No response
The text was updated successfully, but these errors were encountered:
Overview of the Issue
We use the table routing rules to decide where reads and writes are routed for tables which are part of
MoveTables
workflows.For each table we have rules like
when no traffic is switched, or when all traffic is switched:
To determine whether writes are switched, we check the route for
t1
. If it is pointing totarget
it is considered that writes have been switched.The problem comes the same table exists in different source keyspaces. For example if there are two workflows one from
source1
=>target1
and another fromsource2
=>target2
, both with a tablet1
.Now if one workflow's writes are switched we end up with the route for
t1
pointing totarget1.t1
. When the next workflow's writes are switched we now overwrite that rule so that it points totarget2.t1
. The logic now assumes writes for the first workflow have not been switched.Reproduction Steps
.
Binary Version
Operating System and Environment details
.
Log Fragments
No response
The text was updated successfully, but these errors were encountered: