diff --git a/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra.app.src b/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra.app.src index 26028e8ab..59661d7c0 100644 --- a/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra.app.src +++ b/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra.app.src @@ -1,6 +1,6 @@ {application, emqx_bridge_cassandra, [ {description, "EMQX Enterprise Cassandra Bridge"}, - {vsn, "0.1.4"}, + {vsn, "0.1.5"}, {registered, []}, {applications, [ kernel, diff --git a/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra_connector.erl b/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra_connector.erl index 0610ee743..afea652ef 100644 --- a/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra_connector.erl +++ b/apps/emqx_bridge_cassandra/src/emqx_bridge_cassandra_connector.erl @@ -332,7 +332,7 @@ on_get_status(_InstId, #{pool_name := PoolName} = State) -> end. do_get_status(Conn) -> - ok == element(1, ecql:query(Conn, "SELECT count(1) AS T FROM system.local")). + ok == element(1, ecql:query(Conn, "SELECT cluster_name FROM system.local")). do_check_prepares(#{prepare_cql := Prepares}) when is_map(Prepares) -> ok; diff --git a/changes/ee/fix-11760.en.md b/changes/ee/fix-11760.en.md new file mode 100644 index 000000000..9d5861529 --- /dev/null +++ b/changes/ee/fix-11760.en.md @@ -0,0 +1 @@ +Simplified the CQL query employed for Cassandra bridge health check that was apparently the source of warnings in Cassandra server logs.