Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

sink(ticdc): limit the number of transactions cached in a mysql worker #10892

Merged
merged 10 commits into from
Apr 22, 2024

address comments

4d8fef9
Select commit
Loading
Failed to load commit list.
Merged

sink(ticdc): limit the number of transactions cached in a mysql worker #10892

address comments
4d8fef9
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Apr 22, 2024 in 1s

63.6363% of diff hit (target 0.0000%)

View this Pull Request on Codecov

63.6363% of diff hit (target 0.0000%)

Annotations

Check warning on line 109 in cdc/sink/dmlsink/txn/worker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/dmlsink/txn/worker.go#L108-L109

Added lines #L108 - L109 were not covered by tests

Check warning on line 148 in cdc/sink/dmlsink/txn/worker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/dmlsink/txn/worker.go#L148

Added line #L148 was not covered by tests

Check warning on line 150 in cdc/sink/dmlsink/txn/worker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

cdc/sink/dmlsink/txn/worker.go#L150

Added line #L150 was not covered by tests

Check warning on line 63 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L53-L63

Added lines #L53 - L63 were not covered by tests

Check warning on line 79 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L79

Added line #L79 was not covered by tests

Check warning on line 84 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L81-L84

Added lines #L81 - L84 were not covered by tests

Check warning on line 93 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L92-L93

Added lines #L92 - L93 were not covered by tests

Check warning on line 97 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L95-L97

Added lines #L95 - L97 were not covered by tests

Check warning on line 99 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L99

Added line #L99 was not covered by tests

Check warning on line 101 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L101

Added line #L101 was not covered by tests

Check warning on line 105 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L105

Added line #L105 was not covered by tests

Check warning on line 110 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L110

Added line #L110 was not covered by tests

Check warning on line 125 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L123-L125

Added lines #L123 - L125 were not covered by tests

Check warning on line 135 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L132-L135

Added lines #L132 - L135 were not covered by tests

Check warning on line 142 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L139-L142

Added lines #L139 - L142 were not covered by tests

Check warning on line 149 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L147-L149

Added lines #L147 - L149 were not covered by tests

Check warning on line 151 in pkg/causality/conflict_detector.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/conflict_detector.go#L151

Added line #L151 was not covered by tests

Check warning on line 156 in pkg/causality/internal/node.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/internal/node.go#L156

Added line #L156 was not covered by tests

Check warning on line 234 in pkg/causality/internal/node.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/internal/node.go#L230-L234

Added lines #L230 - L234 were not covered by tests

Check warning on line 254 in pkg/causality/internal/node.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/internal/node.go#L254

Added line #L254 was not covered by tests

Check warning on line 265 in pkg/causality/internal/node.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/internal/node.go#L264-L265

Added lines #L264 - L265 were not covered by tests

Check warning on line 277 in pkg/causality/internal/node.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/internal/node.go#L276-L277

Added lines #L276 - L277 were not covered by tests

Check warning on line 69 in pkg/causality/txn_cache.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/txn_cache.go#L68-L69

Added lines #L68 - L69 were not covered by tests

Check warning on line 77 in pkg/causality/txn_cache.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/txn_cache.go#L76-L77

Added lines #L76 - L77 were not covered by tests

Check warning on line 115 in pkg/causality/txn_cache.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/causality/txn_cache.go#L114-L115

Added lines #L114 - L115 were not covered by tests