test: [DNM] Test test task manager entry size

pkg/disttask/framework/storage/table_test.go

@@ -17,6 +17,7 @@ package storage_test
 import (
 	"context"
 	"fmt"
+	"runtime"
 	"slices"
 	"sort"
 	"testing"
@@ -31,6 +32,7 @@ import (
 	"github.com/pingcap/tidb/pkg/sessionctx/vardef"
 	"github.com/pingcap/tidb/pkg/testkit"
 	"github.com/pingcap/tidb/pkg/testkit/testfailpoint"
+	tidbutil "github.com/pingcap/tidb/pkg/util"
 	"github.com/pingcap/tidb/pkg/util/sqlexec"
 	"github.com/stretchr/testify/require"
 	"github.com/tikv/client-go/v2/util"
@@ -1190,6 +1192,24 @@ func TestGetActiveTaskExecInfo(t *testing.T) {
 }
 
 func TestTaskManagerEntrySize(t *testing.T) {
+	//	t.Skip(`this case is used to verify that the global TxnEntrySizeLimit is used in DXF,
+	//it success in local test, and success in CI in most cases, but it times out sometimes,
+	//one guess is it's related to the uni-store storage badger,
+	//to avoid block CI, skip it, as we have already verified it works`)
+	var wg tidbutil.WaitGroupWrapper
+	bgCtx, cancelFunc := context.WithCancel(context.Background())
+	wg.Run(func() {
+		for {
+			select {
+			case <-bgCtx.Done():
+				return
+			case <-time.After(10 * time.Second):
+			}
+			buf := make([]byte, 8<<20)
+			stackLen := runtime.Stack(buf, true)
+			t.Logf("\n\n\n\n=== dump goroutine stack. ===\n%s\n\n\n", string(buf[:stackLen]))
+		}
+	})
 	store, tm, ctx := testutil.InitTableTest(t)
 	getMeta := func(l int) []byte {
 		meta := make([]byte, l)
@@ -1214,4 +1234,6 @@ func TestTaskManagerEntrySize(t *testing.T) {
 	require.NoError(t, insertSubtask(meta6m))
 	// TiKV also have a limit raftstore.raft-entry-max-size which is 8M by default,
 	// we won't test that param here
+	cancelFunc()
+	wg.Wait()
 }