[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-16 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r808740283 ## File path: pom.xml ## @@ -54,20 +54,23 @@ under the License. flink-table-store-core flink-table-store-connector +

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-18 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r809796359 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/log/LogStoreTableFactory.java ## @@ -0,0 +1,132 @@ +/* + * Licen

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-18 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r809796729 ## File path: flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java ## @@ -0,0 +1,189 @@ +/* + * Licensed

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-18 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r809797632 ## File path: flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/TestOffsetsLogSink.java ## @@ -0,0 +1,105 @@ +/* + * Lice

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-18 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r809805083 ## File path: flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java ## @@ -0,0 +1,189 @@ +/* + * Licensed

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #20: [FLINK-26103] Introduce log store

2022-02-18 Thread GitBox
JingsongLi commented on a change in pull request #20: URL: https://github.com/apache/flink-table-store/pull/20#discussion_r809810261 ## File path: flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaLogITCase.java ## @@ -0,0 +1,189 @@ +/* + * Licensed