Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
32 commits
Select commit Hold shift + click to select a range
f140f71
Add IcebergResourceManager
tarun-google Nov 13, 2025
df42009
Add IcebergResource Manager for IT
tarun-google Nov 14, 2025
4d0b2b8
Fix Testcase
tarun-google Nov 14, 2025
5a481f1
Order fields
tarun-google Nov 14, 2025
a6f1bc9
Apply spotless
tarun-google Nov 14, 2025
2290ce6
Add Unit tests
tarun-google Nov 15, 2025
25233f2
Apply Spotless
tarun-google Nov 15, 2025
b5ab434
Add Postgres to Iceberg
tarun-google Nov 18, 2025
7fbf4e3
Add Pipeline Options
tarun-google Nov 24, 2025
bdbdc1d
Merge branch 'GoogleCloudPlatform:main' into iceberg_yaml
tarun-google Nov 24, 2025
35d4a4f
fix options
tarun-google Nov 24, 2025
0d25345
fix options
tarun-google Nov 24, 2025
cfe6f04
Merge branch 'iceberg_yaml' of github.com:tarun-google/DataflowTempla…
tarun-google Nov 24, 2025
b1f70f3
Add Postgres to Iceberg Template
tarun-google Nov 25, 2025
b347d08
Add test case for framework
tarun-google Nov 26, 2025
1461815
Fix Tests
tarun-google Nov 26, 2025
7698e22
spotless
tarun-google Nov 26, 2025
5bedfa6
Fix dependency
tarun-google Nov 27, 2025
72691a6
Add PostgresToIceberg Template
tarun-google Dec 1, 2025
3a5e082
Fix failing test
tarun-google Dec 1, 2025
afc72f4
Fix names
tarun-google Dec 1, 2025
8a58236
Fix data type
tarun-google Dec 3, 2025
f378296
Add Iceberg setup beforehand
tarun-google Dec 3, 2025
4cc74c3
use GCS Bucket for warehouse
tarun-google Dec 3, 2025
2f1a0b4
Use base path
tarun-google Dec 4, 2025
25f254d
test
tarun-google Dec 4, 2025
d69e098
test
tarun-google Dec 4, 2025
77d3afb
test2
tarun-google Dec 4, 2025
b077746
test3
tarun-google Dec 4, 2025
ae5c76d
Merge branch 'main' into test_yaml
tarun-google Dec 4, 2025
b287be8
test4
tarun-google Dec 4, 2025
328eeda
merge
tarun-google Dec 4, 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
122 changes: 7 additions & 115 deletions .github/workflows/java-pr.yml
Original file line number Diff line number Diff line change
Expand Up @@ -57,112 +57,23 @@ env:
permissions: write-all

