Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/983#discussion_r36411464
--- Diff:
flink-staging/flink-language-binding/flink-language-binding-generic/src/main/java/org/apache/flink/languagebinding/api/java/common/streaming/Receiver.java
---
@@ -346,61 +349,12 @@ public Tuple deserialize() {
}
public static Tuple createTuple(int size) {
- switch (size) {
- case 0:
- return new Tuple0();
- case 1:
- return new Tuple1();
- case 2:
- return new Tuple2();
- case 3:
- return new Tuple3();
- case 4:
- return new Tuple4();
- case 5:
- return new Tuple5();
- case 6:
- return new Tuple6();
- case 7:
- return new Tuple7();
- case 8:
- return new Tuple8();
- case 9:
- return new Tuple9();
- case 10:
- return new Tuple10();
- case 11:
- return new Tuple11();
- case 12:
- return new Tuple12();
- case 13:
- return new Tuple13();
- case 14:
- return new Tuple14();
- case 15:
- return new Tuple15();
- case 16:
- return new Tuple16();
- case 17:
- return new Tuple17();
- case 18:
- return new Tuple18();
- case 19:
- return new Tuple19();
- case 20:
- return new Tuple20();
- case 21:
- return new Tuple21();
- case 22:
- return new Tuple22();
- case 23:
- return new Tuple23();
- case 24:
- return new Tuple24();
- case 25:
- return new Tuple25();
- default:
- throw new IllegalArgumentException("Tuple size
not supported: " + size);
+ try {
+ return Tuple.getTupleClass(size).newInstance();
--- End diff --
Yep, you're right...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
