diff --git a/test/command/test_fluentd.rb b/test/command/test_fluentd.rb
index 78d63856c8..d812a0a791 100644
--- a/test/command/test_fluentd.rb
+++ b/test/command/test_fluentd.rb
@@ -1400,7 +1400,7 @@ def conf(udp_port, tcp_port, syslog_port)
     def run_fluentd(config)
       conf_path = create_conf_file("test.conf", config)
       assert File.exist?(conf_path)
-      cmdline = create_cmdline(conf_path, "-vv")
+      cmdline = create_cmdline(conf_path)
 
       stdio_buf = ""
       execute_command(cmdline) do |pid, stdout|
@@ -1464,7 +1464,7 @@ def send_end(port)
     end
 
     test "should restart with zero downtime (no data loss)" do
-      print_logs = true # set true if you need to print logs for debug
+      print_logs = false # set true if you need to print logs for debug
 
       udp_port, syslog_port = unused_port(2, protocol: :udp)
       tcp_port = unused_port(protocol: :tcp)
@@ -1519,23 +1519,23 @@ def send_end(port)
         end
       end
 
-      assert_equal(
-        [500, 500, 500],
-        [
-          records_by_type["udp"].size,
-          records_by_type["tcp"].size,
-          records_by_type["syslog"].size,
-        ]
-      )
-
       # assert_equal(
-      #   [(0..499).to_a, (0..499).to_a, (0..499).to_a],
+      #   [500, 500, 500],
       #   [
-      #     records_by_type["udp"].sort,
-      #     records_by_type["tcp"].sort,
-      #     records_by_type["syslog"].sort,
+      #     records_by_type["udp"].size,
+      #     records_by_type["tcp"].size,
+      #     records_by_type["syslog"].size,
       #   ]
       # )
+
+      assert_equal(
+        [(0..499).to_a, (0..499).to_a, (0..499).to_a],
+        [
+          records_by_type["udp"].sort,
+          records_by_type["tcp"].sort,
+          records_by_type["syslog"].sort,
+        ]
+      )
     ensure
       threads.each(&:kill)
     end