Skip to content

Commit

Permalink
temp test
Browse files Browse the repository at this point in the history
  • Loading branch information
masteryhx committed Apr 1, 2024
1 parent 52e3f01 commit 6ed3187
Showing 1 changed file with 14 additions and 14 deletions.
28 changes: 14 additions & 14 deletions env/flink/env_flink_test_suite.cc
Original file line number Diff line number Diff line change
Expand Up @@ -119,20 +119,20 @@ void EnvFlinkTestSuites::testGetChildren() {
}

void EnvFlinkTestSuites::testFileReadAndWrite() {
// const std::string file_name = "test-file";
// const std::string content1 = "Hello World", content2 = ", Hello ForSt",
// content = content1 + content2;
//
// std::unique_ptr<WritableFile> write_result;
// ASSERT_TRUE(
// flink_env_->NewWritableFile(file_name, &write_result,
// EnvOptions()).ok());
// write_result->Append(content1);
// write_result->Append(content2);
// write_result->Sync();
// write_result->Flush();
// write_result->Close();
//
const std::string file_name = "test-file";
const std::string content1 = "Hello World", content2 = ", Hello ForSt",
content = content1 + content2;

std::unique_ptr<WritableFile> write_result;
ASSERT_TRUE(
flink_env_->NewWritableFile(file_name, &write_result,
EnvOptions()).ok());
write_result->Append(content1);
write_result->Append(content2);
write_result->Sync();
write_result->Flush();
write_result->Close();

// std::unique_ptr<SequentialFile> sequential_result;
// ASSERT_TRUE(
// flink_env_->NewSequentialFile(file_name, &sequential_result,
Expand Down

0 comments on commit 6ed3187

Please sign in to comment.