Fix CI

Author: caicancai

kvrocks/src/main/java/org/apache/calcite/adapter/kvrocks/KvrocksDataProcess.java

@@ -25,6 +25,7 @@
 import java.util.List;
 
 import redis.clients.jedis.Jedis;
+import redis.clients.jedis.StreamEntry;
 import redis.clients.jedis.StreamEntryID;
 
 import static java.util.Objects.requireNonNull;
@@ -52,11 +53,12 @@ public class KvrocksDataProcess {
     this.fields = fieldInfo.getFields();
 
     String type = jedis.type(tableName);
-    this.dataType = requireNonNull(KvrocksDataType.fromTypeName(type),
-        () -> "unsupported Kvrocks data type: " + type);
-    this.dataFormat = requireNonNull(
-        KvrocksDataFormat.fromTypeName(fieldInfo.getDataFormat()),
-        () -> "unsupported data format: " + fieldInfo.getDataFormat());
+    this.dataType =
+        requireNonNull(KvrocksDataType.fromTypeName(type));
+    this.dataFormat =
+        requireNonNull(
+            KvrocksDataFormat.fromTypeName(
+                fieldInfo.getDataFormat()));
 
     this.objectMapper = new ObjectMapper();
     objectMapper.configure(JsonParser.Feature.ALLOW_UNQUOTED_FIELD_NAMES, true);
@@ -99,17 +101,19 @@ private List<Object[]> readString() {
   /** Reads entries from a Kvrocks Stream via XRANGE. */
   private List<Object[]> readStream() {
     List<Object[]> rows = new ArrayList<>();
-    jedis.xrange(tableName, (StreamEntryID) null, (StreamEntryID) null,
-        Integer.MAX_VALUE).forEach(entry -> {
-      // Each stream entry has an ID and a map of field-value pairs.
-      // We serialize the map as a JSON string and parse it.
+    List<StreamEntry> entries =
+        jedis.xrange(tableName, (StreamEntryID) null,
+            (StreamEntryID) null, Integer.MAX_VALUE);
+    for (StreamEntry entry : entries) {
       try {
-        String json = objectMapper.writeValueAsString(entry.getFields());
+        String json =
+            objectMapper.writeValueAsString(entry.getFields());
         rows.add(parseRow(json));
       } catch (Exception e) {
-        throw new RuntimeException("Failed to serialize stream entry", e);
+        throw new RuntimeException(
+            "Failed to serialize stream entry", e);
       }
-    });
+    }
     return rows;
   }
 

kvrocks/src/main/java/org/apache/calcite/adapter/kvrocks/KvrocksTable.java

@@ -98,8 +98,8 @@ static Table create(KvrocksSchema schema, String tableName,
   /** Creates a table from an operand map (used by {@link KvrocksTableFactory}). */
   static Table create(KvrocksSchema schema, String tableName,
       Map operand, @Nullable RelProtoDataType protoRowType) {
-    KvrocksConfig config = new KvrocksConfig(
-        schema.host, schema.port, schema.database,
+    KvrocksConfig config =
+        new KvrocksConfig(schema.host, schema.port, schema.database,
         schema.password, schema.namespace);
     return create(schema, tableName, config, protoRowType);
   }

kvrocks/src/test/resources/log4j2-test.xml

@@ -1,20 +1,20 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to you under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-  http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
+  ~ Licensed to the Apache Software Foundation (ASF) under one or more
+  ~ contributor license agreements.  See the NOTICE file distributed with
+  ~ this work for additional information regarding copyright ownership.
+  ~ The ASF licenses this file to you under the Apache License, Version 2.0
+  ~ (the "License"); you may not use this file except in compliance with
+  ~ the License.  You may obtain a copy of the License at
+  ~
+  ~ http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+  -->
 <Configuration status="WARN">
   <Appenders>
     <Console name="Console" target="SYSTEM_OUT">