diff --git a/include/pika_define.h b/include/pika_define.h
index dcc99b14eb..91874fc3ec 100644
--- a/include/pika_define.h
+++ b/include/pika_define.h
@@ -32,7 +32,7 @@
 class PikaServer;
 /* Global Const */
 constexpr int MAX_DB_NUM = 8;
-constexpr int FWRITE_USER_SPACE_BUF_SIZE = 4 << 10;//4KB
+constexpr int FWRITE_USER_SPACE_BUF_SIZE = 512LL << 10;//512KB
 
 /* Port shift */
 const int kPortShiftRSync = 1000;
diff --git a/src/pika_binlog.cc b/src/pika_binlog.cc
index 9cc01b3730..5af3ddb64e 100644
--- a/src/pika_binlog.cc
+++ b/src/pika_binlog.cc
@@ -277,9 +277,9 @@ Status Binlog::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n, int*
   s = queue_->Append(pstd::Slice(buf, kHeaderSize));
   if (s.ok()) {
     s = queue_->Append(pstd::Slice(ptr, n));
-    if (s.ok()) {
-      s = queue_->Flush();
-    }
+//    if (s.ok()) {
+//      s = queue_->Flush();
+//    }
   }
   block_offset_ += static_cast<int32_t>(kHeaderSize + n);