New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-1982] [record-api] Remove dependencies on Record API from flink-runtime tests #1294
Conversation
…k-runtime tests Rename Match*Test to Join*Test
@@ -39,7 +38,7 @@ | |||
import org.junit.Test; | |||
|
|||
@SuppressWarnings("deprecation") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this suppression can be removed
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Good catch, thanks!
Will check the other classes as well.
Updated |
@@ -38,8 +37,7 @@ | |||
import org.junit.Assert; | |||
import org.junit.Test; | |||
|
|||
@SuppressWarnings("deprecation") | |||
public class MapTaskTest extends DriverTestBase<GenericCollectorMap<Record, Record>> { | |||
public class MapTaskTest extends DriverTestBase<FlatMapFunction<Record, Record>> { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Small nit: should probably rename this to FlatMapTaskTest
since now it is actually using flatMap
function instead?
36d8fa4
to
9df82a9
Compare
Thanks @hsaputra |
Will merge this PR |
…k-runtime tests Rename Match*Test to Join*Test and MapTaskTest to FlatMapTaskTest This closes #1294
Rename Match_Test to Join_Test