Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
None
Description
When testing the Flink 1.12 in a standalone mode cluster, I found that if the user job jar contains both flink-avro and flink-parquet/flink-orc, the FileSystemTableSink would not be able to load the corresponding format factory correctly. But if only one format is dependent it works.
The test project located in here and the test class is FileCompactionTest.
The conflict does not seem to affect the local runner, but only has problem when submitted to the standalone cluster.
If the problem does exists, we might need to fix it or give user some tips about the conflicts.
Attachments
Issue Links
- relates to
-
FLINK-20122 Test Small file compaction
- Closed
- links to