scylladb / gemini

Test data integrity by comparing against an Oracle running in parallel
Apache License 2.0
28 stars 16 forks source link

fix(jobs): fix pk values circulating #397

Closed dkropachev closed 1 year ago

dkropachev commented 1 year ago

There is mechanism for circulating pk values:

  1. Pk value is being generated and injected into db
  2. It is remembered in inflights to do not allow generators to generate same values
  3. It is put into old chan
  4. Read from old chan, to run validation query on it
  5. Released from inflights

On some ocasions gemini either don't send values to old chan, or don't release them, which makes these values stuck in infligths and being blocked forever