dl-on-flink
dl-on-flink copied to clipboard
flink-extended
Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.
Bumps hadoop-common from 2.10.1 to 3.2.4. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
## What is the purpose of the change *(For example: This pull request makes user can stop workflow externally.)* ## Brief change log *(for example:)* - *Send StopDagEvent to Airflow...
Bumps [protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.16.1 to 3.16.3. Release notes Sourced from protobuf-java's releases. Protobuf Release v3.16.3 Java Refactoring java full runtime to reuse sub-message builders and prepare to migrate parsing logic...
### 我执行的步骤 按照初始化步骤对dl-on-flink进行打包 新建了一个服务用来跑flink任务 服务中引入dl-on-flink-dist ``` xml org.flinkextended dl-on-flink-dist 0.6.0-SNAPSHOT org.apache.flink flink-python_2.12 ${flink.version} ``` 复制dl-on-flink-examples-tensorflow项目下的Linear.java到新服务中运行 对应报错信息 ``` [08-29 17:52:28] [INFO] [org.mortbay.log:67] Start logging process worker:0 with org.flinkextended.flink.ml.cluster.node.runner.python.log.StdOutErrorProcessOutputConsumer@610546a2 [08-29 17:52:28] [INFO]...
Bumps org.apache.hadoop:hadoop-common from 2.10.1 to 3.4.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
Bumps [com.google.protobuf:protobuf-java](https://github.com/protocolbuffers/protobuf) from 3.16.1 to 3.25.5. Release notes Sourced from com.google.protobuf:protobuf-java's releases. Protocol Buffers v3.20.3 Java Refactoring java full runtime to reuse sub-message builders and prepare to migrate parsing logic...
Bumps [actions/download-artifact](https://github.com/actions/download-artifact) from 2 to 4.1.7. Release notes Sourced from actions/download-artifact's releases. v4.1.7 What's Changed Update @actions/artifact dependency by @bethanyj28 in actions/download-artifact#325 Full Changelog: https://github.com/actions/download-artifact/compare/v4.1.6...v4.1.7 v4.1.6 What's Changed updating @actions/artifact...
Metadata
Owner
Metadata
Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.