Hi, I am trying to create an sql statement that is suppose to return a string and and integer
Mytable.sql("select mystringfield,myintfield .... ) I am trying to give the typefinormation as a class to the TypeInformation<Tuple2<String, Long>> tpinf = new TypeHint<Tuple2<String, Long>>(){}.getTypeInfo(); .toDataStream( , tpinf.getTypeClass() ) However I get the following error shown below. Can someone give me an example of some working tuples for this case. Exception in thread "main" org.apache.flink.api.common.functions.InvalidTypesException: Tuple needs to be parameterized by using generics. at