[
https://issues.apache.org/jira/browse/FLINK-23835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409527#comment-17409527
]
Matthias commented on FLINK-23835:
----------------------------------
I did a manual test on this issue using the data from
[DataStreamJavaITCase|https://github.com/apache/flink/pull/17060/files#diff-a08bcfb72b9ea9207dbc53c4149608589136f22c1f8b6acb1a84083708d18807]:
{code}
# topic 1
./kafka_2.12-2.4.1/bin/kafka-console-producer.sh --topic flink-23850-in1
--broker-list localhost:9092 --property "parse.key=true" --property
"key.separator=:"
>1:1,1
>2:2,2
{code}
{code}
# topic 2
./kafka_2.12-2.4.1/bin/kafka-console-producer.sh --topic flink-23850-in2
--broker-list localhost:9092 --property "parse.key=true" --property
"key.separator=:"
>1:1,A,1.0
>2:2,B,2.0
>1:1,A,1.1
>2:2,B,2.1
{code}
{code}
# topic 3
./kafka_2.12-2.4.1/bin/kafka-console-producer.sh --topic flink-23850-in3
--broker-list localhost:9092 --property "parse.key=true" --property
"key.separator=:"
>1,A:1,A,10.0
>1,B:1,B,11.0
{code}
The corresponding output matches the ITCase's expected output:
{code}
./kafka_2.12-2.4.1/bin/kafka-console-consumer.sh --topic flink-23850-out
--from-beginning --bootstrap-server localhost:9092 --consumer-property
isolation.level=read_committed --property print.key=true
1 1,10.0,1,A
1 null
1 1,11.0,1,A
2 2,,,
2 null
2 2,,,
1 1,,,
1 1,11.0,1,A
2 2,,,
1 1,,,
1 1,11.0,1,A
2 2,,,
{code}
> Test upsert sink with upsert keys
> ---------------------------------
>
> Key: FLINK-23835
> URL: https://issues.apache.org/jira/browse/FLINK-23835
> Project: Flink
> Issue Type: Improvement
> Components: Tests
> Reporter: Jingsong Lee
> Assignee: Timo Walther
> Priority: Major
> Fix For: 1.14.0
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
