diff --git a/apps/emqx_bridge_greptimedb/src/emqx_bridge_greptimedb_connector.erl b/apps/emqx_bridge_greptimedb/src/emqx_bridge_greptimedb_connector.erl index c021e4354..666073913 100644 --- a/apps/emqx_bridge_greptimedb/src/emqx_bridge_greptimedb_connector.erl +++ b/apps/emqx_bridge_greptimedb/src/emqx_bridge_greptimedb_connector.erl @@ -271,7 +271,7 @@ protocol_config( } = Config ) -> [ - {dbname, DbName} + {dbname, str(DbName)} ] ++ auth(Config) ++ ssl_config(SSL). @@ -288,7 +288,7 @@ ssl_config(SSL = #{enable := true}) -> auth(#{username := Username, password := Password}) -> [ - {auth, {basic, #{username => Username, password => Password}}} + {auth, {basic, #{username => str(Username), password => str(Password)}}} ]; auth(_) -> []. @@ -397,8 +397,6 @@ parse_batch_data(InstId, BatchData, SyntaxLines) -> {[Points | ListOfPoints], ErrAccIn}; {error, ErrorPoints} -> log_error_points(InstId, ErrorPoints), - {ListOfPoints, ErrAccIn + 1}; - _ -> {ListOfPoints, ErrAccIn + 1} end end, diff --git a/apps/emqx_bridge_greptimedb/test/emqx_bridge_greptimedb_SUITE.erl b/apps/emqx_bridge_greptimedb/test/emqx_bridge_greptimedb_SUITE.erl index 25bdb6b76..bcd57f530 100644 --- a/apps/emqx_bridge_greptimedb/test/emqx_bridge_greptimedb_SUITE.erl +++ b/apps/emqx_bridge_greptimedb/test/emqx_bridge_greptimedb_SUITE.erl @@ -49,7 +49,6 @@ end_per_suite(_Config) -> emqx_conf, emqx_bridge, emqx_resource, emqx_rule_engine ]), _ = application:stop(emqx_connector), - _ = application:stop(greptimedb), ok. init_per_group(GreptimedbType, Config0) when @@ -145,6 +144,7 @@ end_per_group(Group, Config) when emqx_common_test_helpers:reset_proxy(ProxyHost, ProxyPort), ehttpc_sup:stop_pool(EHttpcPoolName), delete_bridge(Config), + _ = application:stop(greptimedb), ok; end_per_group(_Group, _Config) -> ok.