Skip to content

Commit ff5f220

Browse files
craig[bot]Lidor Carmelyuzefovich
committed
106310: streamingest: unskip a multi-node c2c test, and skip under deadlock r=lidorcarmel a=lidorcarmel These tests are slow and flaky under deadlock. Epic: none Fixes: cockroachdb#105956 Fixes: cockroachdb#99900 Release note: None 106765: rfcs: rename the filename to adhere to the pattern r=yuzefovich a=yuzefovich Recently merged RFC on query SST metrics was missing the prepended date in the filename. Epic: None. Release note: None Co-authored-by: Lidor Carmel <[email protected]> Co-authored-by: Yahor Yuzefovich <[email protected]>
3 parents 907479d + 8f009ec + 9dd9a3f commit ff5f220

File tree

2 files changed

+7
-6
lines changed

2 files changed

+7
-6
lines changed
File renamed without changes.

pkg/ccl/streamingccl/streamingest/replication_stream_e2e_test.go

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -462,8 +462,8 @@ func TestTenantStreamingDropTenantCancelsStream(t *testing.T) {
462462
func TestTenantStreamingUnavailableStreamAddress(t *testing.T) {
463463
defer leaktest.AfterTest(t)()
464464
defer log.Scope(t).Close(t)
465-
skip.WithIssue(t, 105956)
466465

466+
skip.UnderDeadlock(t, "multi-node may time out under deadlock")
467467
skip.UnderRace(t, "takes too long with multiple nodes")
468468

469469
ctx := context.Background()
@@ -510,11 +510,6 @@ func TestTenantStreamingUnavailableStreamAddress(t *testing.T) {
510510
defer alternateSrcTenantConn.Close()
511511
alternateSrcTenantSQL := sqlutils.MakeSQLRunner(alternateSrcTenantConn)
512512

513-
cleanUpTenant := c.StartDestTenant(ctx)
514-
defer func() {
515-
require.NoError(t, cleanUpTenant())
516-
}()
517-
518513
alternateCompareResult := func(query string) {
519514
sourceData := alternateSrcTenantSQL.QueryStr(c.T, query)
520515
destData := c.DestTenantSQL.QueryStr(c.T, query)
@@ -537,6 +532,11 @@ func TestTenantStreamingUnavailableStreamAddress(t *testing.T) {
537532
require.Equal(c.T, cutoverTime, cutoverOutput.GoTime())
538533
jobutils.WaitForJobToSucceed(c.T, c.DestSysSQL, jobspb.JobID(ingestionJobID))
539534

535+
cleanUpTenant := c.StartDestTenant(ctx)
536+
defer func() {
537+
require.NoError(t, cleanUpTenant())
538+
}()
539+
540540
// The destroyed address should have been removed from the topology
541541
progress = jobutils.GetJobProgress(c.T, c.DestSysSQL, jobspb.JobID(ingestionJobID))
542542
newStreamAddresses := progress.GetStreamIngest().StreamAddresses
@@ -652,6 +652,7 @@ func TestTenantStreamingMultipleNodes(t *testing.T) {
652652
defer leaktest.AfterTest(t)()
653653
defer log.Scope(t).Close(t)
654654

655+
skip.UnderDeadlock(t, "multi-node may time out under deadlock")
655656
skip.UnderRace(t, "takes too long with multiple nodes")
656657

657658
ctx := context.Background()

0 commit comments

Comments
 (0)