wclaralee commented on pull request #11351: URL: https://github.com/apache/beam/pull/11351#issuecomment-713845148
Hello, I am now getting this error since adding usage of BigQuery Storage API when reading from a table using `.withMethod(Method.DIRECT_READ)` using beam 2.21.0. The error stack trace I get is similar to the one above: `Error message from worker: java.lang.IllegalStateException: BEAM-9399: publish should not be called with the lock as it may cause deadlock org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Preconditions.checkState(Preconditions.java:507) org.apache.beam.runners.dataflow.worker.logging.JulHandlerPrintStreamAdapterFactory$JulHandlerPrintStream.publishIfNonEmpty(JulHandlerPrintStreamAdapterFactory.java:380) org.apache.beam.runners.dataflow.worker.logging.JulHandlerPrintStreamAdapterFactory$JulHandlerPrintStream.println(JulHandlerPrintStreamAdapterFactory.java:332) java.lang.Throwable$WrappedPrintStream.println(Throwable.java:748) java.lang.Throwable.printStackTrace(Throwable.java:655) java.lang.Throwable.printStackTrace(Throwable.java:643) java.lang.Throwable.printStackTrace(Throwable.java:634) org.slf4j.helpers.Util.report(Util.java:124) ` (^truncated a bit.) Please let me know. Thank you. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
