Skip to content

Commit 93d0d93

Browse files
jeff-zoujeff-zou
committed
2 parents 73ec002 + b9818c9 commit 93d0d93

File tree

7 files changed

+147
-4
lines changed

7 files changed

+147
-4
lines changed

‎.github/workflows/build-redis-connector.yml

Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
# http://www.apache.org/licenses/LICENSE-2.0
10+
#
11+
# Unless required by applicable law or agreed to in writing,
12+
# software distributed under the License is distributed on an
13+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14+
# KIND, either express or implied. See the License for the
15+
# specific language governing permissions and limitations
16+
# under the License.
17+
#
18+
---
19+
name: Build Redis Connector
20+
on:
21+
pull_request:
22+
push:
23+
24+
jobs:
25+
build-extension:
26+
name: "Build Connector"
27+
runs-on: ubuntu-latest
28+
defaults:
29+
run:
30+
shell: bash
31+
steps:
32+
- name: Checkout
33+
uses: actions/checkout@master
34+
35+
- name: Setup java
36+
uses: actions/setup-java@v2
37+
with:
38+
distribution: adopt
39+
java-version: '8'
40+
41+
- name: Build flink connector 1.15
42+
run: |
43+
mvn clean package -DskipTests \
44+
-Dflink.version=1.15.0

‎.github/workflows/checkstyle.yaml

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
# http://www.apache.org/licenses/LICENSE-2.0
10+
#
11+
# Unless required by applicable law or agreed to in writing,
12+
# software distributed under the License is distributed on an
13+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14+
# KIND, either express or implied. See the License for the
15+
# specific language governing permissions and limitations
16+
# under the License.
17+
#
18+
---
19+
name: Code Style Checker
20+
21+
on:
22+
pull_request:
23+
push:
24+
branches:
25+
- dev
26+
27+
jobs:
28+
java-checkstyle:
29+
name: "CheckStyle"
30+
runs-on: ubuntu-24.04
31+
steps:
32+
- name: Checkout
33+
uses: actions/checkout@v3
34+
with:
35+
persist-credentials: false
36+
submodules: recursive
37+
38+
- name: Setup java
39+
uses: actions/setup-java@v2
40+
with:
41+
distribution: adopt
42+
java-version: '8'
43+
44+
- name: Run java checkstyle
45+
run:
46+
mvn clean compile checkstyle:checkstyle

‎.github/workflows/license-eyes.yml

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
#
2+
#Licensed to the Apache Software Foundation (ASF) under one
3+
# or more contributor license agreements. See the NOTICE file
4+
# distributed with this work for additional information
5+
# regarding copyright ownership. The ASF licenses this file
6+
# to you under the Apache License, Version 2.0 (the
7+
# "License"); you may not use this file except in compliance
8+
# with the License. You may obtain a copy of the License at
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
# Unless required by applicable law or agreed to in writing,
13+
# software distributed under the License is distributed on an
14+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15+
# KIND, either express or implied. See the License for the
16+
# specific language governing permissions and limitations
17+
# under the License.
18+
#
19+
---
20+
name: License Check
21+
on:
22+
pull_request:
23+
push:
24+
branches:
25+
- dev
26+
jobs:
27+
license-check:
28+
name: "License Check"
29+
runs-on: ubuntu-24.04
30+
steps:
31+
- name: "Checkout ${{ github.ref }} ( ${{ github.sha }} )"
32+
uses: actions/checkout@v2
33+
- name: Check License
34+
uses: apache/skywalking-eyes@v0.2.0
35+
env:
36+
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

‎src/test/java/org/apache/flink/streaming/connectors/redis/table/SQLExpireTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public void testSinkValueWithExpire() throws Exception {
4444

4545
String sink =
4646
"create table sink_redis(name varchar, level varchar, age varchar) with ( "
47-
+ sigleWith()
47+
+ singleWith()
4848
+ "'ttl'='10', '"
4949
+ REDIS_COMMAND
5050
+ "'='"
@@ -74,7 +74,7 @@ public void testSinkValueWithExpireOnKeyPresent() throws Exception {
7474

7575
String dim =
7676
"create table sink_redis(name varchar, level varchar, age varchar) with ( "
77-
+ sigleWith()
77+
+ singleWith()
7878
+ " 'ttl'='8', 'ttl.key.not.absent'='true', '"
7979
+ REDIS_COMMAND
8080
+ "'='"

‎src/test/java/org/apache/flink/streaming/connectors/redis/table/SQLLettuceLimitTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public void testSinkLimitLettucePool() throws Exception {
4444

4545
String sink =
4646
"create table sink_redis(name varchar, level varchar, age varchar) with ( "
47-
+ sigleWith()
47+
+ singleWith()
4848
+ "'ttl'='10', '"
4949
+ REDIS_COMMAND
5050
+ "'='"

‎src/test/java/org/apache/flink/streaming/connectors/redis/table/base/TestRedisConfigBase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ public static void stopSingle() {
6363
redisClient.shutdown();
6464
}
6565

66-
protected String sigleWith() {
66+
protected String singleWith() {
6767
return "'connector'='redis', "
6868
+ "'host'='"
6969
+ REDIS_HOST

‎style/spotless-formatter.xml

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,22 @@
11
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
2+
<!--
3+
Licensed to the Apache Software Foundation (ASF) under one
4+
or more contributor license agreements. See the NOTICE file
5+
distributed with this work for additional information
6+
regarding copyright ownership. The ASF licenses this file
7+
to you under the Apache License, Version 2.0 (the
8+
"License"); you may not use this file except in compliance
9+
with the License. You may obtain a copy of the License at
210
11+
http://www.apache.org/licenses/LICENSE-2.0
12+
13+
Unless required by applicable law or agreed to in writing,
14+
software distributed under the License is distributed on an
15+
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
KIND, either express or implied. See the License for the
17+
specific language governing permissions and limitations
18+
under the License.
19+
-->
320
<profiles version="13">
421
<profile kind="CodeFormatterProfile" name="'Flink Connector for Redis'" version="13">
522
<setting id="org.eclipse.jdt.core.compiler.source" value="1.8"/>

0 commit comments

Comments
 (0)