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)
