[skywalking-banyandb-java-client] branch fix-offset-issue updated: add test case

[lu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lujiajing pushed a commit to branch fix-offset-issue
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb-java-client.git


The following commit(s) were added to refs/heads/fix-offset-issue by this push:
     new 01df7bd  add test case
01df7bd is described below

commit 01df7bdd4b70826a464e5cf2a7c611b327432334
Author: Megrez Lu <lu...@gmail.com>
AuthorDate: Mon Nov 21 14:38:53 2022 +0800

    add test case
---
 .../skywalking/banyandb/v1/client/BanyanDBClientStreamWriteTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/test/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClientStreamWriteTest.java b/src/test/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClientStreamWriteTest.java
index 21ac83a..3d80b40 100644
--- a/src/test/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClientStreamWriteTest.java
+++ b/src/test/java/org/apache/skywalking/banyandb/v1/client/BanyanDBClientStreamWriteTest.java
@@ -154,7 +154,6 @@ public class BanyanDBClientStreamWriteTest extends AbstractBanyanDBClientTest {
         String queue = "queue_2";
         String httpStatusCode = "200";
         String dbType = "SQL";
-        String dbInstance = "127.0.0.1:3306";
 
         StreamWrite streamWrite = new StreamWrite("default", "sw", segmentId, now.toEpochMilli())
                 .tag("data_binary", Value.binaryTagValue(byteData))
@@ -167,7 +166,7 @@ public class BanyanDBClientStreamWriteTest extends AbstractBanyanDBClientTest {
                 .tag("http.method", Value.stringTagValue(null)) // 6
                 .tag("status_code", Value.stringTagValue(httpStatusCode)) // 7
                 .tag("db.type", Value.stringTagValue(dbType)) // 8
-                .tag("db.instance", Value.stringTagValue(dbInstance)) // 9
+                .tag("db.instance", null) // 9
                 .tag("mq.broker", Value.stringTagValue(broker)) // 10
                 .tag("mq.topic", Value.stringTagValue(topic)) // 11
                 .tag("mq.queue", Value.stringTagValue(queue)); // 12
@@ -182,6 +181,7 @@ public class BanyanDBClientStreamWriteTest extends AbstractBanyanDBClientTest {
             Assert.assertEquals(traceId, request.getElement().getTagFamilies(1).getTags(0).getStr().getValue());
             Assert.assertEquals(latency, request.getElement().getTagFamilies(1).getTags(5).getInt().getValue());
             Assert.assertEquals(request.getElement().getTagFamilies(1).getTags(7).getNull(), NullValue.NULL_VALUE);
+            Assert.assertEquals(request.getElement().getTagFamilies(1).getTags(9).getNull(), NullValue.NULL_VALUE);
             Assert.assertEquals(queue, request.getElement().getTagFamilies(1).getTags(12).getStr().getValue());
         } else {
             Assert.fail();