Skip to content

Commit 503d307

Browse files
committed
check if outputSpec is not specified.
1 parent e7af902 commit 503d307

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

windowing/src/main/java/com/sap/hadoop/windowing/query2/translate/OutputTranslation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public static void validateOutputSpec(QueryDef qDef) throws WindowingException
5757
QueryOutputSpec spec = qDef.getSpec().getOutput();
5858

5959
// ensure outputPath is specified. It is optional in grammar because it is not required in Hive mode.
60-
if ( spec.getPath() == null )
60+
if ( spec == null || spec.getPath() == null )
6161
{
6262
throw new WindowingException("Query doesn't contain an output Path for results");
6363
}

0 commit comments

Comments
 (0)