execute_sql语句中wait的含义

Question

我想知道使用和不使用 wait() 命令在 pyflink 中执行 sql 语句有什么区别和含义：

t_env.execute_sql(query)
t_env.execute_sql(query).wait()

我对两者都进行了试验，并没有发现执行上的差异。

Answer 1

def wait(self, timeout_ms: int = None):
    """
    Wait if necessary for at most the given time (milliseconds) for the data to be ready.

    For a select operation, this method will wait until the first row can be accessed locally.
    For an insert operation, this method will wait for the job to finish,
    because the result contains only one row.
    For other operations, this method will return immediately,
    because the result is already available locally.

    .. versionadded:: 1.12.0
    """

execute_sql语句中wait的含义

The meaning of wait in execute_sql statement

apache-flink

pyflink