[FLINK-32971][python] Add proper development version support in pyflink

Author: gaborgsomogyi

.gitignore

@@ -43,8 +43,8 @@ flink-python/dev/.conda/
 flink-python/dev/log/
 flink-python/dev/.stage.txt
 flink-python/.eggs/
-flink-python/apache-flink-*.dev0/
-flink-python/apache-flink-libraries/apache_flink_libraries-*.dev0/
+flink-python/apache-flink-*.dev*/
+flink-python/apache-flink-libraries/apache_flink_libraries-*.dev*/
 flink-python/**/*.c
 flink-python/.idea/
 flink-python/**/*.so

flink-python/apache-flink-libraries/setup.py

@@ -21,6 +21,7 @@
 import io
 import os
 import platform
+import re
 import subprocess
 import sys
 from shutil import copytree, copy, rmtree
@@ -97,7 +98,7 @@ def find_file_path(pattern):
             print("Temp path for symlink to parent already exists {0}".format(TEMP_PATH),
                   file=sys.stderr)
             sys.exit(-1)
-        flink_version = VERSION.replace(".dev0", "-SNAPSHOT")
+        flink_version = re.sub("[.]dev.*", "-SNAPSHOT", VERSION)
         FLINK_HOME = os.path.abspath(
             "../../flink-dist/target/flink-%s-bin/flink-%s" % (flink_version, flink_version))
 

flink-python/setup.py

@@ -20,6 +20,7 @@
 import io
 import os
 import platform
+import re
 import sys
 from distutils.command.build_ext import build_ext
 from shutil import copytree, copy, rmtree
@@ -206,7 +207,7 @@ def extracted_output_files(base_dir, file_path, output_directory):
             print("Temp path for symlink to parent already exists {0}".format(TEMP_PATH),
                   file=sys.stderr)
             sys.exit(-1)
-        flink_version = VERSION.replace(".dev0", "-SNAPSHOT")
+        flink_version = re.sub("[.]dev.*", "-SNAPSHOT", VERSION)
         FLINK_HOME = os.path.abspath(
             "../flink-dist/target/flink-%s-bin/flink-%s" % (flink_version, flink_version))
         FLINK_ROOT = os.path.abspath("..")
@@ -252,7 +253,7 @@ def extracted_output_files(base_dir, file_path, output_directory):
                   "is complete, or do this in the flink-python directory of the flink source "
                   "directory.")
             sys.exit(-1)
-    if VERSION.find('dev0') != -1:
+    if re.search('dev.*$', VERSION) is not None:
         apache_flink_libraries_dependency = 'apache-flink-libraries==%s' % VERSION
     else:
         split_versions = VERSION.split('.')