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 877547d commit 04f6c50Copy full SHA for 04f6c50
1 file changed
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java
@@ -2371,11 +2371,10 @@ private static void warnIfValueStateContainsCollection(
2371
}
2372
2373
if (recommendation != null) {
2374
- LOG.info(
+ LOG.warn(
2375
"DoFn {} declares ValueState '{}' with collection type {}. "
2376
+ "ValueState reads/writes the entire collection on each access. "
2377
- + "This is appropriate for small collections or atomic replacement. "
2378
- + "For large collections or frequent appends, consider using {} instead "
+ + "For large or frequently-updated collections, consider using {} instead "
2379
+ "(if supported by your runner).",
2380
fnClazz.getSimpleName(),
2381
stateId,
0 commit comments