fix type

risingwavelabs · Mar 17, 2023 · c627260 · c627260
1 parent b050232
commit c627260
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/java/connector-node/python-client/integration_tests.py b/java/connector-node/python-client/integration_tests.py
@@ -245,7 +245,7 @@ def test_deltalake_sink(input_file):
     parser.add_argument('--upsert_iceberg_sink', action='store_true', help="run upsert iceberg sink test")
     parser.add_argument('--deltalake_sink', action='store_true', help="run deltalake sink test")
     parser.add_argument('--input_file', default="./data/sink_input.json", help="input data to run tests")
-    parser.add_argument('--input_bianry_file', default="./data/stream_chunk_data", help="input stream chunk data to run tests")
+    parser.add_argument('--input_binary_file', default="./data/stream_chunk_data", help="input stream chunk data to run tests")
     args = parser.parse_args()
     if args.file_sink:
         test_file_sink(args.input_file)
@@ -254,7 +254,7 @@ def test_deltalake_sink(input_file):
     if args.print_sink:
         test_print_sink(args.input_file)
     if args.print_stream_chunk_sink:
-        test_print_stream_chunk_sink(args.input_bianry_file)
+        test_print_stream_chunk_sink(args.input_binary_file)
     if args.iceberg_sink:
         test_iceberg_sink(args.input_file)
     if args.upsert_iceberg_sink: