v2.4.0

What's Changed

• feat: add extstatetype support for Pebble by @weiji6 in #3856
• feat: revise GetByPrefix by @weiji6 in #3906
• feat: revise websocket source by @Yisaer in #3905
• feat(io): add rollingSize option to file sink by @e7217 in #3910
• feat(op): ratelimit support batch input by @ngjaying in #3907
• feat(slice): support select * by @ngjaying in #3912
• feat: support ToUint32Slice by @Yisaer in #3908
• feat: split checkpoint db by @Yisaer in #3909
• fix(io): fix sql sink build sql by @Yisaer in #3913
• feat: revise cast.ToBool by @Yisaer in #3917
• fix(window): statewindow support group by key by @Yisaer in #3916
• fix(cast): bool conversion by @ngjaying in #3918
• fix(core): Enforce safe path validation user Input by @Yisaer in #3911
• fix(trial): rename rule trial mock stream by @ngjaying in #3919
• fix(io): rest sink access token support by @ngjaying in #3921
• fix(io): http support refresh token by @ngjaying in #3922
• chore: update gorilla/schema by @ngjaying in #3924
• fix(slice): limit wildcard expander by @ngjaying in #3925
• feat: upgrade go version by @ngjaying in #3926
• feat: upgrade go version and lint by @ngjaying in #3927
• build(deps): bump jose2go from 1.6.0 to 1.7.0 by @dependabot[bot] in #3928
• fix(io): sql lookup unsafe string by @ngjaying in #3930
• fix(util): safe unzip by @ngjaying in #3931
• chore(ci): add workflow permission by @ngjaying in #3929
• build(deps): bump golang.org/x/crypto by @dependabot[bot] in #3933
• feat: support statewindow partition by by @Yisaer in #3936
• build(deps): bump paho.mqtt.golang by @dependabot[bot] in #3939
• feat: upgrade fdb to 7.3 by @Yisaer in #3938
• build(deps): bump github.com/sirupsen/logrus by @dependabot[bot] in #3941
• feat(stream): support temp stream by @ngjaying in #3940
• feat(conf): add global config provider by @ngjaying in #3942
• fix(path): file downloads secured root by @ngjaying in #3943
• fix(test): fixes unstable tests by @ngjaying in #3947
• fix(test): flaky onnx test by @ngjaying in #3945
• chore: update logrus mod by @ngjaying in #3944
• feat: SSRF protection for HTTP clients by @ngjaying in #3948
• fix(http): ensure safe file cleanup by @ngjaying in #3949
• feat(security): add file access restriction by @ngjaying in #3950
• feat(api): validate id by @ngjaying in #3951
• refactor(api): upload auto-create subdirectories by @ngjaying in #3952
• test: fix flaky tests by @ngjaying in #3953
• feat(video): add more props and remove filter by @ngjaying in #3955
• fix(planner): add field details in error by @ngjaying in #3957
• fix(api): prevent upload embeded path traversal by @ngjaying in #3958
• feat(sink): tuple sink supports format by @ngjaying in #3954
• docs(io): new video source props by @ngjaying in #3960
• feat(video): refactor source to push model by @ngjaying in #3959
• feat(sink): add HasFields support by @ngjaying in #3964
• fix(fvt): fix flaky trace lookup test by @ngjaying in #3966
• fix(sdk): add timeout for function channel by @ngjaying in #3965
• fix(sdk/python): add timeout for function channel by @ngjaying in #3967
• feat(server): version wins in concurrent upsert by @ngjaying in #3970
• ci: limit lint action to official org by @ngjaying in #3972
• docs: add Swagger API playground link by @ankur-paan in #3975
• fix(server): prevent cpu api panic by @ngjaying in #3978
• fix(stream): allow deleting corrupted streams by @ngjaying in #3979
• docs: update helm installation to use OCI registry by @ngjaying in #3980
• docs: update Kafka Docker image by @igor-soldev in #3977
• fix(conf): add log symlink validation by @ngjaying in #3981
• fix: replace path.Join with filepath.Join by @ngjaying in #3982
• fix: fix sql sink quote string value by @Yisaer in #3983
• fix(video): enforce image2pipe by @ngjaying in #3984
• ci: add perf action by @Yisaer in #3985
• ci: add semgrep for nested lock detection by @ngjaying in #3988
• fix: add syncx wrapper and fix deadlocks by @ngjaying in #3989
• ci: fix perf action by @Yisaer in #3990
• ci: add explicit permissions to semgrep workflow by @ngjaying in #3992
• fix(test): resolve flaky FVT test by @ngjaying in #3993
• fix: enable race ci and fix problems by @ngjaying in #3996
• feat(trial): replace websocket with sse by @ngjaying in #3991
• fix: fix TestWindowState race test by @Yisaer in #3997
• test(http): add oauth test with header by @ngjaying in #3998
• build(deps): bump filippo.io/edwards25519 by @dependabot[bot] in #4005
• chore: add markdown linter by @Elia-Renzoni in #4004
• build(deps): bump go.opentelemetry.io/otel/sdk by @dependabot[bot] in #4007
• fix(planner): mocksource emit name for unnest by @Yisaer in #4008
• fix(test): table load optimization by @ngjaying in #4001
• feat(pb): support schemas from a directory by @ngjaying in #4006
• fix: revise kfk groupid setting by @Yisaer in #4009
• feat: add mqtt properties in meta by @Yisaer in #4010
• build(deps): bump google.golang.org/grpc by @dependabot[bot] in #4011
• fix: fix cve issue by @Yisaer in #4012
• feat: Open-source ekuiper manager by @ankur-paan in #3987
• fix: fix cve issue by @Yisaer in #4014
• feat(server): start and stop rules via tags by @Elia-Renzoni in #3968
• chore: add errors for log ln sqrt by @Elia-Renzoni in #4016
• build(deps): bump go-jose/v4 by @dependabot[bot] in #4017
• build(deps): bump aws/protocol/eventstream by @dependabot[bot] in #4018
• build(deps): bump aws-sdk-go-v2/service/s3 by @dependabot[bot] in #4019
• docs: fix conf api example by @piepor in #4020
• build(deps): bump otel dep by @dependabot[bot] in #4021
• build(deps): bump github.com/jackc/pgx/v5 by @dependabot[bot] in #4029
• fix: add shared connection log by @Yisaer in #4030
• build(deps): bump github.com/jackc/pgx/v5 by @dependabot[bot] in #4033
• fix: shared conn data race and FVT tests by @ngjaying in #4032
• fix(kafka): close transport on sink close by @ngjaying in #4034
• fix(topo): avoid maps.Clear by @Elia-Renzoni in #4037
• feat: add kafka connection by @Yisaer in #4036
• build(deps): bump github.com/apache/thrift by @dependabot[bot] in #4038
• fix(slice): support project expressions by @ngjaying in #4039
• fix(topo): shared subtopo init race by @ngjaying in #4040
• fix(planner): cancel partial topo on plan failure by @ngjaying in #4042
• fix(topo): refactor pool to avoid close race by @ngjaying in #4043
• fix: fix kfk connection issue by @Yisaer in #4045
• test: stabilize topology tests and fix flakiness by @ngjaying in #4044
• fix: fix MQTT V5 SSL connection by @L-607 in #4046
• fix(schema): fix wildcard rules schema detaches by @ngjaying in #4047

New Contributors

• @weiji6 made their first contribution in #3856
• @e7217 made their first contribution in #3910
• @ankur-paan made their first contribution in #3975
• @igor-soldev made their first contribution in #3977
• @Elia-Renzoni made their first contribution in #4004
• @piepor made their first contribution in #4020

Full Changelog: v2.3.0...v2.4.0