This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 554f07f7205 Fix openGauss replication privilege in nightly E2E (#37824)
554f07f7205 is described below
commit 554f07f72054ff7bc313bd391d6774ad0c33bc9f
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Fri Jan 23 19:33:10 2026 +0800
Fix openGauss replication privilege in nightly E2E (#37824)
* Add test_user replication privilege in pg_hba.conf for openGauss docker
conf
* Comment CDCE2EIT TimeZone.setDefault
* Update dead link in CDC usage doc
---
.../document/content/user-manual/shardingsphere-proxy/cdc/usage.cn.md | 2 +-
.../document/content/user-manual/shardingsphere-proxy/cdc/usage.en.md | 2 +-
.../env/src/test/resources/container/opengauss/cnf/pg_hba.conf.sample | 2 ++
.../test/e2e/operation/pipeline/cases/cdc/CDCE2EIT.java | 4 ++--
4 files changed, 6 insertions(+), 4 deletions(-)
diff --git
a/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.cn.md
b/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.cn.md
index 80bc4db2552..b7c1280ed76 100644
--- a/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.cn.md
+++ b/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.cn.md
@@ -203,7 +203,7 @@ public final class Bootstrap {
> CDCClient.await 是阻塞主线程，非必需的步骤，用其他方式也可以，只要保证 CDC 线程一直在工作就行。
-如果需要更复杂数据消费的实现，例如写入到数据库，可以参考
[DataSourceRecordConsumer](https://github.com/apache/shardingsphere/blob/master/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/cdc/DataSourceRecordConsumer.java)
+如果需要更复杂数据消费的实现，例如写入到数据库，可以参考 `DataSourceRecordConsumer.java`。
#### 写入数据
diff --git
a/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.en.md
b/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.en.md
index 42c8eb76121..e0100136246 100644
--- a/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.en.md
+++ b/docs/document/content/user-manual/shardingsphere-proxy/cdc/usage.en.md
@@ -203,7 +203,7 @@ There are mainly 4 steps
> CDCClient.await is to block the main thread, it is not a necessary step,
> other methods can also be used, as long as the CDC thread is always working.
-If you need more complex data consumption implementation, such as writing to
the database, you can refer to
[DataSourceRecordConsumer](https://github.com/apache/shardingsphere/blob/master/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/data/pipeline/cases/cdc/DataSourceRecordConsumer.java)
+If you need more complex data consumption implementation, such as writing to
the database, you can refer to `DataSourceRecordConsumer.java`.
#### Write Data
diff --git
a/test/e2e/env/src/test/resources/container/opengauss/cnf/pg_hba.conf.sample
b/test/e2e/env/src/test/resources/container/opengauss/cnf/pg_hba.conf.sample
index 851b615ae14..c02528e3610 100644
--- a/test/e2e/env/src/test/resources/container/opengauss/cnf/pg_hba.conf.sample
+++ b/test/e2e/env/src/test/resources/container/opengauss/cnf/pg_hba.conf.sample
@@ -29,3 +29,5 @@ host all all ::1/128
@authmethodhost@
#local replication @default_username@
@authmethodlocal@
#host replication @default_username@ 127.0.0.1/32
@authmethodhost@
#host replication @default_username@ ::1/128
@authmethodhost@
+
+host replication test_user 0.0.0.0/0 md5
diff --git
a/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/operation/pipeline/cases/cdc/CDCE2EIT.java
b/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/operation/pipeline/cases/cdc/CDCE2EIT.java
index ee280ce29d9..346f1600cd5 100644
---
a/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/operation/pipeline/cases/cdc/CDCE2EIT.java
+++
b/test/e2e/operation/pipeline/src/test/java/org/apache/shardingsphere/test/e2e/operation/pipeline/cases/cdc/CDCE2EIT.java
@@ -69,7 +69,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
-import java.util.TimeZone;
import java.util.concurrent.TimeUnit;
import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -97,7 +96,8 @@ class CDCE2EIT {
@EnabledIf("isEnabled")
@ArgumentsSource(PipelineE2ETestCaseArgumentsProvider.class)
void assertCDCDataImportSuccess(final PipelineTestParameter testParam)
throws SQLException {
- TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
+ // If run on NATIVE mode and database timezone is UTC, then: 1) set
`e2e.timezone=UTC` in e2e-env.properties, 2) add this line of code in proxy
Bootstrap main method.
+ // TimeZone.setDefault(TimeZone.getTimeZone("UTC"));
try (PipelineContainerComposer containerComposer = new
PipelineContainerComposer(testParam)) {
PipelineE2EDistSQLFacade distSQLFacade = new
PipelineE2EDistSQLFacade(containerComposer, new CDCJobType());
distSQLFacade.alterPipelineRule();
