[GitHub] [carbondata] ShreelekhyaG opened a new pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

classic Classic list List threaded Threaded
32 messages Options
12
Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] ShreelekhyaG commented on a change in pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox

ShreelekhyaG commented on a change in pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#discussion_r589273380



##########
File path: core/src/main/java/org/apache/carbondata/core/index/Segment.java
##########
@@ -378,11 +382,10 @@ public void write(DataOutput out) throws IOException {
       out.writeUTF(segmentString);
     }
     out.writeLong(indexSize);
-    if (segmentPath == null) {
-      out.writeBoolean(false);
-    } else {
+    if (isExternalSegment()) {

Review comment:
       Done




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] ShreelekhyaG commented on a change in pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

ShreelekhyaG commented on a change in pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#discussion_r589273743



##########
File path: core/src/main/java/org/apache/carbondata/core/indexstore/ExtendedBlockletWrapper.java
##########
@@ -121,8 +121,9 @@ public ExtendedBlockletWrapper(List<ExtendedBlocklet> extendedBlockletList, Stri
     DataOutputStream stream = new DataOutputStream(bos);
     try {
       for (ExtendedBlocklet extendedBlocklet : extendedBlockletList) {
+        boolean isExternalPath = !extendedBlocklet.getFilePath().contains(tablePath);

Review comment:
       ok, removed. using isexternalSegment flag instead




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] CarbonDataQA2 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

CarbonDataQA2 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-792736871


   Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12545/job/ApacheCarbonPRBuilder2.3/5115/
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] CarbonDataQA2 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

CarbonDataQA2 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-792743166


   Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12545/job/ApacheCarbon_PR_Builder_2.4.5/3356/
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] Indhumathi27 commented on a change in pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

Indhumathi27 commented on a change in pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#discussion_r589412990



##########
File path: core/src/main/java/org/apache/carbondata/core/indexstore/ExtendedBlocklet.java
##########
@@ -225,25 +223,15 @@ public void deserializeFields(DataInput in, String[] locations, String tablePath
     if (in.readBoolean()) {
       indexUniqueId = in.readUTF();
     }
-    String filePath = getPath();
-    boolean isLocalFile = FileFactory.getCarbonFile(filePath) instanceof LocalCarbonFile;
-
-    // For external segment, table path need not be appended to filePath as contains has full path
-    // Example filepath for ext segment:
-    //  1. /home/user/carbondata/integration/spark/newsegmentpath
-    //  2. hdfs://hacluster/opt/newsegmentpath/
-    // Example filepath for loaded segment: /Fact/Part/Segment0
-    // To identify a filePath as ext segment path,
-    // for other storage systems (hdfs,s3): filePath doesn't start with File separator.
-    // for ubuntu storage: it starts with File separator, so check if given path exists or not.
-    if ((!isLocalFile && filePath.startsWith(File.separator)) || (isLocalFile && !FileFactory
-        .isFileExist(filePath))) {
-      setFilePath(tablePath + filePath);
-    } else {
-      setFilePath(filePath);
-    }
     boolean isSplitPresent = in.readBoolean();
     if (isSplitPresent) {
+      String filePath = getPath();
+      boolean isExternalPath = in.readBoolean();

Review comment:
       ```suggestion
         boolean isExternalSegment = in.readBoolean();
   ```




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] CarbonDataQA2 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

CarbonDataQA2 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-793005147


   Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12545/job/ApacheCarbonPRBuilder2.3/5117/
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] CarbonDataQA2 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

CarbonDataQA2 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-793005760


   Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12545/job/ApacheCarbon_PR_Builder_2.4.5/3358/
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] Indhumathi27 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

Indhumathi27 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-793425074


   retest this please


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] CarbonDataQA2 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

CarbonDataQA2 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-793534638


   Build Success with Spark 2.4.5, Please check CI http://121.244.95.60:12545/job/ApacheCarbon_PR_Builder_2.4.5/3360/
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] CarbonDataQA2 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

CarbonDataQA2 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-793536640


   Build Success with Spark 2.3.4, Please check CI http://121.244.95.60:12545/job/ApacheCarbonPRBuilder2.3/5119/
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] Indhumathi27 commented on pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

Indhumathi27 commented on pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096#issuecomment-793540052


   LGTM


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


Reply | Threaded
Open this post in threaded view
|

[GitHub] [carbondata] asfgit closed pull request #4096: [CARBONDATA-4133] Concurrent Insert Overwrite with static partition on Index server fails

GitBox
In reply to this post by GitBox

asfgit closed pull request #4096:
URL: https://github.com/apache/carbondata/pull/4096


   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[hidden email]


12