Feature Highlight
- Refactor source to connector, decompressor and decoder and allow ordered concurrency. This should improve throughput a lot if the payload is big and decoding latency is long
- Refactor ping for connectors, provide more accurate info
- New function object_pick and kv/kvarray conversion functions
- Introduce error code
What's Changed
* feat: support object_pick function by rextang in https://github.com/lf-edge/ekuiper/pull/2560
* fix: delete default username of redisPubSub by retoool in https://github.com/lf-edge/ekuiper/pull/2566
* feat: support message processed metrics by Yisaer in https://github.com/lf-edge/ekuiper/pull/2561
* feat: support connection native ping by Yisaer in https://github.com/lf-edge/ekuiper/pull/2562
* test: add more test for lines format by carlclone in https://github.com/lf-edge/ekuiper/pull/2570
* refactor: extract format reader from file source by carlclone in https://github.com/lf-edge/ekuiper/pull/2571
* feat: support more kv functions by rextang in https://github.com/lf-edge/ekuiper/pull/2575
* refactor: node runtime by ngjaying in https://github.com/lf-edge/ekuiper/pull/2582
* fix: fix object function args is nil by Yisaer in https://github.com/lf-edge/ekuiper/pull/2586
* fix: fix and test array function if has nil by Yisaer in https://github.com/lf-edge/ekuiper/pull/2581
* feat: support errorcode framework by Yisaer in https://github.com/lf-edge/ekuiper/pull/2577
* feat(node): split source connector and decoder by ngjaying in https://github.com/lf-edge/ekuiper/pull/2583
* fix(functions): args validation of `date_calc` by yai-dev in https://github.com/lf-edge/ekuiper/pull/2585
* fix: fix TestPing test by Yisaer in https://github.com/lf-edge/ekuiper/pull/2595
* feat: support parser/plan/executor error code by Yisaer in https://github.com/lf-edge/ekuiper/pull/2594
* feat: introduce undefined error code by Yisaer in https://github.com/lf-edge/ekuiper/pull/2596
* feat: revise restart rule by Yisaer in https://github.com/lf-edge/ekuiper/pull/2597
* feat: support neuron/kafka ping by Yisaer in https://github.com/lf-edge/ekuiper/pull/2591
* feat(node): ordered concurrency support by ngjaying in https://github.com/lf-edge/ekuiper/pull/2592
* fix(topo): avoid plan twice by ngjaying in https://github.com/lf-edge/ekuiper/pull/2600
* fix(stats): fix get metrics wrong pos by ngjaying in https://github.com/lf-edge/ekuiper/pull/2601
* fix: fix source kafka plugin ci build by Yisaer in https://github.com/lf-edge/ekuiper/pull/2604
* fix: fix schemaless decode error by Yisaer in https://github.com/lf-edge/ekuiper/pull/2605
* feat: add error code by Yisaer in https://github.com/lf-edge/ekuiper/pull/2598
* refactor(node): split decompressor op by ngjaying in https://github.com/lf-edge/ekuiper/pull/2602
New Contributors
* rextang made their first contribution in https://github.com/lf-edge/ekuiper/pull/2560
**Full Changelog**: https://github.com/lf-edge/ekuiper/compare/1.13.0-alpha.1...1.13.0-alpha.2