This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1e0c54ca7dc [FLINK-38711][build] Set maven-shade-plugin logs to `DEBUG`
add 667cacc0ef0 [FLINK-38690][python] Support adjusting log level for
python worker (#27247)
No new revisions were added by this update.
Summary of changes:
.../shortcodes/generated/python_configuration.html | 12 ++++
.../src/main/flink-bin/conf/log4j-cli.properties | 3 +
.../main/flink-bin/conf/log4j-console.properties | 3 +
.../main/flink-bin/conf/log4j-session.properties | 3 +
.../src/main/flink-bin/conf/log4j.properties | 3 +
.../src/main/flink-bin/conf/logback-console.xml | 2 +
.../src/main/flink-bin/conf/logback-session.xml | 2 +
flink-dist/src/main/flink-bin/conf/logback.xml | 2 +
.../flink-python-test/python/add_one.py | 3 +
.../test-scripts/test_pyflink.sh | 11 ++++
flink-python/pyflink/common/configuration.py | 12 ++++
.../pyflink/common/tests/test_configuration.py | 4 ++
.../datastream/stream_execution_environment.py | 3 +-
.../pyflink/datastream/tests/test_data_stream.py | 52 +++++++++++++++-
.../fn_execution/beam/beam_worker_pool_service.py | 53 ++++++++++++++++-
flink-python/pyflink/pyflink_gateway_server.py | 19 +++---
flink-python/pyflink/table/table_environment.py | 5 +-
.../control/DefaultJobBundleFactory.java | 5 +-
.../apache/flink/python/FlinkSlf4jLogWriter.java | 69 ++++++++++++++++++++++
.../org/apache/flink/python/PythonOptions.java | 22 +++++++
.../python/beam/BeamPythonFunctionRunner.java | 18 ++++++
tools/ci/log4j.properties | 3 +
22 files changed, 296 insertions(+), 13 deletions(-)
create mode 100644
flink-python/src/main/java/org/apache/flink/python/FlinkSlf4jLogWriter.java
