[IMPALA-3112] Data stream test always times out before getting a receiver.

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Not A Bug
• Affects Version/s: Impala 2.5.0
• Component/s: Distributed Exec
• Labels: test_issue
• Assignee: Unassigned
• Reporter: Sailesh Mukil
• Created: 02/Mar/16 03:22
• Updated: 02/Mar/16 03:40
• Resolved: 02/Mar/16 03:40

Description

We always get this error in data-stream-test. However, we never catch the error and so the tests always pass.

I0301 18:39:56.864101  8437 data-stream-mgr.cc:122] Datastream sender timed-out waiting for recvr for fragment instance: 0:0 (time-out was: 250.082ms).

Our data-stream-test code:

  void Sender(int sender_num, int channel_buffer_size,
              TPartitionType::type partition_type) {
    ...
    ...
    ...
    for (int i = 0; i < NUM_BATCHES; ++i) {
      GetNextBatch(batch.get(), &next_val);
      VLOG_QUERY << "sender " << sender_num << ": #rows=" << batch->num_rows();
      info.status = sender.Send(&state, batch.get(), false);
      if (!info.status.ok()) break; // VVVV: WE NEVER ACT ON A FAILED STATUS
    }
    VLOG_QUERY << "closing sender" << sender_num;
    sender.Close(&state);
    info.num_bytes_sent = sender.GetNumDataBytesSent();

    batch->Reset();
  }