pnowojski commented on a change in pull request #21:
URL: https://github.com/apache/flink-benchmarks/pull/21#discussion_r670343387
##########
File path: src/main/resources/log4j2-test.properties
##########
@@ -16,8 +16,13 @@
# limitations under the License.
################################################################################
-log4j.rootLogger=WARN, console
+rootLogger.level = ERROR
Review comment:
Hmm, with `INFO` level I can see somethings that are being logged. But
indeed exception is not. I'm only getting this:
```
12:29:30,861 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Disconnect job manager
a01911f835cbdd195148423ad40f4070@akka://flink/user/rpc/jobmanager_3 for job
0d151cff076a2fc1cb273c9d9d61236d from the resource manager.
<failure>
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
(...)
Caused by: java.lang.UnsupportedOperationException
at
org.apache.flink.benchmark.AsyncWaitOperatorBenchmark$1.invoke(AsyncWaitOperatorBenchmark.java:89)
at
org.apache.flink.benchmark.AsyncWaitOperatorBenchmark$1.invoke(AsyncWaitOperatorBenchmark.java:85)
at
org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(SinkFunction.java:50)
at
org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54)
at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)
(...)
```
And if that happens benchmark doesn't shut down:
```
12:29:30,952 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
[] - Stopped Akka RPC service.
<JMH had finished, but forked VM did not exit, are there stray running
threads? Waiting 24 seconds more...>
Non-finished threads:
Thread[pool-2-thread-6,5,main]
at sun.misc.Unsafe.park(Native Method)
(...)
```
But that looks like a pre-existing problem unrelated to this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
