yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-436592966
AFAIK, many test cases are unstable. Recently, I have encountered Travis
failures caused by various problems in
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-436235491
@shaoxuan-wang Can you share your error log with us? The test cases related
to kafka connector are not very
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-435904341
updated.
This is an automated message from the
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-435902208
@pnowojski Oh... yes, I take it for granted that this is streaming's example
and does not rely on batch API. It's
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-435898739
@pnowojski updated (squashed commits for `pull --rebase`) and I think what
do mean is `flink-streaming-java` and
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434615379
@pnowojski Thank you for your guidance, now the test can pass. I submitted
the last change, can you help me to
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434539461
@pnowojski I can give you more details :
added `set -x` and `set -e`:
```
+ stop_kafka_cluster
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434372198
@pnowojski I just tested again, added `set -x` on the top of
`kafka-common.sh`, `test_streaming_kafka_common.sh`
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434361242
> shell function `get_partition_end_offset` in kafka-common.sh :
>
> ```
>
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434358753
@pnowojski I have debugged locally, and the new changes have fixed the shell
error. Before fixing, even if I do
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434348494
@pnowojski You can check the [old Travis
log](https://api.travis-ci.org/v3/job/448260257/log.txt). Just search :
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434255369
@pnowojski We cannot add `set -e` to top of the modified files. This action
would cause the test to fail.
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-434190482
@tzulitai shell function `get_partition_end_offset` in kafka-common.sh :
```
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433904230
Let me try to locate it. This code was written by @tzulitai before.
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433887813
@pnowojski I have fixed some of the issues you mentioned. Regarding the
shell error, I don't actually change the
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433603466
@pnowojski I solved the test problem and it is now ready to be reviewed
again.
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433472224
No, I mean if we package a jar which contains old connector and new
connector and multiple kafka client this pr's
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-433394209
@pnowojski Using maven-shade-plugin, it's hard to type a jar that doesn't
contain flink kafka 0.10 or old kafka
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases
for modern Kafka connectors
URL: https://github.com/apache/flink/pull/6924#issuecomment-432962337
@pnowojski The error log shows my new shell script has permission problem :
`test_streaming_kafka.sh: Permission
19 matches
Mail list logo
