Closed liuxiaocs7 closed 2 years ago
In example/FlinkConnectorExample.java and example/FlinkConnectorSourceExample.java, the CREATE SPACE statement in comment is
example/FlinkConnectorExample.java
example/FlinkConnectorSourceExample.java
CREATE SPACE
CREATE SPACE `flinkSink` (partition_num = 100, replica_factor = 3, charset = utf8, collate = utf8_bin, vid_type = INT64, atomic_edge = false) ON default
when i execute the above statement using nebula console, the result is:
The version of nebula is 3.1.0 and is deployed by Docker. Also i can't find the corresponding parameter description on the doc.
Should we remove on default, it seems works fine after that just as below.
on default
(root@nebula) [(none)]> CREATE SPACE `tt` (partition_num = 100, replica_factor = 3, charset = utf8, collate = utf8_bin, vid_type = INT64, atomic_edge = false) ON default [ERROR (-1009)]: SemanticError: Create space with zone is unsupported Mon, 11 Jul 2022 18:26:25 CST (root@nebula) [(none)]> CREATE SPACE `tt` (partition_num = 100, replica_factor = 3, charset = utf8, collate = utf8_bin, vid_type = INT64, atomic_edge = false) Execution succeeded (time spent 19188/19153 us) Mon, 11 Jul 2022 18:26:29 CST (root@nebula) [(none)]> SHOW CREATE SPACE `tt` +-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | Space | Create Space | +-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | "tt" | "CREATE SPACE `tt` (partition_num = 100, replica_factor = 3, charset = utf8, collate = utf8_bin, vid_type = INT64, atomic_edge = false) ON default_zone_172.28.2.1_9779,default_zone_172.28.2.2_9779,default_zone_172.28.2.3_9779" | +-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ Got 1 rows (time spent 732/1513 us) Mon, 11 Jul 2022 18:26:46 CST
In
example/FlinkConnectorExample.java
andexample/FlinkConnectorSourceExample.java
, theCREATE SPACE
statement in comment iswhen i execute the above statement using nebula console, the result is:
The version of nebula is 3.1.0 and is deployed by Docker. Also i can't find the corresponding parameter description on the doc.
Should we remove
on default
, it seems works fine after that just as below.