[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #584: [FLINK-31338] support infer parallelism for flink table store

2023-03-10 Thread via GitHub
JingsongLi commented on code in PR #584: URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1132208344 ## flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java: ## @@ -162,15

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #584: [FLINK-31338] support infer parallelism for flink table store

2023-03-10 Thread via GitHub
JingsongLi commented on code in PR #584: URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1132084496 ## flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java: ## @@ -162,15

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #584: [FLINK-31338] support infer parallelism for flink table store

2023-03-10 Thread via GitHub
JingsongLi commented on code in PR #584: URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1132084496 ## flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java: ## @@ -162,15

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #584: [FLINK-31338] support infer parallelism for flink table store

2023-03-10 Thread via GitHub
JingsongLi commented on code in PR #584: URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1132073196 ## flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java: ## @@ -162,15

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #584: [FLINK-31338] support infer parallelism for flink table store

2023-03-09 Thread via GitHub
JingsongLi commented on code in PR #584: URL: https://github.com/apache/flink-table-store/pull/584#discussion_r1132003909 ## flink-table-store-flink/flink-table-store-flink-common/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java: ## @@ -162,15