@@ -76,15 +76,15 @@ public TargetUpsertRunDetailsStatement(CqlSession session, String keyspaceTable)
76
76
}
77
77
78
78
boundInitInfoStatement = bindStatement ("INSERT INTO " + cdmKsTabInfo
79
- + " (table_name, run_id, run_type, prev_run_id, start_time, status) VALUES (?, ?, ?, ?, dateof (now()), ?)" );
79
+ + " (table_name, run_id, run_type, prev_run_id, start_time, status) VALUES (?, ?, ?, ?, totimestamp (now()), ?)" );
80
80
boundInitStatement = bindStatement ("INSERT INTO " + cdmKsTabDetails
81
81
+ " (table_name, run_id, token_min, token_max, status) VALUES (?, ?, ?, ?, ?)" );
82
82
boundEndInfoStatement = bindStatement ("UPDATE " + cdmKsTabInfo
83
- + " SET end_time = dateof (now()), run_info = ?, status = ? WHERE table_name = ? AND run_id = ?" );
83
+ + " SET end_time = totimestamp (now()), run_info = ?, status = ? WHERE table_name = ? AND run_id = ?" );
84
84
boundUpdateStatement = bindStatement ("UPDATE " + cdmKsTabDetails
85
85
+ " SET status = ?, run_info = ? WHERE table_name = ? AND run_id = ? AND token_min = ?" );
86
86
boundUpdateStartStatement = bindStatement ("UPDATE " + cdmKsTabDetails
87
- + " SET start_time = dateof (now()), status = ? WHERE table_name = ? AND run_id = ? AND token_min = ?" );
87
+ + " SET start_time = totimestamp (now()), status = ? WHERE table_name = ? AND run_id = ? AND token_min = ?" );
88
88
boundSelectInfoStatement = bindStatement (
89
89
"SELECT status FROM " + cdmKsTabInfo + " WHERE table_name = ? AND run_id = ?" );
90
90
boundSelectStatement = bindStatement ("SELECT token_min, token_max FROM " + cdmKsTabDetails
0 commit comments