(arrow) branch main updated: GH-39326: [C++] Flaky DatasetWriterTestFixture.MaxRowsOneWriteBackpresure test (#39379)

[maplefu]

This is an automated email from the ASF dual-hosted git repository.

maplefu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow.git


The following commit(s) were added to refs/heads/main by this push:
     new 7c3480e2f0 GH-39326: [C++] Flaky 
DatasetWriterTestFixture.MaxRowsOneWriteBackpresure test (#39379)
7c3480e2f0 is described below

commit 7c3480e2f028f5881242f227f42155cf833efee7
Author: mwish <maplewish...@gmail.com>
AuthorDate: Fri Dec 29 10:58:12 2023 +0800

    GH-39326: [C++] Flaky DatasetWriterTestFixture.MaxRowsOneWriteBackpresure 
test (#39379)
    
    
    
    ### Rationale for this change
    
    This patch reduce the number of open files in testing first. I've verify 
the test in 14.0.2, it hangs forever.
    
    ### What changes are included in this PR?
    
    Change the test file number from 100 to 20
    
    ### Are these changes tested?
    
    Already
    
    ### Are there any user-facing changes?
    
    no
    
    * Closes: #39326
    
    Authored-by: mwish <maplewish...@gmail.com>
    Signed-off-by: mwish <maplewish...@gmail.com>
---
 cpp/src/arrow/dataset/dataset_writer_test.cc | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/cpp/src/arrow/dataset/dataset_writer_test.cc 
b/cpp/src/arrow/dataset/dataset_writer_test.cc
index e62e779f71..1ac0ec3f39 100644
--- a/cpp/src/arrow/dataset/dataset_writer_test.cc
+++ b/cpp/src/arrow/dataset/dataset_writer_test.cc
@@ -290,12 +290,12 @@ TEST_F(DatasetWriterTestFixture, 
MaxRowsOneWriteBackpresure) {
   write_options_.max_open_files = 2;
   write_options_.min_rows_per_group = kFileSizeLimit - 1;
   auto dataset_writer = MakeDatasetWriter(/*max_rows=*/kFileSizeLimit);
-  for (int i = 0; i < 20; ++i) {
-    dataset_writer->WriteRecordBatch(MakeBatch(kFileSizeLimit * 5), "");
+  for (int i = 0; i < 5; ++i) {
+    dataset_writer->WriteRecordBatch(MakeBatch(kFileSizeLimit * 2), "");
   }
   EndWriterChecked(dataset_writer.get());
   std::vector<ExpectedFile> expected_files;
-  for (int i = 0; i < 100; ++i) {
+  for (int i = 0; i < 10; ++i) {
     expected_files.emplace_back("testdir/chunk-" + std::to_string(i) + 
".arrow",
                                 kFileSizeLimit * i, kFileSizeLimit);
   }