yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
14,051 Commits 393 Branches 684 Tags 74 MiB
c20da5ffa6
Commit Graph

14051 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Ivan Dyachkov
c20da5ffa6 fix(emqx_dashboard): fix monitor_current api 2023-04-04 19:58:43 +02:00
Zaiming (Stone) Shi
d25db3ace4 chore: bump version to e5.0.2-rc.4 2023-04-04 16:38:25 +02:00
Zaiming (Stone) Shi
9e17064e47
Merge pull request #10325 from zmstone/0404-delay-config-change-replay-until-handler-is-ready 
0404 delay config change replay until handler is ready
 2023-04-04 16:37:35 +02:00
SergeTupchiy
877b828d4a
Merge pull request #10327 from SergeTupchiy/EMQX-8786-fix-unknown-counter-inc-on-unrecoverable-err 
fix(rule_engine): don't increment unknown counter on unrecoverable er…
 2023-04-04 16:51:34 +03:00
Zaiming (Stone) Shi
5925ff07c2 test(emqx_cluster_rpc): fix test cases 2023-04-04 15:20:30 +02:00
Serge Tupchii
aca65ca2d4 fix(rule_engine): don't increment unknown counter on unrecoverable errors 
Closes: EMQX-8786
 2023-04-04 15:59:53 +03:00
Thales Macedo Garitezi
be2f867cde
Merge pull request #10326 from thalesmg/fix-def-req-timeout-rv50 
fix(buffer_worker): check request timeout and health check interval
 2023-04-04 09:48:53 -03:00
Zaiming (Stone) Shi
196ca43fbb fix(emqx_conf_app): call the right API to retrieve core nodes 2023-04-04 14:19:48 +02:00
Thales Macedo Garitezi
0b6fd7fe14 fix(buffer_worker): check request timeout and health check interval 
Port of https://github.com/emqx/emqx/pull/10154 for `release-50`

Fixes https://emqx.atlassian.net/browse/EMQX-9099

Originally, the `resume_interval`, which is what defines how often a
buffer worker will attempt to retry its inflight window, was set to
the same as the `health_check_interval`.  This had the problem that,
with default values, `health_check_interval = request_timeout`.  This
meant that, if a buffer worker with those configs were ever blocked,
all requests would have timed out by the time it retried them.

Here we change the default `resume_interval` to a reasonable value
dependent on `health_check_interval` and `request_timeout`, and also
expose that as a hidden parameter for fine tuning if necessary.
 2023-04-04 08:58:36 -03:00
Zaiming (Stone) Shi
8fd9dd741e fix(emqx_conf_app): wait for tables ready beofre starting apps 2023-04-04 13:50:50 +02:00
Zaiming (Stone) Shi
974b180da8 build: fix buildx.sh with git config 2023-04-04 12:39:33 +02:00
Zaiming (Stone) Shi
b16c516e6b refactor: rename cluster_rpc_handler to cluster_rpc_cleaner 
this reflects what is actually does
 2023-04-04 10:28:47 +02:00
Zaiming (Stone) Shi
e1d5894209 docs: delete clickhous bridge doc fix change log 
because the feature is not released yet (new to e5.0.2)
 2023-04-03 20:28:29 +02:00
Zaiming (Stone) Shi
2f2e8b8218 chore: bump version to e5.0.2-rc.3 2023-04-03 20:23:31 +02:00
JimMoen
5b10937c8a
Merge pull request #10313 from JimMoen/fix-cluster-node-selected 
fix: running nodes should not include replica nodes
 2023-04-04 02:08:51 +08:00
JimMoen
53712e6146
fix: running nodes should not include replica nodes 2023-04-03 20:01:37 +08:00
Kjell Winblad
7c60a1e276
Merge pull request #10255 from emqx/Meggielqk-patch-1 
Doc: Refined Chinese UI
 2023-04-03 13:31:20 +02:00
Thales Macedo Garitezi
246a792965
Merge pull request #10273 from thalesmg/refactor-kprod-start-error-msg-rv50 
fix: return friendly message when kafka producer and consumer fails to start (rv5.0)
 2023-03-31 16:25:26 -03:00
