[
https://issues.apache.org/jira/browse/AVRO-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794127#comment-17794127
]
Julien OPOIX edited comment on AVRO-3903 at 12/7/23 2:44 PM:
-------------------------------------------------------------
[~sachk9393] Any chance you could update your jdk version on your side since it
is a JDK issue?
Otherwise, you could have a look at this kind of workaround:
[https://github.com/apache/dubbo/blob/5554706256c9daf550f36858e5bc3d17f3ec6143/dubbo-common/src/main/java/org/apache/dubbo/common/utils/ConcurrentHashMapUtils.java]
was (Author: JIRAUSER303298):
[~sachk9393] Any chance you could update your jdk version on your side since it
is a JDK issue?
Otherwise, you could have a look a this kind of workaround:
https://github.com/apache/dubbo/blob/5554706256c9daf550f36858e5bc3d17f3ec6143/dubbo-common/src/main/java/org/apache/dubbo/common/utils/ConcurrentHashMapUtils.java
> Avro 1.11.x read getting stuck due to MapUtil.computeIfAbsent
> -------------------------------------------------------------
>
> Key: AVRO-3903
> URL: https://issues.apache.org/jira/browse/AVRO-3903
> Project: Apache Avro
> Issue Type: Bug
> Components: java
> Affects Versions: 1.11.0, 1.11.1, 1.11.2, 1.11.3
> Reporter: Sachin Sharma
> Priority: Blocker
> Attachments: blitz_threaddump.txt
>
>
> Hi Team, we are facing an issue where Avro deserialized/reads getting stuck
> indefinitely
> ""ConcurrentHashMap.computeIfAbsent as the blocked issue is a common jdk 8
> issue
> [https://bugs.openjdk.org/browse/JDK-8062841]
> [https://bugs.openjdk.org/browse/JDK-8161372]
> [https://bugs.openjdk.org/browse/JDK-8184907]
> adding a small part of stack traced here rest is attached in the attachment.
> ""
> "blitz-reader-client-mqs-reactive-2" #1020 prio=5 os_prio=31
> tid=0x0000000134d68800 nid=0x32403 waiting for monitor entry
> [0x00000002cac40000]
> java. lang.Thread.State: *BLOCKED (on object monitor)*
> *at
> java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1674)*
> *- waiting to lock <0x00000007a225d648> (a
> java.util.concurrent.ConcurrentHashMap$ReservationNode)*
> *at org.apache.avro.util.MapUtil.computeIfAbsent(MapUtil.java:42)*
> *at org.apache.avro.specific.SpecificData.getClass(SpecificData.java:255)*
> *at
> org.apache.avro.specific.SpecificData.newRecord(SpecificData.java:488)*
> *at*
> org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:237)
> at
> org.apache.avro.specific.SpecificDatumReader.readRecord(SpecificDatumReader.java:123)
> at
> org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:180)
> at
> org.apache.avro.generic.GenericDatumReader.readArray(GenericDatumReader.java:299)
> at
> org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:184)
> at
>
> can we please have a look at it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
