|
Change Variable Type future : Future<byte[]> to future : Future<String> in method public testFoldingState() : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type future : Future<byte[]> to future : Future<Tuple2<Integer,Long>> in method private executeQuery(deadline Deadline, client QueryableStateClient, jobId JobID, queryableStateName String, valueSerializer TypeSerializer<Tuple2<Integer,Long>>, expected long) : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type results : Iterable<byte[]> to results : Iterable<Integer> in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type future : Future<Iterable<byte[]>> to future : Future<Iterable<Integer>> in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type serializedResult : Future<byte[]> to result : Future<Tuple2<Integer,Long>> in method public testQueryableState() : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type futures : List<Future<byte[]>> to futures : List<Future<Tuple2<Integer,Long>>> in method public testQueryableState() : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type futures : List<Future<byte[]>> to futures : List<Future<Integer>> in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type serializedKey : byte[] to valueSerializer : TypeSerializer<Tuple2<Integer,Long>> in method private executeQuery(deadline Deadline, client QueryableStateClient, jobId JobID, queryableStateName String, valueSerializer TypeSerializer<Tuple2<Integer,Long>>, expected long) : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type result : Future<byte[]> to result : Future<Integer> in method public testForceLookupOnOutdatedLocation() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type futureSequence : Future<Iterable<byte[]>> to futureSequence : Future<Iterable<Tuple2<Integer,Long>>> in method public testQueryableState() : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type buffer : byte[] to buffer : int in method public testIntegrationWithKvStateServer() : void in class org.apache.flink.runtime.query.QueryableStateClientTest |
From |
To |
|
Change Variable Type future : Future<byte[]> to future : Future<Tuple2<Integer,Long>> in method public testValueStateDefault() : void in class org.apache.flink.test.query.AbstractQueryableStateITCase |
From |
To |