This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a change to branch k8s-v2
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
from da2b1a514 [Improve] Move the flink-k8s-operator code from the dev
branch to the k8s-v2 branch
add 2369ace5e [Improve] implicit minor improvement
No new revisions were added by this update.
Summary of changes:
.../streampark/common/util/HadoopUtils.scala | 2 +-
.../streampark/common/util/PropertiesUtils.scala | 25 ++--
.../flink/connector/conf/ThresholdConf.scala | 6 +-
.../flink/connector/failover/SinkRequestTest.scala | 4 +-
.../conf/ClickHouseSinkConfigOption.scala | 4 +-
.../doris/conf/DorisSinkConfigOption.scala | 6 +-
.../elasticsearch5/conf/ESSinkConfigOption.scala | 4 +-
.../elasticsearch6/conf/ES6SinkConfigOption.scala | 4 +-
.../elasticsearch7/conf/ES7SinkConfigOption.scala | 4 +-
.../jdbc/internal/JdbcSourceFunction.scala | 4 +-
.../redis/conf/RedisSinkConfigOption.scala | 4 +-
.../flink/kubernetes/KubernetesRetriever.scala | 3 +-
.../flink/kubernetes/PodTemplateParser.scala | 28 ++--
.../kubernetes/watcher/FlinkJobStatusWatcher.scala | 2 +-
.../flink/kubernetes/FlinkRestJsonTest.scala | 2 +-
.../flink/kubernetes/PodTemplateParserTest.scala | 166 +--------------------
.../flink/packer/pipeline/BuildPipeline.scala | 4 +-
.../packer/pipeline/DockerResolveSnapshot.scala | 8 +-
.../pipeline/impl/FlinkRemoteBuildPipeline.scala | 3 +-
19 files changed, 65 insertions(+), 218 deletions(-)
