Skip to content

Commit 3bba342

Browse files
committed
add config for TISPBReporterFactory
1 parent 1c572dd commit 3bba342

4 files changed

Lines changed: 13 additions & 13 deletions

File tree

tis-incr/tis-flink-cdc-common/pom.xml

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -52,11 +52,16 @@
5252
<!-- <version>${flink.cdc.version}</version>-->
5353
<!-- </dependency>-->
5454

55+
<!-- <dependency>-->
56+
<!-- <groupId>org.apache.flink</groupId>-->
57+
<!-- <artifactId>flink-core</artifactId>-->
58+
<!-- <version>${flink.version}</version>-->
59+
<!-- <scope>provided</scope>-->
60+
<!-- </dependency>-->
61+
5562
<dependency>
56-
<groupId>org.apache.flink</groupId>
57-
<artifactId>flink-core</artifactId>
58-
<version>${flink.version}</version>
59-
<scope>provided</scope>
63+
<groupId>com.qlangtech.tis.plugins</groupId>
64+
<artifactId>tis-flink-dependency</artifactId>
6065
</dependency>
6166

6267
<!-- <dependency>-->

tis-incr/tis-flink-dependency/pom.xml

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -72,14 +72,12 @@
7272
<version>${flink.version}</version>
7373
<!-- <scope>provided</scope>-->
7474
</dependency>
75-
7675
<dependency>
7776
<groupId>org.apache.flink</groupId>
78-
<!--NEED TO FIX-->
7977
<artifactId>flink-core</artifactId>
8078
<version>${flink.version}</version>
81-
<!-- <scope>provided</scope>-->
8279
</dependency>
80+
8381
<dependency>
8482
<groupId>org.apache.flink</groupId>
8583
<artifactId>flink-streaming-java</artifactId>
@@ -101,11 +99,7 @@
10199

102100

103101

104-
<dependency>
105-
<groupId>org.apache.flink</groupId>
106-
<artifactId>flink-core</artifactId>
107-
<version>${flink.version}</version>
108-
</dependency>
102+
109103

110104
<dependency>
111105
<groupId>org.apache.flink</groupId>

tis-incr/tis-flink-extends/src/main/java/com/qlangtech/plugins/incr/flink/metrics/TISPBReporterFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525

2626
/**
2727
* TIS通过 grpc 协议将flink metric 信息反馈给TIS节点汇总
28-
*
28+
* https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/deployment/config/#metrics-reporter-%3Cname%3E-factory-class
2929
* @author: 百岁(baisui@qlangtech.com)
3030
* @create: 2025-05-14 10:22
3131
**/
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
com.qlangtech.plugins.incr.flink.metrics.TISPBReporterFactory

0 commit comments

Comments
 (0)