Thales Macedo Garitezi
5011486b18 fix(kafka_consumer): return better error messages when probing kafka consumer bridge 
Fixes https://emqx.atlassian.net/browse/EMQX-9422
 2023-03-31 11:33:15 -03:00
Kjell Winblad
fe400c7f8d
Merge pull request #10272 from kjellwinblad/kjell/better_label 
docs: make clickhouse config label for Server URL more concise
 2023-03-31 16:17:26 +02:00
Zaiming (Stone) Shi
36240d310c
Merge pull request #10305 from zmstone/0331-docs-fix-bridge-batch-size-desc 
docs: fix max batch size desc
 2023-03-31 15:49:39 +02:00
Zaiming (Stone) Shi
abf0329b60 test(emqx_banned_SUITE): fix flaky test case 2023-03-31 13:03:00 +02:00
Kinplemelon
d8aa1368f9
Merge pull request #10304 from Kinplemelon/kinple/for-upgrade-dashboard 
chore: upgrade dashboard to e1.0.5 for ee
 2023-03-31 18:41:21 +08:00
Zaiming (Stone) Shi
bcde52383b docs: fix max batch size desc 2023-03-31 12:35:27 +02:00
Kinplemelon
a0361e1021 chore: upgrade dashboard to e1.0.5 for ee 2023-03-31 17:05:41 +08:00
Kjell Winblad
1c799af065
Merge pull request #10289 from kjellwinblad/pr_for_merge_into_release-50 
Fix clickhouse bug in release-50
 2023-03-31 09:40:31 +02:00
Kjell Winblad
6f6d12f930
docs: better Chinese labels 
Co-authored-by: LenaLenaPan <120552185+LenaLenaPan@users.noreply.github.com>
 2023-03-31 09:39:04 +02:00
Thales Macedo Garitezi
4875b4454d
Merge pull request #10275 from thalesmg/fix-redis-default-required-db-rv50 
fix(redis): remove `required` meta from schema
 2023-03-30 15:03:51 -03:00
Thales Macedo Garitezi
632bffd451 fix: return friendly message when kafka producer fails to start (rv5.0) 
Fixes https://emqx.atlassian.net/browse/EMQX-9392

The returned information does not allow to diagnose the issue (i.e.: a
connection issue due to the wrong host and port, the wrong password
failing authn).  However, such information is printed to the logs.

This changes the returned error to the API so that the user is hinted
at looking at the logs for further investigation of the error.
 2023-03-30 11:51:36 -03:00
Kjell Winblad
2755829ebf docs: add changelog entry for clickhouse fix 2023-03-30 15:17:16 +02:00
Kjell Winblad
8c4d211b54 fix: on_get_status clickhouse just reporting connecting 
The on_get_status callback for clickhouse just returned `connecting`
without error information when the status check was unsuccessful. This is
fixed by letting the callback return error information similarly to how
the HTTP connector does it.

Fixes:
https://emqx.atlassian.net/browse/EMQX-9374
https://emqx.atlassian.net/browse/EMQX-9278
 2023-03-30 15:10:03 +02:00
Kjell Winblad
91a784134c docs: update Chinese version of batch value separator label 2023-03-30 14:55:58 +02:00
Kjell Winblad
aefa0e5ffb docs: make clickhouse config label for Server URL more concise 2023-03-30 14:55:22 +02:00
Meggielqk
dfc9141da6 docs: Refined Chinese UI 
Also updated the English hints according to the refined Chinese according to Guowei's comments.

Co-authored-by: Kjell Winblad <kjellwinblad@gmail.com>
 2023-03-30 14:50:24 +02:00
Thales Macedo Garitezi
b3c6ae99d2
Merge pull request #10269 from thalesmg/tdengine-required-password-rv50 
fix(tdengine): make password a required field (rv5.0)
 2023-03-30 09:25:38 -03:00
Zaiming (Stone) Shi
09f6d87a7e
Merge pull request #10268 from zmstone/0329-fix-bridge-docs 
fix: hide nodelay Kafka client socket option
 2023-03-29 22:49:49 +02:00
Thales Macedo Garitezi
806ee716ee fix(redis): remove required meta from schema 
Since there's a default value, this field shouldn't be marked as
required.
 2023-03-29 16:43:52 -03:00
