[
https://issues.apache.org/jira/browse/FLINK-35673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859535#comment-17859535
]
Weijie Guo commented on FLINK-35673:
------------------------------------
96fbb705 introduce two test testCreateUnboundedSource/testCreateBoundedSource
recently. I guess the method `getScanRuntimeProvider` in
`TestFileSystemTableSource` is never called before this.
> TestFileSource$TestFileSourceBuilder cannot be cast to class
> FileSource$FileSourceBuilder
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-35673
> URL: https://issues.apache.org/jira/browse/FLINK-35673
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 1.20.0
> Reporter: Weijie Guo
> Assignee: Weijie Guo
> Priority: Major
> Labels: pull-request-available
>
> {code:java}
> Jun 22 02:11:41 java.lang.ClassCastException: class
> org.apache.flink.connector.file.src.TestFileSource$TestFileSourceBuilder
> cannot be cast to class
> org.apache.flink.connector.file.src.FileSource$FileSourceBuilder
> (org.apache.flink.connector.file.src.TestFileSource$TestFileSourceBuilder and
> org.apache.flink.connector.file.src.FileSource$FileSourceBuilder are in
> unnamed module of loader 'app')
> Jun 22 02:11:41 at
> org.apache.flink.connector.file.table.TestFileSystemTableSource.lambda$createSourceProvider$0(TestFileSystemTableSource.java:70)
> Jun 22 02:11:41 at
> java.base/java.util.Optional.ifPresent(Optional.java:178)
> Jun 22 02:11:41 at
> org.apache.flink.connector.file.table.TestFileSystemTableSource.createSourceProvider(TestFileSystemTableSource.java:70)
> Jun 22 02:11:41 at
> org.apache.flink.connector.file.table.FileSystemTableSource.getScanRuntimeProvider(FileSystemTableSource.java:222)
> Jun 22 02:11:41 at
> org.apache.flink.table.file.testutils.TestFileSystemTableFactoryTest.testCreateUnboundedSource(TestFileSystemTableFactoryTest.java:87)
> Jun 22 02:11:41 at
> java.base/java.lang.reflect.Method.invoke(Method.java:568)
> Jun 22 02:11:41 at
> java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:194)
> Jun 22 02:11:41 at
> java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
> Jun 22 02:11:41 at
> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
> Jun 22 02:11:41 at
> java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
> Jun 22 02:11:41 at
> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
> Jun 22 02:11:41 at
> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60431&view=logs&j=59a2b95a-736b-5c46-b3e0-cee6e587fd86&t=c301da75-e699-5c06-735f-778207c16f50&l=22872
> NB. This only raise on JDK >= 11, I suspect this is because a known javac
> bug: https://bugs.openjdk.org/browse/JDK-8058199
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
