Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-12868

Insert into Table resulting in unable to serialize DoFnWithExecutionInformation

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • 2.32.0
    • Missing
    • dsl-sql
    • None

    Description

      //No issues was able to read the file successfully

      PCollection<String> revisionPCollection = dataPipe.apply(TextIO.read().from(revisionCSVFile));

      //Was able to convert string into Pcollection object with fields defined through schema
      PCollection<EgpItemRevisionInterface> revRecordPCollection = revisionPCollection.apply(ParDo.of(new ConvertToRevisionRecFn()));

       

      String sqlStmt = "INSERT INTO (BATCH_ID,PROCESS_STATUS,THREAD_NUMBER," +
      "ITEM_NUMBER, ORGANIZATION_CODE,INVENTORY_ITEM_ID," +
      "ORGANIZATION_ID,REVISION_ID,REVISION," +
      "LAST_UPDATED_BY,CREATED_BY,OBJECT_VERSION_NUMBER) " +
      "ITEM_REVISIONS_INTERFACE VALUES(?,?,?,?,?,?,?,?,?,?,?,?)";

      //I am getting error on the below code line..

      revRecordPCollection.apply(JdbcIO.<EgpItemRevisionInterface>write().withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create
      ("oracle.jdbc.driver.OracleDriver" ,"jdbc:oracle:thin:@machine:1540/EMS11619_FDB")
      .withUsername("****")
      .withPassword("****"))
      .withStatement(sqlStmt)
      .withPreparedStatementSetter(new JdbcIO.PreparedStatementSetter<EgpItemRevisionInterface>()
      {
      public void setParameters(EgpItemRevisionInterface element, PreparedStatement query) throws SQLException
      {
      query.setLong(1, element.getBatchId());
      query.setInt(2, element.getProcessStatus());
      query.setInt(3, element.getThreadNumber());
      query.setString(4, element.getItemNumber());
      query.setString(5, element.getOrgnizationCode());
      query.setLong(6, element.getInventoryItemId());
      query.setLong(7, element.getOrganizationId());
      query.setLong(8, element.getRevisionId());
      query.setString(9, element.getRevision());
      query.setString(10, element.getLastUpdatedBy());
      query.setString(11, element.getCreatedBy());
      query.setInt(12, element.getObjectVersionNumber());
      }
      }
      ));

       

      java.lang.IllegalArgumentException: unable to serialize DoFnWithExecutionInformation{doFn=org.apache.beam.sdk.io.jdbc.JdbcIO$WriteVoid$WriteFn@4ff9b813, mainOutputTag=Tag<output>, sideInputMapping={}, schemaInformation=DoFnSchemaInformation{elementConverters=[]}}
      at org.apache.beam.sdk.util.SerializableUtils.serializeToByteArray (SerializableUtils.java:59)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateDoFn (ParDoTranslation.java:695)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$1.translateDoFn (ParDoTranslation.java:253)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.payloadForParDoLike (ParDoTranslation.java:817)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:249)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:210)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$ParDoTranslator.translate (ParDoTranslation.java:176)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformTranslation.toProto (PTransformTranslation.java:248)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.getParDoPayload (ParDoTranslation.java:746)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.isSplittable (ParDoTranslation.java:761)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformMatchers$6.matches (PTransformMatchers.java:274)
      at org.apache.beam.sdk.Pipeline$2.visitPrimitiveTransform (Pipeline.java:290)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:593)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500 (TransformHierarchy.java:240)
      at org.apache.beam.sdk.runners.TransformHierarchy.visit (TransformHierarchy.java:214)
      at org.apache.beam.sdk.Pipeline.traverseTopologically (Pipeline.java:469)
      at org.apache.beam.sdk.Pipeline.replace (Pipeline.java:268)
      at org.apache.beam.sdk.Pipeline.replaceAll (Pipeline.java:218)
      at org.apache.beam.runners.direct.DirectRunner.performRewrites (DirectRunner.java:254)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:175)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:67)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:323)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:309)
      at loadRevisionInterfaceTable.runPipeline (loadRevisionInterfaceTable.java:102)
      at loadRevisionInterfaceTable.main (loadRevisionInterfaceTable.java:109)
      at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:254)
      at java.lang.Thread.run (Thread.java:748)
      Caused by: java.io.NotSerializableException: loadRevisionInterfaceTable
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1184)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.writeObject (ObjectOutputStream.java:348)
      at org.apache.beam.sdk.util.SerializableUtils.serializeToByteArray (SerializableUtils.java:55)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateDoFn (ParDoTranslation.java:695)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$1.translateDoFn (ParDoTranslation.java:253)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.payloadForParDoLike (ParDoTranslation.java:817)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:249)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:210)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$ParDoTranslator.translate (ParDoTranslation.java:176)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformTranslation.toProto (PTransformTranslation.java:248)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.getParDoPayload (ParDoTranslation.java:746)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.isSplittable (ParDoTranslation.java:761)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformMatchers$6.matches (PTransformMatchers.java:274)
      at org.apache.beam.sdk.Pipeline$2.visitPrimitiveTransform (Pipeline.java:290)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:593)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500 (TransformHierarchy.java:240)
      at org.apache.beam.sdk.runners.TransformHierarchy.visit (TransformHierarchy.java:214)
      at org.apache.beam.sdk.Pipeline.traverseTopologically (Pipeline.java:469)
      at org.apache.beam.sdk.Pipeline.replace (Pipeline.java:268)
      at org.apache.beam.sdk.Pipeline.replaceAll (Pipeline.java:218)
      at org.apache.beam.runners.direct.DirectRunner.performRewrites (DirectRunner.java:254)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:175)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:67)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:323)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:309)
      at loadRevisionInterfaceTable.runPipeline (loadRevisionInterfaceTable.java:102)
      at loadRevisionInterfaceTable.main (loadRevisionInterfaceTable.java:109)
      at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:254)
      at java.lang.Thread.run (Thread.java:748)
      [INFO] ------------------------------------------------------------------------
      [INFO] BUILD FAILURE
      [INFO] ------------------------------------------------------------------------
      [INFO] Total time: 4.872 s
      [INFO] Finished at: 2021-09-09T18:17:20-05:00
      [INFO] ------------------------------------------------------------------------
      [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:3.0.0:java (default-cli) on project pipelineDemo: An exception occured while executing the Java class. unable to serialize DoFnWithExecutionInformation{doFn=org.apache.beam.sdk.io.jdbc.JdbcIO$WriteVoid$WriteFn@4ff9b813, mainOutputTag=Tag<output>, sideInputMapping={}, schemaInformation=DoFnSchemaInformation{elementConverters=[]}}: loadRevisionInterfaceTable -> [Help 1]
      org.apache.maven.lifecycle.LifecycleExecutionException: Failed to execute goal org.codehaus.mojo:exec-maven-plugin:3.0.0:java (default-cli) on project pipelineDemo: An exception occured while executing the Java class. unable to serialize DoFnWithExecutionInformation{doFn=org.apache.beam.sdk.io.jdbc.JdbcIO$WriteVoid$WriteFn@4ff9b813, mainOutputTag=Tag<output>, sideInputMapping={}, schemaInformation=DoFnSchemaInformation{elementConverters=[]}}
      at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:215)
      at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:156)
      at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:148)
      at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModuleBuilder.java:117)
      at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModuleBuilder.java:81)
      at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build (SingleThreadedBuilder.java:56)
      at org.apache.maven.lifecycle.internal.LifecycleStarter.execute (LifecycleStarter.java:128)
      at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:305)
      at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:192)
      at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:105)
      at org.apache.maven.cli.MavenCli.execute (MavenCli.java:972)
      at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:293)
      at org.apache.maven.cli.MavenCli.main (MavenCli.java:196)
      at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke (Method.java:498)
      at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced (Launcher.java:282)
      at org.codehaus.plexus.classworlds.launcher.Launcher.launch (Launcher.java:225)
      at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode (Launcher.java:406)
      at org.codehaus.plexus.classworlds.launcher.Launcher.main (Launcher.java:347)
      Caused by: org.apache.maven.plugin.MojoExecutionException: An exception occured while executing the Java class. unable to serialize DoFnWithExecutionInformation{doFn=org.apache.beam.sdk.io.jdbc.JdbcIO$WriteVoid$WriteFn@4ff9b813, mainOutputTag=Tag<output>, sideInputMapping={}, schemaInformation=DoFnSchemaInformation{elementConverters=[]}}
      at org.codehaus.mojo.exec.ExecJavaMojo.execute (ExecJavaMojo.java:311)
      at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo (DefaultBuildPluginManager.java:137)
      at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:210)
      at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:156)
      at org.apache.maven.lifecycle.internal.MojoExecutor.execute (MojoExecutor.java:148)
      at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModuleBuilder.java:117)
      at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject (LifecycleModuleBuilder.java:81)
      at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build (SingleThreadedBuilder.java:56)
      at org.apache.maven.lifecycle.internal.LifecycleStarter.execute (LifecycleStarter.java:128)
      at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:305)
      at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:192)
      at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:105)
      at org.apache.maven.cli.MavenCli.execute (MavenCli.java:972)
      at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:293)
      at org.apache.maven.cli.MavenCli.main (MavenCli.java:196)
      at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke (Method.java:498)
      at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced (Launcher.java:282)
      at org.codehaus.plexus.classworlds.launcher.Launcher.launch (Launcher.java:225)
      at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode (Launcher.java:406)
      at org.codehaus.plexus.classworlds.launcher.Launcher.main (Launcher.java:347)
      Caused by: java.lang.IllegalArgumentException: unable to serialize DoFnWithExecutionInformation{doFn=org.apache.beam.sdk.io.jdbc.JdbcIO$WriteVoid$WriteFn@4ff9b813, mainOutputTag=Tag<output>, sideInputMapping={}, schemaInformation=DoFnSchemaInformation{elementConverters=[]}}
      at org.apache.beam.sdk.util.SerializableUtils.serializeToByteArray (SerializableUtils.java:59)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateDoFn (ParDoTranslation.java:695)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$1.translateDoFn (ParDoTranslation.java:253)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.payloadForParDoLike (ParDoTranslation.java:817)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:249)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:210)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$ParDoTranslator.translate (ParDoTranslation.java:176)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformTranslation.toProto (PTransformTranslation.java:248)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.getParDoPayload (ParDoTranslation.java:746)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.isSplittable (ParDoTranslation.java:761)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformMatchers$6.matches (PTransformMatchers.java:274)
      at org.apache.beam.sdk.Pipeline$2.visitPrimitiveTransform (Pipeline.java:290)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:593)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500 (TransformHierarchy.java:240)
      at org.apache.beam.sdk.runners.TransformHierarchy.visit (TransformHierarchy.java:214)
      at org.apache.beam.sdk.Pipeline.traverseTopologically (Pipeline.java:469)
      at org.apache.beam.sdk.Pipeline.replace (Pipeline.java:268)
      at org.apache.beam.sdk.Pipeline.replaceAll (Pipeline.java:218)
      at org.apache.beam.runners.direct.DirectRunner.performRewrites (DirectRunner.java:254)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:175)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:67)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:323)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:309)
      at loadRevisionInterfaceTable.runPipeline (loadRevisionInterfaceTable.java:102)
      at loadRevisionInterfaceTable.main (loadRevisionInterfaceTable.java:109)
      at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:254)
      at java.lang.Thread.run (Thread.java:748)
      Caused by: java.io.NotSerializableException: loadRevisionInterfaceTable
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1184)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.defaultWriteFields (ObjectOutputStream.java:1548)
      at java.io.ObjectOutputStream.writeSerialData (ObjectOutputStream.java:1509)
      at java.io.ObjectOutputStream.writeOrdinaryObject (ObjectOutputStream.java:1432)
      at java.io.ObjectOutputStream.writeObject0 (ObjectOutputStream.java:1178)
      at java.io.ObjectOutputStream.writeObject (ObjectOutputStream.java:348)
      at org.apache.beam.sdk.util.SerializableUtils.serializeToByteArray (SerializableUtils.java:55)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateDoFn (ParDoTranslation.java:695)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$1.translateDoFn (ParDoTranslation.java:253)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.payloadForParDoLike (ParDoTranslation.java:817)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:249)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.translateParDo (ParDoTranslation.java:210)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation$ParDoTranslator.translate (ParDoTranslation.java:176)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformTranslation.toProto (PTransformTranslation.java:248)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.getParDoPayload (ParDoTranslation.java:746)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.ParDoTranslation.isSplittable (ParDoTranslation.java:761)
      at org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformMatchers$6.matches (PTransformMatchers.java:274)
      at org.apache.beam.sdk.Pipeline$2.visitPrimitiveTransform (Pipeline.java:290)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:593)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.visit (TransformHierarchy.java:585)
      at org.apache.beam.sdk.runners.TransformHierarchy$Node.access$500 (TransformHierarchy.java:240)
      at org.apache.beam.sdk.runners.TransformHierarchy.visit (TransformHierarchy.java:214)
      at org.apache.beam.sdk.Pipeline.traverseTopologically (Pipeline.java:469)
      at org.apache.beam.sdk.Pipeline.replace (Pipeline.java:268)
      at org.apache.beam.sdk.Pipeline.replaceAll (Pipeline.java:218)
      at org.apache.beam.runners.direct.DirectRunner.performRewrites (DirectRunner.java:254)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:175)
      at org.apache.beam.runners.direct.DirectRunner.run (DirectRunner.java:67)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:323)
      at org.apache.beam.sdk.Pipeline.run (Pipeline.java:309)
      at loadRevisionInterfaceTable.runPipeline (loadRevisionInterfaceTable.java:102)
      at loadRevisionInterfaceTable.main (loadRevisionInterfaceTable.java:109)
      at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:254)
      at java.lang.Thread.run (Thread.java:748)

      Attachments

        Activity

          People

            Unassigned Unassigned
            mantyaku Murthy Antyakula
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: