[flink] branch master updated (749f70d -> b692300)

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 749f70d  [FLINK-19372][python] Support Pandas Batch Over Window Aggregation
     add b692300  [FLINK-19124][datastream] Remove ClassLoader parameter from JobClient methods

No new revisions were added by this update.

Summary of changes:
 docs/dev/datastream_api.md                                 |  2 +-
 docs/dev/datastream_api.zh.md                              |  2 +-
 .../client/deployment/ClusterClientJobClientAdapter.java   | 13 ++++++++-----
 .../client/deployment/application/EmbeddedJobClient.java   | 14 +++++++++-----
 .../deployment/application/WebSubmissionJobClient.java     |  4 ++--
 .../deployment/application/executors/EmbeddedExecutor.java |  8 ++++----
 .../application/executors/EmbeddedExecutorFactory.java     |  4 ++--
 .../application/executors/EmbeddedJobClientCreator.java    |  3 ++-
 .../executors/WebSubmissionExecutorFactory.java            |  2 +-
 .../deployment/executors/AbstractJobClusterExecutor.java   |  2 +-
 .../executors/AbstractSessionClusterExecutor.java          |  3 ++-
 .../apache/flink/client/program/ContextEnvironment.java    |  2 +-
 .../flink/client/program/PerJobMiniClusterFactory.java     | 14 ++++++++------
 .../flink/client/program/StreamContextEnvironment.java     |  2 +-
 .../java/org/apache/flink/client/program/ClientTest.java   |  4 ++--
 .../flink/client/program/PerJobMiniClusterFactoryTest.java | 12 ++++++------
 .../java/org/apache/flink/core/execution/JobClient.java    |  6 ++----
 .../org/apache/flink/sql/tests/BatchSQLTestProgram.java    |  2 +-
 .../org/apache/flink/table/tpcds/TpcdsTestProgram.java     |  2 +-
 .../org/apache/flink/api/java/ExecutionEnvironment.java    |  2 +-
 .../java/org/apache/flink/api/java/TestingJobClient.java   |  4 ++--
 flink-python/pyflink/common/job_client.py                  | 14 ++++----------
 .../api/environment/StreamExecutionEnvironment.java        |  2 +-
 .../api/operators/collect/CollectResultFetcher.java        |  2 +-
 .../api/operators/collect/utils/TestJobClient.java         |  4 ++--
 .../flink/streaming/environment/TestingJobClient.java      |  4 ++--
 .../flink/table/client/gateway/local/LocalExecutor.java    |  3 +--
 .../flink/table/client/gateway/local/ResultStore.java      | 11 ++++-------
 .../gateway/local/result/ChangelogCollectStreamResult.java |  5 ++---
 .../client/gateway/local/result/CollectStreamResult.java   | 10 ++--------
 .../local/result/MaterializedCollectBatchResult.java       |  9 ++-------
 .../local/result/MaterializedCollectStreamResult.java      | 11 ++++-------
 .../local/result/MaterializedCollectStreamResultTest.java  |  6 ++----
 .../flink/table/api/internal/InsertResultIterator.java     |  2 +-
 .../org/apache/flink/table/sinks/BatchSelectTableSink.java |  3 +--
 .../flink/table/api/internal/BatchTableEnvImpl.scala       |  2 +-
 .../UnalignedCheckpointCompatibilityITCase.java            |  4 ++--
 .../flink/test/example/client/LocalExecutorITCase.java     |  4 ++--
 .../api/environment/RemoteStreamEnvironmentTest.java       |  2 +-
 39 files changed, 93 insertions(+), 112 deletions(-)