[ 
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)

Reply via email to