This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c40081d [FLINK-24689][runtime-web] Add log's last modified time in
log list view
new df2c47d [hotfix][testutils] Read result files recursively
new 3762c3b [hotfix][yarn-tests] drop assertion on streaming word count
output
new a3830ed [hotfix][e2e] Run kerberos test under AUTOMATIC execution
new 83a2541 [FLINK-24830][examples] Update DataStream WordCount example
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:
.../test_yarn_application_kerberos_docker.sh | 10 --
.../test-scripts/test_yarn_job_kerberos_docker.sh | 10 --
flink-examples/flink-examples-streaming/pom.xml | 44 +-----
.../streaming/examples/wordcount/WordCount.java | 142 ++++++++++++-----
.../streaming/examples/wordcount/util/CLI.java | 149 ++++++++++++++++++
.../scala/examples/wordcount/WordCount.scala | 169 +++++++++++++++------
.../scala/examples/wordcount/util/CLI.scala | 65 ++++++++
.../streaming/test/StreamingExamplesITCase.java | 5 +-
.../scala/examples/StreamingExamplesITCase.scala | 5 +-
.../org/apache/flink/test/util/TestBaseUtils.java | 35 +++--
.../yarn/YARNSessionCapacitySchedulerITCase.java | 12 --
11 files changed, 475 insertions(+), 171 deletions(-)
create mode 100644
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount/util/CLI.java
create mode 100644
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/wordcount/util/CLI.scala
