Merge pull request #36 from dataux/qlbridge_upgrade

araddon · web-flow · commit 29b6c71510b3 · 2016-11-27T10:05:23.000-08:00
upstream qlbridge upgrade
diff --git a/planner/executor.go b/planner/executor.go
@@ -120,7 +120,7 @@ func (m *ExecutorGrid) WalkSelect(p *plan.Select) (exec.Task, error) {
 	//u.WarnT(10)
 	//u.Debugf("%p Walk Select %s", m, p.Stmt)
 	if !p.ChildDag && len(p.Stmt.With) > 0 && p.Stmt.With.Bool("distributed") {
-		u.Warnf("%p has distributed!!!!!: %#v", m, p.Stmt.With)
+		u.Debugf("%p has distributed!!!!!: %#v", m, p.Stmt.With)
 		// We are going to run tasks remotely, so need a local grid source for them
 		//  remoteSink  -> nats ->  localSource
 		localTask := exec.NewTaskSequential(m.Ctx)
diff --git a/planner/sqlactor.go b/planner/sqlactor.go
@@ -280,7 +280,7 @@ func (m *SqlActor) Running() dfa.Letter {
 	for {
 		select {
 		case <-m.exit:
-			u.Warnf("%s exit?   what caused this?", m)
+			u.Debugf("%s exit?   what caused this?", m)
 			return Exit
 		case <-ticker.C:
 			u.Debugf("%p alive  %s", m, m.ID())
@@ -297,7 +297,7 @@ func (m *SqlActor) Running() dfa.Letter {
 			}
 			//u.Warnf("%s about to do ticker store", m)
 		case <-finished:
-			u.Warnf("%s sqlactor ending due to everybody finished", m)
+			u.Debugf("%s sqlactor ending due to everybody finished", m)
 			return EverybodyFinished
 		case <-masterDone:
 			// In this scenario, we have not finished our dag, either client
