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 b34e14c commit acfd5a0Copy full SHA for acfd5a0
src/main/java/org/radarbase/hdfs/Application.kt
@@ -130,8 +130,10 @@ class Application(override val config: RestructureConfig) : FileStoreFactory {
130
logger.error("Processing interrupted")
131
} finally {
132
// Print timings and reset the timings for the next iteration.
133
- println(Timer)
134
- Timer.reset()
+ if (Timer.isEnabled) {
+ logger.info("{}", Timer)
135
+ Timer.reset()
136
+ }
137
}
138
139
src/main/java/org/radarbase/hdfs/util/Timer.kt
@@ -44,6 +44,7 @@ object Timer {
44
Runtime.getRuntime().addShutdownHook(shutdownHook)
45
} else {
46
Runtime.getRuntime().removeShutdownHook(shutdownHook)
47
+ times.clear()
48
49
50
field = value
0 commit comments