This is an automated email from the ASF dual-hosted git repository. iemejia pushed a commit to branch branch-1.9 in repository https://gitbox.apache.org/repos/asf/avro.git
commit 16cf5712b27d30d01fb5192acdeae5742e1ef9da Author: Ismaël Mejía <[email protected]> AuthorDate: Thu Feb 6 14:14:58 2020 +0100 AVRO-2726: Remove deprecation warnings --- .../avro/src/main/java/org/apache/avro/file/ZstandardLoader.java | 7 ++++--- .../java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java | 2 +- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/lang/java/avro/src/main/java/org/apache/avro/file/ZstandardLoader.java b/lang/java/avro/src/main/java/org/apache/avro/file/ZstandardLoader.java index 0a4bf33..d6f2a4a 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/file/ZstandardLoader.java +++ b/lang/java/avro/src/main/java/org/apache/avro/file/ZstandardLoader.java @@ -35,9 +35,10 @@ final class ZstandardLoader { } static OutputStream output(OutputStream compressed, int level, boolean checksum) throws IOException { - int bounded = Math.max(Math.min(level, Zstd.maxCompressionLevel()), Zstd.minCompressionLevel()); - - return new ZstdOutputStream(compressed, bounded, false, checksum); + ZstdOutputStream zstdOutputStream = new ZstdOutputStream(compressed, bounded); + zstdOutputStream.setCloseFrameOnFlush(false); + zstdOutputStream.setChecksum(checksum); + return zstdOutputStream; } } diff --git a/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java b/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java index 1e2fba4..9953b3b 100644 --- a/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java +++ b/lang/java/avro/src/main/java/org/apache/avro/io/parsing/ResolvingGrammarGenerator.java @@ -176,7 +176,7 @@ public class ResolvingGrammarGenerator extends ValidatingGrammarGenerator { return Symbol.STRING; case FIXED: - return Symbol.seq(new Symbol.IntCheckAction(s.getFixedSize()), Symbol.FIXED); + return Symbol.seq(Symbol.intCheckAction(s.getFixedSize()), Symbol.FIXED); case ENUM: return Symbol.seq(Symbol.enumAdjustAction(s.getEnumSymbols().size(), null), Symbol.ENUM);
