Skip to content

Commit

Permalink
[FLINK-11752] [dist] Move flink-python to opt (apache#7843)
Browse files Browse the repository at this point in the history
* [FLINK-11752] [dist] Move flink-python to opt

* [FLINK-11752] [dist] Point pyflink scripts to opt
  • Loading branch information
uce committed Feb 27, 2019
1 parent 654e718 commit d637d86
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 13 deletions.
12 changes: 1 addition & 11 deletions flink-dist/src/main/assemblies/bin.xml
Original file line number Diff line number Diff line change
Expand Up @@ -227,17 +227,7 @@ under the License.
<include>flink-gelly-examples_${scala.binary.version}-${project.version}.jar</include>
</includes>
</fileSet>

<!-- copy python jar -->
<fileSet>
<directory>../flink-libraries/flink-python/target</directory>
<outputDirectory>lib</outputDirectory>
<fileMode>0644</fileMode>
<includes>
<include>flink-python_${scala.binary.version}-${project.version}.jar</include>
</includes>
</fileSet>


<!-- copy python example to examples of dist -->
<fileSet>
<directory>../flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/example</directory>
Expand Down
8 changes: 8 additions & 0 deletions flink-dist/src/main/assemblies/opt.xml
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,14 @@
<fileMode>0644</fileMode>
</file>

<!-- Batch Python API -->
<file>
<source>../flink-libraries/flink-python/target/flink-python_${scala.binary.version}-${project.version}.jar</source>
<outputDirectory>opt</outputDirectory>
<destName>flink-python_${scala.binary.version}-${project.version}.jar</destName>
<fileMode>0644</fileMode>
</file>

<!-- Streaming Python API -->
<file>
<source>../flink-libraries/flink-streaming-python/target/flink-streaming-python_${scala.binary.version}-${project.version}.jar</source>
Expand Down
2 changes: 1 addition & 1 deletion flink-dist/src/main/flink-bin/bin/pyflink.bat
Original file line number Diff line number Diff line change
Expand Up @@ -22,4 +22,4 @@ setlocal EnableDelayedExpansion
SET bin=%~dp0
SET FLINK_ROOT_DIR=%bin%..

"%FLINK_ROOT_DIR%\bin\flink" run -v "%FLINK_ROOT_DIR%"\lib\flink-python*.jar %*
"%FLINK_ROOT_DIR%\bin\flink" run -v "%FLINK_ROOT_DIR%"\opt\flink-python*.jar %*
2 changes: 1 addition & 1 deletion flink-dist/src/main/flink-bin/bin/pyflink.sh
Original file line number Diff line number Diff line change
Expand Up @@ -22,4 +22,4 @@ bin=`cd "$bin"; pwd`

. "$bin"/config.sh

"$FLINK_BIN_DIR"/flink run -v "$FLINK_ROOT_DIR"/lib/flink-python*.jar "$@"
"$FLINK_BIN_DIR"/flink run -v "$FLINK_ROOT_DIR"/opt/flink-python*.jar "$@"

0 comments on commit d637d86

Please sign in to comment.