Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
83 commits
Select commit Hold shift + click to select a range
9cf618c
[Optimization] Optimize the execution logic of the script. (#4068)
Zzzz-zmy Dec 20, 2024
de3aeed
[BugFix][Flink Jar]Fix FLINK JAR submission (#4073)
zackyoungh Dec 22, 2024
5978fc2
[Optimization][web]Optimize dolphin push info when enable English (#4…
MactavishCui Dec 23, 2024
2235f21
[Bug]Change k8s StringUtils import (#4081)
gaoyan1998 Dec 23, 2024
0f14777
[BugFix][FlinkJar]Fix flink jar (#4079)
zackyoungh Dec 23, 2024
91af61a
[Bug] [dinky-common] Fix deserialization exceptions caused by incorre…
Jam804 Dec 24, 2024
779d803
[Bugfix][FlinkJar]Fix FlinkJar args global variable parsing (#4113)
zackyoungh Jan 3, 2025
2d94bc7
[Bug]Fix variable can`t throw error (#4114)
gaoyan1998 Jan 4, 2025
d340ee9
[Bug-4102][admin]Bug fix for task lock strategy condition (#4122)
MactavishCui Jan 6, 2025
eab7cd0
[Bug-4084][Web]Bug fix 4 flinkJar task lost info (#4123)
MactavishCui Jan 6, 2025
e394019
[Bug-4097][admin]bug fix 4 post gre sql when using concat (#4121)
MactavishCui Jan 6, 2025
548a4e9
[Bug] [dinky-core] Click to trigger savepoint error (#4107) (#4125)
MactavishCui Jan 6, 2025
1c388b9
[Bug-4099][admin]bug fix 4 task with variable lineage (#4120)
MactavishCui Jan 7, 2025
b4721a5
[Bug-4117][core]Bug fix for debug task when target table contains '.'…
MactavishCui Jan 7, 2025
dded7cf
[Bug-4131]Bug fix for reading 'root-exception' (#4133)
MactavishCui Jan 9, 2025
f4cb166
[Optimize][Docker]Optimize docker image build (#4126)
zackyoungh Jan 9, 2025
0bdb863
[Optimization-4134][Web] Optimization home page icon and job detail l…
MactavishCui Jan 10, 2025
2ca6b0d
[Feature][flink] Support CALL statement (#4145)
aiwenmo Jan 15, 2025
5eb18a0
[Optimize] Optimize lineage relationship chart display (#4146)
zackyoungh Jan 15, 2025
1e67568
[Optimize][E2E]Optimize e2e (#4147)
zackyoungh Jan 15, 2025
2a31ef0
[Optimization-4116][cdc] Add source url param in CDCSOURCE (#4151)
aiwenmo Jan 15, 2025
31e6c2c
[Fix-4075][metadata] Fix the errors when querying the data of numeric…
aiwenmo Jan 15, 2025
b42408b
[Optimize][Web] Update antd frontend dependencies (#4156)
zackyoungh Jan 16, 2025
91f190a
[Fix-4158] [flink] Fix CALL statement can not be executed on standalo…
aiwenmo Jan 17, 2025
7c278bc
[Optimize-4127][gateway] The user-defined flink conf path overrides t…
aiwenmo Jan 17, 2025
0d6c2c0
[Feature-4140][gateway] Flink Kubernetes opoerator supports ingress (…
aiwenmo Jan 17, 2025
226d052
[Bug-4149] Bug fix for web socket session do not closed correctly and…
MactavishCui Jan 17, 2025
78d34fd
[Fix-4162][flink]Fix set statement is not effective in application mo…
aiwenmo Jan 20, 2025
273007c
[Feature-4153][*] Release 1.2.1 (#4168)
aiwenmo Jan 20, 2025
631a386
[Feature][Web]Replace NPM, switch to PNPM (#4157)
zackyoungh Jan 21, 2025
01ff64a
[Fix-4004] Fix unable to execute statements such as create database (…
aiwenmo Feb 7, 2025
571a524
[Fix-4192] Fix repeat job submission when switch tab in the detail pa…
aiwenmo Feb 7, 2025
987a199
[Optimize][Web]Optimize web package.json content (#4206)
zackyoungh Feb 12, 2025
7f643c9
[Feature-4139] Support data studio catalog tree list scroll interacti…
aiwenmo Feb 20, 2025
c8266db
[Fix-4104] Fix for pipeline.jars configuration during task submit (#4…
aiwenmo Feb 21, 2025
04ffd46
[Optimization-4176] Optimization flink catalog table info (#4242)
aiwenmo Feb 24, 2025
7c3380c
[Fix-4235] Fix the task failed to start due to empty configuration (#…
aiwenmo Feb 24, 2025
4c9853f
[Fix-4211] Fix the error reporting of non-existence when parsing glob…
aiwenmo Feb 24, 2025
857e4dd
[Fix-4209] Fix projects having same name but different parents cannot…
aiwenmo Feb 24, 2025
61d7680
[Optimization-4083] Register center document modal display optimizati…
aiwenmo Feb 25, 2025
d26fccf
[Optimization-4165] Optimization udf saved placeholder (#4255)
aiwenmo Feb 25, 2025
6088123
[Optimization-4194] Display the timestamp type field as a string valu…
aiwenmo Feb 25, 2025
478e6d7
[Optimization-4205] Compatible with kubernetes.container.image and ku…
aiwenmo Feb 25, 2025
f2042f8
[Optimization-4243] [admin] Optimize the verification of the availabi…
aiwenmo Feb 25, 2025
e404518
[Optimization-4237] Optimize the internationalization of prompt messa…
aiwenmo Feb 25, 2025
e5f5c97
[Fix-4182] Fix the bug in mounting the log configuration file in Flin…
aiwenmo Feb 26, 2025
9b1b2f0
[Optimize-4183] Optimize the architecture of websocket to work with S…
aiwenmo Feb 26, 2025
5c7c89c
[Fix] Fixed the issue that the historical version was not refreshed a…
aiwenmo Feb 27, 2025
02cdefa
Release-1.2.2 (#4267)
aiwenmo Feb 27, 2025
d6cab25
[Fix-4263] Fix web socket bug in data studio (#4268)
aiwenmo Feb 27, 2025
ae5bb66
[bug][dinky-gateway] Fix the issue where two Flink configuration item…
Jam804 Mar 8, 2025
d2ba411
[bug][dinky-gateway] Fix the issue where two Flink configuration item…
Jam804 Mar 13, 2025
d621bc8
[Fix-4308] Fix Array type in paimon query did not show the value (#4313)
aiwenmo Mar 23, 2025
92077a5
[Optimization-4314][admin] Optimize WebSocket for asynchronous sendin…
aiwenmo Mar 23, 2025
3cde6b9
[Bug] [dinky-gateway] Fix import errors in utility classes and Fix co…
Jam804 Mar 28, 2025
86f78fe
[Fix-4269] Fix the flinksql multi-version switch button does not take…
aiwenmo Mar 29, 2025
6ae88fd
[Optimization-4270] Check if the cluster is disabled before starting …
aiwenmo Mar 29, 2025
4add3b6
[Fix-4271] Fix the issue of the page constantly refreshing (#4331)
aiwenmo Mar 29, 2025
fdf6426
[Fix-4317] Fix metadata-hive MissingFormatArgumentException (#4334)
aiwenmo Mar 30, 2025
f430c80
[Fix-4287] Fix the issue where the form is cleared on the frontend wh…
aiwenmo Mar 30, 2025
f77c501
[Fix-4290] Sync the helm configuration with src/main/resources direct…
aiwenmo Mar 30, 2025
cd56727
[Fix-4327] Fix comparison expression issue (#4335)
aiwenmo Mar 30, 2025
f800da4
[Fix-4336] Fix Paimon tinyint data can not preview in data source cen…
aiwenmo Mar 30, 2025
a1576b2
[Fix-4338] Optimize the page rendering logic (#4339)
aiwenmo Mar 30, 2025
6385bda
[Optimization-4303] Support recover from the latest completed CheckPo…
aiwenmo Mar 30, 2025
ecfbd69
Release-1.2.3 (#4341)
aiwenmo Mar 30, 2025
18111de
[Fix-4344] Fix dinky-release-1.20-1.2.3.jar lacks dinky-cdc-plus.jar …
aiwenmo Apr 2, 2025
e4a6388
[Fix-4191][Fix-4288] fix jar sqlstatement split (#4292)
jiangwwwei Apr 2, 2025
56e80e6
[Optimization-4053] Support flink table planner loader (#4277)
aiwenmo Apr 24, 2025
8a860cf
[Action] fix cicd k3d bug add k3d-tag: v5.7.5 add k3s version:v1.27.1…
gaoyan1998 Jul 7, 2025
6783e26
[Bug] Fix operator submit bug (#4402)
gaoyan1998 Jul 11, 2025
33a0b48
[Bug] Fix the token cannot be refreshed properly. (#4403)
gaoyan1998 Jul 11, 2025
9b15fe0
[Fix-4324] [k8s] Modify the k8s deploy command (#4416)
aiwenmo Jul 24, 2025
90e3eb9
[Optimize-3599][admin] CatalogueService add a new method findByTaskId…
aiwenmo Jul 25, 2025
362db9e
[Fix-4385] Fix A bug occurred when other sending methods were switche…
aiwenmo Jul 25, 2025
35deca4
[Fix-4384][web] Fix the problem of task positioning error (#4420)
aiwenmo Jul 25, 2025
0a503e4
[Fix-3862][cdc] Fix not specifying it will result in a null pointer e…
aiwenmo Jul 25, 2025
185e151
[Fix-3912][web] Fix the menu of subtype on document module does not r…
aiwenmo Jul 25, 2025
23b7859
[Fix-4419] Remove CONF_DIR from FlinkConfiguration (#4424)
aiwenmo Jul 28, 2025
b027cbb
Release-1.2.4 (#4426)
aiwenmo Jul 29, 2025
6f629fd
[Optimization-4431] Dockerfile retains flink-table-planner-loader.jar…
aiwenmo Aug 4, 2025
6e874a7
[Optimize-4414] Remove slash checks for jm url (#4423)
aiwenmo Aug 6, 2025
0b964f3
fix(admin): Ignore tenant conditions when refreshing a job
gaoyan1998 Aug 14, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion .github/ISSUE_TEMPLATE/bug-report.yml
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ body:
Which version of Dinky are you running? We only accept bugs report from the LTS projects.
options:
- dev
- 1.2.0
- 1.2.4
- 1.1.0
- 1.0.3
- 0.7.5(Archived, Not Maintained)
Expand Down
188 changes: 170 additions & 18 deletions .github/workflows/backend.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,11 @@ name: Backend

on:
push:
workflow_dispatch:
pull_request:
branches:
- dev
- 1.2
paths-ignore:
- 'docs/**'
- '**/*.md'
Expand All @@ -41,8 +43,8 @@ jobs:
- name: Check Style
run: |
./mvnw -T 4C -B --no-snapshot-updates clean spotless:check -P flink-all
build_npm:
name: Build_NPM
build_web:
name: Build_Web
runs-on: ubuntu-latest
timeout-minutes: 30
needs: check
Expand All @@ -57,17 +59,17 @@ jobs:
frontend:
- 'dinky-web/**'
- uses: actions/setup-node@v3
if: steps.filter.outputs.frontend == 'true'
if: steps.filter.outputs.frontend == 'true'
with:
node-version: 16
node-version: 18
- name: Get npm cache directory
id: npm-cache-dir
if: steps.filter.outputs.frontend == 'true'
if: steps.filter.outputs.frontend == 'true'
run: |
echo "::set-output name=dir::$(npm config get cache)"
- uses: actions/cache@v3
id: npm-cache # use this to check for `cache-hit` ==> if: steps.npm-cache.outputs.cache-hit != 'true'
if: steps.filter.outputs.frontend == 'true'
if: steps.filter.outputs.frontend == 'true'
with:
path: |
${{ steps.npm-cache-dir.outputs.dir }}
Expand All @@ -76,20 +78,25 @@ jobs:
restore-keys: |
${{ runner.os }}-node-
- name: Install Dependencies
if: steps.filter.outputs.frontend == 'true'
run: cd dinky-web && npm install --no-audit --progress=false --legacy-peer-deps
if: steps.filter.outputs.frontend == 'true'
run: cd dinky-web && npm install -g pnpm && pnpm install
- name: Npm Web Build
if: steps.filter.outputs.frontend == 'true'
run: cd dinky-web && npm run build
build_jdk:
name: Build_JDK
if: steps.filter.outputs.frontend == 'true'
run: cd dinky-web && pnpm run build
- name: Upload artifact
uses: actions/upload-artifact@v4
with:
name: dinky-web
path: ./dinky-web/dist
build_release:
name: Build Release
runs-on: ubuntu-latest
needs: check
strategy:
fail-fast: true
matrix:
jdk: [8, 11]
flink: ['1.14', '1.15', '1.16', '1.17', '1.18', '1.19', '1.20']
jdk: [ 8, 11 ]
flink: [ '1.14', '1.15', '1.16', '1.17', '1.18', '1.19', '1.20' ]

timeout-minutes: 30
env:
Expand All @@ -100,7 +107,7 @@ jobs:
- name: Set up JDK ${{ matrix.jdk }}
uses: actions/setup-java@v2
with:
java-version: ${{ matrix.jdk }}
java-version: ${{ matrix.jdk }}
distribution: 'adopt'
- name: Cache local Maven repository
uses: actions/cache@v3
Expand Down Expand Up @@ -132,6 +139,151 @@ jobs:
- name: Check package size
run: |
./check_package_size.sh
# - name: Run Unit tests
# run: |
# ./mvnw -T 2C -B clean verify -Dmaven.test.skip=false -Dgpg.skip=true --no-snapshot-updates
- name: Upload artifact
uses: actions/upload-artifact@v4
if: ${{ matrix.jdk == 8 }}
with:
name: dinky-realease-${{ matrix.flink }}
path: ./build/dinky-release*.tar.gz
# - name: Run Unit tests
# run: |
# ./mvnw -T 2C -B clean verify -Dmaven.test.skip=false -Dgpg.skip=true --no-snapshot-updates


run_e2e:
name: Run E2E
needs: build_release
strategy:
fail-fast: true
matrix:
flink: [ '1.15', '1.16', '1.17', '1.18', '1.19', '1.20' ]
runs-on: ubuntu-latest
services:
registry:
image: registry:2
ports:
- 5000:5000
steps:
- name: Checkout
uses: actions/checkout@v4
- name: Init Docker Network
run: |
docker network create -d bridge --subnet 172.28.0.0/16 --gateway 172.28.0.1 dinky_net
- name: Download artifact
uses: actions/download-artifact@v4
with:
name: dinky-realease-${{ matrix.flink }}
path: ./build
# 设置 QEMU, 后面 docker buildx 依赖此.
- name: Set up QEMU
uses: docker/setup-qemu-action@v3
# 设置 Docker buildx, 方便构建 Multi platform 镜像
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@v3
with:
driver-opts: network=host
- name: Build Dinky Image
uses: docker/build-push-action@v5
with:
context: .
file: ./e2e_test/docker-compose-env/Dockerfile
# 是否 docker push
push: true
build-args: |
FLINK_VERSION=${{ matrix.flink }}
tags: |
localhost:5000/dinky/dinky-test:flink
- name: Build Flink Image
uses: docker/build-push-action@v5
with:
context: .
file: ./e2e_test/docker-compose-env/FlinkDockerfile
# 是否 docker push
push: true
build-args: |
FLINK_VERSION=${{ matrix.flink }}
tags: |
localhost:5000/dinky/flink:flink
- name: Init Env Jar
run: |
mkdir O e2e_test/docker-compose-env/dinky/jars
wget -O e2e_test/docker-compose-env/dinky/mysql-connector-java-8.0.30.jar https://repo1.maven.org/maven2/mysql/mysql-connector-java/8.0.30/mysql-connector-java-8.0.30.jar &&
wget -O e2e_test/docker-compose-env/flink/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar https://repo1.maven.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar &&
wget -O e2e_test/docker-compose-env/dinky/javax.ws.rs-api-2.1.1.jar https://repo1.maven.org/maven2/javax/ws/rs/javax.ws.rs-api/2.1.1/javax.ws.rs-api-2.1.1.jar
wget -O e2e_test/docker-compose-env/dinky/jars/flink-doris-connector.jar https://repo1.maven.org/maven2/org/apache/doris/flink-doris-connector-${{ matrix.flink }}/24.0.1/flink-doris-connector-${{ matrix.flink }}-24.0.1.jar
wget -O e2e_test/docker-compose-env/dinky/jars/flink-sql-connector-mysql-cdc.jar https://repo1.maven.org/maven2/org/apache/flink/flink-sql-connector-mysql-cdc/3.2.0/flink-sql-connector-mysql-cdc-3.2.0.jar
cp e2e_test/docker-compose-env/dinky/mysql-connector-java-8.0.30.jar e2e_test/docker-compose-env/dinky/jars/mysql-connector-java.jar
- name: Init Run Docker MySQL
uses: hoverkraft-tech/compose-action@v2.0.2
with:
compose-file: ./e2e_test/docker-compose-env/mysql/docker-compose.yml
# - name: Init System Env And Clear Docker Build Cache
# run: |
# echo y | docker builder prune
# df -h
# ulimit -a
# sudo swapoff -a
# sudo sysctl -w vm.max_map_count=2000000
# - name: Init Run Docker Doris
# uses: hoverkraft-tech/compose-action@v2.0.2
# with:
# compose-file: ./e2e_test/docker-compose-env/doris/docker-compose.yml
- name: Init Run Docker Dinky
uses: hoverkraft-tech/compose-action@v2.0.2
with:
compose-file: ./e2e_test/docker-compose-env/dinky/docker-compose.yml
- name: Init Run Docker Hadoop
uses: hoverkraft-tech/compose-action@v2.0.2
with:
compose-file: ./e2e_test/docker-compose-env/hadoop/docker-compose.yml
- name: Init Run Docker Flink
uses: hoverkraft-tech/compose-action@v2.0.2
with:
compose-file: ./e2e_test/docker-compose-env/flink/docker-compose.yml
# k8s env
- name: Init k3s
uses: nolar/setup-k3d-k3s@v1
with:
version: v1.27.16+k3s1
k3d-args: -s 1 --network dinky_net --api-port 172.28.0.1:6550
k3d-tag: v5.7.5
- name: Get k3s kube config
run: k3d kubeconfig get --all && mkdir ./kube && k3d kubeconfig get --all > ./kube/k3s.yaml && sed -i 's/0.0.0.0/172.28.0.1/g' ./kube/k3s.yaml
- name: Init k8s RBAC and namespace
run: |
kubectl create namespace dinky
kubectl create serviceaccount dinky -n dinky
kubectl create clusterrolebinding flink-role-binding-dinky --clusterrole=edit --serviceaccount=dinky:dinky
- name: Init k3s main images
run: |
docker exec k3d-k3s-default-server-0 crictl pull library/busybox:latest
docker exec k3d-k3s-default-server-0 crictl pull flink:${{ matrix.flink }}-scala_2.12-java8
docker pull localhost:5000/dinky/flink:flink
docker tag localhost:5000/dinky/flink:flink dinky/flink:flink
docker save -o flink.tar dinky/flink:flink
k3d images import ./flink.tar
rm -rf ./flink.tar
- name: Test k3s host
run: |
curl -k https://172.28.0.1:6550
- name: Cp Flink Jar Deps
run: |
docker cp dinky:/opt/dinky/ ./dinky-release
mv ./dinky-release/jar/dinky-app*.jar e2e_test/docker-compose-env/dinky/dinky-app.jar
- name: Run python http server
run: |
mkdir -p logs
ls e2e_test/docker-compose-env/dinky/
nohup python -m http.server -d e2e_test/docker-compose-env/dinky/ 9001 > ./logs/python_http.log &
- name: Run Docker Python Script
run: |
docker run -v ./e2e_test/tools:/app -w /app -v ./kube:/kube -v ./e2e_test/docker-compose-env/dinky:/dinky/jar -v ./dinky-release/extends/flink${{ matrix.flink }}:/opt/flink/lib -v ./e2e_test/docker-compose-env/dinky/mysql-connector-java-8.0.30.jar:/opt/flink/lib/mysql-connector-java-8.0.30.jar --net dinky_net --rm --entrypoint /bin/bash python:3.9 -c 'pip install -r requirements.txt && python main.py dinky:8888 ${{ matrix.flink }}'
- name: Get k8s pods info and logs
if: ${{ always() }}
run: |
chmod -R 755 ./e2e_test/view_k8s_all_pod_logs.sh
./e2e_test/view_k8s_all_pod_logs.sh dinky
- name: Get Python HttpServer log
if: ${{ always() }}
run: |
cat ./logs/python_http.log
Loading
Loading