Skip to content

Commit

Permalink
Fix scala fmt failure on MV query line
Browse files Browse the repository at this point in the history
Signed-off-by: Chen Dai <[email protected]>
  • Loading branch information
dai-chen committed Sep 22, 2023
1 parent aab3059 commit 7c433b4
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,10 @@ class FlintSparkMaterializedViewITSuite extends FlintSparkSuite {

val index = flint.describeIndex(testFlintIndex)
index shouldBe defined

val expectedSource =
"\n SELECT\n window.start AS startTime,\n COUNT(*) AS count\n" +
" FROM default.mv_test\n GROUP BY TUMBLE(time, '1 Hour')\n"
index.get.metadata().getContent should matchJson(s"""
| {
| "_meta": {
Expand All @@ -57,7 +61,7 @@ class FlintSparkMaterializedViewITSuite extends FlintSparkSuite {
| "columnName": "count",
| "columnType": "long"
| }],
| "source": "\n SELECT\n window.start AS startTime,\n COUNT(*) AS count\n FROM default.mv_test\n GROUP BY TUMBLE(time, '1 Hour')\n",
| "source": "$expectedSource",
| "options": {}
| },
| "properties": {
Expand Down

0 comments on commit 7c433b4

Please sign in to comment.