Revert "[FLINK-17303][python] Support Python TableResult"

This reverts commit 381131a.

flink-python/pyflink/common/__init__.py

@@ -22,27 +22,19 @@
     - :class:`ExecutionConfig`:
       A config to define the behavior of the program execution.
 """
-from pyflink.common.completable_future import CompletableFuture
 from pyflink.common.configuration import Configuration
 from pyflink.common.execution_config import ExecutionConfig
 from pyflink.common.execution_mode import ExecutionMode
 from pyflink.common.input_dependency_constraint import InputDependencyConstraint
-from pyflink.common.job_client import JobClient
 from pyflink.common.job_execution_result import JobExecutionResult
-from pyflink.common.job_id import JobID
-from pyflink.common.job_status import JobStatus
 from pyflink.common.restart_strategy import RestartStrategies, RestartStrategyConfiguration
 
 __all__ = [
-    'CompletableFuture',
     'Configuration',
     'ExecutionConfig',
     'ExecutionMode',
     'InputDependencyConstraint',
-    'JobClient',
     'JobExecutionResult',
-    'JobID',
-    'JobStatus',
     'RestartStrategies',
     'RestartStrategyConfiguration',
 ]

flink-python/pyflink/common/execution_mode.py

@@ -83,7 +83,7 @@ def _from_j_execution_mode(j_execution_mode):
         elif j_execution_mode == JExecutionMode.BATCH_FORCED:
             return ExecutionMode.BATCH_FORCED
         else:
-            raise Exception("Unsupported java execution mode: %s" % j_execution_mode)
+            raise Exception("Unsupported java exection mode: %s" % j_execution_mode)
 
     @staticmethod
     def _to_j_execution_mode(execution_mode):

flink-python/pyflink/common/job_execution_result.py

@@ -15,7 +15,6 @@
 #  See the License for the specific language governing permissions and
 # limitations under the License.
 ################################################################################
-from pyflink.common.job_id import JobID
 
 __all__ = ['JobExecutionResult']
 
@@ -36,7 +35,7 @@ def get_job_id(self):
         :return: JobID, or null if the job has been executed on a runtime without JobIDs
                  or if the execution failed.
         """
-        return JobID(self._j_job_execution_result.getJobID())
+        return self._j_job_execution_result.getJobID()
 
     def is_job_execution_result(self):
         """