Skip to content

Commit 9e42e1e

Browse files
committed
update
1 parent dd801af commit 9e42e1e

2 files changed

Lines changed: 1 addition & 2 deletions

File tree

docs/streaming-sql-guide.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ CREATE STREAMING TABLE metric_hop_uv_10m WITH (
144144
SELECT
145145
HOP(INTERVAL '1' MINUTE, INTERVAL '10' MINUTE) AS time_window,
146146
ad_id,
147-
COUNT(DISTINCT user_id) AS unique_users
147+
COUNT(DISTINCT CAST(user_id AS STRING)) AS unique_users
148148
FROM ad_impressions
149149
GROUP BY
150150
1,

src/runtime/streaming/factory/operator_factory.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313

1414
use anyhow::{anyhow, Result};
1515
use prost::Message;
16-
use tracing::info;
1716
use std::collections::HashMap;
1817
use std::sync::Arc;
1918
use protocol::grpc::api::ProjectionOperator as ProjectionOperatorProto;

0 commit comments

Comments
 (0)