3
Vote

LINQ to HIVE System.AggregateException

description

Example:

var db = new HiveConnection(
        webHCatUri: new Uri("https://<name>.azurehdinsight.net"),
        userName: (string)"username", password: (string)"password");

        var task = db.ExecuteQuery("select count(*) from mytable");
        task.Wait();
InnerException:

{System.NullReferenceException: Object reference not set to an instance of an object.
at System.Threading.Tasks.TaskAwaiter`1.GetResult()
at Microsoft.Hadoop.Hive.HiveConnection.<ExecuteQuery>d__13.MoveNext()}

StackTrace:

at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.Wait()
at HiveExperiments.Program.Main(String[] args) in ...\Program.cs:line 42
at System.AppDomain._nExecuteAssembly(RuntimeAssembly assembly, String[] args)
at Microsoft.VisualStudio.HostingProcess.HostProc.RunUsersAssembly()
at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Threading.ThreadHelper.ThreadStart()


Could you plz help

comments

nikhilarjunagi wrote Mar 5, 2015 at 6:15 AM

Seeing the same issue. The weird thing is the job actually succeeds, and you can see this if you check the job progress on the namenode. Could this be a time out issue?

Also, is the code for Microsoft.Hadoop.Hive shared? The codeplex source has no Hive code.

maxluk wrote Mar 5, 2015 at 5:37 PM

The source code is in the dev branch.