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 63320bc commit 25cff7fCopy full SHA for 25cff7f
1 file changed
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJsonUtils.java
@@ -56,7 +56,7 @@ public static JsonFactory createJsonFactory(int sizeLimit) {
56
Class.forName("com.fasterxml.jackson.core.StreamReadConstraints");
57
com.fasterxml.jackson.core.StreamReadConstraints streamReadConstraints =
58
com.fasterxml.jackson.core.StreamReadConstraints.builder()
59
- .maxStringLength(MAX_STRING_LENGTH)
+ .maxStringLength(sizeLimit)
60
.build();
61
jsonFactory.setStreamReadConstraints(streamReadConstraints);
62
} catch (ClassNotFoundException e) {
0 commit comments