[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361797527 ## File path: integration/flink/src/test/scala/org/apache/carbon/flink/TestCarbonPartitionW

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361797390 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796705 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonS3Writer.java

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361797118 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796904 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361797118 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361797038 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796993 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796993 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796894 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796904 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796868 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796793 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796748 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonWriter.java ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-28 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361796705 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonS3Writer.java

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-27 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361770999 ## File path: integration/flink/src/test/scala/org/apache/carbon/flink/TestSource.scala ##

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-27 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361770968 ## File path: integration/flink/src/main/java/org/apache/carbon/flink/CarbonS3Writer.java

[GitHub] [carbondata] jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table

2019-12-27 Thread GitBox
jackylk commented on a change in pull request #3532: [CARBONDATA-3557] Write flink streaming data to partition table URL: https://github.com/apache/carbondata/pull/3532#discussion_r361770939 ## File path: core/src/main/java/org/apache/carbondata/core/statusmanager/StageInput.java