deadwind4 commented on a change in pull request #18388:
URL: https://github.com/apache/flink/pull/18388#discussion_r791295394
##
File path: flink-connectors/pom.xml
##
@@ -105,6 +105,7 @@ under the License.
flink-sql-connector-hive-3.1.2
deadwind4 commented on a change in pull request #18388:
URL: https://github.com/apache/flink/pull/18388#discussion_r791427956
##
File path: flink-connectors/flink-sql-connector-pulsar/pom.xml
##
@@ -0,0 +1,73 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
deadwind4 commented on a change in pull request #18388:
URL: https://github.com/apache/flink/pull/18388#discussion_r791298184
##
File path:
tools/ci/java-ci-tools/src/main/java/org/apache/flink/tools/ci/licensecheck/JarFileChecker.java
##
@@ -210,6 +210,11 @@ private static
deadwind4 commented on a change in pull request #18388:
URL: https://github.com/apache/flink/pull/18388#discussion_r791295394
##
File path: flink-connectors/pom.xml
##
@@ -105,6 +105,7 @@ under the License.
flink-sql-connector-hive-3.1.2
deadwind4 commented on a change in pull request #18388:
URL: https://github.com/apache/flink/pull/18388#discussion_r790425806
##
File path: flink-python/pyflink/datastream/tests/test_connectors.py
##
@@ -149,6 +150,80 @@ def tearDown(self):
deadwind4 commented on a change in pull request #18388:
URL: https://github.com/apache/flink/pull/18388#discussion_r790406471
##
File path: flink-python/pyflink/datastream/connectors.py
##
@@ -1079,6 +1085,320 @@ def for_row_format(base_path: str, encoder: Encoder) ->
