diff --git a/src/DataStreams/ParallelParsingBlockInputStream.cpp b/src/DataStreams/ParallelParsingBlockInputStream.cpp
index 610a38d80a0c1c3d1497d8bcdd025d480693160b..5b2fddce40b310c6602815937bf1f1f398791170 100644
--- a/src/DataStreams/ParallelParsingBlockInputStream.cpp
+++ b/src/DataStreams/ParallelParsingBlockInputStream.cpp
@@ -63,8 +63,10 @@ void ParallelParsingBlockInputStream::cancel(bool kill)
 
 void ParallelParsingBlockInputStream::scheduleParserThreadForUnitWithNumber(size_t ticket_number)
 {
-    pool.scheduleOrThrowOnError(std::bind(
-        &ParallelParsingBlockInputStream::parserThreadFunction, this, CurrentThread::getGroup(), ticket_number));
+    pool.scheduleOrThrowOnError([this, ticket_number]()
+    {
+        parserThreadFunction(CurrentThread::getGroup(), ticket_number);
+    });
 }
 
 void ParallelParsingBlockInputStream::finishAndWait()