We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2753f55 commit 5198f55Copy full SHA for 5198f55
1 file changed
core/sling/task.go
@@ -159,13 +159,19 @@ func (t *TaskExecution) setLogDetails() {
159
}
160
rowCount := t.GetCount()
161
rowRate, byteRate := t.GetRate(1)
162
+ bytes, _ := t.GetBytes()
163
os.Setenv("SLING_LOG_DETAILS", g.Marshal(g.M(
164
"run_file", t.Config.Env["SLING_CONFIG_PATH"],
165
"run_type", "replication",
166
+ "source_name", t.Config.SrcConn.Name,
167
+ "source_type", t.Config.SrcConn.Type,
168
+ "target_name", t.Config.TgtConn.Name,
169
+ "target_type", t.Config.TgtConn.Type,
170
"stream_name", t.Config.StreamName,
171
"object_name", t.getTargetObjectValue(),
172
"row_count", rowCount,
173
"row_rate", rowRate,
174
+ "byte_count", bytes,
175
"byte_rate", byteRate,
176
"status", t.Status,
177
"duration", duration,
0 commit comments