[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339441796 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonLocalWriter.java

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339438820 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonLocalWriterFacto

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339438417 ## File path: integration/flink-proxy/src/main/java/org/apache/carbon/flink/ProxyRecoverable

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339438332 ## File path: integration/flink/src/main/java/org/apache/carbon/core/metadata/SegmentManager

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339437741 ## File path: integration/flink-proxy/pom.xml ## @@ -0,0 +1,43 @@ + +http://maven.a

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339438278 ## File path: integration/flink/src/main/java/org/apache/carbon/core/metadata/SegmentManager

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339437741 ## File path: integration/flink-proxy/pom.xml ## @@ -0,0 +1,43 @@ + +http://maven.a

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339437071 ## File path: hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonTableOutputFormat.

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339437140 ## File path: core/src/main/java/org/apache/carbondata/core/statusmanager/FileFormat.java #

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339435060 ## File path: core/src/main/java/org/apache/carbondata/core/indexstore/row/DataMapRowImpl.ja

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339421585 ## File path: core/src/main/java/org/apache/carbondata/core/indexstore/blockletindex/BlockDa

[GitHub] [carbondata] niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon

niuge01 commented on a change in pull request #3421: [CARBONDATA-3557] Support write Flink streaming data to Carbon URL: https://github.com/apache/carbondata/pull/3421#discussion_r339418531 ## File path: core/src/main/java/org/apache/carbondata/core/indexstore/blockletindex/BlockDa