You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2021/05/13 07:46:29 UTC
[pulsar] 35/46: cleaned some code in GenericJsonRecord (#10527)
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch 2.7.2_ds_tmp
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 56c2f6b3f95ff603de705fd4ebc65c5ac55b983c
Author: Abhilash Mandaliya <ab...@gmail.com>
AuthorDate: Wed May 12 16:50:18 2021 +0530
cleaned some code in GenericJsonRecord (#10527)
(cherry picked from commit 24b0d064e377dedda2049f6177028f4c26a870bf)
---
.../impl/schema/generic/GenericJsonRecord.java | 38 +++++++++++-----------
1 file changed, 19 insertions(+), 19 deletions(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java
index 7b4a530..eaefaa5 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericJsonRecord.java
@@ -98,29 +98,29 @@ public class GenericJsonRecord extends VersionedGenericRecord {
}
private boolean isBinaryValue(String fieldName) {
- boolean isBinary = false;
+ if (schemaInfo == null) {
+ return false;
+ }
- do {
- if (schemaInfo == null) {
- break;
+ boolean isBinary = false;
+ try {
+ org.apache.avro.Schema schema = parseAvroSchema(schemaInfo.getSchemaDefinition());
+ org.apache.avro.Schema.Field field = schema.getField(fieldName);
+ if (field == null) {
+ return false;
}
-
- try {
- org.apache.avro.Schema schema = parseAvroSchema(schemaInfo.getSchemaDefinition());
- org.apache.avro.Schema.Field field = schema.getField(fieldName);
- ObjectMapper objectMapper = new ObjectMapper();
- JsonNode jsonNode = objectMapper.readTree(field.schema().toString());
- for (JsonNode node : jsonNode) {
- JsonNode jn = node.get("type");
- if (jn != null && ("bytes".equals(jn.asText()) || "byte".equals(jn.asText()))) {
- isBinary = true;
- }
+ ObjectMapper objectMapper = new ObjectMapper();
+ JsonNode jsonNode = objectMapper.readTree(field.schema().toString());
+ for (JsonNode node : jsonNode) {
+ JsonNode jn = node.get("type");
+ if (jn != null && ("bytes".equals(jn.asText()) || "byte".equals(jn.asText()))) {
+ isBinary = true;
+ break;
}
- } catch (Exception e) {
- log.error("parse schemaInfo failed. ", e);
}
- } while (false);
-
+ } catch (Exception e) {
+ log.error("parse schemaInfo failed. ", e);
+ }
return isBinary;
}