error.message: Could not complete the stream element: Record @ 1713226735083 : UpdateEvent(meta=UpdateEvent.Meta(domain=ru.wikinews.org, dt=2024-04-16T00:19:02.796562Z, id=48504d77-d37b-46fa-bdb1-46f05f315e99, requestId=48504d77
-d37b-46fa-bdb1-46f05f315e99, stream=cirrussearch.update_pipeline.sanity_fix.pseudo_stream, uri=null), changeType=PAGE_RERENDER_UPSERT, eventTime=2024-04-16T00:19:02.796562Z, revId=null, ingestionTime=2024-04-16T00:19:02.796562Z, targetDocu
ment=UpdateEvent.TargetDocument(domain=ru.wikinews.org, wikiId=ruwikinews, pageNamespace=2, pageId=27592, clusterGroup=chi, indexName=ruwikinews_general, pageTitle=null), update=null, fetchAttempt=0).
error.stack_trace: java.lang.Exception: Could not complete the stream element: Record @ 1713226735083 : UpdateEvent(meta=UpdateEvent.Meta(domain=ru.wikinews.org, dt=2024-04-16T00:19:02.796562Z, id=48504d77-d37b-46fa-bdb1-46f05f315e9
9, requestId=48504d77-d37b-46fa-bdb1-46f05f315e99, stream=cirrussearch.update_pipeline.sanity_fix.pseudo_stream, uri=null), changeType=PAGE_RERENDER_UPSERT, eventTime=2024-04-16T00:19:02.796562Z, revId=null, ingestionTime=2024-04-16T00:19:0
2.796562Z, targetDocument=UpdateEvent.TargetDocument(domain=ru.wikinews.org, wikiId=ruwikinews, pageNamespace=2, pageId=27592, clusterGroup=chi, indexName=ruwikinews_general, pageTitle=null), update=null, fetchAttempt=0).
at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$ResultHandler.completeExceptionally(AsyncWaitOperator.java:633)
at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$RetryableResultHandlerDelegator.processRetry(AsyncWaitOperator.java:550)
at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$RetryableResultHandlerDelegator.lambda$processRetryInMailBox$1(AsyncWaitOperator.java:509)
at org.apache.flink.util.function.FunctionUtils.lambda$asCallable$5(FunctionUtils.java:126)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMail(MailboxProcessor.java:398)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:383)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:345)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:229)
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:839)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:788)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:931)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.lang.IllegalArgumentException: Missing property '/cirrusbuilddoc'
at org.wikimedia.discovery.cirrus.updater.common.model.JsonPathUtils.getRequiredNode(JsonPathUtils.java:13)
at org.wikimedia.discovery.cirrus.updater.common.model.CirrusDocJsonHelper.<init>(CirrusDocJsonHelper.java:33)
at org.wikimedia.discovery.cirrus.updater.consumer.graph.RerenderCirrusDocEndpoint.extractAndAugment(RerenderCirrusDocEndpoint.java:72)
at org.wikimedia.discovery.cirrus.updater.consumer.graph.RerenderCirrusDocEndpoint.extractAndAugment(RerenderCirrusDocEndpoint.java:21)
at org.wikimedia.discovery.cirrus.updater.common.graph.CirrusFetcher$1.completed(CirrusFetcher.java:101)
at org.wikimedia.discovery.cirrus.updater.common.graph.CirrusFetcher$1.completed(CirrusFetcher.java:92)
at org.apache.hc.core5.concurrent.BasicFuture.completed(BasicFuture.java:123)
at org.apache.hc.core5.concurrent.ComplexFuture.completed(ComplexFuture.java:72)
at org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient$2$1.completed(InternalAbstractHttpAsyncClient.java:304)
at com.ok2c.hc5.json.http.AbstractJsonMessageConsumer$1.completed(AbstractJsonMessageConsumer.java:65)
at com.ok2c.hc5.json.http.AbstractJsonEntityConsumer.lambda$streamStart$0(AbstractJsonEntityConsumer.java:62)
at com.ok2c.hc5.json.JsonNodeAssembler.endOfStream(JsonNodeAssembler.java:195)