Skip to content

Commit d54e685

Browse files
committed
Pass chunk directly instead of chunk.metadata
Signed-off-by: Hiroshi Hatake <[email protected]>
1 parent ed7c675 commit d54e685

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/fluent/plugin/out_mongo.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -172,8 +172,8 @@ def multi_workers_ready?
172172
end
173173

174174
def write(chunk)
175-
collection_name = extract_placeholders(@collection, chunk.metadata)
176-
database_name = extract_placeholders(@database, chunk.metadata)
175+
collection_name = extract_placeholders(@collection, chunk)
176+
database_name = extract_placeholders(@database, chunk)
177177
operate(database_name, format_collection_name(collection_name), collect_records(chunk))
178178
end
179179

0 commit comments

Comments
 (0)