lib/flydata/query_based_sync/client.rb in flydata-0.7.15 vs lib/flydata/query_based_sync/client.rb in flydata-0.7.16

@@ -99,9 +99,12 @@
         end
       end
 
       # Set the current snapshot to master(resume) binlog.pos file
       context.cur_src_pos_file.save(context.table_meta.current_snapshot)
+      # Also set the same value to the sent.binlog.pos file as the file is
+      # required by the agent commands.
+      context.cur_sent_pos_file.save(context.table_meta.current_snapshot)
 
       log_info("Updated source position -", resume_pos:context.table_meta.current_snapshot)
     end
   end