This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-hive.git
commit 204c8bdc0e4be6892b03d707a0895c32f4d5f745
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Sat Jan 11 21:47:12 2025 +0100
[hotfix] Apply 1.20.0 in github ci
---
.github/workflows/push_pr.yml | 14 ++++----------
.github/workflows/weekly.yml | 10 ++--------
.../org/apache/flink/connectors/hive/HiveTableSink.java | 2 +-
3 files changed, 7 insertions(+), 19 deletions(-)
diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index b852d0bc..569ea12a 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -25,20 +25,14 @@ jobs:
compile_and_test:
strategy:
matrix:
- flink: [ 1.18-SNAPSHOT, 1.19-SNAPSHOT ]
- jdk: [ 8, 11 ]
+ flink: [ 1.20.0 ]
+ jdk: [ 8 ]
# empty means test against hive2
mvn_profile: [ "", hive3 ]
- exclude:
- - jdk: 11
- mvn_profile: hive3
include:
- jdk: 11
- flink: 1.18-SNAPSHOT
- mvn_profile: "hive3,skipE2ETests"
- - jdk: 11
- flink: 1.19-SNAPSHOT
- mvn_profile: "hive3,skipE2ETests"
+ flink: 1.20.0
+ mvn_profile: ""
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
diff --git a/.github/workflows/weekly.yml b/.github/workflows/weekly.yml
index 1f66c5fd..a11ab87c 100644
--- a/.github/workflows/weekly.yml
+++ b/.github/workflows/weekly.yml
@@ -26,7 +26,7 @@ jobs:
if: github.repository_owner == 'apache'
strategy:
matrix:
- flink: [ 1.18.0, 1.18-SNAPSHOT, 1.19-SNAPSHOT ]
+ flink: [ 1.20.0 ]
jdk: [ 8, 11 ]
# empty means test against hive2
mvn_profile: [ "", hive3 ]
@@ -35,13 +35,7 @@ jobs:
mvn_profile: hive3
include:
- jdk: 11
- flink: 1.18.0
- mvn_profile: "hive3,skipE2ETests"
- - jdk: 11
- flink: 1.18-SNAPSHOT
- mvn_profile: "hive3,skipE2ETests"
- - jdk: 11
- flink: 1.19-SNAPSHOT
+ flink: 1.20.0
mvn_profile: "hive3,skipE2ETests"
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
diff --git
a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
index e89cdbaf..d7e9a058 100644
---
a/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
+++
b/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java
@@ -607,7 +607,7 @@ public class HiveTableSink implements DynamicTableSink,
SupportsPartitioning, Su
builder.setOverwrite(overwrite);
builder.setIsToLocal(isToLocal);
builder.setStaticPartitions(staticPartitionSpec);
- builder.setPath(new
org.apache.flink.core.fs.Path(toStagingDir(stagingParentDir, jobConf)));
+ builder.setPath(new org.apache.flink.core.fs.Path(stagingParentDir));
builder.setOutputFileConfig(fileNaming);
builder.setIdentifier(identifier);
builder.setPartitionCommitPolicyFactory(