Zaiming (Stone) Shi
9b35aeec6d
Merge pull request #10267 from Kinplemelon/kinple/for-upgrade-dashboard 
chore: upgrade dashboard to e1.0.5-beta.4 for ee
 2023-03-29 15:10:30 +02:00
Zaiming (Stone) Shi
94726eb7f1 docs: refine zh translations 2023-03-29 15:07:19 +02:00
Thales Macedo Garitezi
b2b9732edb fix(tdengine): make password a required field (rv5.0) 
Fixes https://emqx.atlassian.net/browse/EMQX-9395

```
2023-03-29T09:59:02.655495+00:00 [warning] msg: start_resource_failed, mfa: emqx_resource_manager:start_resource/2, line: 524, id: <<"bridge:tdengine:jimmoen-test-trigger">>, reason: {error,function_clause,[{emqx_ee_connector_tdengine,on_start,[<<"bridge:tdengine:jimmoen-test-trigger:1076">>,#{database => <<"db">>,enable => true,pool_size => 8,resource_opts => #{auto_restart_interval => 60000,batch_size => 1,batch_time => 0,health_check_interval => 15000,max_queue_bytes => 104857600,query_mode => sync,request_timeout => 15000,start_after_created => true,start_timeout => 5000,worker_pool_size => 16},server => "127.0.0.1",sql => <<"insert into mqtt.t_mqtt_msg(ts, msgid, mqtt_topic, qos, payload, arrived) values (${ts}, ${id}, ${topic}, ${qos}, ${payload}, ${timestamp})">>,username => <<"root">>}],[{file,"emqx_ee_connector_tdengine.erl"},{line,76}]},{emqx_resource,call_start,3,[{file,"emqx_resource.erl"},{line,359}]},{emqx_resource_manager,start_resource,2,[{file,"emqx_resource_manager.erl"},{line,513}]},{gen_statem,loop_state_callback,11,[{file,"gen_statem.erl"},{line,1205}]},{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,226}]}]}
```
 2023-03-29 10:07:02 -03:00
Thales Macedo Garitezi
5089449203
Merge pull request #10260 from thalesmg/minor-refactor-basic-usage-rule-rv50 
refactor(rule_engine): use more helper functions
 2023-03-29 09:44:23 -03:00
Zaiming (Stone) Shi
624c168dde fix: hide nodelay Kafka client socket option 
also fix a few descriptions
 2023-03-29 11:42:17 +02:00
Kinplemelon
d62698dd0b chore: upgrade dashboard to e1.0.5-beta.4 for ee 2023-03-29 16:32:18 +08:00
Zaiming (Stone) Shi
11c120f87c chore: bump emqx app vsn 2023-03-28 21:19:03 +02:00
Zaiming (Stone) Shi
4b428f7a29 chore: bump version to e5.0.2-rc.2 2023-03-28 21:18:21 +02:00
Zaiming (Stone) Shi
575e7cad01
Merge pull request #10261 from thalesmg/fix-kconsumer-flaky-test-rv50 
test: fix flaky kafka consumer test
 2023-03-28 21:13:52 +02:00
Thales Macedo Garitezi
64faccf50b test: fix flaky kafka consumer test 2023-03-28 14:50:55 -03:00
Thales Macedo Garitezi
d126c7dc62 refactor(rule_engine): use more helper functions 
Follow up to
https://github.com/emqx/emqx/pull/10251#discussion_r1150710899 and
https://github.com/emqx/emqx/pull/10251#discussion_r1150720420
 2023-03-28 13:46:56 -03:00
Thales Macedo Garitezi
b78d835e08
Merge pull request #10251 from thalesmg/fix-ingress-bridge-rule-dependency-rv50 
fix(rule_engine): count referenced bridges in `from` clauses as dependencies (rv5.0)
 2023-03-28 12:00:22 -03:00
Thales Macedo Garitezi
1a7ca7235e
Merge pull request #10249 from thalesmg/fix-kafka-offset-doc-rv50 
feat(kafka_consumer): tie `offset_reset_policy` and `begin_offset` together (rv5.0)
 2023-03-28 11:37:46 -03:00