This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 8c6f13cead9 [FLINK-36230][pyflink-table] Fix the incorrect calling of
REGEXP_EXTRACT Python Table API
new 581a4f761d2 [FLINK-36185][state-processor] Remove deprecated internal
class BoundedOneInputStreamTaskRunner.
new d564e889264 [FLINK-36185][e2e] Rewrite end to end cases with new Kafka
source.
new c7b1f4be424 [FLINK-36185][core] Remove
RuntimeContext#getExecutionConfig
new 356e2af4b27 [FLINK-36185][e2e] Disable PyFlink end-to-end case that
uses Kafka legacy source.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/api/common/functions/RuntimeContext.java | 12 --
.../functions/util/AbstractRuntimeUDFContext.java | 6 -
.../registry/test/TestAvroConsumerConfluent.java | 33 ++--
.../test-scripts/test_pyflink.sh | 180 +++++++++++----------
.../flink/cep/operator/CepRuntimeContext.java | 7 -
.../output/BoundedOneInputStreamTaskRunner.java | 96 -----------
.../state/api/runtime/SavepointRuntimeContext.java | 7 -
.../util/MockStreamingRuntimeContext.java | 7 +
.../api/functions/async/RichAsyncFunction.java | 7 -
pom.xml | 4 +
10 files changed, 129 insertions(+), 230 deletions(-)
delete mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java
