rkhachatryan opened a new pull request #16401:
URL: https://github.com/apache/flink/pull/16401
## What is the purpose of the change
Log for `JdbcExactlyOnceSinkE2eTest`: db type, progress, errors, task
transitions, wait times.
Using hardcoded string to prevent log parsing scripts from failing CI (on
expected exceptions).
Sample size: 200Kb
Sample output:
```
2021-07-06 22:31:29,074 INFO test insert for postgres:9.6.12, parallelism=4
[main JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,698 DEBUG Mapper will fail after 3 records [Source:
Custom Source -> Map -> Sink: Unnamed (3/4)#0 JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,698 DEBUG Mapper will fail after 6 records [Source:
Custom Source -> Map -> Sink: Unnamed (4/4)#0 JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,698 DEBUG Mapper will fail after 14 records [Source:
Custom Source -> Map -> Sink: Unnamed (2/4)#0 JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,698 DEBUG Mapper will fail after 10 records [Source:
Custom Source -> Map -> Sink: Unnamed (1/4)#0 JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,699 DEBUG Source initialized with ranges: [100..150]
[Source: Custom Source -> Map -> Sink: Unnamed (3/4)#0
JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,700 DEBUG Source initialized with ranges: [0..50]
[Source: Custom Source -> Map -> Sink: Unnamed (1/4)#0
JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,700 DEBUG Source initialized with ranges: [150..200]
[Source: Custom Source -> Map -> Sink: Unnamed (4/4)#0
JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,701 DEBUG Source initialized with ranges: [50..100]
[Source: Custom Source -> Map -> Sink: Unnamed (2/4)#0
JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,952 DEBUG Mapper failing intentionally [Legacy Source
Thread - Source: Custom Source -> Map -> Sink: Unnamed (3/4)#0
JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:29,956 DEBUG Mapper failing intentionally [Legacy Source
Thread - Source: Custom Source -> Map -> Sink: Unnamed (4/4)#0
JdbcExactlyOnceSinkE2eTest]
2021-07-06 22:31:30,018 WARN Source: Custom Source -> Map -> Sink: Unnamed
(4/4)#0 (8571da132faab99391432bab1182eeed) switched from RUNNING to FAILED with
failure cause:
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest$TestException:
java.lang.Exception: Artificial failure
[Source: Custom Source -> Map -> Sink: Unnamed (4/4)#0 Task]
2021-07-06 22:31:30,018 WARN Source: Custom Source -> Map -> Sink: Unnamed
(3/4)#0 (e96da42632e92d517950d5aed126d87f) switched from RUNNING to FAILED with
failure cause:
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest$TestException:
java.lang.Exception: Artificial failure
[Source: Custom Source -> Map -> Sink: Unnamed (3/4)#0 Task]
```
--
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]
