LEEKYE commented on code in PR #36003:
URL: https://github.com/apache/beam/pull/36003#discussion_r2310455956
##########
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ExecutionStateSampler.java:
##########
@@ -400,25 +400,26 @@ private Optional<String> takeSample(long
currentTimeMillis, long millisSinceLast
if (thread == null) {
timeoutMessage =
String.format(
- "Operation ongoing in bundle %s for at least %s without
outputting "
- + "or completing (stack trace unable to be generated).
The SDK worker will restart.",
+ "Processing of an element in bundle %s has exceeded the
specified timeout of %s "
+ + "(stack trace unable to be generated). The SDK
worker will be terminated.",
processBundleId.get(),
DURATION_FORMATTER.print(
Duration.millis(userSpecifiedLullTimeMsForRestart).toPeriod()));
} else if (currentExecutionState == null) {
timeoutMessage =
String.format(
- "Operation ongoing in bundle %s for at least %s without
outputting "
- + "or completing:%n at %s. The SDK worker will
restart.",
+ "Processing of an element in bundle %s has exceeded the
specified timeout of %s "
+ + "without outputting or completing:%n at %s. The SDK
worker will be terminated.",
processBundleId.get(),
DURATION_FORMATTER.print(
Duration.millis(userSpecifiedLullTimeMsForRestart).toPeriod()),
Joiner.on("\n at ").join(thread.getStackTrace()));
} else {
timeoutMessage =
String.format(
- "Operation ongoing in bundle %s for PTransform{id=%s,
name=%s, state=%s} "
- + "for at least %s without outputting or completing:%n
at %s. The SDK worker will restart.",
+ "Processing of an element in bundle %s for
PTransform{id=%s, name=%s, state=%s} "
+ + "has exceeded the specified timeout of %s without
outputting or completing:%n at %s. "
Review Comment:
It's unnecessary as the parameter is in Duration format
DURATION_FORMATTER.print(
Duration.millis(userSpecifiedLullTimeMsForRestart).toPeriod())
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
