[
https://issues.apache.org/jira/browse/AVRO-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Sharma updated AVRO-3903:
--------------------------------
Description:
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.
was:
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 small part of stack traced here rest 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 on it.
> 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)
