X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/3596aff0954f405b06799814585d834502d0d76a..6d95130da47af9fd0290d3c8f80a0364faf74957:/services/crunch-run/logging.go diff --git a/services/crunch-run/logging.go b/services/crunch-run/logging.go index fc9c6f6289..01cab69cd0 100644 --- a/services/crunch-run/logging.go +++ b/services/crunch-run/logging.go @@ -15,7 +15,7 @@ import ( "sync" "time" - "git.curoverse.com/arvados.git/sdk/go/arvadosclient" + "git.arvados.org/arvados.git/sdk/go/arvadosclient" ) // Timestamper is the signature for a function that takes a timestamp and @@ -197,8 +197,8 @@ var crunchLogThrottleLines int64 = 1024 var crunchLogPartialLineThrottlePeriod time.Duration = time.Second * 5 var crunchLogBytesPerEvent int64 = 4096 var crunchLogSecondsBetweenEvents = time.Second -var crunchLogCheckpointMaxDuration = time.Hour / 2 -var crunchLogCheckpointMaxBytes = int64(1 << 25) +var crunchLogUpdatePeriod = time.Hour / 2 +var crunchLogUpdateSize = int64(1 << 25) // ArvLogWriter is an io.WriteCloser that processes each write by // writing it through to another io.WriteCloser (typically a @@ -401,7 +401,7 @@ func loadLogThrottleParams(clnt IArvadosClient) { loadDuration(&crunchLogPartialLineThrottlePeriod, "crunchLogPartialLineThrottlePeriod") loadInt64(&crunchLogBytesPerEvent, "crunchLogBytesPerEvent") loadDuration(&crunchLogSecondsBetweenEvents, "crunchLogSecondsBetweenEvents") - loadInt64(&crunchLogCheckpointMaxBytes, "crunchLogCheckpointMaxBytes") - loadDuration(&crunchLogCheckpointMaxDuration, "crunchLogCheckpointMaxDuration") + loadInt64(&crunchLogUpdateSize, "crunchLogUpdateSize") + loadDuration(&crunchLogUpdatePeriod, "crunchLogUpdatePeriod") }