Yun Gao created FLINK-25102: ------------------------------- Summary: ParquetFileSystemITCase.testPartialDynamicPartition failed on azure Key: FLINK-25102 URL: https://issues.apache.org/jira/browse/FLINK-25102 Project: Flink Issue Type: Bug Components: Connectors / FileSystem Affects Versions: 1.15.0 Reporter: Yun Gao
{code:java} Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.getResource(Configuration.java:2780) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.getStreamReader(Configuration.java:3036) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.loadResource(Configuration.java:2995) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.loadResources(Configuration.java:2968) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.getProps(Configuration.java:2848) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.get(Configuration.java:1200) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.getTrimmed(Configuration.java:1254) Nov 29 23:00:01 at org.apache.hadoop.conf.Configuration.getInt(Configuration.java:1479) Nov 29 23:00:01 at org.apache.parquet.hadoop.codec.SnappyCodec.createInputStream(SnappyCodec.java:75) Nov 29 23:00:01 at org.apache.parquet.hadoop.CodecFactory$HeapBytesDecompressor.decompress(CodecFactory.java:109) Nov 29 23:00:01 at org.apache.parquet.hadoop.ColumnChunkPageReadStore$ColumnChunkPageReader$1.visit(ColumnChunkPageReadStore.java:103) Nov 29 23:00:01 at org.apache.parquet.hadoop.ColumnChunkPageReadStore$ColumnChunkPageReader$1.visit(ColumnChunkPageReadStore.java:99) Nov 29 23:00:01 at org.apache.parquet.column.page.DataPageV1.accept(DataPageV1.java:120) Nov 29 23:00:01 at org.apache.parquet.hadoop.ColumnChunkPageReadStore$ColumnChunkPageReader.readPage(ColumnChunkPageReadStore.java:99) Nov 29 23:00:01 at org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader.readToVector(AbstractColumnReader.java:154) Nov 29 23:00:01 at org.apache.flink.formats.parquet.ParquetVectorizedInputFormat$ParquetReader.nextBatch(ParquetVectorizedInputFormat.java:390) Nov 29 23:00:01 at org.apache.flink.formats.parquet.ParquetVectorizedInputFormat$ParquetReader.readBatch(ParquetVectorizedInputFormat.java:358) Nov 29 23:00:01 at org.apache.flink.connector.file.src.impl.FileSourceSplitReader.fetch(FileSourceSplitReader.java:67) Nov 29 23:00:01 at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) Nov 29 23:00:01 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142) Nov 29 23:00:01 ... 6 more Nov 29 23:00:01 Nov 29 23:00:02 [INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.341 s - in org.apache.flink.formats.parquet.ParquetFileCompactionITCase Nov 29 23:00:03 [ERROR] Picked up JAVA_TOOL_OPTIONS: -XX:+HeapDumpOnOutOfMemoryError Nov 29 23:00:03 [INFO] Running org.apache.flink.formats.parquet.ParquetFsStreamingSinkITCase Nov 29 23:00:20 [INFO] Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 17.033 s - in org.apache.flink.formats.parquet.ParquetFsStreamingSinkITCase Nov 29 23:00:21 [INFO] Nov 29 23:00:21 [INFO] Results: Nov 29 23:00:21 [INFO] Nov 29 23:00:21 [ERROR] Errors: Nov 29 23:00:21 [ERROR] ParquetFileSystemITCase.testPartialDynamicPartition Nov 29 23:00:21 [ERROR] Run 1: Failed to fetch next result Nov 29 23:00:21 [INFO] Run 2: PASS Nov 29 23:00:21 [INFO] Nov 29 23:00:21 [INFO] Nov 29 23:00:21 [ERROR] Tests run: 42, Failures: 0, Errors: 1, Skipped: 1 {code} https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27235&view=logs&j=ba53eb01-1462-56a3-8e98-0dd97fbcaab5&t=2e426bf0-b717-56bb-ab62-d63086457354&l=11545 -- This message was sent by Atlassian Jira (v8.20.1#820001)