This is an automated email from the ASF dual-hosted git repository. ppkarwasz pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/logging-flume-legacy.git
commit 9906b0fbefa230a03092bcb5674a62882bcf83a1 Author: nikita15p <[email protected]> AuthorDate: Thu Feb 23 15:37:43 2023 +0530 FLUME-3448 fixed unit test errors related to bump up Signed-off-by: nikita15p <[email protected]> --- .../apache/flume/clients/log4jappender/TestLog4jAppenderWithAvro.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLog4jAppenderWithAvro.java b/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLog4jAppenderWithAvro.java index 9ccebc8..23c2d7e 100644 --- a/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLog4jAppenderWithAvro.java +++ b/flume-ng-log4jappender/src/test/java/org/apache/flume/clients/log4jappender/TestLog4jAppenderWithAvro.java @@ -71,8 +71,7 @@ public class TestLog4jAppenderWithAvro { @Before public void setUp() throws Exception { URL schemaUrl = getClass().getClassLoader().getResource("myrecord.avsc"); - Files.copy(Resources.newInputStreamSupplier(schemaUrl), - new File("/tmp/myrecord.avsc")); + Resources.asByteSource(schemaUrl).copyTo(Files.asByteSink(new File("/tmp/myrecord.avsc"))); port = getFreePort(); source = new AvroSource();
