[
https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450877#comment-17450877
]
Yun Gao commented on FLINK-25102:
---------------------------------
Hi [~lzljs3620320] this issue seems to have the same cause with
https://issues.apache.org/jira/browse/FLINK-24763, could you have a double look
on this issue or if we need to also ignore this case~?
> 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
> Priority: Major
> Labels: test-stability
>
> {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)
