text:
page_builder#add method does not allow an array that includes nil

In Embulk v0.6.13 and v0.6.14, if page_builder#add method received an array that included nil in parser plugins, following exception raised. Such an array was allowed in previous versions of Embulk.
If nil was replaced by "" before calling page_builder#add method, the following exception did not raise.
2015-06-30 00:39:27.546 +0900 [INFO] (preview): Loading files [/Users/myoshiz/devel/myproject/myproject.log.20150314]
java.lang.NullPointerException
        at org.embulk.spi.util.dynamic.AbstractDynamicColumnSetter.setRubyObject(org/embulk/spi/util/dynamic/org/embulk/spi/util/dynamic/org/embulk/spi/util/dynamic/AbstractDynamicColumnSetter.java:76)
        at java.lang.reflect.Method.invoke(java/lang/reflect/java/lang/reflect/java/lang/reflect/Method.java:483)
        at RUBY.add(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/page_builder.rb:19)
        at RUBY.add(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/page_builder.rb:19)
        at RUBY.add(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/page_builder.rb:19)
        at RUBY.add(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/page_builder.rb:19)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:109)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:109)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:109)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:109)
        at org.jruby.RubyKernel.loop(org/jruby/org/jruby/org/jruby/RubyKernel.java:1507)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:91)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:91)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:91)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:91)
        at org.jruby.RubyKernel.loop(org/jruby/org/jruby/org/jruby/RubyKernel.java:1507)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:52)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:52)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:52)
        at RUBY.run(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:52)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:57)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:57)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:57)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:57)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.run(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at org.embulk.spi.FileInputRunner.run(org/embulk/spi/org/embulk/spi/org/embulk/spi/FileInputRunner.java:145)
        at org.embulk.exec.PreviewExecutor$2$1.run(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:107)
        at org.embulk.spi.util.Filters$RecursiveControl.transaction(org/embulk/spi/util/org/embulk/spi/util/org/embulk/spi/util/Filters.java:97)
        at org.embulk.spi.util.Filters.transaction(org/embulk/spi/util/org/embulk/spi/util/org/embulk/spi/util/Filters.java:50)
        at org.embulk.exec.PreviewExecutor$2.run(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:96)
        at org.embulk.spi.FileInputRunner$RunnerControl$1$1.run(org/embulk/spi/org/embulk/spi/org/embulk/spi/FileInputRunner.java:117)
        at java.lang.reflect.Method.invoke(java/lang/reflect/java/lang/reflect/java/lang/reflect/Method.java:483)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:46)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:46)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:46)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:46)
        at RUBY.transaction(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:38)
        at RUBY.transaction(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:38)
        at RUBY.transaction(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:38)
        at RUBY.transaction(/Users/myoshiz/devel/embulk-parser-multiline-log-sample/lib/embulk/parser/multiline-log-sample.rb:38)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:43)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:43)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:43)
        at RUBY.transaction(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/parser_plugin.rb:43)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at Embulk$$ParserPlugin$$JavaAdapter_1742249157.transaction(Embulk$$ParserPlugin$$JavaAdapter_1742249157.gen:13)
        at org.embulk.spi.FileInputRunner$RunnerControl$1.run(org/embulk/spi/org/embulk/spi/org/embulk/spi/FileInputRunner.java:111)
        at org.embulk.spi.util.Decoders$RecursiveControl.transaction(org/embulk/spi/util/org/embulk/spi/util/org/embulk/spi/util/Decoders.java:77)
        at org.embulk.spi.util.Decoders.transaction(org/embulk/spi/util/org/embulk/spi/util/org/embulk/spi/util/Decoders.java:33)
        at org.embulk.spi.FileInputRunner$RunnerControl.run(org/embulk/spi/org/embulk/spi/org/embulk/spi/FileInputRunner.java:108)
        at org.embulk.standards.LocalFileInputPlugin.resume(org/embulk/standards/org/embulk/standards/org/embulk/standards/LocalFileInputPlugin.java:80)
        at org.embulk.standards.LocalFileInputPlugin.transaction(org/embulk/standards/org/embulk/standards/org/embulk/standards/LocalFileInputPlugin.java:70)
        at org.embulk.spi.FileInputRunner.transaction(org/embulk/spi/org/embulk/spi/org/embulk/spi/FileInputRunner.java:63)
        at org.embulk.exec.PreviewExecutor.doPreview(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:93)
        at org.embulk.exec.PreviewExecutor.access$000(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:27)
        at org.embulk.exec.PreviewExecutor$1.run(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:67)
        at org.embulk.exec.PreviewExecutor$1.run(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:63)
        at org.embulk.spi.Exec.doWith(org/embulk/spi/org/embulk/spi/org/embulk/spi/Exec.java:24)
        at org.embulk.exec.PreviewExecutor.preview(org/embulk/exec/org/embulk/exec/org/embulk/exec/PreviewExecutor.java:63)
        at org.embulk.command.Runner.preview(org/embulk/command/org/embulk/command/org/embulk/command/Runner.java:250)
        at org.embulk.command.Runner.main(org/embulk/command/org/embulk/command/org/embulk/command/Runner.java:110)
        at java.lang.reflect.Method.invoke(java/lang/reflect/java/lang/reflect/java/lang/reflect/Method.java:483)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/command/embulk_run.rb:351)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/command/embulk_run.rb:351)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/command/embulk_run.rb:351)
        at RUBY.run(file:/Users/myoshiz/.embulk/bin/embulk!/embulk/command/embulk_run.rb:351)
        at classpath_3a_embulk.command.embulk.(root)(classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at classpath_3a_embulk.command.embulk.(root)(classpath_3a_embulk/command/classpath_3a_embulk/command/classpath_3a_embulk/command/classpath:embulk/command/embulk.rb:47)
        at org.embulk.cli.Main.main(org/embulk/cli/org/embulk/cli/org/embulk/cli/Main.java:11)

Sample plugin used in the above case: https://github.com/muziyoshiz/embulk-parser-multiline-log-sample/blob/master/lib/embulk/parser/multiline-log-sample.rb

Fixed at #222!

Embulk v0.6.15 solved the problem in my enviroment. Thank you!

authors: frsyuki muziyoshiz

repo: embulk/embulk


text:
Reimplement standard guess plugins in Java, except for csv

"Standard" guess plugins are implemented in (J)Ruby in embulk-standards (embulk.gem since v0.10.24). In that Ruby code, the CSV guess calls CSVParserPlugin to perform a guess about CSV.
This dependency is blocking CSVParserPlugin from being "modernized" for Embulk v0.10 to use embulk-util-config instead of embulk-core's org.embulk.config.* classes. To unblock this, we are going to reimplement standard guess plugins in Java from Ruby.
This pull request is the first step before CSV -- reimplementing all other bzip2, gzip, and JSON guess, which are not very complicated. (On the other hand, CSV guess is complicated, to be done in another pull request.)

Thanks!

source: gharchive/pull-request

license_type: permissive

license_source: github-api


text:
Add raw_window_handle to WindowInfo

All this does is expose the winit window raw_window_handle and put it into the WindowInfo so it can be accessed through the Frame's or CreationContexts's IntegrationInfo.
I'm a bit uncertain about the safety of this since most of raw_window_handle's structs are wrapping *mut c_void, but I think it's fine? Any input there would be appreciated.
Closes #3050

I had missed (due to a branching mistake) that this was already implemented in #3073 and is available on current master, closing in favor of that.

repo: emilk/egui


text:
Fix: ScrollArea repeatedly appears and disappears quickly issue. + For scroll_with_delta() + inner_margin

Fix: ScrollArea repeatedly appears and disappears quickly issue. (#4658)

Closes #4658

If the mouse is at a specific position above the ScrollArea (in TextEdit?), the ScrollArea repeatedly appears and disappears quickly.
You can more easily find the issue if you set Full bar width to the maximum value of 32.
If there is a better way to fix this than the solution in this Pull Request, please revise it accordingly.
AND
Fix: scroll_with_delta() for ScrollArea::vertical() and ScrollArea::horizontal()

Closes #4584

We need to do this in order for ScrollArea::vertical() and ScrollArea::horizontal() to work even where they are divided or nested.
AND
inner_margin also applies to floating scroll.

Closes #4664

Don't open multiple PRs with the same functionality. You have three options:

Wait for https://github.com/emilk/egui/pull/4658 to be merged
Use https://github.com/emilk/egui/pull/4658 as a merge-target for this PR
Remove the duplicated commits

authors: emilk rustbasic


text:
Durability

These trinkets should have durability so they have to be rebuilt over time

Some of them do have durability, other than the mining glove, which I might change, everything that doesn't have durability I don't think should (backpack, belts). If you have some specific ones in mind I'd be willing to hear why you think they should.

I'm using the latest and only version 1.0.0. and Minecraft version 1.15.2 with fabric loader v0.7.8
I see no durability bar on any trinkets, no one on our server has mysteriously lost a trinket (due to possible invisible durability changes)

I believe the only trinket that uses durability is the rocket aglet

I see, that is one I have not yet to got to playing with.. So then I suggest the following trinkets support durability:
Aglet of the Traveller
Builder's Belt
Mining Glove

source: gharchive/issue

repo: emilyploszaj/bunch-o-trinkets

license: MIT


text:
[API] Ability to check whether EMI keybinds are pressed

An API to check whether a certain keybind is pressed when given a key code and scan code would allow mods to do things like opening recipes for or usages of an item when hovering non-slot widgets.
For context, I have a crafting system that looks similar to vanilla's stonecutter with a grid of buttons and I would like to allow players to open the "show recipe" screen of the item shown on the button they are hovering.

EMI is unlikely to expose such a large amount of unstable API surface. However, to accomplish your goal, you can register a stack provider for your screen. EmiStackInteractions can specify a recipe context for lookups.

Understandable. A custom stack provider does the trick, I completely missed that part of the API.

authors: XFactHD emilyploszaj

repo: emilyploszaj/emi


text:
On Reload Opening Fullscreen Map Defaults to Spawn

When opening the fullscreen map after loading an existing single player world the map is centered on spawn instead of player's position.

Do you have the right mod? EMI doesn't have any maps of the world.

Pardon me, a minor and temporary case of cerebral flatulence.  I was intending to take this issue to Journeymap.
EMI works fantastic, btw!

authors: digitaltrucker emilyploszaj


text:
feat(facets): Fix SlicedFilters filters input in facets.vue

Description
The aim of this PR is import and fix the SlicedFilters in the facets.vue.
Issue: EX-4087
Motivation and Context
SlicedFilters was not imported in the facets.vue component so it was not warking.
SlicedFitlers didn't receive filters as property.
Test
Check that the SlicedFilter works properly.

Wait for the update dependencies pull request to be merged before merging these one or update them here too and perform an npm install so the package-lock.json gets updated too.

Wait for the update dependencies pull request to be merged before merging these one or update them here too and perform an npm install so the package-lock.json gets updated too.

Done @LuisMartinez15 !

repo: empathyco/x-archetype


text:
it can’t work  Follow the steps

WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/emqttc to be an app dir (containing ebin/.app), but no .app found.
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/getopt to be an app dir (containing ebin/.app), but no .app found.
==> emqtt_benchmark-master (get-deps)
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/emqttc to be an app dir (containing ebin/.app), but no .app found.
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/getopt to be an app dir (containing ebin/.app), but no .app found.
Pulling emqttc from {git,"git://github.com/emqtt/emqttc.git",
{branch,"master"}}
正克隆到 'emqttc'...
Pulling getopt from {git,"https://github.com/jcomellas/getopt.git",
{branch,"master"}}
正克隆到 'getopt'...
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/gen_logger to be an app dir (containing ebin/.app), but no .app found.
==> getopt (get-deps)
==> emqttc (get-deps)
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/gen_logger to be an app dir (containing ebin/.app), but no .app found.
Pulling gen_logger from {git,"https://github.com/emqtt/gen_logger.git",
{branch,"master"}}
正克隆到 'gen_logger'...
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/lager to be an app dir (containing ebin/.app), but no .app found.
==> gen_logger (get-deps)
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/lager to be an app dir (containing ebin/.app), but no .app found.
Pulling lager from {git,"git://github.com/basho/lager.git",{branch,"master"}}
正克隆到 'lager'...
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/goldrush to be an app dir (containing ebin/.app), but no .app found.
==> lager (get-deps)
WARN:  Expected /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/goldrush to be an app dir (containing ebin/.app), but no .app found.
Pulling goldrush from {git,"git://github.com/DeadZen/goldrush.git",
{tag,"0.1.8"}}
正克隆到 'goldrush'...
==> goldrush (get-deps)
==> goldrush (compile)
ERROR: OTP release R17 or later is required, you have: R16B03
ERROR: compile failed while processing /home/congzhou/engyne/test/Server/emqtt_benchmark-master/deps/goldrush: rebar_abort
make: *** [compile] 错误 1

You need to upgrade Erlang to OTP 17 or 17+
Please go to the following website for getting new versions.
https://www.erlang.org/downloads

@zhiyoujingtian please upgrade Erlang/OTP to R17+.

authors: emqplus msdevanms zhiyoujingtian

license: mit

license_source: bigquery


text:
make failed

I have erlang 19 installed

@hezhijun sorry for the late reply. You Erlang/OPT environment missed 'crypto' library. Please fix it first.

authors: emqplus hezhijun


text:
remove erlang:now/0

kill Warning.

Invalid fix. Closed. You should not use os:timestamp() as random seed.

@redink  @emqplus #31 shall be the correct fix

authors: emqplus mingchuno redink

repo: emqtt/emqttc


text:
集群怎么设置？不成功？

设置'etc/vm.args':
192.168.6.156上
-name emqttd@192.168.6.156
./bin/emqtt start    启动不成功。
-name emqttd@127.0.0.1
./bin/emqtt start    启动成功。
2台不能都设为 -name emqttd@127.0.0.1   这个集群就设置不成功了。
如何设置，谢谢

if I set -name emqttd@host1  can't start the emqttd
print:
emqttd failed to start within 15 seconds,
see the output of 'emqttd console' for more information.
If you want to wait longer, set the environment variable
WAIT_FOR_ERLANG to the number of seconds to wait.

please rm data/mnesia/* first if you changed node name.

thanks

我试了，仍然不能成功。

cannot start still?

在 2015年4月24日，下午12:23，杨延斌 notifications@github.com 写道：
我试了，仍然不能成功。
—
Reply to this email directly or view it on GitHub https://github.com/emqtt/emqttd/issues/108#issuecomment-95797682.

yes ,can't start     -name emqttd@192.168.6.156  or -name emqttd@host1

first, my etc/vm.args config:
-name emqttd@192.168.18.124

second:
rm -rf data/mnesia/*

and then:
./bin/emqttd console
airlee:emqttd erylee$ ./bin/emqttd console
Exec: /Users/erylee/Projects/emqttd/rel/emqttd/erts-6.3/bin/erlexec -boot /Users/erylee/Projects/emqttd/rel/emqttd/releases/0.6.0/emqttd             -embedded -config /Users/erylee/Projects/emqttd/rel/emqttd/etc/app.config             -pa ./lib/basho-patches             -args_file /Users/erylee/Projects/emqttd/rel/emqttd/etc/vm.args -- console
Root: /Users/erylee/Projects/emqttd/rel/emqttd
Erlang/OTP 17 [erts-6.3] [source] [64-bit] [smp:4:4] [async-threads:32] [hipe] [kernel-poll:true]

=INFO REPORT==== 24-Apr-2015::15:36:04 ===
    alarm_handler: {set,{system_memory_high_watermark,[]}}
starting emqttd on node 'emqttd@192.168.18.124'
emqttd config is starting...[done]
emqttd event is starting...[done]
emqttd pooler is starting...[done]
emqttd client manager is starting...[done]
emqttd session manager is starting...[done]
emqttd session supervisor is starting...[done]
emqttd pubsub is starting...[done]
emqttd broker is starting...[done]
emqttd metrics is starting...[done]
emqttd bridge supervisor is starting...[done]
emqttd access control is starting...[done]
emqttd system monitor is starting...[done]
15:36:05.245 [info] mqtt listen on 0.0.0.0:1883 with 16 acceptors.
15:36:05.246 [info] mqtts listen on 0.0.0.0:8883 with 4 acceptors.
15:36:05.256 [info] http listen on 0.0.0.0:8083 with 4 acceptors.
Erlang MQTT Broker 0.6.2 is running now
Eshell V6.3  (abort with ^G)
(emqttd@192.168.18.124)1> node().
'emqttd@192.168.18.124'

[root@cndkbtamqpusha02 emqttd]# ./bin/emqttd console
Exec: /opt/emqttd/erts-6.3/bin/erlexec -boot /opt/emqttd/releases/0.6.0/emqttd             -embedded -config /opt/emqttd/etc/app.config             -pa ./lib/basho-patches             -args_file /opt/emqttd/etc/vm.args -- console
Root: /opt/emqttd
Erlang/OTP 17 [erts-6.3] [source] [64-bit] [smp:4:4] [async-threads:64] [hipe] [kernel-poll:true]
starting emqttd on node 'emqttd@192.168.6.157'
emqttd config is starting...[done]
emqttd event is starting...[done]
emqttd pooler is starting...[done]
emqttd client manager is starting...[done]
emqttd session manager is starting...[done]
emqttd session supervisor is starting...[done]
emqttd pubsub is starting...[done]
emqttd broker is starting...[done]
emqttd metrics is starting...[done]
emqttd bridge supervisor is starting...[done]
emqttd access control is starting...[done]
emqttd system monitor is starting...[done]
16:10:46.349 [info] mqtt listen on 0.0.0.0:1885 with 64 acceptors.
16:10:46.350 [info] mqtts listen on 0.0.0.0:8883 with 4 acceptors.
16:10:46.357 [info] http listen on 0.0.0.0:8083 with 4 acceptors.
Erlang MQTT Broker 0.6.1 is running now
Eshell V6.3  (abort with ^G)
(emqttd@192.168.6.157)1> 16:11:26.284 [info] metrics PUBLISH to $SYS/brokers/emqttd@192.168.6.157/bytes/received
16:11:26.284 [info] metrics PUBLISH to $SYS/brokers/emqttd@192.168.6.157/bytes/sent

OK, now  emqttd@192.168.6.157 successful!!!!!!!!!

Hi, Yang, I released 0.6.2, thanks for your bug report.

repo: emqtt/emqttd


text:
eheap_alloc: Cannot allocate 441485240 bytes of memory (of type "heap").

Environment

OS: AWS Ubuntu 16.04 server
Erlang/OTP: Erlang/OTP 20
EMQ: 2.3.3

Description
the emq server process has been killed automatically during the night
I checked the /var/log/emqttd and found a file was created: crash.dump
this dump is so big that the size is 3.7M
I checked the file and the slogan shows
eheap_alloc: Cannot allocate 441485240 bytes of memory (of type "heap").
I think I need to provide more info but the current process has been killed
so Im not really sure if I run below commands will help
emqttd_ctl listeners
emqttd_ctl broker metrics
emqttd_ctl broker stats
emqttd_ctl plugins load emqttd_recon
emqttd_ctl recon bin_leak
please let me know how can I get the info so that we can find the root cause
I'm happy to do anything I  can to, thanks  : )
PS. Attach is crash.dump file
emq.log

What is the memory size of your ubuntu machine? Only 1GB?
And what is your log level? error? debug? The log module(lager_event) has consumed 376MB memory.

authors: Cavduu grutabow


text:
SELECT collect(*) as r1 FROM mapper lead to collapse

time="2021-01-12 21:06:05" level=debug msg="mqtt_1 publish {"energy":[[null]]}" file="sinks/mqtt_sink.go:190" rule=rule1
runtime: goroutine stack exceeds 1000000000-byte limit
runtime: sp=0xc020630340 stack=[0xc020630000, 0xc040630000]
fatal error: stack overflow
runtime stack:
runtime.throw(0xe33d05, 0xe)
/home/liuxiang/go/src/runtime/panic.go:1116 +0x72
runtime.newstack()
/home/liuxiang/go/src/runtime/stack.go:1060 +0x78d
runtime.morestack()
/home/liuxiang/go/src/runtime/asm_amd64.s:449 +0x8f
goroutine 60 [running]:
runtime.assertE2I2(0xd8bb00, 0xdb76e0, 0xc00009b200, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/runtime/iface.go:494 +0xa5 fp=0xc020630350 sp=0xc020630348 pc=0x67b145
fmt.(*pp).handleMethods(0xc00048e0d0, 0xc000000073, 0x0)
/home/liuxiang/go/src/fmt/print.go:594 +0x88 fp=0xc0206305c0 sp=0xc020630350 pc=0x76be28
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115b16)
/home/liuxiang/go/src/fmt/print.go:727 +0x25a5 fp=0xc020630798 sp=0xc0206305c0 pc=0x76f385
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115b15)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020630970 sp=0xc020630798 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115b14)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020630b48 sp=0xc020630970 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c5bb0, 0x94, 0x73, 0x115b13)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020630d20 sp=0xc020630b48 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115b12)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020630ef8 sp=0xc020630d20 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115b11)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206310d0 sp=0xc020630ef8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115b10)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc0206312a8 sp=0xc0206310d0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c5a70, 0x94, 0x73, 0x115b0f)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020631480 sp=0xc0206312a8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115b0e)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020631658 sp=0xc020631480 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115b0d)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020631830 sp=0xc020631658 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115b0c)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020631a08 sp=0xc020631830 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c5930, 0x94, 0x73, 0x115b0b)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020631be0 sp=0xc020631a08 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115b0a)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020631db8 sp=0xc020631be0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115b09)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020631f90 sp=0xc020631db8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115b08)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020632168 sp=0xc020631f90 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c5790, 0x94, 0x73, 0x115b07)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020632340 sp=0xc020632168 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115b06)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020632518 sp=0xc020632340 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115b05)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206326f0 sp=0xc020632518 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115b04)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc0206328c8 sp=0xc0206326f0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c56b0, 0x94, 0x73, 0x115b03)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020632aa0 sp=0xc0206328c8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115b02)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020632c78 sp=0xc020632aa0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115b01)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020632e50 sp=0xc020632c78 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115b00)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020633028 sp=0xc020632e50 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c54d0, 0x94, 0x73, 0x115aff)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020633200 sp=0xc020633028 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115afe)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc0206333d8 sp=0xc020633200 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115afd)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206335b0 sp=0xc0206333d8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115afc)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020633788 sp=0xc0206335b0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c5430, 0x94, 0x73, 0x115afb)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020633960 sp=0xc020633788 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115afa)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020633b38 sp=0xc020633960 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115af9)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020633d10 sp=0xc020633b38 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115af8)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020633ee8 sp=0xc020633d10 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c52b0, 0x94, 0x73, 0x115af7)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206340c0 sp=0xc020633ee8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115af6)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020634298 sp=0xc0206340c0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115af5)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020634470 sp=0xc020634298 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115af4)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020634648 sp=0xc020634470 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c50f0, 0x94, 0x73, 0x115af3)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020634820 sp=0xc020634648 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115af2)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc0206349f8 sp=0xc020634820 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115af1)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020634bd0 sp=0xc0206349f8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115af0)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020634da8 sp=0xc020634bd0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4f70, 0x94, 0x73, 0x115aef)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020634f80 sp=0xc020634da8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115aee)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020635158 sp=0xc020634f80 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115aed)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020635330 sp=0xc020635158 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115aec)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020635508 sp=0xc020635330 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4e70, 0x94, 0x73, 0x115aeb)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206356e0 sp=0xc020635508 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115aea)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc0206358b8 sp=0xc0206356e0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ae9)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020635a90 sp=0xc0206358b8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ae8)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020635c68 sp=0xc020635a90 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4db0, 0x94, 0x73, 0x115ae7)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020635e40 sp=0xc020635c68 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ae6)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020636018 sp=0xc020635e40 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ae5)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206361f0 sp=0xc020636018 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ae4)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc0206363c8 sp=0xc0206361f0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4c50, 0x94, 0x73, 0x115ae3)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206365a0 sp=0xc0206363c8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ae2)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020636778 sp=0xc0206365a0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ae1)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020636950 sp=0xc020636778 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ae0)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020636b28 sp=0xc020636950 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4b10, 0x94, 0x73, 0x115adf)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020636d00 sp=0xc020636b28 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ade)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020636ed8 sp=0xc020636d00 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115add)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206370b0 sp=0xc020636ed8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115adc)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020637288 sp=0xc0206370b0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4990, 0x94, 0x73, 0x115adb)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020637460 sp=0xc020637288 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ada)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020637638 sp=0xc020637460 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ad9)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020637810 sp=0xc020637638 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ad8)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc0206379e8 sp=0xc020637810 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4850, 0x94, 0x73, 0x115ad7)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020637bc0 sp=0xc0206379e8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ad6)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020637d98 sp=0xc020637bc0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ad5)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020637f70 sp=0xc020637d98 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ad4)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020638148 sp=0xc020637f70 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4710, 0x94, 0x73, 0x115ad3)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020638320 sp=0xc020638148 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ad2)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc0206384f8 sp=0xc020638320 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ad1)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206386d0 sp=0xc0206384f8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ad0)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc0206388a8 sp=0xc0206386d0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4570, 0x94, 0x73, 0x115acf)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020638a80 sp=0xc0206388a8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ace)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020638c58 sp=0xc020638a80 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115acd)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020638e30 sp=0xc020638c58 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115acc)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020639008 sp=0xc020638e30 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4410, 0x94, 0x73, 0x115acb)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc0206391e0 sp=0xc020639008 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115aca)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc0206393b8 sp=0xc0206391e0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ac9)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020639590 sp=0xc0206393b8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ac8)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020639768 sp=0xc020639590 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4350, 0x94, 0x73, 0x115ac7)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020639940 sp=0xc020639768 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ac6)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc020639b18 sp=0xc020639940 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ac5)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc020639cf0 sp=0xc020639b18 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ac4)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc020639ec8 sp=0xc020639cf0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4270, 0x94, 0x73, 0x115ac3)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063a0a0 sp=0xc020639ec8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ac2)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc02063a278 sp=0xc02063a0a0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ac1)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063a450 sp=0xc02063a278 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ac0)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc02063a628 sp=0xc02063a450 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c4150, 0x94, 0x73, 0x115abf)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063a800 sp=0xc02063a628 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115abe)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc02063a9d8 sp=0xc02063a800 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115abd)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063abb0 sp=0xc02063a9d8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115abc)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc02063ad88 sp=0xc02063abb0 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c1f30, 0x94, 0x73, 0x115abb)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063af60 sp=0xc02063ad88 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115aba)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc02063b138 sp=0xc02063af60 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ab9)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063b310 sp=0xc02063b138 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xd4b0c0, 0xc000090be0, 0x97, 0xc000000073, 0x115ab8)
/home/liuxiang/go/src/fmt/print.go:869 +0x517 fp=0xc02063b4e8 sp=0xc02063b310 pc=0x76d2f7
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc0179c1e30, 0x94, 0x73, 0x115ab7)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063b6c0 sp=0xc02063b4e8 pc=0x76e56c
fmt.(*pp).printValue(0xc00048e0d0, 0xdb76e0, 0xc00009b200, 0x15, 0xc000000073, 0x115ab6)
/home/liuxiang/go/src/fmt/print.go:784 +0xe38 fp=0xc02063b898 sp=0xc02063b6c0 pc=0x76dc18
fmt.(*pp).printValue(0xc00048e0d0, 0xd70600, 0xc000097dc0, 0x194, 0x73, 0x115ab5)
/home/liuxiang/go/src/fmt/print.go:823 +0x178c fp=0xc02063ba70 sp=0xc02063b898 pc=0x76e56c
...additional frames elided...
created by github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).Exec
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:69 +0x1cb
goroutine 1 [chan receive]:
github.com/emqx/kuiper/xstream/server/server.StartUp(0xe2f26d, 0x7, 0xe2fdab, 0x8)
/home/liuxiang/workspace/kuiper/xstream/server/server/server.go:142 +0xe08
main.main()
/home/liuxiang/workspace/kuiper/xstream/server/main.go:11 +0x51
goroutine 7 [chan receive]:
github.com/emqx/kuiper/xstream/server/server.init.0.func1(0xc00007caf0)
/home/liuxiang/workspace/kuiper/xstream/server/server/rpc.go:279 +0x3b
created by github.com/emqx/kuiper/xstream/server/server.init.0
/home/liuxiang/workspace/kuiper/xstream/server/server/rpc.go:277 +0x52
goroutine 41 [chan receive]:
github.com/emqx/kuiper/xstream/server/server.doStartRule.func1(0xc0003553c0)
/home/liuxiang/workspace/kuiper/xstream/server/server/ruleManager.go:74 +0x72
created by github.com/emqx/kuiper/xstream/server/server.doStartRule
/home/liuxiang/workspace/kuiper/xstream/server/server/ruleManager.go:71 +0x6e
goroutine 24 [select]:
github.com/emqx/kuiper/xstream/nodes.(*SinkNode).Open.func1.1(0xc0000a87e0, 0xf05120, 0xc000094cb0, 0xf061e0, 0xc000094e00, 0xc000234000, 0xc000376090, 0xc0003760b8, 0xc0003760b9, 0xc000098188, ...)
/home/liuxiang/workspace/kuiper/xstream/nodes/sink_node.go:201 +0x285
created by github.com/emqx/kuiper/xstream/nodes.(*SinkNode).Open.func1
/home/liuxiang/workspace/kuiper/xstream/nodes/sink_node.go:166 +0x6b1
goroutine 19 [select]:
github.com/emqx/kuiper/xstream/nodes.(*SinkNode).Open.func1.1(0xc00031aba0, 0xf05120, 0xc000248070, 0xf061e0, 0xc0002482a0, 0xc000234120, 0xc0000c2000, 0xc0000c2028, 0xc0000c2029, 0xc000098008, ...)
/home/liuxiang/workspace/kuiper/xstream/nodes/sink_node.go:201 +0x285
created by github.com/emqx/kuiper/xstream/nodes.(*SinkNode).Open.func1
/home/liuxiang/workspace/kuiper/xstream/nodes/sink_node.go:166 +0x6b1
goroutine 16 [chan receive]:
github.com/emqx/kuiper/xstream/server/server.doStartRule.func1(0xc0003545c0)
/home/liuxiang/workspace/kuiper/xstream/server/server/ruleManager.go:74 +0x72
created by github.com/emqx/kuiper/xstream/server/server.doStartRule
/home/liuxiang/workspace/kuiper/xstream/server/server/ruleManager.go:71 +0x6e
goroutine 38 [select]:
github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).doOp(0xc000314e80, 0xf061e0, 0xc000248460, 0xc000234120)
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:106 +0x3e5
created by github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).Exec
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:69 +0x1cb
goroutine 39 [select]:
github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).doOp(0xc000314ec0, 0xf061e0, 0xc0002485b0, 0xc000234120)
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:106 +0x3e5
created by github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).Exec
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:69 +0x1cb
goroutine 116 [select]:
github.com/eclipse/paho.mqtt.golang.keepalive(0xc00055c1e0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/ping.go:41 +0x1ea
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:306 +0x8cb
goroutine 40 [select]:
github.com/emqx/kuiper/xstream/nodes.(*SinkNode).Open.func1.1(0xc00031aae0, 0xf05120, 0xc000248070, 0xf061e0, 0xc0002481c0, 0xc000234120, 0xc000488000, 0xc000488028, 0xc000488029, 0xc00048a000, ...)
/home/liuxiang/workspace/kuiper/xstream/nodes/sink_node.go:201 +0x285
created by github.com/emqx/kuiper/xstream/nodes.(*SinkNode).Open.func1
/home/liuxiang/workspace/kuiper/xstream/nodes/sink_node.go:166 +0x6b1
goroutine 69 [select]:
github.com/emqx/kuiper/xstream/nodes.(*SourceNode).Open.func1.1(0xc00031a960, 0xc000234120, 0xf061e0, 0xc000248620, 0xf05120, 0xc000248070, 0xc00051c180, 0xc000516128, 0x0)
/home/liuxiang/workspace/kuiper/xstream/nodes/source_node.go:129 +0x5b0
created by github.com/emqx/kuiper/xstream/nodes.(*SourceNode).Open.func1
/home/liuxiang/workspace/kuiper/xstream/nodes/source_node.go:80 +0x26e
goroutine 61 [select]:
github.com/eclipse/paho.mqtt.golang.keepalive(0xc00055c000)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/ping.go:41 +0x1ea
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:306 +0x8cb
goroutine 72 [select]:
github.com/emqx/kuiper/xstream/nodes.(*DynamicChannelBuffer).run(0xc000508140)
/home/liuxiang/workspace/kuiper/xstream/nodes/dynamic_channel_buffer.go:55 +0x4b4
created by github.com/emqx/kuiper/xstream/nodes.NewDynamicChannelBuffer
/home/liuxiang/workspace/kuiper/xstream/nodes/dynamic_channel_buffer.go:25 +0x137
goroutine 47 [select]:
github.com/eclipse/paho.mqtt.golang.errorWatch(0xc00055c5a0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:346 +0xf3
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:319 +0x60a
goroutine 99 [select]:
github.com/emqx/kuiper/xstream/nodes.(*SourceNode).Open.func1.1(0xc0000a8600, 0xc000234000, 0xf061e0, 0xc000095500, 0xf05120, 0xc000094cb0, 0xc00036e2a0, 0xc000488158, 0x0)
/home/liuxiang/workspace/kuiper/xstream/nodes/source_node.go:129 +0x5b0
created by github.com/emqx/kuiper/xstream/nodes.(*SourceNode).Open.func1
/home/liuxiang/workspace/kuiper/xstream/nodes/source_node.go:80 +0x26e
goroutine 58 [select]:
github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).doOp(0xc0000ac4c0, 0xf061e0, 0xc0000951f0, 0xc000234000)
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:106 +0x3e5
created by github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).Exec
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:69 +0x1cb
goroutine 59 [select]:
github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).doOp(0xc0000ac500, 0xf061e0, 0xc000095340, 0xc000234000)
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:106 +0x3e5
created by github.com/emqx/kuiper/xstream/nodes.(*UnaryOperator).Exec
/home/liuxiang/workspace/kuiper/xstream/nodes/operations.go:69 +0x1cb
goroutine 100 [select]:
github.com/emqx/kuiper/xstream/nodes.(*DynamicChannelBuffer).run(0xc0003141c0)
/home/liuxiang/workspace/kuiper/xstream/nodes/dynamic_channel_buffer.go:55 +0x4b4
created by github.com/emqx/kuiper/xstream/nodes.NewDynamicChannelBuffer
/home/liuxiang/workspace/kuiper/xstream/nodes/dynamic_channel_buffer.go:25 +0x137
goroutine 42 [IO wait]:
internal/poll.runtime_pollWait(0x7fb0d8588f18, 0x72, 0x0)
/home/liuxiang/go/src/runtime/netpoll.go:220 +0x55
internal/poll.(*pollDesc).wait(0xc00009e698, 0x72, 0x0, 0x0, 0xe2e65e)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:87 +0x45
internal/poll.(*pollDesc).waitRead(...)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:92
internal/poll.(*FD).Accept(0xc00009e680, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/internal/poll/fd_unix.go:394 +0x1fc
net.(*netFD).accept(0xc00009e680, 0xc000482d80, 0xc00053c000, 0x7fb100a3e560)
/home/liuxiang/go/src/net/fd_unix.go:172 +0x45
net.(*TCPListener).accept(0xc0003546a0, 0xc000482dc0, 0x67da18, 0x30)
/home/liuxiang/go/src/net/tcpsock_posix.go:139 +0x32
net.(*TCPListener).Accept(0xc0003546a0, 0xde2b20, 0xc00036e930, 0xd758e0, 0x1251ee0)
/home/liuxiang/go/src/net/tcpsock.go:261 +0x65
net/http.(*Server).Serve(0xc00025e0e0, 0xefc000, 0xc0003546a0, 0x0, 0x0)
/home/liuxiang/go/src/net/http/server.go:2937 +0x266
net/http.(*Server).ListenAndServe(0xc00025e0e0, 0x0, 0x0)
/home/liuxiang/go/src/net/http/server.go:2866 +0xb7
github.com/emqx/kuiper/xstream/server/server.StartUp.func2(0xc00025e0e0)
/home/liuxiang/workspace/kuiper/xstream/server/server/server.go:100 +0x153
created by github.com/emqx/kuiper/xstream/server/server.StartUp
/home/liuxiang/workspace/kuiper/xstream/server/server/server.go:97 +0x839
goroutine 45 [select]:
github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch.func1(0xc0005140c0, 0xc0003142c0, 0xc00055c5a0, 0xc000514001)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:145 +0x43d
created by github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:143 +0x5c
goroutine 43 [IO wait]:
internal/poll.runtime_pollWait(0x7fb0d8588ff8, 0x72, 0x0)
/home/liuxiang/go/src/runtime/netpoll.go:220 +0x55
internal/poll.(*pollDesc).wait(0xc000246a18, 0x72, 0x0, 0x0, 0xe2e65e)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:87 +0x45
internal/poll.(*pollDesc).waitRead(...)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:92
internal/poll.(*FD).Accept(0xc000246a00, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/internal/poll/fd_unix.go:394 +0x1fc
net.(*netFD).accept(0xc000246a00, 0xc0001cfda0, 0xc000080400, 0x7fb100a3de98)
/home/liuxiang/go/src/net/fd_unix.go:172 +0x45
net.(*TCPListener).accept(0xc000203d00, 0xc0001cfde0, 0x67da18, 0x30)
/home/liuxiang/go/src/net/tcpsock_posix.go:139 +0x32
net.(*TCPListener).Accept(0xc000203d00, 0xde2b20, 0xc00019b2f0, 0xd758e0, 0x1251ee0)
/home/liuxiang/go/src/net/tcpsock.go:261 +0x65
net/http.(*Server).Serve(0xc00025e1c0, 0xefc000, 0xc000203d00, 0x0, 0x0)
/home/liuxiang/go/src/net/http/server.go:2937 +0x266
net/http.(*Server).ListenAndServe(0xc00025e1c0, 0x0, 0x0)
/home/liuxiang/go/src/net/http/server.go:2866 +0xb7
github.com/emqx/kuiper/xstream/server/server.StartUp.func3(0xc00025e1c0, 0xc0001734f0)
/home/liuxiang/workspace/kuiper/xstream/server/server/server.go:125 +0x2f
created by github.com/emqx/kuiper/xstream/server/server.StartUp
/home/liuxiang/workspace/kuiper/xstream/server/server/server.go:124 +0xacf
goroutine 131 [select]:
github.com/eclipse/paho.mqtt.golang.keepalive(0xc00055c3c0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/ping.go:41 +0x1ea
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:306 +0x8cb
goroutine 106 [syscall]:
os/signal.signal_recv(0x0)
/home/liuxiang/go/src/runtime/sigqueue.go:147 +0x9d
os/signal.loop()
/home/liuxiang/go/src/os/signal/signal_unix.go:23 +0x25
created by os/signal.Notify.func1.1
/home/liuxiang/go/src/os/signal/signal.go:150 +0x45
goroutine 62 [select]:
github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch.func1(0xc0000a8cc0, 0xc000508080, 0xc00055c000, 0xc0000a8c01)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:145 +0x43d
created by github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:143 +0x5c
goroutine 64 [select]:
github.com/eclipse/paho.mqtt.golang.errorWatch(0xc00055c000)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:346 +0xf3
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:319 +0x60a
goroutine 65 [select]:
github.com/eclipse/paho.mqtt.golang.alllogic(0xc00055c000)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:240 +0x1f4
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:320 +0x62f
goroutine 114 [select]:
github.com/eclipse/paho.mqtt.golang.outgoing(0xc00055c000)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:171 +0x23f
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:321 +0x654
goroutine 115 [IO wait]:
internal/poll.runtime_pollWait(0x7fb0d8589378, 0x72, 0xeedc80)
/home/liuxiang/go/src/runtime/netpoll.go:220 +0x55
internal/poll.(*pollDesc).wait(0xc000550198, 0x72, 0xc000376200, 0x1, 0x1)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:87 +0x45
internal/poll.(*pollDesc).waitRead(...)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:92
internal/poll.(*FD).Read(0xc000550180, 0xc000376248, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/internal/poll/fd_unix.go:159 +0x1b1
net.(*netFD).Read(0xc000550180, 0xc000376248, 0x1, 0x1, 0x0, 0x1, 0x203000)
/home/liuxiang/go/src/net/fd_posix.go:55 +0x4f
net.(*conn).Read(0xc00048a010, 0xc000376248, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/net/net.go:182 +0x8e
io.ReadAtLeast(0xeec7e0, 0xc00048a010, 0xc000376248, 0x1, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/io/io.go:314 +0x87
io.ReadFull(...)
/home/liuxiang/go/src/io/io.go:333
github.com/eclipse/paho.mqtt.golang/packets.ReadPacket(0xeec7e0, 0xc00048a010, 0xc00048a010, 0xeec7e0, 0xc00048a010, 0x0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/packets/packets.go:105 +0x94
github.com/eclipse/paho.mqtt.golang.incoming(0xc00055c000)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:132 +0x125
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:322 +0x679
goroutine 117 [select]:
github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch.func1(0xc0000a8de0, 0xc0005081c0, 0xc00055c1e0, 0xc0000a8d01)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:145 +0x43d
created by github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:143 +0x5c
goroutine 44 [select]:
github.com/eclipse/paho.mqtt.golang.keepalive(0xc00055c5a0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/ping.go:41 +0x1ea
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:306 +0x8cb
goroutine 119 [select]:
github.com/eclipse/paho.mqtt.golang.errorWatch(0xc00055c1e0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:346 +0xf3
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:319 +0x60a
goroutine 120 [select]:
github.com/eclipse/paho.mqtt.golang.alllogic(0xc00055c1e0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:240 +0x1f4
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:320 +0x62f
goroutine 121 [select]:
github.com/eclipse/paho.mqtt.golang.outgoing(0xc00055c1e0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:171 +0x23f
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:321 +0x654
goroutine 122 [IO wait]:
internal/poll.runtime_pollWait(0x7fb0d8589298, 0x72, 0xeedc80)
/home/liuxiang/go/src/runtime/netpoll.go:220 +0x55
internal/poll.(*pollDesc).wait(0xc000550298, 0x72, 0xc000582600, 0x1, 0x1)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:87 +0x45
internal/poll.(*pollDesc).waitRead(...)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:92
internal/poll.(*FD).Read(0xc000550280, 0xc0005826fc, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/internal/poll/fd_unix.go:159 +0x1b1
net.(*netFD).Read(0xc000550280, 0xc0005826fc, 0x1, 0x1, 0x203000, 0x1, 0x203000)
/home/liuxiang/go/src/net/fd_posix.go:55 +0x4f
net.(*conn).Read(0xc000204390, 0xc0005826fc, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/net/net.go:182 +0x8e
io.ReadAtLeast(0xeec7e0, 0xc000204390, 0xc0005826fc, 0x1, 0x1, 0x1, 0xc00055c1f8, 0xc00000eb60, 0xc00000eb60)
/home/liuxiang/go/src/io/io.go:314 +0x87
io.ReadFull(...)
/home/liuxiang/go/src/io/io.go:333
github.com/eclipse/paho.mqtt.golang/packets.ReadPacket(0xeec7e0, 0xc000204390, 0xc000204390, 0xeec7e0, 0xc000204390, 0x0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/packets/packets.go:105 +0x94
github.com/eclipse/paho.mqtt.golang.incoming(0xc00055c1e0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:132 +0x125
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:322 +0x679
goroutine 48 [select]:
github.com/eclipse/paho.mqtt.golang.alllogic(0xc00055c5a0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:240 +0x1f4
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:320 +0x62f
goroutine 49 [select]:
github.com/eclipse/paho.mqtt.golang.outgoing(0xc00055c5a0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:171 +0x23f
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:321 +0x654
goroutine 130 [IO wait]:
internal/poll.runtime_pollWait(0x7fb0d85890d8, 0x72, 0xeedc80)
/home/liuxiang/go/src/runtime/netpoll.go:220 +0x55
internal/poll.(*pollDesc).wait(0xc00009e618, 0x72, 0xc0000c2600, 0x1, 0x1)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:87 +0x45
internal/poll.(*pollDesc).waitRead(...)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:92
internal/poll.(*FD).Read(0xc00009e600, 0xc0000c2698, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/internal/poll/fd_unix.go:159 +0x1b1
net.(*netFD).Read(0xc00009e600, 0xc0000c2698, 0x1, 0x1, 0x0, 0x1, 0x203000)
/home/liuxiang/go/src/net/fd_posix.go:55 +0x4f
net.(*conn).Read(0xc000204398, 0xc0000c2698, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/net/net.go:182 +0x8e
io.ReadAtLeast(0xeec7e0, 0xc000204398, 0xc0000c2698, 0x1, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/io/io.go:314 +0x87
io.ReadFull(...)
/home/liuxiang/go/src/io/io.go:333
github.com/eclipse/paho.mqtt.golang/packets.ReadPacket(0xeec7e0, 0xc000204398, 0xc000204398, 0xeec7e0, 0xc000204398, 0x0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/packets/packets.go:105 +0x94
github.com/eclipse/paho.mqtt.golang.incoming(0xc00055c5a0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:132 +0x125
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:322 +0x679
goroutine 132 [select]:
github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch.func1(0xc000514240, 0xc000314240, 0xc00055c3c0, 0xc000514201)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:145 +0x43d
created by github.com/eclipse/paho.mqtt.golang.(*router).matchAndDispatch
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/router.go:143 +0x5c
goroutine 134 [select]:
github.com/eclipse/paho.mqtt.golang.errorWatch(0xc00055c3c0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:346 +0xf3
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:319 +0x60a
goroutine 135 [select]:
github.com/eclipse/paho.mqtt.golang.alllogic(0xc00055c3c0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:240 +0x1f4
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:320 +0x62f
goroutine 136 [select]:
github.com/eclipse/paho.mqtt.golang.outgoing(0xc00055c3c0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:171 +0x23f
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:321 +0x654
goroutine 137 [IO wait]:
internal/poll.runtime_pollWait(0x7fb0d85891b8, 0x72, 0xeedc80)
/home/liuxiang/go/src/runtime/netpoll.go:220 +0x55
internal/poll.(*pollDesc).wait(0xc00009e218, 0x72, 0xc0000c2600, 0x1, 0x1)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:87 +0x45
internal/poll.(*pollDesc).waitRead(...)
/home/liuxiang/go/src/internal/poll/fd_poll_runtime.go:92
internal/poll.(*FD).Read(0xc00009e200, 0xc0000c269e, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/internal/poll/fd_unix.go:159 +0x1b1
net.(*netFD).Read(0xc00009e200, 0xc0000c269e, 0x1, 0x1, 0x203000, 0x1, 0x203000)
/home/liuxiang/go/src/net/fd_posix.go:55 +0x4f
net.(*conn).Read(0xc0002043a0, 0xc0000c269e, 0x1, 0x1, 0x0, 0x0, 0x0)
/home/liuxiang/go/src/net/net.go:182 +0x8e
io.ReadAtLeast(0xeec7e0, 0xc0002043a0, 0xc0000c269e, 0x1, 0x1, 0x1, 0xc00055c3d8, 0xc000090720, 0xc000090720)
/home/liuxiang/go/src/io/io.go:314 +0x87
io.ReadFull(...)
/home/liuxiang/go/src/io/io.go:333
github.com/eclipse/paho.mqtt.golang/packets.ReadPacket(0xeec7e0, 0xc0002043a0, 0xc0002043a0, 0xeec7e0, 0xc0002043a0, 0x0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/packets/packets.go:105 +0x94
github.com/eclipse/paho.mqtt.golang.incoming(0xc00055c3c0)
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/net.go:132 +0x125
created by github.com/eclipse/paho.mqtt.golang.(*client).Connect.func1
/home/liuxiang/workspace/goproject/pkg/mod/github.com/eclipse/paho.mqtt.golang@v1.2.0/client.go:322 +0x679
Process finished with exit code 2

Can you provide following information?

The detailed rule.
Configuration of etc/kuiper.yaml

Can you provide following information?

The detailed rule.
Configuration of etc/kuiper.yaml

etc/kuiper.yaml
basic:
true|false, with debug level, it prints more debug info
debug: true
true|false, if it's set to true, then the log will be print to console
consoleLog: true
true|false, if it's set to true, then the log will be print to log file
fileLog: true
How many hours to split the file
rotateTime: 24
Maximum file storage hours
maxAge: 72
CLI ip
ip: 0.0.0.0
CLI port
port: 20498
REST service ip
restIp: 0.0.0.0
REST service port
restPort: 9081
restTls:
certfile: /var/https-server.crt
keyfile: /var/https-server.key
Prometheus settings
prometheus: false
prometheusPort: 20499
The URL where hosts all of pre-build plugins. By default it's at packages.emqx.io
There could be several hosts (host can be separated with comma), if same package could be found in the several hosts,
then the package in the 1st host will have the highest priority.
pluginHosts: https://www.emqx.io/downloads
The default options for all rules. Each rule can override this setting by defining its own option
rule:
The qos of the rule. The values can be 0: At most once; 1: At least once; 2: Exactly once
If qos is bigger than 0, the checkpoint mechanism will launch to save states so that they can be
restored for unintended interrupt or planned restart of the rule. The performance may be affected
to enable the checkpoint mechanism
qos: 0
The interval in millisecond to run the checkpoint mechanism.
checkpointInterval: 300000
sink:
The cache persistence threshold size. If the message in sink cache is larger than 10, then it triggers persistence. If you find
the remote system is slow to response, or sink throughput is small, then it's recommend to increase below 2 configurations.
More memory is required with the increase of below 2 configurations.
If the message count reaches below value, then it triggers persistence.
cacheThreshold: 10
The message persistence is triggered by a ticker, and cacheTriggerCount is for using configure the count to trigger the persistence procedure
regardless if the message number reaches cacheThreshold or not. This is to prevent the data won't be saved as the cache never pass the threshold.
cacheTriggerCount: 15
Control to disable cache or not. If it's set to true, then the cache will be disabled, otherwise, it will be enabled.
disableCache: true

etc/kuiper.yaml
basic:
true|false, with debug level, it prints more debug info
debug: true
true|false, if it's set to true, then the log will be print to console
consoleLog: true
true|false, if it's set to true, then the log will be print to log file
fileLog: true
How many hours to split the file
rotateTime: 24
Maximum file storage hours
maxAge: 72
CLI ip
ip: 0.0.0.0
CLI port
port: 20498
REST service ip
restIp: 0.0.0.0
REST service port
restPort: 9081
restTls:
certfile: /var/https-server.crt
keyfile: /var/https-server.key
Prometheus settings
prometheus: false
prometheusPort: 20499
The URL where hosts all of pre-build plugins. By default it's at packages.emqx.io
There could be several hosts (host can be separated with comma), if same package could be found in the several hosts,
then the package in the 1st host will have the highest priority.
pluginHosts: https://www.emqx.io/downloads
The default options for all rules. Each rule can override this setting by defining its own option
rule:
The qos of the rule. The values can be 0: At most once; 1: At least once; 2: Exactly once
If qos is bigger than 0, the checkpoint mechanism will launch to save states so that they can be
restored for unintended interrupt or planned restart of the rule. The performance may be affected
to enable the checkpoint mechanism
qos: 0
The interval in millisecond to run the checkpoint mechanism.
checkpointInterval: 300000
sink:
The cache persistence threshold size. If the message in sink cache is larger than 10, then it triggers persistence. If you find
the remote system is slow to response, or sink throughput is small, then it's recommend to increase below 2 configurations.
More memory is required with the increase of below 2 configurations.
If the message count reaches below value, then it triggers persistence.
cacheThreshold: 10
The message persistence is triggered by a ticker, and cacheTriggerCount is for using configure the count to trigger the persistence procedure
regardless if the message number reaches cacheThreshold or not. This is to prevent the data won't be saved as the cache never pass the threshold.
cacheTriggerCount: 15
Control to disable cache or not. If it's set to true, then the cache will be disabled, otherwise, it will be enabled.
disableCache: true

Can you provide following information?

The detailed rule.
Configuration of etc/kuiper.yaml
First, create stream:
CREATE STREAM   mapper  WITH ( datasource = "topic/temperature", FORMAT = "json" );
The second create rule and action, action is mqtt:
{
"id": "rule1",
"sql": "SELECT collect(*) as r1 FROM mapper"
",
"actions": [{
"mqtt":  {"server":"tcp://192.168.8.9:1833","topic":"device/test"}
}]
}
etc/kuiper.yaml:
`basic:

true|false, with debug level, it prints more debug info
debug: true
true|false, if it's set to true, then the log will be print to console
consoleLog: true
true|false, if it's set to true, then the log will be print to log file
fileLog: true
How many hours to split the file
rotateTime: 24
Maximum file storage hours
maxAge: 72
CLI ip
ip: 0.0.0.0
CLI port
port: 20498
REST service ip
restIp: 0.0.0.0
REST service port
restPort: 9081
restTls:
certfile: /var/https-server.crt
keyfile: /var/https-server.key
Prometheus settings
prometheus: false
prometheusPort: 20499
The URL where hosts all of pre-build plugins. By default it's at packages.emqx.io
There could be several hosts (host can be separated with comma), if same package could be found in the several hosts,
then the package in the 1st host will have the highest priority.
pluginHosts: https://www.emqx.io/downloads
The default options for all rules. Each rule can override this setting by defining its own option
rule:
The qos of the rule. The values can be 0: At most once; 1: At least once; 2: Exactly once
If qos is bigger than 0, the checkpoint mechanism will launch to save states so that they can be
restored for unintended interrupt or planned restart of the rule. The performance may be affected
to enable the checkpoint mechanism
qos: 0
The interval in millisecond to run the checkpoint mechanism.
checkpointInterval: 300000
sink:
The cache persistence threshold size. If the message in sink cache is larger than 10, then it triggers persistence. If you find
the remote system is slow to response, or sink throughput is small, then it's recommend to increase below 2 configurations.
More memory is required with the increase of below 2 configurations.
If the message count reaches below value, then it triggers persistence.
cacheThreshold: 10
The message persistence is triggered by a ticker, and cacheTriggerCount is for using configure the count to trigger the persistence procedure
regardless if the message number reaches cacheThreshold or not. This is to prevent the data won't be saved as the cache never pass the threshold.
cacheTriggerCount: 15
Control to disable cache or not. If it's set to true, then the cache will be disabled, otherwise, it will be enabled.
disableCache: true
`

Can you provide following information?

The detailed rule.
Configuration of etc/kuiper.yaml
First, create stream:
CREATE STREAM   mapper  WITH ( datasource = "topic/temperature", FORMAT = "json" );
The second create rule and action, action is mqtt:
{
"id": "rule1",
"sql": "SELECT collect(*) as r1 FROM mapper"
",
"actions": [{
"mqtt":  {"server":"tcp://192.168.8.9:1833","topic":"device/test"}
}]
}
etc/kuiper.yaml:
`basic:

true|false, with debug level, it prints more debug info
debug: true
true|false, if it's set to true, then the log will be print to console
consoleLog: true
true|false, if it's set to true, then the log will be print to log file
fileLog: true
How many hours to split the file
rotateTime: 24
Maximum file storage hours
maxAge: 72
CLI ip
ip: 0.0.0.0
CLI port
port: 20498
REST service ip
restIp: 0.0.0.0
REST service port
restPort: 9081
restTls:
certfile: /var/https-server.crt
keyfile: /var/https-server.key
Prometheus settings
prometheus: false
prometheusPort: 20499
The URL where hosts all of pre-build plugins. By default it's at packages.emqx.io
There could be several hosts (host can be separated with comma), if same package could be found in the several hosts,
then the package in the 1st host will have the highest priority.
pluginHosts: https://www.emqx.io/downloads
The default options for all rules. Each rule can override this setting by defining its own option
rule:
The qos of the rule. The values can be 0: At most once; 1: At least once; 2: Exactly once
If qos is bigger than 0, the checkpoint mechanism will launch to save states so that they can be
restored for unintended interrupt or planned restart of the rule. The performance may be affected
to enable the checkpoint mechanism
qos: 0
The interval in millisecond to run the checkpoint mechanism.
checkpointInterval: 300000
sink:
The cache persistence threshold size. If the message in sink cache is larger than 10, then it triggers persistence. If you find
the remote system is slow to response, or sink throughput is small, then it's recommend to increase below 2 configurations.
More memory is required with the increase of below 2 configurations.
If the message count reaches below value, then it triggers persistence.
cacheThreshold: 10
The message persistence is triggered by a ticker, and cacheTriggerCount is for using configure the count to trigger the persistence procedure
regardless if the message number reaches cacheThreshold or not. This is to prevent the data won't be saved as the cache never pass the threshold.
cacheTriggerCount: 15
Control to disable cache or not. If it's set to true, then the cache will be disabled, otherwise, it will be enabled.
disableCache: true
`

Can you also provide the log file?

Can you also provide the log file?

Can you also provide the full log file?

stream.log.txt

Can you also provide the full log file?

stream.log.txt

Can you also provide the full log file?

Sorry the log file has been lost

Can you also provide the full log file?

Sorry the log file has been lost

authors: hedengfeng jinfahua ngjaying

repo: emqx/kuiper


text:
add reason to whitelist

I think this fixes the missing Reason problem. I tested it on a clean install and I no longer find the error. Also, I was able to test using the test method, which worked without error.
Fixes #16

Thank you very much, Greg, for this PR!

authors: emxsys zomGreg

repo: emxsys/callattendant


text:
[Android] Fix links for EOLed releases

Those links are not used on the website, but will soon be used in the API (#2062).

Why do we need link: ''? Just to get the changelogTemplate to render correctly?

Why do we need link: ''? Just to get the changelogTemplate to render correctly?

Nope, to indicate there is no changelog for these ones.
I would have used null, but it does not work when it is used in the front (on API side it will be null).

perhaps we should move to link: false to distinguish release cycles where the changelogTemplate should not be used

Unfortunately we cannot without also modifying the template. Currently link: false seems to be ignore and only link: '' disables the link.

I think the best course of action is to support link: nil or link: null (whatever is correct in YAML) before merging this PR. I have the intuition it will be very useful after #2080 is merged.

Yeah, that can be covered in a later PR (template update + link: false). Let's merge this.


text:
[unity] Update changelogTemplate and update/fix latest versions

https://unity3d.com/unity/whats-new/ URLs are now redirected to https://unity.com/releases/editor/whats-new/.
Some latest version were also wrong or outdated.
Also normalized the page (#2124).

LGTM. Merging. The eol date for  2020 (LTS) will need a slight adjustment once the final release comes out. I've tentatively set it to 5th May, based on the last release for now.


text:
Google Kubernetes Engine

I'd thought this would be easy, but damn Google makes this confusing :rage1:
Important considerations:

Users can pick different kinds of clusters (standard v/s autopilot)
autopilot clusters must pick a release channel, but standard clusters can pick a kubernetes minor version
standard clusters not enrolled in a release channel will still get automatic control plane upgrades. You can delay them or limit them by defining maintenance windows, but you can't stop them.
node upgrades are in your control only if you picked a minor version.
Even then, google can decide to upgrade your nodes in select cases (See last link)

Note that there are no EoL dates or active support dates for release channels since they will always be supported. Static releases do have a  "release date" (when the version was made available in static), but I had to remove it to keep it consistent.
Preview: https://deploy-preview-314--endoflife-date.netlify.app/gke
Pages consulted:

https://cloud.google.com/kubernetes-engine/docs/concepts/autopilot-overview
https://cloud.google.com/kubernetes-engine/versioning
https://cloud.google.com/kubernetes-engine/docs/release-notes
https://cloud.google.com/kubernetes-engine/docs/release-notes-nochannel
https://cloud.google.com/anthos/clusters/docs/security-bulletins
https://cloud.google.com/kubernetes-engine/docs/concepts/release-channels
https://cloud.google.com/kubernetes-engine/docs/release-schedule
https://cloud.google.com/kubernetes-engine/upgrades

Automation Notes
Since GKE releases are quite frequent, it is very hard to keep the latest field updated regularly. Hence, I tried to automate it.
GKE has a Get Server Config API which returns the data gke.json.zip
However, the API needs authentication, so I've created a service account with zero permissions. There's 2 new scripts:
_auto/gke.rb
Authenticates to Google APIs, calls the get_server_config API and stores a parsed output in _data/gke.json
_plugins/liquify.rb
Jekyll doesn't permit YAML frontmatter to contain liquid tags. So we keep the latest tag as a liquid string, and then parse it with a liquify filter in the layout file instead.
An option, perhaps down the line would be to move the gke.json file (and corresponding code) to a separate repo, which can perhaps be fetched at build-time instead.

Forgot to rebase against master (icon_slug changed to iconSlug there). Should be good now


text:
Methods are not getting imported into VSCode

Hello Team,
We are trying to use the below extension. Upon successfully connecting to my developer workspace i am able to browse all the BO, BS etc. However i am not able to get any of the methods.
We tried both of the below given option after clicking on almost all BS , BO etc .

Yes
Only Methods Names
We cant see any methods getting imported. Kindly help.
Also we want to integrated this extension along with Co -pilot. Please suggest if both extension can work together to harness generative AI capabilities of co-pilot.

Attaching screenshot.

Hi,
Does the Siebel objects have any server scripts? Because the extension only shows them in that case, methods without servers scripts are not shown.
About co-pilot integration, we have neither tested nor used co-pilot, but you can give it a try.
Regards,
László

authors: ashipanw lbakosendo

repo: endoit/siebelScriptsEditor


text:
On Android Tablet, if screen powers off between rounds, it gets disconnected from session

It's stuck at the end of round screen and won't move on to the next round.

Fixing this required a fun hack: I make the browser think there's a video playing. 💯

After a brief delay, the tablet is eventually able to submit/vote, but when the next leaderboard appears, that player has been dropped from the game.

Tablet isn't able to submit after that point, but can still vote.

I've yet to be able to get a device to disconnect via going to sleep.

Is this fixed?

I cannot reproduce it.

just like 72, I think these are ancient problems that we already fixed, but just to be sure, please check. If we aren't sure, lets move these to QA pipeline to try and reproduce

Should be fixed as of commit 2953101a8264b523298f7dd2afe3828c21fb6ad6. Please confirm.

Unable to reproduce

authors: johnnycrich jpailthorpe mattwbenson

repo: engagementgamelab/emerging-citizens


text:
Test 122.88MSPS on AD9361.

https://www.nuand.com/2023-02-release-122-88mhz-bandwidth/
https://destevez.net/2023/02/running-the-ad9361-at-122-88-msps/
It would probably be better to operate in 1T1R to use the same data clk rate than in 61.44MSPS / 2T2R.

Initial support is in place and seems to be working when in PCie Gen2 X4. More tests will be done in the future to compare it to 61.44MSPS and lower specified supported ranges.


text:
🛑 Dipuravanarentals is down

In 4af7cde, Dipuravanarentals (https://dipuravanarentals.com) was down:

HTTP code: 500
Response time: 547 ms

Resolved: Dipuravanarentals is back up in 9b7e7e6 after 28 minutes.

repo: enlivenonedrive/upptime


text:
Use the base UIBarButtonItem selector for storyboard integration

Instead of replacing the UIBarButtonItem with the embedded UIButton action, modify the class to be truly encapsulated.  This then allows using the Segue generated in the storyboard.  It's a simple modification as shown below:
required init(coder aDecoder: NSCoder) {
super.init(coder: aDecoder)!
let image = self.image
self.button = UIButton(type: .Custom)
if let knownImage = image {
    self.button!.frame = CGRectMake(0.0, 0.0, knownImage.size.width, knownImage.size.height)
} else {
    self.button!.frame = CGRectZero;
}

self.button!.setBackgroundImage(image, forState: UIControlState.Normal)
**self.button!.addTarget(self, action: #selector(UIBadgeBarButtonItem.buttonWasTapped(_:)),
    forControlEvents: UIControlEvents.TouchUpInside)**
    self.customView = button

}
extension UIBadgeBarButtonItem {
internal func buttonWasTapped(sender: UIButton) {
UIApplication.sharedApplication().sendAction(self.action, to: self.target, from: nil, forEvent: nil)
}
}

v3 of the library was just released and adds storyboard support.

authors: enmiller jmiglietta-inc

repo: enmiller/ENMBadgedBarButtonItem-Swift


text:
Make index.html fallback override-able

[ ] Add an indexFallback parameter to options. Can be string, array of strings (check/resolve in order start->end), object (relativeFolderPath -> string) or function (relativeResourcePath -> string)
[ ] Pass it through optionsParser, and return a indexFallbackFunc (relativeResourcePath -> stringArray).
[ ] During existence lookup and fallback (#27), use indexFallbackFunc instead to append the result to the path and look for match.
[ ] Update readme
[ ] Test

Implemented differently

repo: enonic/lib-static


text:
[BUG] Can't connect to LM Studio on https://get.big-agi.com/

Description

I got this error on https://get.big-agi.com/
Can you please take look this?
This problem does not exist when I run the project locally. By the way, i have already enabled CROS. I think it is not a CROS problem.
I have also run debug in broswer, there is no any request to http://localhost:1234 when i click models button.
Device and browser
windows 11, chrome
Screenshots and more
No response
Willingness to Contribute

[ ] 🙋♂ Yes, I would like to contribute a fix.

Yes the issue here (fully expected) is that it is the Backend of Big-AGI that's trying to connect to LM Studio.
When you run locally, the front end and back end are both running on localhost. But when you run that official website the backend is running on Vercel servers, while the frontend is on the browser (localhost).
So then the back end, which is running in some server somewhere will be trying to connect to a port on its own "localhost", and it fails because LM Studio is running on your computer.
Please take a look at https://github.com/enricoros/big-AGI/issues/276#issuecomment-1858591483 for the same issue, with a description and a diagram.

Yes the issue here (fully expected) is that it is the Backend of Big-AGI that's trying to connect to LM Studio.
When you run locally, the front end and back end are both running on localhost. But when you run that official website the backend is running on Vercel servers, while the frontend is on the browser (localhost).
So then the back end, which is running in some server somewhere will be trying to connect to a port on its own "localhost", and it fails because LM Studio is running on your computer.
Please take a look at #276 (comment) for the same issue, with a description and a diagram.

@enricoros Thank you for your help.

Yes the issue here (fully expected) is that it is the Backend of Big-AGI that's trying to connect to LM Studio.
When you run locally, the front end and back end are both running on localhost. But when you run that official website the backend is running on Vercel servers, while the frontend is on the browser (localhost).
So then the back end, which is running in some server somewhere will be trying to connect to a port on its own "localhost", and it fails because LM Studio is running on your computer.
Please take a look at #276 (comment) for the same issue, with a description and a diagram.

@enricoros Thank you for your help.

If you served your lm studio api endpoint publicly via ngrok you might be able to get it to work btw.

authors: PylotLight enricoros rikyotei

repo: enricoros/big-AGI


text:
[BUG] big-agi doesn't show list of model for Ollama provider

Describe the bug
big-agi doesn't show a list of models for Ollama provider.
If I have an ollama model that doesn't contain PARAMETER in Modelfile big-agi will return 500 code for  request /api/trpc-edge/llmOllama.listModels
Here is information that only FROM field is required in Modelfile: https://github.com/jmorganca/ollama/blob/main/docs/modelfile.md#format
so it confirms what in ollama endpoint response /api/show only field modelfile is requered.
To Reproduce
Add ollama model without PARAMETER in Modelifle example
ollama pull g1ibby/deepseek

Check what model doesn't have PARAMETER:
curl http://localhost:11434/api/show -d '{"name": "deepseek:latest"}' | jq .

Trying to get list of ollama models:
curl 'http://localhost:3000/api/trpc-edge/llmOllama.listModels?batch=1&input=%7B%220%22%3A%7B%22json%22%3A%7B%22access%22%3A%7B%22dialect%22%3A%22ollama%22%2C%22ollamaHost%22%3A%22http%3A%2F%2F127.0.0.1%3A11434%22%7D%7D%7D%7D' -H 'User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.15; rv:109.0) Gecko/20100101 Firefox/119.0' -H 'Accept: */*' -H 'Accept-Language: en-US,en;q=0.5' -H 'Accept-Encoding: gzip, deflate, br' -H 'Referer: http://localhost:3000/' -H 'content-type: application/json' -H 'DNT: 1' -H 'Connection: keep-alive' -H 'Sec-Fetch-Dest: empty' -H 'Sec-Fetch-Mode: cors' -H 'Sec-Fetch-Site: same-origin' -H 'Pragma: no-cache' -H 'Cache-Control: no-cache'

it returns 500 code.
Expected behavior

Screenshots / context

Thanks, closed by #240. Added to the Roadmap and 1.6.0 milestone as well.

repo: enricoros/big-agi


text:
How to set path to sbt?

I cant find  sbt Exec box.  According to the docs, I have

Open Preferences in Atom
In Packages, search for ENSIME.
Click Settings.
In the sbt Exec box, enter the path to the sbt command.
For example, enter /usr/local/bin/sbt if there’s where sbt is for you.

I would like to to so. But there is not such thing as  sbt Exec box. Appreciate any suggestions.

Thats so strange. I have open the package settings multiple times. Then "Settings" part at the top appeared finally

repo: ensime/ensime-atom