fix

risingwavelabs · Oct 9, 2023 · 8d799b4 · 8d799b4
1 parent 51da627
commit 8d799b4
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 10 deletions.
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
@@ -2,7 +2,7 @@
 version: "3"
 services:
   compactor-0:
-    image: "ghcr.io/risingwavelabs/risingwave:${RW_IMAGE_VERSION:-v1.2.0}"
+    image: "ghcr.io/risingwavelabs/risingwave:git-51da6271ec5e482ab62bb24aac267c45ab2be350"
     command:
       - compactor-node
       - "--listen-addr"
@@ -37,7 +37,7 @@ services:
       timeout: 5s
       retries: 5
   compute-node-0:
-    image: "ghcr.io/risingwavelabs/risingwave:${RW_IMAGE_VERSION:-v1.2.0}"
+    image: "ghcr.io/risingwavelabs/risingwave:git-51da6271ec5e482ab62bb24aac267c45ab2be350"
     command:
       - compute-node
       - "--listen-addr"
@@ -122,7 +122,7 @@ services:
       timeout: 5s
       retries: 5
   frontend-node-0:
-    image: "ghcr.io/risingwavelabs/risingwave:${RW_IMAGE_VERSION:-v1.2.0}"
+    image: "ghcr.io/risingwavelabs/risingwave:git-51da6271ec5e482ab62bb24aac267c45ab2be350"
     command:
       - frontend-node
       - "--listen-addr"
@@ -179,7 +179,7 @@ services:
       timeout: 5s
       retries: 5
   meta-node-0:
-    image: "ghcr.io/risingwavelabs/risingwave:${RW_IMAGE_VERSION:-v1.2.0}"
+    image: "ghcr.io/risingwavelabs/risingwave:git-51da6271ec5e482ab62bb24aac267c45ab2be350"
     command:
       - meta-node
       - "--listen-addr"
@@ -295,7 +295,7 @@ services:
       timeout: 5s
       retries: 5
   connector-node:
-    image: ghcr.io/risingwavelabs/risingwave:${RW_IMAGE_VERSION:-v1.2.0}
+    image: ghcr.io/risingwavelabs/risingwave:git-51da6271ec5e482ab62bb24aac267c45ab2be350
     entrypoint: "/risingwave/bin/connector-node/start-service.sh"
     ports:
       - 50051

diff --git a/integration_tests/starrocks-sink/README.md b/integration_tests/starrocks-sink/README.md
@@ -28,8 +28,8 @@ CREATE table demo_bhv_table(
     target_id text,
     event_timestamp datetime
 ) ENGINE=OLAP
-PRIMARY KEY(`id`)
-DISTRIBUTED BY HASH(`id`) properties("replication_num" = "1");
+PRIMARY KEY(`user_id`)
+DISTRIBUTED BY HASH(`user_id`) properties("replication_num" = "1");
 
 CREATE USER 'users'@'%' IDENTIFIED BY '123456';
 GRANT ALL ON *.* TO 'users'@'%';

diff --git a/integration_tests/starrocks-sink/append-only-sql/create_sink.sql b/integration_tests/starrocks-sink/append-only-sql/create_sink.sql
@@ -3,7 +3,7 @@ FROM
     bhv_mv WITH (
     connector = 'starrocks',
     type = 'append-only',
-    starrocks.host = '127.0.0.1',
+    starrocks.host = 'starrocks-fe',
     starrocks.mysqlport = '9030',
     starrocks.httpport = '8030',
     starrocks.user = 'users',

diff --git a/integration_tests/starrocks-sink/upsert/create_sink.sql b/integration_tests/starrocks-sink/upsert/create_sink.sql
@@ -3,12 +3,12 @@ FROM
     bhv_mv WITH (
     connector = 'starrocks',
     type = 'upsert',
-    starrocks.host = '127.0.0.1',
+    starrocks.host = 'starrocks-fe',
     starrocks.mysqlport = '9030',
     starrocks.httpport = '8030',
     starrocks.user = 'users',
     starrocks.password = '123456',
     starrocks.database = 'demo',
     starrocks.table = 'demo_bhv_table',
-    primary_key = 'id'
+    primary_key = 'user_id'
 );
diff --git a/src/connector/src/sink/mod.rs b/src/connector/src/sink/mod.rs
@@ -76,6 +76,7 @@ macro_rules! for_all_sinks {
                 { ElasticSearch, $crate::sink::remote::ElasticSearchSink },
                 { Cassandra, $crate::sink::remote::CassandraSink },
                 { Doris, $crate::sink::doris::DorisSink },
+                { Starrocks, $crate::sink::starrocks::StarrocksSink },
                 { Test, $crate::sink::test_sink::TestSink }
             }
             $(,$arg)*