Done (delta-io#414)

tdas · Jul 28, 2022 · 5e37b08 · 5e37b08
1 parent 3d25c59
commit 5e37b08
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/examples/build.sbt b/examples/build.sbt
@@ -26,8 +26,7 @@ lazy val commonSettings = Seq(
   resolvers += Resolver.mavenLocal,
   libraryDependencies ++= Seq(
     "io.delta" %% "delta-standalone" % getStandaloneVersion(),
-    "org.apache.hadoop" % "hadoop-client" % "3.1.0",
-    "org.apache.parquet" % "parquet-hadoop" % "1.10.1"
+    "org.apache.hadoop" % "hadoop-client" % "3.1.0"
   )
 )
 
@@ -75,6 +74,11 @@ lazy val flinkExample = (project in file("flink-example")) settings (
     "org.apache.flink" % "flink-table-common" % flinkVersion,
     "org.apache.hadoop" % "hadoop-client" % flinkHadoopVersion,
 
+    // Log4j runtime dependencies
+    "org.apache.logging.log4j" % "log4j-slf4j-impl" % "2.12.1" % "runtime",
+    "org.apache.logging.log4j" % "log4j-api" % "2.12.1" % "runtime",
+    "org.apache.logging.log4j" % "log4j-core" % "2.12.1" % "runtime",
+
     // Below dependencies are needed only to run the example project in memory
     "org.apache.flink" %% "flink-clients" % flinkVersion,
     "org.apache.flink" %% "flink-table-runtime-blink" % flinkVersion

diff --git a/examples/flink-example/src/main/java/org/utils/Utils.java b/examples/flink-example/src/main/java/org/utils/Utils.java
@@ -31,8 +31,10 @@ private Utils() {}
     public static String resolveExampleTableAbsolutePath(String resourcesTableDir) {
         String rootPath = Paths.get(".").toAbsolutePath().normalize().toString();
         return rootPath.endsWith("flink-example") ?
+            // Maven commands are run from the examples/flink-example/ directory
             rootPath + "/src/main/resources/" + resourcesTableDir :
-            rootPath + "/examples/flink-example/src/main/resources/" + resourcesTableDir;
+            // while SBT commands are run from the examples/ directory
+            rootPath + "/flink-example/src/main/resources/" + resourcesTableDir;
     }
 
     public static void prepareDirs(String tablePath) throws IOException {