This is an automated email from the ASF dual-hosted git repository.
FrankChen021 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 134d4c81866 build(deps): bump org.apache.thrift:libthrift from 0.13.0
to 0.23.0 in /extensions-contrib/thrift-extensions (#19764)
134d4c81866 is described below
commit 134d4c8186663cb2ccc32212a646fbdca5676dea
Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
AuthorDate: Tue Jul 28 10:00:04 2026 +0800
build(deps): bump org.apache.thrift:libthrift from 0.13.0 to 0.23.0 in
/extensions-contrib/thrift-extensions (#19764)
* build(deps): bump org.apache.thrift:libthrift
Bumps [org.apache.thrift:libthrift](https://github.com/apache/thrift) from
0.13.0 to 0.23.0.
- [Release notes](https://github.com/apache/thrift/releases)
- [Changelog](https://github.com/apache/thrift/blob/master/CHANGES.md)
- [Commits](https://github.com/apache/thrift/compare/v0.13.0...v0.23.0)
---
updated-dependencies:
- dependency-name: org.apache.thrift:libthrift
dependency-version: 0.23.0
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <[email protected]>
* Fix Thrift serializer initialization
---------
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Frank Chen <[email protected]>
---
extensions-contrib/thrift-extensions/pom.xml | 2 +-
.../data/input/thrift/ThriftDeserialization.java | 29 +++++++++++++++++++---
2 files changed, 26 insertions(+), 5 deletions(-)
diff --git a/extensions-contrib/thrift-extensions/pom.xml
b/extensions-contrib/thrift-extensions/pom.xml
index 9d5a64dc887..639329390f9 100644
--- a/extensions-contrib/thrift-extensions/pom.xml
+++ b/extensions-contrib/thrift-extensions/pom.xml
@@ -34,7 +34,7 @@
<modelVersion>4.0.0</modelVersion>
<properties>
- <thrift.version>0.13.0</thrift.version>
+ <thrift.version>0.23.0</thrift.version>
<elephantbird.version>4.17</elephantbird.version>
<scrooge.version>19.10.0</scrooge.version>
</properties>
diff --git
a/extensions-contrib/thrift-extensions/src/main/java/org/apache/druid/data/input/thrift/ThriftDeserialization.java
b/extensions-contrib/thrift-extensions/src/main/java/org/apache/druid/data/input/thrift/ThriftDeserialization.java
index 956d9f3c8ce..5de018c6805 100644
---
a/extensions-contrib/thrift-extensions/src/main/java/org/apache/druid/data/input/thrift/ThriftDeserialization.java
+++
b/extensions-contrib/thrift-extensions/src/main/java/org/apache/druid/data/input/thrift/ThriftDeserialization.java
@@ -31,6 +31,7 @@ import org.apache.thrift.protocol.TJSONProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
import org.apache.thrift.protocol.TProtocolUtil;
import org.apache.thrift.protocol.TSimpleJSONProtocol;
+import org.apache.thrift.transport.TTransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -44,7 +45,7 @@ public class ThriftDeserialization
@Override
protected TDeserializer initialValue()
{
- return new TDeserializer(new TCompactProtocol.Factory());
+ return createDeserializer(new TCompactProtocol.Factory());
}
};
@@ -53,7 +54,7 @@ public class ThriftDeserialization
@Override
protected TDeserializer initialValue()
{
- return new TDeserializer(new TBinaryProtocol.Factory());
+ return createDeserializer(new TBinaryProtocol.Factory());
}
};
@@ -62,7 +63,7 @@ public class ThriftDeserialization
@Override
protected TDeserializer initialValue()
{
- return new TDeserializer(new TJSONProtocol.Factory());
+ return createDeserializer(new TJSONProtocol.Factory());
}
};
@@ -71,13 +72,33 @@ public class ThriftDeserialization
@Override
protected TSerializer initialValue()
{
- return new TSerializer(new TSimpleJSONProtocol.Factory());
+ return createSerializer(new TSimpleJSONProtocol.Factory());
}
};
private static final byte[] EMPTY_BYTES = new byte[0];
+ private static TDeserializer createDeserializer(final TProtocolFactory
protocolFactory)
+ {
+ try {
+ return new TDeserializer(protocolFactory);
+ }
+ catch (final TTransportException e) {
+ throw new IllegalStateException(e);
+ }
+ }
+
+ private static TSerializer createSerializer(final TProtocolFactory
protocolFactory)
+ {
+ try {
+ return new TSerializer(protocolFactory);
+ }
+ catch (final TTransportException e) {
+ throw new IllegalStateException(e);
+ }
+ }
+
public static byte[] decodeB64IfNeeded(final byte[] src)
{
Preconditions.checkNotNull(src, "src bytes cannot be null");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
