Skip to content

Commit 45c47ba

Browse files
gustavodemoraisdawidwys
gustavodemorais
authored and
dawidwys
committed
[FLINK-38211][table] Regenerate description restore tests
1 parent 5b546e7 commit 45c47ba

File tree

18 files changed

+157
-96
lines changed

18 files changed

+157
-96
lines changed

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-complex-preserves-upsert-key-with-restore/plan/four-way-complex-preserves-upsert-key-with-restore.json‎

Lines changed: 41 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
{
22
"flinkVersion" : "2.2",
33
"nodes" : [ {
4-
"id" : 1,
4+
"id" : 68,
55
"type" : "stream-exec-table-source-scan_1",
66
"scanTableSource" : {
77
"table" : {
@@ -27,7 +27,7 @@
2727
"outputType" : "ROW<`user_id_0` VARCHAR(2147483647) NOT NULL, `name` VARCHAR(2147483647)>",
2828
"description" : "TableSourceScan(table=[[default_catalog, default_database, Users]], fields=[user_id_0, name])"
2929
}, {
30-
"id" : 2,
30+
"id" : 69,
3131
"type" : "stream-exec-exchange_1",
3232
"inputProperties" : [ {
3333
"requiredDistribution" : {
@@ -40,7 +40,7 @@
4040
"outputType" : "ROW<`user_id_0` VARCHAR(2147483647) NOT NULL, `name` VARCHAR(2147483647)>",
4141
"description" : "Exchange(distribution=[hash[user_id_0]])"
4242
}, {
43-
"id" : 3,
43+
"id" : 70,
4444
"type" : "stream-exec-table-source-scan_1",
4545
"scanTableSource" : {
4646
"table" : {
@@ -73,7 +73,7 @@
7373
"outputType" : "ROW<`order_id` VARCHAR(2147483647) NOT NULL, `user_id_1` VARCHAR(2147483647) NOT NULL, `product` VARCHAR(2147483647)>",
7474
"description" : "TableSourceScan(table=[[default_catalog, default_database, Orders, filter=[]]], fields=[order_id, user_id_1, product])"
7575
}, {
76-
"id" : 4,
76+
"id" : 71,
7777
"type" : "stream-exec-calc_1",
7878
"projection" : [ {
7979
"kind" : "INPUT_REF",
@@ -105,7 +105,7 @@
105105
"outputType" : "ROW<`order_id` VARCHAR(2147483647) NOT NULL, `user_id_1` VARCHAR(2147483647) NOT NULL>",
106106
"description" : "Calc(select=[order_id, user_id_1], where=[product IS NOT NULL])"
107107
}, {
108-
"id" : 5,
108+
"id" : 72,
109109
"type" : "stream-exec-exchange_1",
110110
"inputProperties" : [ {
111111
"requiredDistribution" : {
@@ -118,7 +118,7 @@
118118
"outputType" : "ROW<`order_id` VARCHAR(2147483647) NOT NULL, `user_id_1` VARCHAR(2147483647) NOT NULL>",
119119
"description" : "Exchange(distribution=[hash[user_id_1]])"
120120
}, {
121-
"id" : 6,
121+
"id" : 73,
122122
"type" : "stream-exec-table-source-scan_1",
123123
"scanTableSource" : {
124124
"table" : {
@@ -151,7 +151,7 @@
151151
"outputType" : "ROW<`payment_id` VARCHAR(2147483647) NOT NULL, `user_id_2` VARCHAR(2147483647) NOT NULL, `price` INT>",
152152
"description" : "TableSourceScan(table=[[default_catalog, default_database, Payments, filter=[]]], fields=[payment_id, user_id_2, price])"
153153
}, {
154-
"id" : 7,
154+
"id" : 74,
155155
"type" : "stream-exec-calc_1",
156156
"projection" : [ {
157157
"kind" : "INPUT_REF",
@@ -187,7 +187,7 @@
187187
"outputType" : "ROW<`payment_id` VARCHAR(2147483647) NOT NULL, `user_id_2` VARCHAR(2147483647) NOT NULL>",
188188
"description" : "Calc(select=[payment_id, user_id_2], where=[(price >= 0)])"
189189
}, {
190-
"id" : 8,
190+
"id" : 75,
191191
"type" : "stream-exec-exchange_1",
192192
"inputProperties" : [ {
193193
"requiredDistribution" : {
@@ -200,7 +200,7 @@
200200
"outputType" : "ROW<`payment_id` VARCHAR(2147483647) NOT NULL, `user_id_2` VARCHAR(2147483647) NOT NULL>",
201201
"description" : "Exchange(distribution=[hash[user_id_2]])"
202202
}, {
203-
"id" : 9,
203+
"id" : 76,
204204
"type" : "stream-exec-table-source-scan_1",
205205
"scanTableSource" : {
206206
"table" : {
@@ -230,7 +230,7 @@
230230
"outputType" : "ROW<`user_id_3` VARCHAR(2147483647) NOT NULL, `location` VARCHAR(2147483647)>",
231231
"description" : "TableSourceScan(table=[[default_catalog, default_database, Address, filter=[]]], fields=[user_id_3, location])"
232232
}, {
233-
"id" : 10,
233+
"id" : 77,
234234
"type" : "stream-exec-calc_1",
235235
"projection" : [ {
236236
"kind" : "INPUT_REF",
@@ -262,7 +262,7 @@
262262
"outputType" : "ROW<`user_id_3` VARCHAR(2147483647) NOT NULL, `location` VARCHAR(2147483647)>",
263263
"description" : "Calc(select=[user_id_3, location], where=[location IS NOT NULL])"
264264
}, {
265-
"id" : 11,
265+
"id" : 78,
266266
"type" : "stream-exec-exchange_1",
267267
"inputProperties" : [ {
268268
"requiredDistribution" : {
@@ -275,7 +275,7 @@
275275
"outputType" : "ROW<`user_id_3` VARCHAR(2147483647) NOT NULL, `location` VARCHAR(2147483647)>",
276276
"description" : "Exchange(distribution=[hash[user_id_3]])"
277277
}, {
278-
"id" : 12,
278+
"id" : 79,
279279
"type" : "stream-exec-multi-join_1",
280280
"joinTypes" : [ "INNER", "INNER", "INNER", "INNER" ],
281281
"joinConditions" : [ {
@@ -458,9 +458,9 @@
458458
"priority" : 3
459459
} ],
460460
"outputType" : "ROW<`user_id_0` VARCHAR(2147483647) NOT NULL, `name` VARCHAR(2147483647), `order_id` VARCHAR(2147483647) NOT NULL, `user_id_1` VARCHAR(2147483647) NOT NULL, `payment_id` VARCHAR(2147483647) NOT NULL, `user_id_2` VARCHAR(2147483647) NOT NULL, `user_id_3` VARCHAR(2147483647) NOT NULL, `location` VARCHAR(2147483647)>",
461-
"description" : "MultiJoin(joinFilter=[AND(=($0, $6), =($0, $5), =($0, $3))], joinTypes=[[INNER, INNER, INNER, INNER]], joinConditions=[[true, =($0, $3), =($0, $5), =($0, $6)]], joinAttributeMap=[{0=[LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;, LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;, LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;], 1=[LeftInputId:0;LeftFieldIndex:0;RightInputId:1;RightFieldIndex:1;], 2=[LeftInputId:0;LeftFieldIndex:0;RightInputId:2;RightFieldIndex:1;], 3=[LeftInputId:0;LeftFieldIndex:0;RightInputId:3;RightFieldIndex:0;]}], select=[user_id_0,name,order_id,user_id_1,payment_id,user_id_2,user_id_3,location], rowType=[RecordType(VARCHAR(2147483647) user_id_0, VARCHAR(2147483647) name, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id_1, VARCHAR(2147483647) payment_id, VARCHAR(2147483647) user_id_2, VARCHAR(2147483647) user_id_3, VARCHAR(2147483647) location)])"
461+
"description" : "MultiJoin(commonJoinKey=[user_id_0], joinTypes=[INNER, INNER, INNER], inputUniqueKeys=[(user_id_0), (order_id, user_id_1), (payment_id, user_id_2), (user_id_3)], joinConditions=[(user_id_0 = user_id_1), (user_id_0 = user_id_2), (user_id_0 = user_id_3)], select=[user_id_0,name,order_id,user_id_1,payment_id,user_id_2,user_id_3,location], rowType=[RecordType(VARCHAR(2147483647) user_id_0, VARCHAR(2147483647) name, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id_1, VARCHAR(2147483647) payment_id, VARCHAR(2147483647) user_id_2, VARCHAR(2147483647) user_id_3, VARCHAR(2147483647) location)])"
462462
}, {
463-
"id" : 13,
463+
"id" : 80,
464464
"type" : "stream-exec-calc_1",
465465
"projection" : [ {
466466
"kind" : "INPUT_REF",
@@ -502,7 +502,7 @@
502502
"outputType" : "ROW<`user_id_0` VARCHAR(2147483647) NOT NULL, `order_id` VARCHAR(2147483647) NOT NULL, `user_id_1` VARCHAR(2147483647) NOT NULL, `payment_id` VARCHAR(2147483647) NOT NULL, `user_id_2` VARCHAR(2147483647) NOT NULL, `name` VARCHAR(2147483647), `location` VARCHAR(2147483647)>",
503503
"description" : "Calc(select=[user_id_0, order_id, user_id_1, payment_id, user_id_2, name, location])"
504504
}, {
505-
"id" : 14,
505+
"id" : 81,
506506
"type" : "stream-exec-sink_1",
507507
"configuration" : {
508508
"table.exec.sink.keyed-shuffle" : "AUTO",
@@ -560,92 +560,92 @@
560560
"description" : "Sink(table=[default_catalog.default_database.sink], fields=[user_id_0, order_id, user_id_1, payment_id, user_id_2, name, location])"
561561
} ],
562562
"edges" : [ {
563-
"source" : 1,
564-
"target" : 2,
563+
"source" : 68,
564+
"target" : 69,
565565
"shuffle" : {
566566
"type" : "FORWARD"
567567
},
568568
"shuffleMode" : "PIPELINED"
569569
}, {
570-
"source" : 3,
571-
"target" : 4,
570+
"source" : 70,
571+
"target" : 71,
572572
"shuffle" : {
573573
"type" : "FORWARD"
574574
},
575575
"shuffleMode" : "PIPELINED"
576576
}, {
577-
"source" : 4,
578-
"target" : 5,
577+
"source" : 71,
578+
"target" : 72,
579579
"shuffle" : {
580580
"type" : "FORWARD"
581581
},
582582
"shuffleMode" : "PIPELINED"
583583
}, {
584-
"source" : 6,
585-
"target" : 7,
584+
"source" : 73,
585+
"target" : 74,
586586
"shuffle" : {
587587
"type" : "FORWARD"
588588
},
589589
"shuffleMode" : "PIPELINED"
590590
}, {
591-
"source" : 7,
592-
"target" : 8,
591+
"source" : 74,
592+
"target" : 75,
593593
"shuffle" : {
594594
"type" : "FORWARD"
595595
},
596596
"shuffleMode" : "PIPELINED"
597597
}, {
598-
"source" : 9,
599-
"target" : 10,
598+
"source" : 76,
599+
"target" : 77,
600600
"shuffle" : {
601601
"type" : "FORWARD"
602602
},
603603
"shuffleMode" : "PIPELINED"
604604
}, {
605-
"source" : 10,
606-
"target" : 11,
605+
"source" : 77,
606+
"target" : 78,
607607
"shuffle" : {
608608
"type" : "FORWARD"
609609
},
610610
"shuffleMode" : "PIPELINED"
611611
}, {
612-
"source" : 2,
613-
"target" : 12,
612+
"source" : 69,
613+
"target" : 79,
614614
"shuffle" : {
615615
"type" : "FORWARD"
616616
},
617617
"shuffleMode" : "PIPELINED"
618618
}, {
619-
"source" : 5,
620-
"target" : 12,
619+
"source" : 72,
620+
"target" : 79,
621621
"shuffle" : {
622622
"type" : "FORWARD"
623623
},
624624
"shuffleMode" : "PIPELINED"
625625
}, {
626-
"source" : 8,
627-
"target" : 12,
626+
"source" : 75,
627+
"target" : 79,
628628
"shuffle" : {
629629
"type" : "FORWARD"
630630
},
631631
"shuffleMode" : "PIPELINED"
632632
}, {
633-
"source" : 11,
634-
"target" : 12,
633+
"source" : 78,
634+
"target" : 79,
635635
"shuffle" : {
636636
"type" : "FORWARD"
637637
},
638638
"shuffleMode" : "PIPELINED"
639639
}, {
640-
"source" : 12,
641-
"target" : 13,
640+
"source" : 79,
641+
"target" : 80,
642642
"shuffle" : {
643643
"type" : "FORWARD"
644644
},
645645
"shuffleMode" : "PIPELINED"
646646
}, {
647-
"source" : 13,
648-
"target" : 14,
647+
"source" : 80,
648+
"target" : 81,
649649
"shuffle" : {
650650
"type" : "FORWARD"
651651
},

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-complex-preserves-upsert-key-with-restore/savepoint/_metadata‎

12 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-complex-updating-join-with-restore/plan/four-way-complex-updating-join-with-restore.json‎

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -380,6 +380,17 @@
380380
"type" : "BOOLEAN"
381381
},
382382
"joinAttributeMap" : {
383+
"0" : [ {
384+
"leftInputId" : -1,
385+
"leftFieldIndex" : -1,
386+
"rightInputId" : 0,
387+
"rightFieldIndex" : 1
388+
}, {
389+
"leftInputId" : -1,
390+
"leftFieldIndex" : -1,
391+
"rightInputId" : 0,
392+
"rightFieldIndex" : 1
393+
} ],
383394
"1" : [ {
384395
"leftInputId" : 0,
385396
"leftFieldIndex" : 1,
@@ -447,7 +458,7 @@
447458
"priority" : 3
448459
} ],
449460
"outputType" : "ROW<`name` VARCHAR(2147483647), `user_id_0` VARCHAR(2147483647) NOT NULL, `cash` INT, `order_id` VARCHAR(2147483647), `user_id_1` VARCHAR(2147483647), `user_id_2` VARCHAR(2147483647), `payment_id` VARCHAR(2147483647) NOT NULL, `price` INT, `location` VARCHAR(2147483647), `user_id_3` VARCHAR(2147483647)>",
450-
"description" : "MultiJoin(commonJoinKey=[user_id_0], joinTypes=[INNER, LEFT, INNER, LEFT], inputUniqueKeys=[(user_id_0), (order_id), (payment_id), noUniqueKey], joinConditions=[true, (user_id_0 = user_id_1), ((user_id_0 = user_id_2) AND ((cash >= price) OR (price < 0))), (user_id_2 = user_id_3)], joinFilter=[((user_id_0 = user_id_2) AND ((cash >= price) OR (price < 0)))], select=[name,user_id_0,cash,order_id,user_id_1,user_id_2,payment_id,price,location,user_id_3], outputRowType=[RecordType(VARCHAR(2147483647) name, VARCHAR(2147483647) user_id_0, INTEGER cash, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id_1, VARCHAR(2147483647) user_id_2, VARCHAR(2147483647) payment_id, INTEGER price, VARCHAR(2147483647) location, VARCHAR(2147483647) user_id_3)])"
461+
"description" : "MultiJoin(commonJoinKey=[user_id_0], joinTypes=[LEFT, INNER, LEFT], inputUniqueKeys=[(user_id_0), (order_id), (payment_id), noUniqueKey], joinConditions=[(user_id_0 = user_id_1), ((user_id_0 = user_id_2) AND ((cash >= price) OR (price < 0))), (user_id_2 = user_id_3)], select=[name,user_id_0,cash,order_id,user_id_1,user_id_2,payment_id,price,location,user_id_3], rowType=[RecordType(VARCHAR(2147483647) name, VARCHAR(2147483647) user_id_0, INTEGER cash, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id_1, VARCHAR(2147483647) user_id_2, VARCHAR(2147483647) payment_id, INTEGER price, VARCHAR(2147483647) location, VARCHAR(2147483647) user_id_3)])"
451462
}, {
452463
"id" : 30,
453464
"type" : "stream-exec-calc_1",

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-complex-updating-join-with-restore/savepoint/_metadata‎

14 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-join-no-common-join-key-with-restore/plan/four-way-join-no-common-join-key-with-restore.json‎

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -262,6 +262,17 @@
262262
"type" : "BOOLEAN"
263263
},
264264
"joinAttributeMap" : {
265+
"0" : [ {
266+
"leftInputId" : -1,
267+
"leftFieldIndex" : -1,
268+
"rightInputId" : 0,
269+
"rightFieldIndex" : 1
270+
}, {
271+
"leftInputId" : -1,
272+
"leftFieldIndex" : -1,
273+
"rightInputId" : 0,
274+
"rightFieldIndex" : 1
275+
} ],
265276
"1" : [ {
266277
"leftInputId" : 0,
267278
"leftFieldIndex" : 1,
@@ -312,7 +323,7 @@
312323
"priority" : 2
313324
} ],
314325
"outputType" : "ROW<`name` VARCHAR(2147483647), `user_id_0` VARCHAR(2147483647) NOT NULL, `order_id` VARCHAR(2147483647), `user_id_1` VARCHAR(2147483647), `user_id_2` VARCHAR(2147483647), `payment_id` VARCHAR(2147483647) NOT NULL>",
315-
"description" : "MultiJoin(commonJoinKey=[user_id_0], joinTypes=[INNER, LEFT, INNER], inputUniqueKeys=[(user_id_0), (order_id), (payment_id)], joinConditions=[true, (user_id_0 = user_id_1), (user_id_0 = user_id_2)], joinFilter=[(user_id_0 = user_id_2)], select=[name,user_id_0,order_id,user_id_1,user_id_2,payment_id], outputRowType=[RecordType(VARCHAR(2147483647) name, VARCHAR(2147483647) user_id_0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id_1, VARCHAR(2147483647) user_id_2, VARCHAR(2147483647) payment_id)])"
326+
"description" : "MultiJoin(commonJoinKey=[user_id_0], joinTypes=[LEFT, INNER], inputUniqueKeys=[(user_id_0), (order_id), (payment_id)], joinConditions=[(user_id_0 = user_id_1), (user_id_0 = user_id_2)], select=[name,user_id_0,order_id,user_id_1,user_id_2,payment_id], rowType=[RecordType(VARCHAR(2147483647) name, VARCHAR(2147483647) user_id_0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id_1, VARCHAR(2147483647) user_id_2, VARCHAR(2147483647) payment_id)])"
316327
}, {
317328
"id" : 41,
318329
"type" : "stream-exec-calc_1",
@@ -429,6 +440,12 @@
429440
"type" : "BOOLEAN"
430441
},
431442
"joinAttributeMap" : {
443+
"0" : [ {
444+
"leftInputId" : -1,
445+
"leftFieldIndex" : -1,
446+
"rightInputId" : 0,
447+
"rightFieldIndex" : 3
448+
} ],
432449
"1" : [ {
433450
"leftInputId" : 0,
434451
"leftFieldIndex" : 3,
@@ -462,7 +479,7 @@
462479
"priority" : 1
463480
} ],
464481
"outputType" : "ROW<`name` VARCHAR(2147483647), `user_id_0` VARCHAR(2147483647) NOT NULL, `order_id` VARCHAR(2147483647), `payment_id` VARCHAR(2147483647) NOT NULL, `location` VARCHAR(2147483647), `user_id_3` VARCHAR(2147483647)>",
465-
"description" : "MultiJoin(commonJoinKey=[payment_id], joinTypes=[INNER, LEFT], inputUniqueKeys=[noUniqueKey, noUniqueKey], joinConditions=[true, (payment_id = user_id_3)], joinFilter=[true], select=[name,user_id_0,order_id,payment_id,location,user_id_3], outputRowType=[RecordType(VARCHAR(2147483647) name, VARCHAR(2147483647) user_id_0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) payment_id, VARCHAR(2147483647) location, VARCHAR(2147483647) user_id_3)])"
482+
"description" : "MultiJoin(commonJoinKey=[payment_id], joinTypes=[LEFT], inputUniqueKeys=[noUniqueKey, noUniqueKey], joinConditions=[(payment_id = user_id_3)], select=[name,user_id_0,order_id,payment_id,location,user_id_3], rowType=[RecordType(VARCHAR(2147483647) name, VARCHAR(2147483647) user_id_0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) payment_id, VARCHAR(2147483647) location, VARCHAR(2147483647) user_id_3)])"
466483
}, {
467484
"id" : 46,
468485
"type" : "stream-exec-calc_1",

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-join-no-common-join-key-with-restore/savepoint/_metadata‎

0 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/three-way-inner-join-with-restore/plan/three-way-inner-join-with-restore.json‎

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,6 +175,17 @@
175175
"type" : "BOOLEAN"
176176
},
177177
"joinAttributeMap" : {
178+
"0" : [ {
179+
"leftInputId" : -1,
180+
"leftFieldIndex" : -1,
181+
"rightInputId" : 0,
182+
"rightFieldIndex" : 0
183+
}, {
184+
"leftInputId" : -1,
185+
"leftFieldIndex" : -1,
186+
"rightInputId" : 0,
187+
"rightFieldIndex" : 0
188+
} ],
178189
"1" : [ {
179190
"leftInputId" : 0,
180191
"leftFieldIndex" : 0,
@@ -225,7 +236,7 @@
225236
"priority" : 2
226237
} ],
227238
"outputType" : "ROW<`user_id` VARCHAR(2147483647), `name` VARCHAR(2147483647), `user_id0` VARCHAR(2147483647), `order_id` VARCHAR(2147483647), `user_id1` VARCHAR(2147483647), `payment_id` VARCHAR(2147483647)>",
228-
"description" : "MultiJoin(commonJoinKey=[user_id], joinTypes=[INNER, INNER, INNER], inputUniqueKeys=[noUniqueKey, noUniqueKey, noUniqueKey], joinConditions=[true, (user_id = user_id0), (user_id = user_id1)], joinFilter=[((user_id = user_id1) AND (user_id = user_id0))], select=[user_id,name,user_id0,order_id,user_id1,payment_id], outputRowType=[RecordType(VARCHAR(2147483647) user_id, VARCHAR(2147483647) name, VARCHAR(2147483647) user_id0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id1, VARCHAR(2147483647) payment_id)])"
239+
"description" : "MultiJoin(commonJoinKey=[user_id], joinTypes=[INNER, INNER], inputUniqueKeys=[noUniqueKey, noUniqueKey, noUniqueKey], joinConditions=[(user_id = user_id0), (user_id = user_id1)], select=[user_id,name,user_id0,order_id,user_id1,payment_id], rowType=[RecordType(VARCHAR(2147483647) user_id, VARCHAR(2147483647) name, VARCHAR(2147483647) user_id0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id1, VARCHAR(2147483647) payment_id)])"
229240
}, {
230241
"id" : 8,
231242
"type" : "stream-exec-calc_1",

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/three-way-inner-join-with-restore/savepoint/_metadata‎

5 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/three-way-inner-join-with-ttl-hints-with-restore/plan/three-way-inner-join-with-ttl-hints-with-restore.json‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@
236236
"priority" : 2
237237
} ],
238238
"outputType" : "ROW<`user_id` VARCHAR(2147483647), `name` VARCHAR(2147483647), `user_id0` VARCHAR(2147483647), `order_id` VARCHAR(2147483647), `user_id1` VARCHAR(2147483647), `payment_id` VARCHAR(2147483647)>",
239-
"description" : "MultiJoin(joinFilter=[AND(=($0, $4), =($0, $2))], joinTypes=[[INNER, INNER, INNER]], joinConditions=[[true, =($0, $2), =($0, $4)]], joinAttributeMap=[{0=[LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;, LeftInputId:-1;LeftFieldIndex:-1;RightInputId:0;RightFieldIndex:0;], 1=[LeftInputId:0;LeftFieldIndex:0;RightInputId:1;RightFieldIndex:0;], 2=[LeftInputId:0;LeftFieldIndex:0;RightInputId:2;RightFieldIndex:0;]}], select=[user_id,name,user_id0,order_id,user_id1,payment_id], rowType=[RecordType(VARCHAR(2147483647) user_id, VARCHAR(2147483647) name, VARCHAR(2147483647) user_id0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id1, VARCHAR(2147483647) payment_id)], stateTtlHints=[[[STATE_TTL options:[1d, 0s, 2d]]]])"
239+
"description" : "MultiJoin(commonJoinKey=[user_id], joinTypes=[INNER, INNER], inputUniqueKeys=[noUniqueKey, noUniqueKey, noUniqueKey], stateTtlHints=[[[STATE_TTL options:[1d, 0s, 2d]]]], joinConditions=[(user_id = user_id0), (user_id = user_id1)], select=[user_id,name,user_id0,order_id,user_id1,payment_id], rowType=[RecordType(VARCHAR(2147483647) user_id, VARCHAR(2147483647) name, VARCHAR(2147483647) user_id0, VARCHAR(2147483647) order_id, VARCHAR(2147483647) user_id1, VARCHAR(2147483647) payment_id)])"
240240
}, {
241241
"id" : 66,
242242
"type" : "stream-exec-calc_1",

‎flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/three-way-inner-join-with-ttl-hints-with-restore/savepoint/_metadata‎

0 Bytes
Binary file not shown.

0 commit comments

Comments
 (0)