v1.3.28

What's Changed

• expose read metrics of external streams to the current prometheus endpoint by @ilselintp in #303
• bugfix/handle const event time for window function by @yl-lisen in #424
• make function name case insensitive by @lizhou1111 in #417
• fix teardown for log stream by @chenziliang in #429
• make default interval_time to 5 ms to avoid generating huge by @lizhou1111 in #388
• Feature/issue 3303 distinct aggr support changelog by @yokofly in #426

New Contributors

• @ilselintp made their first contribution in #303

Full Changelog: v1.3.27...v1.3.28

v1.3.27

What's Changed

• Bugfix/issue 320 fix tsan by @yokofly in #329
• Bugfix/issue 381 update the ip trie dictionary key type by @lizhou1111 in #382
• fix sql format by @yl-lisen in #385
• add external stream test by @lizhou1111 in #386
• use fixed python docker package version(docker==6.1.3) by @yokofly in #394
• Adding examples for CDC and IoT by @jovezhong in #397
• Feature/issue 396 add a workflow for compatibility test by @leo-cai-timeplus in #398
• Feature/issue 396 refine ci for compatibility test by @leo-cai-timeplus in #401
• binary arithmetic for IPv4, porting ClickHouse/ClickHouse#45150 by @lizhou1111 in #405
• random stream supports native ipv4 and ipv6 data type by @lizhou1111 in #406
• specify the data gen image version by @gangtao in #392
• CI/ issue 413 show more info in title of manual_trigger_test by @leo-cai-timeplus in #414
• bugfix/fix changed aggregated states with StringRef key by @yl-lisen in #416

Full Changelog: v1.3.26...v1.3.27

v1.3.26

What's Changed

• Fix unit test assert for paged asof rows refs by @chenziliang in #362
• feature/support join alignment in general phase 1 by @yl-lisen in #353
• support min_k/max_k retract processing by @yl-lisen in #342
• disable 'snapshot' mode for create query by @yl-lisen in #369
• Bugfix/issue 370 fix backfill with virtual column by @yl-lisen in #372
• add join alignment smoke test and fix more by @yl-lisen in #374
• cleanup trash by @chenziliang in #366
• support monotonic function and support _tp_sn, _tp_shard in random s… by @lizhou1111 in #359
• Feature/issue 67 uda support changelog by @sunset3000 in #137

Full Changelog: v1.3.25...v1.3.26

v1.3.25

What's Changed

• Revert "Send one message to Kafka per row" by @qijun-niu-timeplus in #321
• Feature/issue 275 streaming asof join timestamp alignment by @chenziliang in #293
• feat: support sending one message to Kafka per row. by @zliang-min in #322
• external stream support sasl_plaintext and sasl_ssl by @qijun-niu-timeplus in #324
• small fix sasl_ssl support of kafkasink by @qijun-niu-timeplus in #331
• fix show name with format by @yl-lisen in #330
• fix external stream consumer reuse issue by @qijun-niu-timeplus in #339
• Benchmark RefCountDataBlockPages by @chenziliang in #337
• Porting/issue 3238 context lock contention fix by @yokofly in #306
• random_in_type support ipv4/ipv6 by @yl-lisen in #343
• add show case of fraud detection by @gangtao in #348
• Feature/issue 344 asof join memory efficiency by @chenziliang in #347
• Added missing header in build failure report by @yokofly in #355
• feat: support configuring message.max.bytes for kafka external streams by @zliang-min in #352
• fix: cannot load kafka external streams created before sharding_expr feature by @zliang-min in #351
• Porting/issue 3238 context lock contention fix by @yokofly in #357

New Contributors

• @gangtao made their first contribution in #348

Full Changelog: v1.3.24...v1.3.25

v1.3.24

What's Changed

• fix: seek_to on Kafka external stream could cause core dump by @zliang-min in #305
• fix: time-based seek_to does not work with Kafka external streams by @zliang-min in #309
• supporting select partial columns from external kafka stream by @qijun-niu-timeplus in #307
• Update TelemetryCollector.h, 1hour to 2min by @jovezhong in #308
• Feature/support streaming shuffle by by @yl-lisen in #282
• Fix external log stream init timestamp by @chenziliang in #318

Full Changelog: v1.3.23...v1.3.24

v1.3.23

What's Changed

• feature: kafka external stream partitioning by @zliang-min in #273
• Send one message to Kafka per row by @zliang-min in #284
• std::memcpy has overlapped memory region. Switched to std::memmove by @chenziliang in #296
• checking external stream args by @qijun-niu-timeplus in #290
• rename generate_eps to eps by @lizhou1111 in #302
• enhance telemetry metrics by @qijun-niu-timeplus in #304
• smoke framework support external stream by @jhao0117 in #300

Full Changelog: v1.3.22...v1.3.23

v1.3.22

What's Changed

• support two level hash table for global aggregation by @yl-lisen in #271
• revisit cross compile script and fix typo BUILD.md by @yokofly in #269

Full Changelog: v1.3.21...v1.3.22

v1.3.19

What's Changed

• A temp way to support running server without specify config file. by @yokofly in #235
• improve checkpoint robustness by @yl-lisen in #234
• Add Kafka settings in embedded.xml. by @yokofly in #238
• Bugfix/issue 214 revisit proton local by @yokofly in #218
• Feature/issue 163 replay a stream by @lizhou1111 in #224
• Feature/issue 205 local streaming processing by @chenziliang in #237
• Feature/support emit changelog aggregated result by @yl-lisen in #219
• Fix append time regression by @chenziliang in #245
• enhancement: add append time smoke test by @lizhou1111 in #248
• support random stream table query by @lizhou1111 in #249
• Enhancement/issue 241 mark the replay operation end by @lizhou1111 in #242
• Feature/issue 251 enforce static library build by @yokofly in #255
• update build doc by @yokofly in #253
• Open additional ports for embedded config and add folder for path by @yokofly in #254
• enable backfill from historical store by @yl-lisen in #252
• Improve performance of external aggregation with a lot of temporary f… by @yokofly in #262
• Some refactor and clean up trash by @chenziliang in #183
• Bugfix/issue 239 fix client cancel by @yokofly in #263
• fix ci testing. continue on #239 by @yokofly in #265
• we use a new option to control the proton_local build. by @yokofly in #266

Full Changelog: v1.3.18...v1.3.19

Halloween_2023

Local streaming processing without launching a server. Have fun.

v1.3.18 proton binary

the macOS version proton is generated by cross-compilation.
git commit hash e2427df