From 9a9a0c5e57818a3059868a6c334c2dad360699f0 Mon Sep 17 00:00:00 2001
From: Matt Casters <mattcasters@gmail.com>
Date: Wed, 5 Feb 2020 11:45:25 +0100
Subject: [PATCH] Issue #49, Beam 2.18.0

---
 pom.xml                                       | 22 ++++++++++---------
 .../java/org/kettle/beam/core/BeamKettle.java |  6 ++---
 2 files changed, 15 insertions(+), 13 deletions(-)

diff --git a/pom.xml b/pom.xml
index 192455e..2f5887a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2,14 +2,19 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
+
+  <groupId>kettle-beam</groupId>
+  <artifactId>kettle-beam</artifactId>
+  <name>Kettle Beam</name>
+  <description>Kettle runtime plugins for Apache Beam</description>
+  <version>1.0.1-SNAPSHOT</version>
+
   <parent>
     <groupId>org.pentaho</groupId>
     <artifactId>pentaho-ce-jar-parent-pom</artifactId>
     <version>8.2.0.7-719</version>
   </parent>
-  <artifactId>kettle-beam</artifactId>
-  <name>${project.artifactId}</name>
-  <description>Kettle runtime plugins for Apache Beam</description>
+
   <licenses>
     <license>
       <name>Apache License, version 2.0</name>
@@ -22,8 +27,8 @@
     <pentaho-kettle.version>8.2.0.0-342</pentaho-kettle.version>
     <mockito-all.version>1.9.5</mockito-all.version>
     <junit.version>4.4</junit.version>
-    <apache-beam-version>2.16.0</apache-beam-version>
-    <kettle-beam-version>1.0.0-SNAPSHOT</kettle-beam-version>
+    <apache-beam-version>2.18.0</apache-beam-version>
+    <kettle-beam-version>1.0.1-SNAPSHOT</kettle-beam-version>
     <spark-version>2.4.3</spark-version>
   </properties>
 
@@ -78,7 +83,7 @@
     <dependency>
       <groupId>org.apache.beam</groupId>
       <artifactId>beam-runners-flink_2.11</artifactId>
-      <version>${apache-beam-version}</version>
+      <version>2.16.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.beam</groupId>
@@ -258,7 +263,7 @@
       <dependency>
         <groupId>org.apache.beam</groupId>
         <artifactId>beam-runners-flink_2.11</artifactId>
-        <version>${apache-beam-version}</version>
+        <version>2.16.0</version>
       </dependency>
       <dependency>
         <groupId>org.apache.beam</groupId>
@@ -349,7 +354,4 @@
     </dependencies>
   </dependencyManagement>
 
-
-  <groupId>kettle-beam</groupId>
-  <version>1.0.0-SNAPSHOT</version>
 </project>
\ No newline at end of file
diff --git a/src/main/java/org/kettle/beam/core/BeamKettle.java b/src/main/java/org/kettle/beam/core/BeamKettle.java
index 0099d02..8902739 100644
--- a/src/main/java/org/kettle/beam/core/BeamKettle.java
+++ b/src/main/java/org/kettle/beam/core/BeamKettle.java
@@ -38,7 +38,7 @@ public static final void init( List<String> stepPluginClasses, List<String> xpPl
 
       XMLHandlerCache.getInstance();
 
-      LOG.info( "Registering " + stepPluginClasses.size() + " extra step plugins, and " + xpPluginClasses.size() + " XP plugins" );
+      // LOG.info( "Registering " + stepPluginClasses.size() + " extra step plugins, and " + xpPluginClasses.size() + " XP plugins" );
 
       // Register extra classes from the plugins...
       // If they're already in the classpath, this should be fast.
@@ -57,7 +57,7 @@ public static final void init( List<String> stepPluginClasses, List<String> xpPl
 
             // The plugin class is already in the classpath so we simply call Class.forName() on it.
             //
-            LOG.info( "Registering step plugin class: " + stepPluginClass );
+            // LOG.info( "Registering step plugin class: " + stepPluginClass );
             stepPluginType.handlePluginAnnotation( stepPluginClass, annotation, new ArrayList<String>(), true, null );
           } else {
             LOG.debug( "Plugin " + stepPluginClassName + " is already registered" );
@@ -81,7 +81,7 @@ public static final void init( List<String> stepPluginClasses, List<String> xpPl
 
             // The plugin class is already in the classpath so we simply call Class.forName() on it.
             //
-            LOG.info( "Registering step plugin class: " + xpPluginClass );
+            // LOG.info( "Registering step plugin class: " + xpPluginClass );
             xpPluginType.handlePluginAnnotation( xpPluginClass, annotation, new ArrayList<String>(), true, null );
           } else {
             LOG.debug( "Plugin " + xpPluginClassName + " is already registered" );