This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b83e4126237 [fix](hive-udf) delete Logger to avoid Kryo serialize
problem. (#25312)
b83e4126237 is described below
commit b83e4126237016e3de7b2ede3e310754c6a39355
Author: yagagagaga <[email protected]>
AuthorDate: Mon Oct 16 16:10:06 2023 +0800
[fix](hive-udf) delete Logger to avoid Kryo serialize problem. (#25312)
---
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapAndUDF.java | 4 ----
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapCountUDF.java | 4 ----
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapOrUDF.java | 4 ----
fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapXorUDF.java | 4 ----
4 files changed, 16 deletions(-)
diff --git a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapAndUDF.java
b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapAndUDF.java
index cc84c5afafc..8b5044b51f3 100644
--- a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapAndUDF.java
+++ b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapAndUDF.java
@@ -27,15 +27,12 @@ import org.apache.hadoop.hive.ql.udf.generic.GenericUDF;
import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.BinaryObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
import java.io.IOException;
@Description(name = "bitmap_and", value = "a _FUNC_ b - Compute intersection
of two or more input bitmaps,"
+ " return the new bitmap")
public class BitmapAndUDF extends GenericUDF {
- private static final Logger LOG = LogManager.getLogger(BitmapAndUDF.class);
private transient BinaryObjectInspector inputOI0;
private transient BinaryObjectInspector inputOI1;
@@ -68,7 +65,6 @@ public class BitmapAndUDF extends GenericUDF {
bitmapValue0.and(bitmapValue1);
return BitmapValueUtil.serializeToBytes(bitmapValue1);
} catch (IOException ioException) {
- LOG.warn("", ioException);
throw new RuntimeException(ioException);
}
}
diff --git a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapCountUDF.java
b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapCountUDF.java
index 28475610ec8..408c6c1d470 100644
--- a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapCountUDF.java
+++ b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapCountUDF.java
@@ -27,15 +27,12 @@ import org.apache.hadoop.hive.ql.udf.generic.GenericUDF;
import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.BinaryObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
import java.io.IOException;
@Description(name = "bitmap_count", value = "a _FUNC_ b - Returns the number
of distinct integers"
+ " added to the bitmap (e.g., number of bits set)")
public class BitmapCountUDF extends GenericUDF {
- private static final Logger LOG =
LogManager.getLogger(BitmapCountUDF.class);
private transient BinaryObjectInspector inputOI;
@Override
@@ -62,7 +59,6 @@ public class BitmapCountUDF extends GenericUDF {
BitmapValue bitmapValue =
BitmapValueUtil.deserializeToBitmap(inputBytes);
return bitmapValue.cardinality();
} catch (IOException ioException) {
- LOG.warn("", ioException);
throw new HiveException(ioException);
}
}
diff --git a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapOrUDF.java
b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapOrUDF.java
index 197e137946e..9ed1446d3fb 100644
--- a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapOrUDF.java
+++ b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapOrUDF.java
@@ -27,15 +27,12 @@ import org.apache.hadoop.hive.ql.udf.generic.GenericUDF;
import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.BinaryObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
import java.io.IOException;
@Description(name = "bitmap_or", value = "a _FUNC_ b - Compute"
+ " union of two or more input bitmaps, returns the new bitmap")
public class BitmapOrUDF extends GenericUDF {
- private static final Logger LOG = LogManager.getLogger(BitmapOrUDF.class);
private transient BinaryObjectInspector inputOI0;
private transient BinaryObjectInspector inputOI1;
@@ -68,7 +65,6 @@ public class BitmapOrUDF extends GenericUDF {
bitmapValue0.or(bitmapValue1);
return BitmapValueUtil.serializeToBytes(bitmapValue1);
} catch (IOException ioException) {
- LOG.warn("", ioException);
throw new RuntimeException(ioException);
}
}
diff --git a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapXorUDF.java
b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapXorUDF.java
index d6c23f7dbb7..fa46eeec7a2 100644
--- a/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapXorUDF.java
+++ b/fe/hive-udf/src/main/java/org/apache/doris/udf/BitmapXorUDF.java
@@ -27,15 +27,12 @@ import org.apache.hadoop.hive.ql.udf.generic.GenericUDF;
import org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.BinaryObjectInspector;
import
org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
import java.io.IOException;
@Description(name = "bitmap_xor", value = "a _FUNC_ b - Compute the symmetric"
+ " union of two or more input bitmaps, return the new bitmap")
public class BitmapXorUDF extends GenericUDF {
- private static final Logger LOG = LogManager.getLogger(BitmapXorUDF.class);
private transient BinaryObjectInspector inputOI0;
private transient BinaryObjectInspector inputOI1;
@@ -68,7 +65,6 @@ public class BitmapXorUDF extends GenericUDF {
bitmapValue0.xor(bitmapValue1);
return BitmapValueUtil.serializeToBytes(bitmapValue1);
} catch (IOException ioException) {
- LOG.warn("", ioException);
throw new RuntimeException(ioException);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
