[
https://issues.apache.org/jira/browse/GOBBLIN-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773855#comment-17773855
]
Tao Qin commented on GOBBLIN-1928:
----------------------------------
Exception stack:
{code:java}
ComposedException 1 :
com.google.common.util.concurrent.UncheckedExecutionException:
java.lang.RuntimeException: Error creating writer at
com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2214) at
com.google.common.cache.LocalCache.get(LocalCache.java:4053) at
com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057) at
com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
at
org.apache.gobblin.writer.PartitionedDataWriter.writeEnvelope(PartitionedDataWriter.java:257)
at
org.apache.gobblin.runtime.fork.Fork.lambda$consumeRecordStream$11(Fork.java:217)
at
io.reactivex.internal.subscribers.LambdaSubscriber.onNext(LambdaSubscriber.java:62)
at
io.reactivex.internal.operators.flowable.FlowableDoFinally$DoFinallySubscriber.onNext(FlowableDoFinally.java:85)Caused
by: java.lang.RuntimeException: Error creating writer at
org.apache.gobblin.writer.PartitionedDataWriter$1$1.get(PartitionedDataWriter.java:181)
at
org.apache.gobblin.writer.PartitionedDataWriter$1$1.get(PartitionedDataWriter.java:172)
at
org.apache.gobblin.writer.CloseOnFlushWriterWrapper.<init>(CloseOnFlushWriterWrapper.java:73)
at
org.apache.gobblin.writer.PartitionedDataWriter$1.load(PartitionedDataWriter.java:171)
at
org.apache.gobblin.writer.PartitionedDataWriter$1.load(PartitionedDataWriter.java:166)
at
com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
at com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
at
com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208) at
com.google.common.cache.LocalCache.get(LocalCache.java:4053) at
com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057) at
com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
at
org.apache.gobblin.writer.PartitionedDataWriter.writeEnvelope(PartitionedDataWriter.java:257)
at
org.apache.gobblin.runtime.fork.Fork.lambda$consumeRecordStream$11(Fork.java:217)Caused
by: java.util.concurrent.ExecutionException: java.lang.StackOverflowError at
java.util.concurrent.FutureTask.report(FutureTask.java:122) at
java.util.concurrent.FutureTask.get(FutureTask.java:206) at
org.apache.gobblin.writer.PartitionedDataWriter$1$1.get(PartitionedDataWriter.java:179)
at
org.apache.gobblin.writer.PartitionedDataWriter$1$1.get(PartitionedDataWriter.java:172)
at
org.apache.gobblin.writer.CloseOnFlushWriterWrapper.<init>(CloseOnFlushWriterWrapper.java:73)
at
org.apache.gobblin.writer.PartitionedDataWriter$1.load(PartitionedDataWriter.java:171)
at
org.apache.gobblin.writer.PartitionedDataWriter$1.load(PartitionedDataWriter.java:166)
at
com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3628)
at com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2336)
at
com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2295)
at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2208) at
com.google.common.cache.LocalCache.get(LocalCache.java:4053) at
com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:4057) at
com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4986)
at
org.apache.gobblin.writer.PartitionedDataWriter.writeEnvelope(PartitionedDataWriter.java:257)
at
org.apache.gobblin.runtime.fork.Fork.lambda$consumeRecordStream$11(Fork.java:217)Caused
by: java.lang.StackOverflowError at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:51)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:46)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:51)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:69)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:51)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:51)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:69)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:51)
at
org.apache.gobblin.util.orc.AvroOrcSchemaConverter.getOrcSchema(AvroOrcSchemaConverter.java:51)
…
(1000+ lines with the same call) {code}
> Add OrcSchemaConversionValidator to avoid infinite recursion in
> AvroOrcSchemaConverter.getOrcSchema()
> -----------------------------------------------------------------------------------------------------
>
> Key: GOBBLIN-1928
> URL: https://issues.apache.org/jira/browse/GOBBLIN-1928
> Project: Apache Gobblin
> Issue Type: Bug
> Reporter: Tao Qin
> Priority: Major
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)