You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jan 30, 2021. It is now read-only.
Problem in mutate() function when you don't using mutations:
def mutate( src )
res = {}
@mutations.each_pair do |dstkey, source|
case source
when String then
scrkey = source
next unless src.key?(scrkey)
res[dstkey] = src[scrkey]
when Array then
scrkey = source[0]
next unless src.key?(scrkey)
pattern = source[1]
replace = source[2]
res[dstkey] = src[scrkey].sub( Regexp.new(pattern), replace )
end
end
res
end
I fixed it by adding line:
--- clickhouse.rb.old 2019-11-29 14:14:08.206871867 +0300
+++ clickhouse.rb 2019-11-29 14:12:30.039874141 +0300
@@ -127,6 +127,7 @@
end
def mutate( src )
+ return src if @mutations.empty?
res = {}
@mutations.each_pair do |dstkey, source|
case source
Using logstash 7.4, output plugin sends an empty json doc only to clickhouse.
The text was updated successfully, but these errors were encountered: