Yash Agarwal
07/24/2020, 5:31 AMXiang Fu
00000_0
?Xiang Fu
Yash Agarwal
07/24/2020, 6:05 AMYash Agarwal
07/24/2020, 6:06 AM<hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl/2019/05/18/guest_sdr_gst_data_sgl_data_2019-05-18.avro>
Yash Agarwal
07/24/2020, 6:06 AMUnable to extract out the relative path based on base input path: <hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl>
Yash Agarwal
07/24/2020, 8:08 AMYash Agarwal
07/24/2020, 8:08 AMjava.lang.IllegalStateException: Unable to extract out the relative path based on base input path: <hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl> inputFile: hdfs:/user/Z00290G/guest_sdr_gst_data_sgl/2019/05/21/guest_sdr_gst_data_sgl_data_2019-05-21.avro outputDir: <hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl_staging>
Yash Agarwal
07/24/2020, 8:09 AM<hdfs://bigredns>
from the input file.Xiang Fu
@Test
public void testGetRelativePath() {
System.out.println(SegmentGenerationUtils.getRelativeOutputPath(
URI.create("<hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl>"),
URI.create("<hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl/2019/05/18/guest_sdr_gst_data_sgl_data_2019-05-18.avro>"),
URI.create("<hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl_staging>")));
}
Xiang Fu
<hdfs://bigredns/user/Z00290G/guest_sdr_gst_data_sgl_staging/2019/05/18/>
Xiang Fu
inputFile
is not under base input path
Xiang Fu
URI relativePath = baseInputDir.relativize(inputFile);
to get the relative pathXiang Fu
Elon
07/25/2020, 5:59 AM2020/07/23 22:02:12.981 ERROR [LLRealtimeSegmentDataManager_oas_integration_operation_event__2__1309__20200723T2158Z] [oas_integration_operation_event__2__1309__20200723T2158Z] Holding after response from Controller: {"buildTimeSec":-1,"isSplitCommitType":false,"status":"NOT_SENT","offset":-1}
Elon
07/25/2020, 5:59 AMERROR [ServerSegmentCompletionProtocolHandler] [oas_integration_operation_event__1__1309__20200723T2200Z] Could not send request <http://pinot-controller-1.pinot-controller-headless.pinot.svc.cluster.local:9000/segmentConsumed?name=oas_integration_operation_event__1__1309__20200723T2200Z&offset=238845637&instance=Server_pinot-server-0.pinot-server-headless.pinot.svc.cluster.local_8098&reason=rowLimit&rowCount=1731228>
"
Elon
07/25/2020, 5:59 AMElon
07/25/2020, 6:00 AM{
"status": "FAILED",
"isSplitCommitType": false,
"streamPartitionMsgOffset": null,
"buildTimeSec": -1,
"offset": -1
}
Elon
07/25/2020, 6:00 AMKishore G
Xiang Fu
Xiang Fu
Elon
07/25/2020, 6:32 AMXiang Fu
Xiang Fu
Xiang Fu
Kishore G
Elon
07/27/2020, 7:47 PMElon
07/27/2020, 7:47 PM