hunshenshi

各位大佬： 使用ES作为存储时，是否支持row_number之类的窗口函数？

k8s 环境下使用fluentd采集log，pod中容器重启之后是不是容易造成日志重复采集

4

fluentd关于容器log的pos是记录在`pos_file /pilot/pos/{{ $.containerId }}.{{ .Name }}.pos`这里，但是在pod中容器重启之后log所在的目录不会变，容器id发生了变化，所以pos也就发生了变化，fluentd就会对重启之后的log进行重采集，造成log采集重复，有没有遇到这种情况，反正我遇到了

When sink.directory does not exits，will report an error，flume will exit. I think the sink.directory should be created by flume, if it dose not exits. So I fixed.

When the archive file is in compressed format, if a empty file be renamed, mr will report an error when reading the file. eg: a1.sinks.k1.hdfs.codeC = lzop

Hope [RxGo常用算子手册](https://yuanba.tech/rxgo-examples.html) and [rxgo-examples](https://github.com/hunshenshi/rxgo-examples) can help guy.

feat(api): get method return msg

1

# Description Please include a summary of the changes and the related issue. Please also include relevant motivation and context. List any dependencies that are required for this change. Fixes...

poc(risc0): add http api for risc0 vm server

2

http api : `http --form post :8888/srv-applet-mgr/v0/xvm/x/$PROJECTNAME file@/xx/github/risc0/examples/target/debug/build/factors-methods-301d94e8fa023ff7/out/methods.rs info='{"imageId":"MULTIPLY_ID","elf":"MULTIPLY_ELF","params":["17", "23"]}' -A bearer -a $TOK`

[feat]ratelimit

34

1. qps ratelimit 2. traffic ratelimit for each project

example code: ``` golang // rxgo.Just(2, 5, 1, 6, 3, 4)().Min(min) func min(i1 interface{}, i2 interface{}) int { // 1.Serialize a := i1.(models.Customer) b := i2.(models.Customer) // 2.Invoke wasm code...