[
https://issues.apache.org/jira/browse/HUDI-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Y Ethan Guo updated HUDI-9196:
------------------------------
Description:
Two Flink tests are flaky:
[https://github.com/apache/hudi/actions/runs/13914701358/job/38935560357]
{code:java}
Error: Tests run: 149, Failures: 0, Errors: 1, Skipped: 1, Time elapsed:
2,062.136 s <<< FAILURE! - in org.apache.hudi.table.ITTestHoodieDataSource
11043Error: testIncrementalReadArchivedCommits{HoodieTableType}[2] Time
elapsed: 31.692 s <<< ERROR!
11044java.lang.IllegalStateException: java.lang.IllegalStateException: Trying
to access closed classloader. Please check if you store classloaders directly
or indirectly in static fields. If the stacktrace suggests that the leak occurs
in a third party library and cannot be fixed immediately, you can disable this
check with the configuration 'classloader.check-leaked-classloader'.
11045 at
org.apache.hudi.table.ITTestHoodieDataSource.testIncrementalReadArchivedCommits(ITTestHoodieDataSource.java:1575)
11046Caused by: java.lang.IllegalStateException: Trying to access closed
classloader. Please check if you store classloaders directly or indirectly in
static fields. If the stacktrace suggests that the leak occurs in a third party
library and cannot be fixed immediately, you can disable this check with the
configuration 'classloader.check-leaked-classloader'.
11047 {code}
[https://github.com/apache/hudi/actions/runs/13910405190/job/38925714034]
{code:java}
Error: Tests run: 15, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
294.381 s <<< FAILURE! - in org.apache.hudi.sink.ITTestDataStreamWrite
12549Error: testStreamWriteWithIndexBootstrap{String}[2] Time elapsed: 35.085
s <<< FAILURE!
12550java.lang.AssertionError:
12551Unexpected records number under partition: par1
12552Expected: is <2>
12553 but: was <0>
12554 at
org.apache.hudi.sink.ITTestDataStreamWrite.writeAndCheckExpected(ITTestDataStreamWrite.java:303)
12555 at
org.apache.hudi.sink.ITTestDataStreamWrite.testStreamWriteWithIndexBootstrap(ITTestDataStreamWrite.java:194){code}
[https://github.com/apache/hudi/actions/runs/13932180941/job/38999980966]
{code:java}
Error: Tests run: 149, Failures: 1, Errors: 0, Skipped: 1, Time elapsed:
2,061.854 s <<< FAILURE! - in org.apache.hudi.table.ITTestHoodieDataSource
11235Error: testDynamicPartitionPrune{HoodieTableType, boolean}[4] Time
elapsed: 15.235 s <<< FAILURE!
11236java.lang.AssertionError:
11237
11238Expected: is "[+I[id12, Monica, 27, 1970-01-01T00:00:00.009, par5],
+I[id13, Phoebe, 31, 1970-01-01T00:00:00.010, par5], +I[id14, Rachel, 52,
1970-01-01T00:00:00.011, par6], +I[id15, Ross, 29, 1970-01-01T00:00:00.012,
par6]]"
11239 but: was "[]"
11240 at
org.apache.hudi.table.ITTestHoodieDataSource.testDynamicPartitionPrune(ITTestHoodieDataSource.java:2268)
{code}
was:
Two Flink tests are flaky:
[https://github.com/apache/hudi/actions/runs/13914701358/job/38935560357]
{code:java}
Error: Tests run: 149, Failures: 0, Errors: 1, Skipped: 1, Time elapsed:
2,062.136 s <<< FAILURE! - in org.apache.hudi.table.ITTestHoodieDataSource
11043Error: testIncrementalReadArchivedCommits{HoodieTableType}[2] Time
elapsed: 31.692 s <<< ERROR!
11044java.lang.IllegalStateException: java.lang.IllegalStateException: Trying
to access closed classloader. Please check if you store classloaders directly
or indirectly in static fields. If the stacktrace suggests that the leak occurs
in a third party library and cannot be fixed immediately, you can disable this
check with the configuration 'classloader.check-leaked-classloader'.
11045 at
org.apache.hudi.table.ITTestHoodieDataSource.testIncrementalReadArchivedCommits(ITTestHoodieDataSource.java:1575)
11046Caused by: java.lang.IllegalStateException: Trying to access closed
classloader. Please check if you store classloaders directly or indirectly in
static fields. If the stacktrace suggests that the leak occurs in a third party
library and cannot be fixed immediately, you can disable this check with the
configuration 'classloader.check-leaked-classloader'.
11047 {code}
[https://github.com/apache/hudi/actions/runs/13910405190/job/38925714034]
{code:java}
Error: Tests run: 15, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
294.381 s <<< FAILURE! - in org.apache.hudi.sink.ITTestDataStreamWrite
12549Error: testStreamWriteWithIndexBootstrap{String}[2] Time elapsed: 35.085
s <<< FAILURE!
12550java.lang.AssertionError:
12551Unexpected records number under partition: par1
12552Expected: is <2>
12553 but: was <0>
12554 at
org.apache.hudi.sink.ITTestDataStreamWrite.writeAndCheckExpected(ITTestDataStreamWrite.java:303)
12555 at
org.apache.hudi.sink.ITTestDataStreamWrite.testStreamWriteWithIndexBootstrap(ITTestDataStreamWrite.java:194){code}
[https://github.com/apache/hudi/actions/runs/13932180941/job/38999980966]
{code:java}
Error: Tests run: 149, Failures: 1, Errors: 0, Skipped: 1, Time elapsed:
2,061.854 s <<< FAILURE! - in org.apache.hudi.table.ITTestHoodieDataSource
11235Error: testDynamicPartitionPrune{HoodieTableType, boolean}[4] Time
elapsed: 15.235 s <<< FAILURE!
11236java.lang.AssertionError:
11237
11238Expected: is "[+I[id12, Monica, 27, 1970-01-01T00:00:00.009, par5],
+I[id13, Phoebe, 31, 1970-01-01T00:00:00.010, par5], +I[id14, Rachel, 52,
1970-01-01T00:00:00.011, par6], +I[id15, Ross, 29, 1970-01-01T00:00:00.012,
par6]]"
11239 but: was "[]"
11240 at
org.apache.hudi.table.ITTestHoodieDataSource.testDynamicPartitionPrune(ITTestHoodieDataSource.java:2268)
{code}
> Investigate Flink flaky tests
> -----------------------------
>
> Key: HUDI-9196
> URL: https://issues.apache.org/jira/browse/HUDI-9196
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Y Ethan Guo
> Priority: Blocker
> Fix For: 1.0.2
>
>
> Two Flink tests are flaky:
> [https://github.com/apache/hudi/actions/runs/13914701358/job/38935560357]
> {code:java}
> Error: Tests run: 149, Failures: 0, Errors: 1, Skipped: 1, Time elapsed:
> 2,062.136 s <<< FAILURE! - in org.apache.hudi.table.ITTestHoodieDataSource
> 11043Error: testIncrementalReadArchivedCommits{HoodieTableType}[2] Time
> elapsed: 31.692 s <<< ERROR!
> 11044java.lang.IllegalStateException: java.lang.IllegalStateException: Trying
> to access closed classloader. Please check if you store classloaders directly
> or indirectly in static fields. If the stacktrace suggests that the leak
> occurs in a third party library and cannot be fixed immediately, you can
> disable this check with the configuration
> 'classloader.check-leaked-classloader'.
> 11045 at
> org.apache.hudi.table.ITTestHoodieDataSource.testIncrementalReadArchivedCommits(ITTestHoodieDataSource.java:1575)
> 11046Caused by: java.lang.IllegalStateException: Trying to access closed
> classloader. Please check if you store classloaders directly or indirectly in
> static fields. If the stacktrace suggests that the leak occurs in a third
> party library and cannot be fixed immediately, you can disable this check
> with the configuration 'classloader.check-leaked-classloader'.
> 11047 {code}
> [https://github.com/apache/hudi/actions/runs/13910405190/job/38925714034]
> {code:java}
> Error: Tests run: 15, Failures: 1, Errors: 0, Skipped: 0, Time elapsed:
> 294.381 s <<< FAILURE! - in org.apache.hudi.sink.ITTestDataStreamWrite
> 12549Error: testStreamWriteWithIndexBootstrap{String}[2] Time elapsed:
> 35.085 s <<< FAILURE!
> 12550java.lang.AssertionError:
> 12551Unexpected records number under partition: par1
> 12552Expected: is <2>
> 12553 but: was <0>
> 12554 at
> org.apache.hudi.sink.ITTestDataStreamWrite.writeAndCheckExpected(ITTestDataStreamWrite.java:303)
> 12555 at
> org.apache.hudi.sink.ITTestDataStreamWrite.testStreamWriteWithIndexBootstrap(ITTestDataStreamWrite.java:194){code}
> [https://github.com/apache/hudi/actions/runs/13932180941/job/38999980966]
> {code:java}
> Error: Tests run: 149, Failures: 1, Errors: 0, Skipped: 1, Time elapsed:
> 2,061.854 s <<< FAILURE! - in org.apache.hudi.table.ITTestHoodieDataSource
> 11235Error: testDynamicPartitionPrune{HoodieTableType, boolean}[4] Time
> elapsed: 15.235 s <<< FAILURE!
> 11236java.lang.AssertionError:
> 11237
> 11238Expected: is "[+I[id12, Monica, 27, 1970-01-01T00:00:00.009, par5],
> +I[id13, Phoebe, 31, 1970-01-01T00:00:00.010, par5], +I[id14, Rachel, 52,
> 1970-01-01T00:00:00.011, par6], +I[id15, Ross, 29, 1970-01-01T00:00:00.012,
> par6]]"
> 11239 but: was "[]"
> 11240 at
> org.apache.hudi.table.ITTestHoodieDataSource.testDynamicPartitionPrune(ITTestHoodieDataSource.java:2268)
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