jobs:
spotless_check:
name: Spotless
timeout-minutes: 10
runs-on: ubuntu-latest
steps:
- name: Checkout Code
uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
- name: Setup Environment
id: setup-env
uses: ./.github/actions/setup-env
- name: Run Spotless
run: ./cicd/run-spotless
checkstyle_check:
name: Checkstyle
timeout-minutes: 10
runs-on: ubuntu-latest
steps:
- name: Checkout Code
uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
- name: Setup Environment
id: setup-env
uses: ./.github/actions/setup-env
- name: Run Checkstyle
run: ./cicd/run-checkstyle
java_build:
name: Build
timeout-minutes: 60
runs-on: [self-hosted, it]
steps:
- name: Checkout Code
uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
uses: actions/checkout@93cb6efe18208431cddfb8368fd83d5badbf9bfd # v5.0.1
- name: Setup Environment
id: setup-env
uses: ./.github/actions/setup-env
- name: Run Build
run: ./cicd/run-build
- name: Cleanup Java Environment
uses: ./.github/actions/cleanup-java-env
java_unit_tests:
name: Unit Tests
needs: [java_build]
timeout-minutes: 60
runs-on: [self-hosted, it]
steps:
- name: Checkout Code
uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
- name: Setup Environment
id: setup-env
uses: ./.github/actions/setup-env
- name: Run Unit Tests
run: ./cicd/run-unit-tests
- name: Upload Unit Tests Report
uses: actions/upload-artifact@v5
if: always() # always run even if the previous step fails
with:
name: surefire-unit-test-results
path: |
**/surefire-reports/TEST-*.xml
**/surefire-reports/*.html
**/surefire-reports/html/**
retention-days: 1
- name: Upload coverage reports to Codecov
uses: codecov/codecov-action@v5.5.1
with:
token: ${{ secrets.CODECOV_TOKEN }}
slug: GoogleCloudPlatform/DataflowTemplates
files: 'target/site/jacoco-aggregate/jacoco.xml'
- name: Cleanup Java Environment
uses: ./.github/actions/cleanup-java-env
if: always()
java_integration_smoke_tests_templates:
name: Dataflow Templates Integration Smoke Tests
needs: [spotless_check, checkstyle_check, java_build, java_unit_tests]
timeout-minutes: 60
# Run on any runner that matches all the specified runs-on values.
runs-on: [self-hosted, it]
steps:
- name: Checkout Code
uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
- name: Setup Environment
id: setup-env
uses: ./.github/actions/setup-env
- name: Run Integration Smoke Tests
run: |
./cicd/run-it-smoke-tests \
--modules-to-build="DEFAULT" \
--it-region="${{ env.IT_REGION }}" \
--it-project="cloud-teleport-testing" \
--it-artifact-bucket="cloud-teleport-testing-it-gitactions" \
--it-private-connectivity="datastream-connect-2"
- name: Upload Smoke Tests Report
uses: actions/upload-artifact@v5
if: always() # always run even if the previous step fails
with:
name: surefire-smoke-test-results
path: |
**/surefire-reports/TEST-*.xml
**/surefire-reports/*.html
**/surefire-reports/html/**
retention-days: 1
- name: Cleanup Java Environment
uses: ./.github/actions/cleanup-java-env
if: always()
java_integration_tests_templates:
name: Dataflow Templates Integration Tests
needs: [java_integration_smoke_tests_templates]
needs: [java_build]
timeout-minutes: 240
# Run on any runner that matches all the specified runs-on values.
runs-on: [self-hosted, it]
Expand All @@ -175,7 +86,8 @@ jobs:
- name: Run Integration Tests
run: |
./cicd/run-it-tests \
--modules-to-build="DEFAULT" \
--modules-to-build="YAML" \
--modules-to-build="YAML" \
--it-region="${{ env.IT_REGION }}" \
--it-project="cloud-teleport-testing" \
--it-integration-test-parallelism=6 \
Expand Down Expand Up @@ -207,26 +119,6 @@ jobs:
- name: Cleanup Java Environment
uses: ./.github/actions/cleanup-java-env
if: always()
java_load_tests_templates:
if: contains(github.event.pull_request.labels.*.name, 'run-load-tests')
name: Dataflow Templates Load Tests
needs: [spotless_check, checkstyle_check, java_build, java_unit_tests, java_integration_tests_templates]
timeout-minutes: 600
# Run on any runner that matches all the specified runs-on values.
runs-on: [self-hosted, perf]
steps:
- name: Checkout Code
uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
- name: Setup Environment
id: setup-env
uses: ./.github/actions/setup-env
- name: Run Load Tests
run: |
./cicd/run-load-tests \
--it-region="${{ env.IT_REGION }}" \
--it-project="cloud-teleport-testing" \
--it-artifact-bucket="cloud-teleport-testing-it-gitactions" \
--it-private-connectivity="datastream-connect-2"
- name: Cleanup Java Environment
uses: ./.github/actions/cleanup-java-env
if: always()
- name: Cleanup Java Environment
uses: ./.github/actions/cleanup-java-env
if: always()
2 changes: 2 additions & 0 deletions cicd/internal/flags/common-flags.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ const (
SPANNER = "SPANNER"
BIGTABLE = "BIGTABLE"
DATASTREAM = "DATASTREAM"
YAML = "YAML"
)

// Avoid making these vars public.
Expand Down Expand Up @@ -64,6 +65,7 @@ var (
"v2/datastream-to-mongodb/",
"v2/datastream-to-sql/",
},
YAML: {"yaml/"},
}
)

Expand Down
21 changes: 21 additions & 0 deletions it/iceberg/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@

<properties>
<iceberg.version>1.6.1</iceberg.version>
<bigdataoss.version>3.1.10</bigdataoss.version>
</properties>

<dependencies>
Expand Down Expand Up @@ -69,6 +70,26 @@
<artifactId>parquet-hadoop</artifactId>
<version>1.13.1</version>
</dependency>
<dependency>
<groupId>org.apache.iceberg</groupId>
<artifactId>iceberg-gcp</artifactId>
<version>${iceberg.version}</version>
</dependency>
<dependency>
<groupId>com.google.cloud.bigdataoss</groupId>
<artifactId>gcsio</artifactId>
<version>${bigdataoss.version}</version>
</dependency>
<dependency>
<groupId>com.google.cloud.bigdataoss</groupId>
<artifactId>gcs-connector</artifactId>
<version>${bigdataoss.version}</version>
</dependency>
<dependency>
<groupId>com.google.cloud.bigdataoss</groupId>
<artifactId>util-hadoop</artifactId>
<version>${bigdataoss.version}</version>
</dependency>
</dependencies>


Expand Down
19 changes: 19 additions & 0 deletions yaml/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<postgresql.version>42.6.1</postgresql.version>
</properties>

<dependencies>
Expand Down Expand Up @@ -65,6 +66,24 @@
<artifactId>beam-it-kafka</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.google.cloud.teleport</groupId>
<artifactId>it-jdbc</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.google.cloud.teleport</groupId>
<artifactId>iceberg</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<version>${postgresql.version}</version>
<scope>test</scope>
</dependency>
</dependencies>

<build>
Expand Down
Loading
Loading