diff --git a/licenses/BSL.txt b/licenses/BSL.txt index c47debedb41c..62ce3187227d 100644 --- a/licenses/BSL.txt +++ b/licenses/BSL.txt @@ -3,7 +3,7 @@ Business Source License 1.1 Parameters Licensor: Cockroach Labs, Inc. -Licensed Work: CockroachDB 23.1 +Licensed Work: CockroachDB 23.2 The Licensed Work is (c) 2023 Cockroach Labs, Inc. Additional Use Grant: You may make use of the Licensed Work, provided that you may not use the Licensed Work for a Database @@ -15,7 +15,7 @@ Additional Use Grant: You may make use of the Licensed Work, provided that Licensed Work by creating tables whose schemas are controlled by such third parties. -Change Date: 2026-04-01 +Change Date: 2026-10-01 Change License: Apache License, Version 2.0 diff --git a/pkg/ccl/serverccl/statusccl/tenant_status_test.go b/pkg/ccl/serverccl/statusccl/tenant_status_test.go index 61a7b7b956d6..1492cb73ec58 100644 --- a/pkg/ccl/serverccl/statusccl/tenant_status_test.go +++ b/pkg/ccl/serverccl/statusccl/tenant_status_test.go @@ -1207,7 +1207,7 @@ func testTxnIDResolutionRPC(ctx context.Context, t *testing.T, helper serverccl. "expected a valid txnID, but %+v is found", result) sqlConn.Exec(t, "COMMIT") - testutils.SucceedsSoon(t, func() error { + testutils.SucceedsWithin(t, func() error { resp, err := status.TxnIDResolution(ctx, &serverpb.TxnIDResolutionRequest{ CoordinatorID: strconv.Itoa(int(coordinatorNodeID)), TxnIDs: []uuid.UUID{txnID}, @@ -1220,9 +1220,15 @@ func testTxnIDResolutionRPC(ctx context.Context, t *testing.T, helper serverccl. require.Equal(t, txnID, resp.ResolvedTxnIDs[0].TxnID, "expected to find txn %s on coordinator node %d, but it "+ "was not", txnID.String(), coordinatorNodeID) - require.NotEqual(t, appstatspb.InvalidTransactionFingerprintID, resp.ResolvedTxnIDs[0].TxnFingerprintID) + + // It's possible that adding the transaction id to the cache and + // updating the transaction id with a valid fingerprint are done in + // 2 separate batches. This allows retries to wait for a valid fingerprint + if appstatspb.InvalidTransactionFingerprintID == resp.ResolvedTxnIDs[0].TxnFingerprintID { + return fmt.Errorf("transaction fingerprint id not updated yet. TxnFingerprintID: %d", resp.ResolvedTxnIDs[0].TxnFingerprintID) + } return nil - }) + }, 1*time.Minute) } t.Run("regular_cluster", func(t *testing.T) {