sqoop import --connect "jdbc:jtds:sqlserver://jxx/tmwus;useNTLMv2=true;domain=CROWLEY" --table expedite_audit_tbl --username xx --password xx --incremental lastmodified --check-column updated_dt --hcatalog-database tmwus --hcatalog-table expedite_audit_tbl --create-hcatalog-table --hcatalog-storage-stanza "stored as orc" --last-value '2018-05-22 00:00:00' --split-by ord_hdrnumber -num-mappers 1 I am trying the following command. However, i receive the following error 18/05/23 15:26:12 INFO manager.SqlManager: Executing SQL statement: SELECT t.* FROM [expedite_audit_tbl] AS t WHERE 1=0 18/05/23 15:26:12 ERROR tool.ImportTool: Imported Failed: There is no column found in the target table expedite_audit_tbl. Please ensure that your table name is correct. I know the table exists as I am able to do the following sqoop import --connect "jdbc:jtds:sqlserver://xx;useNTLMv2=true;domain=CROWLEY" --query "select * from tmwus.dbo.expedite_audit_tbl WHERE updated_dt<='2018-05-22 00:00:00' AND \$CONDITIONS" --username xx--password xx--hcatalog-database tmwus --hcatalog-table expedite_audit_tbl --create-hcatalog-table --hcatalog-storage-stanza "stored as orc" --split-by ord_hdrnumber -num-mappers 12 ... View more

I am trying to do a following querey where I need to delete the records that have same 3 columns. However, I can not do the below query. Does anyone have any idea on how I can accomplish it . delete from cargowise.shipmentdetails where consolid,shipmentid,branch in (select distinct(consolid,shipmentid,branch) from cargowise.shipmentdetails_temp); ... View more

I have an external table "shipmentprofile_temp" which has the list of keys that needs to be deleted from my transnational table "shipmentprofile" I am executing below query that executes but does not complete. delete from cargowise.shipmentprofile where transcnno in (select transcnno from cargowise.shipmentprofile_temp); ... View more

I am using ConvertExcelToCSVProcessor in NIFI to convert.xlsx file to csv. However I see the processor is throwing the following error. I have atatched the image of my flow along with it too, 87accf18ba] ConvertExcelToCSVProcessor[id=ba4c3f67-dd21-1af9-95a3-1887accf18ba] failed to process session due to org.apache.nifi.processor.exception.FlowFileHandlingException: StandardFlowFileRecord[uuid=9ef1d06a-c2a4-4f7a-826f-ebfc33f3eef0,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1506002021780-183, container=default, section=183], offset=0, length=912278],offset=0,name=4289436879924664,size=912278] transfer relationship not specified: {} org.apache.nifi.processor.exception.FlowFileHandlingException: StandardFlowFileRecord[uuid=9ef1d06a-c2a4-4f7a-826f-ebfc33f3eef0,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1506002021780-183, container=default, section=183], offset=0, length=912278],offset=0,name=4289436879924664,size=912278] transfer relationship not specified at org.apache.nifi.controller.repository.StandardProcessSession.checkpoint(StandardProcessSession.java:248) at org.apache.nifi.controller.repository.StandardProcessSession.commit(StandardProcessSession.java:318) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:28) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1120) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:748) ... View more