Я получаю исключение ниже, когда пытаюсь вызвать приложение Spring из Apache Beam, используя прямой запуск.
org.apache.beam.sdk.Pipeline$PipelineExecutionException:
java.lang.IllegalAccessError: class
io.grpc.internal.CensusTracingModule$TracingClientInterceptor tried to access
private field io.opencensus.trace.unsafe.ContextUtils.CONTEXT_SPAN_KEY
(io.grpc.internal.CensusTracingModule$TracingClientInterceptor and
io.opencensus.trace.unsafe.ContextUtils are in unnamed module of loader
java.net.URLClassLoader @72906e)
Эта строка кода есть в микросервисе. Я создал флягу и добавил эту зависимость в Apache Beam.
Это строка, вызывающая ошибку:
ApiFuture<QuerySnapshot> future = firestore.collection("dev-project-tablename")
.whereEqualTo("key", key).get();
From Apache Beam, я создал объект Firestore с помощью :
Firestore fireStore = FirestoreOptions.getDefaultInstance().getService();