Skip to content

Commit ff79278

Browse files
jongyoulclaude
andcommitted
[ZEPPELIN-6406] Add commons-logging to Flink lib for YARN integration tests
Flink 1.19+ no longer bundles commons-logging in its distribution, but Hadoop's FileSystem class requires it. This caused NoClassDefFoundError for org.apache.commons.logging.LogFactory in FlinkIntegrationTest119/120. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 6c95408 commit ff79278

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

zeppelin-test/src/main/java/org/apache/zeppelin/test/DownloadUtils.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -509,6 +509,11 @@ public static String downloadFlink(String flinkVersion, String scalaVersion) {
509509
"https://repo1.maven.org/maven2/org/apache/hadoop/hadoop-client-runtime/3.3.6/hadoop-client-runtime-3.3.6.jar",
510510
3, new File(targetFlinkHomeFolder,
511511
"lib" + File.separator + "hadoop-client-runtime-3.3.6.jar"));
512+
// commons-logging is required by Hadoop's FileSystem but not bundled in Flink 1.19+
513+
download(
514+
"https://repo1.maven.org/maven2/commons-logging/commons-logging/1.2/commons-logging-1.2.jar",
515+
3, new File(targetFlinkHomeFolder,
516+
"lib" + File.separator + "commons-logging-1.2.jar"));
512517
download("https://repo1.maven.org/maven2/org/apache/flink/flink-table-api-scala_"
513518
+ scalaVersion + "/"
514519
+ flinkVersion + "/flink-table-api-scala_" + scalaVersion + "-" + flinkVersion + ".jar",

0 commit comments

Comments
 (0)