Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r156940557
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/stringexpr/CorrelateStringExpressionTest.scala
---
@@ -34,7 +34,7 @@ class CorrelateStringExpressionTest extends TableTestBase
{
val util = streamTestUtil()
val sTab = util.addTable[(Int, Long, String)]('a, 'b, 'c)
- val typeInfo = new RowTypeInfo(Seq(Types.INT, Types.LONG,
Types.STRING): _*)
+ val typeInfo = new RowTypeInfo(Seq(typeutils.Types.INT,
typeutils.Types.LONG, typeutils.Types.STRING): _*)
--- End diff --
line exceeds 100 characters.
---
