Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6323#discussion_r202350170
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -103,24 +103,40 @@ abstract class BatchTableEnvironment(
: Unit = {
tableSource match {
+
+ // check for proper batch table source
--- End diff --
ditto, those changes do seems to not belong to this commit. If so please
extract them to separate one:
```
git reset --soft HEAD^
git reset HEAD
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
git commit -m "Clean up and simplify changes"
git commit -a --fixup=42a8a156d4e6f8f3d119c458350b6c897306fc48 # MD5 of
Shuyi Chen's commit
git rebase -i origin/master --autosquash
```
---
