Skip to content

Commit 24faad9

Browse files
committed
Fixed unit test
1 parent 7e2bfb9 commit 24faad9

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

ydb/core/kqp/ut/federated_query/common/common.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,10 +110,11 @@ namespace NKikimr::NKqp::NFederatedQueryTest {
110110
nullptr,
111111
driver);
112112

113+
const auto& kqpSettings = appConfig->GetKQPConfig().GetSettings();
113114
settings
114115
.SetFeatureFlags(featureFlags)
115116
.SetFederatedQuerySetupFactory(federatedQuerySetupFactory)
116-
.SetKqpSettings({})
117+
.SetKqpSettings({kqpSettings.begin(), kqpSettings.end()})
117118
.SetS3ActorsFactory(std::move(s3ActorsFactory))
118119
.SetWithSampleTables(false)
119120
.SetDomainRoot(options.DomainRoot)

ydb/core/kqp/ut/federated_query/datastreams/datastreams_ut.cpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1487,6 +1487,11 @@ Y_UNIT_TEST_SUITE(KqpStreamingQueriesDdl) {
14871487
}
14881488

14891489
Y_UNIT_TEST_F(StreamingQueryWithS3Join, TStreamingTestFixture) {
1490+
// Test that defaults are overridden for streaming queries
1491+
auto& setting = *SetupAppConfig().MutableKQPConfig()->AddSettings();
1492+
setting.SetName("HashJoinMode");
1493+
setting.SetValue("grace");
1494+
14901495
const auto pqGateway = SetupMockPqGateway();
14911496

14921497
constexpr char sourceBucket[] = "test_streaming_query_with_s3_join";

0 commit comments

Comments
 (0)