Yes this looks like what I observed with https://issues.apache.org/jira/browse/BEAM-11657 and should be fixed at head or in 2.29 once it is released.
On Sun, Feb 14, 2021 at 2:04 AM Boyuan Zhang <[email protected]> wrote: > Hi Teoder, > > Have you found that https://github.com/apache/beam/pull/13782 would be > helpful here? > > +Sam Whittle <[email protected]> > > On Sat, Feb 13, 2021 at 7:26 AM Teodor Spæren <[email protected]> > wrote: > >> I forgot that the images where not embedded in the HTML file. I've added >> them now, sorry for the inconvenience. >> >> Teodor >> >> On Sat, Feb 13, 2021 at 04:16:58PM +0100, Teodor Spæren wrote: >> >Hello! >> > >> >I've been running some tests to view the overhead of using beam over >> >just using the underlying runner. For one of the tests, I'm reading >> >data from Kafka and I see by profiling that a lot of time is spent in >> >the reflection part of the KafakIO, more specifically the ConsumerSpEL >> >class. >> > >> >I'm not so familiar with the KafkaIO connector, but I was hoping >> >someone here might know how to diagnoise this further :) >> > >> >/ Teodor Spæren >> >> >Hot Spots >> > >> > Session: Remote attach >> > Time of export: Saturday, February 13, 2021 3:51:32 PM CET >> > JVM time: 06:24 >> > >> > Thread selection: [selector_thread_16.png] >> > >> KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource)/ParDo(UnboundedSou >> > >> rceAsSDFWrapper)/ParMultiDo(UnboundedSourceAsSDFWrapper)/ProcessKeyedEl >> > ements/SplittableParDoViaKeyedWorkItems.ProcessElements -> >> > >> KafkaIO.Read/KafkaIO.Read/Read(KafkaUnboundedSource)/ParDo(StripIds)/Pa >> > rMultiDo(StripIds) -> KafkaIO.Read/Remove Kafka >> > Metadata/ParMultiDo(Anonymous) -> >> > Values/Values/Map/ParMultiDo(Anonymous) -> >> > KafkaIO.KafkaValueWrite/Kafka values with default >> > key/Map/ParMultiDo(Anonymous) -> >> > KafkaIO.KafkaValueWrite/KafkaIO.Write/Kafka >> > ProducerRecord/Map/ParMultiDo(Anonymous) -> >> > >> KafkaIO.KafkaValueWrite/KafkaIO.Write/KafkaIO.WriteRecords/ParDo(KafkaW >> > riter)/ParMultiDo(KafkaWriter) (1/1)#0 [Flink Task Threads] Thread >> > status: [ff00c400_bff000000.png] Runnable Aggregation level: >> Methods >> > Hot spot calculation: Self times Unprofiled classes: Show separately >> > __________________________________________________________________ >> > >> > Hot Spot Self Time Average Time Invocations >> > [menu_tee_minus_18.gif] [hotspot_16.png] java.lang.reflect.Executable. >> > sharedGetParameterAnnotations [pixel_ff800000.png] 46,473 ms (18 %) >> n/ >> > a n/a >> > [menu_bar_18.gif] [menu_corner_minus_18.gif] [call_method_16.png] >> > [pixel_ffff3300.png] 18.1% - 46,473 ms java.lang.reflect.Method. >> > getParameterAnnotations >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 18.1% - 46,473 ms org. >> > springframework.core.MethodParameter.getParameterAnnotations >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 18.1% - 46,473 ms org.springframework.core.convert.TypeDescriptor. >> > <init> >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_tee_plus_18.gif] [call_method_16.png] >> > [pixel_ffff3300.png] 11.1% - 28,542 ms >> org.springframework.expression. >> > spel.support.ReflectiveMethodResolver.resolve >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_plus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 7.0% - 17,931 ms org. >> > springframework.expression.spel.support.ReflectionHelper. >> > convertArguments >> > [menu_tee_minus_18.gif] [hotspot_16.png] java.lang.Class.forName0 >> > [pixel_ff800000.png] 38,524 ms (15 %) n/a n/a >> > [menu_bar_18.gif] [menu_corner_minus_18.gif] [call_method_16.png] >> > [pixel_ffff3300.png] 15.0% - 38,524 ms java.lang.Class.forName >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms sun. >> > reflect.generics.factory.CoreReflectionFactory.makeNamedType >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms sun.reflect.generics.visitor.Reifier. >> > visitClassTypeSignature >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms sun. >> > reflect.generics.tree.ClassTypeSignature.accept >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms sun.reflect.generics.repository. >> > ConstructorRepository.computeParameterTypes >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms sun. >> > reflect.generics.repository.ConstructorRepository.getParameterTypes >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms java.lang.reflect.Executable. >> > getGenericParameterTypes >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms java. >> > lang.reflect.Method.getGenericParameterTypes >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.core.MethodParameter. >> > getGenericParameterType >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > springframework.core.SerializableTypeWrapper$ >> > MethodParameterTypeProvider.getType >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.core.SerializableTypeWrapper. >> > forTypeProvider >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > springframework.core.ResolvableType.forType >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.core.ResolvableType. >> > forMethodParameter >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > springframework.core.ResolvableType.forMethodParameter >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.core.convert.TypeDescriptor. >> > <init> >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > springframework.expression.spel.support.ReflectiveMethodResolver. >> > resolve >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.expression.spel.ast. >> > MethodReference.findAccessorForMethod >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > springframework.expression.spel.ast.MethodReference.getValueInternal >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.expression.spel.ast. >> > MethodReference$MethodValueRef.getValue >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > >> springframework.expression.spel.ast.CompoundExpression.getValueInternal >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.springframework.expression.spel.ast. >> > SpelNodeImpl.getValue >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 15.0% - 38,524 ms org. >> > springframework.expression.spel.standard.SpelExpression.getValue >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 15.0% - 38,524 ms org.apache.beam.sdk.io.kafka.ConsumerSpEL. >> > evaluateDeserializeWithHeaders >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_tee_plus_18.gif] [call_method_16.png] >> > [pixel_ffff3300.png] 7.7% - 19,856 ms org.apache.beam.sdk.io.kafka. >> > ConsumerSpEL.deserializeKey >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_plus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 7.3% - 18,668 ms org. >> > apache.beam.sdk.io.kafka.ConsumerSpEL.deserializeValue >> > [menu_tee_minus_18.gif] [hotspot_16.png] org.springframework. >> > expression.spel.support.ReflectiveMethodResolver.resolve >> > [pixel_ff800000.png] 12,990 ms (5 %) n/a n/a >> > [menu_bar_18.gif] [menu_corner_minus_18.gif] [call_method_16.png] >> > [pixel_ffff3300.png] 5.1% - 12,990 ms org.springframework.expression. >> > spel.ast.MethodReference.findAccessorForMethod >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 5.1% - 12,990 ms org. >> > springframework.expression.spel.ast.MethodReference.getValueInternal >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 5.1% - 12,990 ms org.springframework.expression.spel.ast. >> > MethodReference$MethodValueRef.getValue >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 5.1% - 12,990 ms org. >> > >> springframework.expression.spel.ast.CompoundExpression.getValueInternal >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 5.1% - 12,990 ms >> org.springframework.expression.spel.ast.SpelNodeImpl. >> > getValue >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_minus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 5.1% - 12,990 ms org. >> > springframework.expression.spel.standard.SpelExpression.getValue >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [menu_corner_minus_18.gif] [call_method_16.png] [pixel_ffff3300.png] >> > 5.1% - 12,990 ms org.apache.beam.sdk.io.kafka.ConsumerSpEL. >> > evaluateDeserializeWithHeaders >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_tee_plus_18.gif] [call_method_16.png] >> > [pixel_ffff3300.png] 2.6% - 6,643 ms org.apache.beam.sdk.io.kafka. >> > ConsumerSpEL.deserializeKey >> > [menu_bar_18.gif] [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [pixel_transparent_1.gif] >> > [pixel_transparent_1.gif] [menu_corner_plus_18.gif] >> > [call_method_16.png] [pixel_ffff3300.png] 2.5% - 6,347 ms org. >> > apache.beam.sdk.io.kafka.ConsumerSpEL.deserializeValue >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.StringLatin1.replace >> > [pixel_ff800000.png] 10,404 ms (4 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > ResolvableType.forMethodParameter [pixel_ff800000.png] 10,073 ms (3 >> %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.HashMap.putVal >> > [pixel_ff800000.png] 9,663 ms (3 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.TimSort.binarySort >> > [pixel_ff800000.png] 8,920 ms (3 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.Class.copyMethods >> > [pixel_ff800000.png] 7,974 ms (3 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.skipIdentifier [pixel_ff800000.png] 6,972 ms (2 %) >> n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ConcurrentReferenceHashMap$Segment.getReference [pixel_ff800000.png] >> > 5,387 ms (2 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > convert.support.GenericConversionService$ConverterCacheKey.equals >> > [pixel_ff800000.png] 4,959 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > ResolvableType.forType(java.lang.reflect.Type) [pixel_ff800000.png] >> > 4,708 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.nio.ch.IOUtil.write1 >> > [pixel_ff800000.png] 4,029 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ReflectionUtils.doWithMethods(java.lang.Class, org.springframework. >> > util.ReflectionUtils$MethodCallback, org.springframework.util. >> > ReflectionUtils$MethodFilter) [pixel_ff800000.png] 3,858 ms (1 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.support.ReflectionHelper.compareArguments [pixel_ff800000.png] >> > 3,783 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.apache.beam.sdk.transforms. >> > Contextful.lambda$fn$36334a93$1 [pixel_ff800000.png] 3,634 ms (1 %) >> n/ >> > a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > ResolvableType.forType(java.lang.reflect.Type, org.springframework. >> > core.ResolvableType$VariableResolver) [pixel_ff800000.png] 3,554 ms >> (1 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.HashMap.hash >> > [pixel_ff800000.png] 3,422 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.ast.MethodReference.getValueRef [pixel_ff800000.png] 3,245 ms (1 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.AbstractCollection. >> > addAll [pixel_ff800000.png] 3,058 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.HashMap.put >> > [pixel_ff800000.png] 2,757 ms (1 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.ast.MethodReference.getValueInternal [pixel_ff800000.png] 2,492 >> > ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > BridgeMethodResolver.findBridgedMethod [pixel_ff800000.png] 2,473 ms >> > (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.factory. >> > CoreReflectionFactory.findTypeVariable [pixel_ff800000.png] 2,307 ms >> > (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parseZeroOrMoreTypeSignatures [pixel_ff800000.png] >> > 2,274 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.clients. >> > producer.internals.RecordAccumulator.append [pixel_ff800000.png] >> 2,119 >> > ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.support.ReflectionHelper.getTypeDifferenceWeight >> > [pixel_ff800000.png] 1,831 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.PublicMethods$ >> > MethodList.filter [pixel_ff800000.png] 1,762 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.HashMap.getNode >> > [pixel_ff800000.png] 1,666 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ConcurrentReferenceHashMap.purgeUnreferencedEntries >> > [pixel_ff800000.png] 1,601 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.ArrayList.<init> >> > [pixel_ff800000.png] 1,501 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.common.utils. >> > ByteUtils.sizeOfUnsignedVarint [pixel_ff800000.png] 1,351 ms (0 %) >> n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ReflectionUtils.getAllDeclaredMethods [pixel_ff800000.png] 1,346 ms >> (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.Objects.equals >> > [pixel_ff800000.png] 1,284 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ObjectUtils.nullSafeEquals [pixel_ff800000.png] 1,217 ms (0 %) n/a >> n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.support.ReflectiveMethodExecutor.execute [pixel_ff800000.png] >> > 1,197 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.beam.sdk.io.kafka. >> > KafkaUnboundedReader.advance [pixel_ff800000.png] 1,118 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > convert.support.ConversionUtils.invokeConverter [pixel_ff800000.png] >> > 1,109 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ConcurrentReferenceHashMap.getHash [pixel_ff800000.png] 1,092 ms (0 >> %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.clients. >> > producer.KafkaProducer.doSend [pixel_ff800000.png] 1,058 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parsePackageNameAndSimpleClassTypeSignature >> > [pixel_ff800000.png] 950 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.clients. >> > producer.ProducerRecord.<init> [pixel_ff800000.png] 889 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.common. >> > serialization.StringDeserializer.deserialize [pixel_ff800000.png] 889 >> > ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.StringBuilder.<init> >> > [pixel_ff800000.png] 879 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.<init> [pixel_ff800000.png] 872 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.ast.MethodReference.updateExitTypeDescriptor [pixel_ff800000.png] >> > 825 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.support.StandardEvaluationContext.getMethodResolvers >> > [pixel_ff800000.png] 756 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.visitor. >> > Reifier.visitArrayTypeSignature [pixel_ff800000.png] 723 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.DataOutputStream. >> > writeByte [pixel_ff800000.png] 691 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parseReturnType [pixel_ff800000.png] 690 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.beam.sdk.io.kafka. >> > TimestampPolicyFactory$ProcessingTimePolicy.getTimestampForRecord >> > [pixel_ff800000.png] 648 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.StringBuilder.append >> > [pixel_ff800000.png] 565 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.beam.runners.core. >> > SimpleDoFnRunner.outputWindowedValue [pixel_ff800000.png] 533 ms (0 >> %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parseFieldTypeSignature [pixel_ff800000.png] 526 ms >> (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> java.lang.reflect.Method.invoke >> > [pixel_ff800000.png] 515 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.TimSort. >> > countRunAndMakeAscending [pixel_ff800000.png] 507 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > SerializableTypeWrapper$TypeProxyInvocationHandler.invoke >> > [pixel_ff800000.png] 502 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> jdk.internal.misc.Unsafe.unpark >> > [pixel_ff800000.png] 491 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ConcurrentReferenceHashMap.getReference [pixel_ff800000.png] 470 ms >> (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.beam.sdk.io.kafka. >> > ConsumerSpEL.evaluateDeserializeWithHeaders [pixel_ff800000.png] 457 >> > ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.CodeFlow.toDescriptorFromObject [pixel_ff800000.png] 440 ms (0 >> %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.DataOutputStream.write >> > [pixel_ff800000.png] 433 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ObjectUtils.nullSafeHashCode [pixel_ff800000.png] 423 ms (0 %) n/a >> n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.support.StandardEvaluationContext.initMethodResolvers >> > [pixel_ff800000.png] 407 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parseTypeSignature [pixel_ff800000.png] 406 ms (0 %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > ResolvableType.equals [pixel_ff800000.png] 394 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.reflect.Method. >> > isVarArgs [pixel_ff800000.png] 385 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.Collections$ >> > UnmodifiableCollection$1.<init> [pixel_ff800000.png] 376 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > convert.TypeDescriptor.forObject [pixel_ff800000.png] 362 ms (0 %) >> n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.ast.MethodReference$MethodValueRef.getValue [pixel_ff800000.png] >> > 356 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.common. >> > serialization.StringSerializer.serialize [pixel_ff800000.png] 351 ms >> > (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.reflect.Executable. >> > equalParamTypes [pixel_ff800000.png] 322 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.StringBuilder. >> > toString [pixel_ff800000.png] 309 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parseArrayTypeSignature [pixel_ff800000.png] 301 ms >> (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.Object.hashCode >> > [pixel_ff800000.png] 290 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.ObjectOutputStream$ >> > BlockDataOutputStream.getUTFLength [pixel_ff800000.png] 279 ms (0 %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.Arrays.hashCode >> > [pixel_ff800000.png] 275 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.concurrent.locks. >> > AbstractQueuedSynchronizer.acquire [pixel_ff800000.png] 274 ms (0 %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.tree. >> > ClassTypeSignature.accept [pixel_ff800000.png] 251 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.standard.SpelExpression.getValue [pixel_ff800000.png] 234 ms (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.apache.kafka.common.record. >> > CompressionRatioEstimator.estimation [pixel_ff800000.png] 224 ms (0 >> %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.Throwable. >> > fillInStackTrace [pixel_ff800000.png] 221 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.ObjectOutputStream$ >> > BlockDataOutputStream.writeBytes [pixel_ff800000.png] 219 ms (0 %) >> n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.ast.CompoundExpression.getValueRef [pixel_ff800000.png] 203 ms >> (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.ast.MethodReference.getCachedExecutor [pixel_ff800000.png] 202 >> ms >> > (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] sun.reflect.generics.parser. >> > SignatureParser.parseMethodSig [pixel_ff800000.png] 193 ms (0 %) n/a >> > n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.apache.kafka.common.record. >> > DefaultRecord.writeTo [pixel_ff800000.png] 185 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.beam.runners.core. >> > SimpleDoFnRunner.invokeProcessElement [pixel_ff800000.png] 177 ms (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.ObjectOutputStream$ >> > BlockDataOutputStream.setBlockDataMode [pixel_ff800000.png] 174 ms (0 >> > %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ConcurrentReferenceHashMap$Segment.findInChain [pixel_ff800000.png] >> > 170 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.apache.kafka.common.record. >> > MemoryRecordsBuilder.<init> [pixel_ff800000.png] 164 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.ObjectOutputStream$ >> > HandleTable.lookup [pixel_ff800000.png] 154 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.io.ObjectOutputStream. >> > writeObject0 [pixel_ff800000.png] 129 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.core. >> > convert.support.ArrayToArrayConverter.convert [pixel_ff800000.png] >> 124 >> > ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.apache.kafka.clients. >> > producer.KafkaProducer.send [pixel_ff800000.png] 124 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] org.springframework.util. >> > ReflectionUtils.doWithMethods(java.lang.Class, org.springframework. >> > util.ReflectionUtils$MethodCallback) [pixel_ff800000.png] 123 ms (0 >> %) >> > n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.util.concurrent. >> > ConcurrentHashMap.replaceNode [pixel_ff800000.png] 110 ms (0 %) n/a >> n/ >> > a >> > [menu_tee_plus_18.gif] [hotspot_16.png] java.lang.reflect.Method.copy >> > [pixel_ff800000.png] 106 ms (0 %) n/a n/a >> > [menu_tee_plus_18.gif] [hotspot_16.png] >> org.springframework.expression. >> > spel.support.ReflectiveMethodResolver.getMethods [pixel_ff800000.png] >> > 105 ms (0 %) n/a n/a >> > [menu_corner_plus_18.gif] [hotspot_16.png] java.util.concurrent.locks. >> > LockSupport.park [pixel_ff800000.png] 96,238 µs (0 %) n/a n/a >> >>
