# Could not send query when reading from MySQL

**URL:** <https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533>\
**Category:** Uncategorized\
**Created:** [December 8, 2017, 6:20am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533 "2017-12-08T06:20:21Z")\
**Posts on this page:** 9\
**Page:** 1

<div class="post-metadata">

**Author:** ![JoyJava](https://sea2.discourse-cdn.com/flex020/user_avatar/community.dremio.com/joyjava/32/293_2.png) [@JoyJava](https://community.dremio.com/u/JoyJava)\
**Post date:** [December 8, 2017, 6:20am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/1 "2017-12-08T06:20:21Z")

</div>

DATA\_READ ERROR: The JDBC storage plugin failed while trying setup the SQL query. sql SELECT \* FROM `posloan`.`trm_edw_app_salman_sdsm_mer_dev_w` LIMIT 2000 OFFSET 0 plugin posloanrw\_10-16-30-154 SqlOperatorImpl JDBC\_SUB\_SCAN Location 0:0:6 SqlOperatorImpl JDBC\_SUB\_SCAN Location 0:0:6 Fragment 0:0 [Error Id: 36fe26a4-8548-4bc0-a64b-cb70c35fa387 on gz-public-test-app92-140-228.msfinance.host:31010] (java.sql.SQLNonTransientConnectionException) (conn:82203) Could not send query: Broken pipe (Write failed) org.mariadb.jdbc.internal.util.exceptions.ExceptionMapper.get():156 org.mariadb.jdbc.internal.util.exceptions.ExceptionMapper.getException():118 org.mariadb.jdbc.MariaDbStatement.executeExceptionEpilogue():247 org.mariadb.jdbc.MariaDbStatement.executeInternal():322 org.mariadb.jdbc.MariaDbStatement.executeQuery():492 com.dremio.exec.store.jdbc.JdbcRecordReader.setup():171 com.dremio.exec.store.CoercionReader.setup():109 com.dremio.sabot.op.scan.ScanOperator$1.run():178 com.dremio.sabot.op.scan.ScanOperator$1.run():174 java.security.AccessController.doPrivileged():-2 javax.security.auth.Subject.doAs():422 org.apache.hadoop.security.UserGroupInformation.doAs():1807 com.dremio.sabot.op.scan.ScanOperator.setupReaderAsCorrectUser():174 com.dremio.sabot.op.scan.ScanOperator.setupReader():166 com.dremio.sabot.op.scan.ScanOperator.setup():147 com.dremio.sabot.driver.SmartOp$SmartProducer.setup():552 com.dremio.sabot.driver.Pipe$SetupVisitor.visitProducer():79 com.dremio.sabot.driver.Pipe$SetupVisitor.visitProducer():63 com.dremio.sabot.driver.SmartOp$SmartProducer.accept():522 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.Pipeline.setup():58 com.dremio.sabot.exec.fragment.FragmentExecutor.setupExecution():331 com.dremio.sabot.exec.fragment.FragmentExecutor.run():227 com.dremio.sabot.exec.fragment.FragmentExecutor.access$800():83 com.dremio.sabot.exec.fragment.FragmentExecutor$AsyncTaskImpl.run():577 com.dremio.sabot.task.AsyncTaskWrapper.run():92 com.dremio.sabot.task.slicing.SlicingThread.run():71 Caused By (java.sql.SQLException) Could not send query: Broken pipe (Write failed) org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol.handleIoException():1472 org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery():169 org.mariadb.jdbc.MariaDbStatement.executeInternal():316 org.mariadb.jdbc.MariaDbStatement.executeQuery():492 com.dremio.exec.store.jdbc.JdbcRecordReader.setup():171 com.dremio.exec.store.CoercionReader.setup():109 com.dremio.sabot.op.scan.ScanOperator$1.run():178 com.dremio.sabot.op.scan.ScanOperator$1.run():174 java.security.AccessController.doPrivileged():-2 javax.security.auth.Subject.doAs():422 org.apache.hadoop.security.UserGroupInformation.doAs():1807 com.dremio.sabot.op.scan.ScanOperator.setupReaderAsCorrectUser():174 com.dremio.sabot.op.scan.ScanOperator.setupReader():166 com.dremio.sabot.op.scan.ScanOperator.setup():147 com.dremio.sabot.driver.SmartOp$SmartProducer.setup():552 com.dremio.sabot.driver.Pipe$SetupVisitor.visitProducer():79 com.dremio.sabot.driver.Pipe$SetupVisitor.visitProducer():63 com.dremio.sabot.driver.SmartOp$SmartProducer.accept():522 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.Pipeline.setup():58 com.dremio.sabot.exec.fragment.FragmentExecutor.setupExecution():331 com.dremio.sabot.exec.fragment.FragmentExecutor.run():227 com.dremio.sabot.exec.fragment.FragmentExecutor.access$800():83 com.dremio.sabot.exec.fragment.FragmentExecutor$AsyncTaskImpl.run():577 com.dremio.sabot.task.AsyncTaskWrapper.run():92 com.dremio.sabot.task.slicing.SlicingThread.run():71 Caused By (java.net.SocketException) Broken pipe (Write failed) java.net.SocketOutputStream.socketWrite0():-2 java.net.SocketOutputStream.socketWrite():109 java.net.SocketOutputStream.write():153 org.mariadb.jdbc.internal.io.output.StandardPacketOutputStream.flushBuffer():103 org.mariadb.jdbc.internal.io.output.AbstractPacketOutputStream.flush():157 org.mariadb.jdbc.internal.protocol.AbstractQueryProtocol.executeQuery():163 org.mariadb.jdbc.MariaDbStatement.executeInternal():316 org.mariadb.jdbc.MariaDbStatement.executeQuery():492 com.dremio.exec.store.jdbc.JdbcRecordReader.setup():171 com.dremio.exec.store.CoercionReader.setup():109 com.dremio.sabot.op.scan.ScanOperator$1.run():178 com.dremio.sabot.op.scan.ScanOperator$1.run():174 java.security.AccessController.doPrivileged():-2 javax.security.auth.Subject.doAs():422 org.apache.hadoop.security.UserGroupInformation.doAs():1807 com.dremio.sabot.op.scan.ScanOperator.setupReaderAsCorrectUser():174 com.dremio.sabot.op.scan.ScanOperator.setupReader():166 com.dremio.sabot.op.scan.ScanOperator.setup():147 com.dremio.sabot.driver.SmartOp$SmartProducer.setup():552 com.dremio.sabot.driver.Pipe$SetupVisitor.visitProducer():79 com.dremio.sabot.driver.Pipe$SetupVisitor.visitProducer():63 com.dremio.sabot.driver.SmartOp$SmartProducer.accept():522 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.StraightPipe.setup():102 com.dremio.sabot.driver.Pipeline.setup():58 com.dremio.sabot.exec.fragment.FragmentExecutor.setupExecution():331 com.dremio.sabot.exec.fragment.FragmentExecutor.run():227 com.dremio.sabot.exec.fragment.FragmentExecutor.access$800():83 com.dremio.sabot.exec.fragment.FragmentExecutor$AsyncTaskImpl.run():577 com.dremio.sabot.task.AsyncTaskWrapper.run():92 com.dremio.sabot.task.slicing.SlicingThread.run():71

---

<div class="post-metadata">

**Author:** ![dbrody](https://avatars.discourse-cdn.com/v4/letter/d/b9bd4f/32.png) [@dbrody](https://community.dremio.com/u/dbrody)\
**Post date:** [December 8, 2017, 7:25pm UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/2 "2017-12-08T19:25:01Z")

</div>

Hi @JoyJava,

```
 Is this exception consistent, even if you try to reconnect to MySQL? Meanwhile you please attach the server log, server.out and the profile of the failed job 

```

[share-query-profile](https://www.dremio.com/tutorials/share-query-profile/)

[Dremio log files](https://docs.dremio.com/advanced-administration/log-files.html)

Thanks,  
@dbrody

---

<div class="post-metadata">

**Author:** ![JoyJava](https://sea2.discourse-cdn.com/flex020/user_avatar/community.dremio.com/joyjava/32/293_2.png) [@JoyJava](https://community.dremio.com/u/JoyJava)\
**Post date:** [December 11, 2017, 3:22am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/3 "2017-12-11T03:22:05Z")

</div>

![image](https://us1.discourse-cdn.com/flex020/uploads/dremio/original/1X/5e2b77821aa67d928c5b356e3cf3a908646c48aa.png)  
i found it in server.out

We use the dremio community version, which we how to upload profile document?

thx

---

<div class="post-metadata">

**Author:** ![jduong](https://sea2.discourse-cdn.com/flex020/user_avatar/community.dremio.com/jduong/32/21_2.png) [@jduong](https://community.dremio.com/u/jduong)\
**Post date:** [December 11, 2017, 4:26am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/4 "2017-12-11T04:26:02Z")

</div>

Hi @JoyJava,

The error is coming from the MariaDB JDBC driver that Dremio is using to connect to MySQL. A broken pipe error usually means the backend terminated the connection.

> [@JoyJava](#):
>
> SELECT \* FROM posloan.trm\_edw\_app\_salman\_sdsm\_mer\_dev\_w LIMIT 2000 OFFSET 0

Are you able to run this query with with a standalone JDBC tool such as SQuirreL or DBVisualizer? Does it work with both the MariaDB JDBC driver and the MySQL driver?

---

<div class="post-metadata">

**Author:** ![JoyJava](https://sea2.discourse-cdn.com/flex020/user_avatar/community.dremio.com/joyjava/32/293_2.png) [@JoyJava](https://community.dremio.com/u/JoyJava)\
**Post date:** [December 11, 2017, 6:03am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/5 "2017-12-11T06:03:23Z")

</div>

In dremio the second execution of this sql able to get the correct results

Other tools are able to execute correctly

---

<div class="post-metadata">

**Author:** ![dbrody](https://avatars.discourse-cdn.com/v4/letter/d/b9bd4f/32.png) [@dbrody](https://community.dremio.com/u/dbrody)\
**Post date:** [December 11, 2017, 6:07pm UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/6 "2017-12-11T18:07:23Z")

</div>

Hi @JoyJava,

You can find how to upload SQL profiles using this link:

> **[How To Share A Query Profile](https://www.dremio.com/tutorials/share-query-profile-dremio/)**
>
> Tutorial explaining how to share a query profile in Dremio.

Like @jduong said, most likely the error is pertaining to DB has terminated the DBsession.

Thanks,  
@dbrody

---

<div class="post-metadata">

**Author:** ![HLNA](https://avatars.discourse-cdn.com/v4/letter/h/f1d935/32.png) [@HLNA](https://community.dremio.com/u/HLNA)\
**Post date:** [February 15, 2018, 3:01am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/7 "2018-02-15T03:01:20Z")

</div>

Any solution on this error? I have similar errors

> [@Could not send query unexpected end of exception](https://community.dremio.com/t/could-not-send-query-unexpected-end-of-exception/767):
>
> Received following error on a query (which sometimes work). I am on community edition of 1.4. Caused by: java.sql.SQLNonTransientConnectionException: (conn:706080479) Could not send query: unexpected end of exception, read 0 bytes from 4 Blockquote In all cases, it seems to be MariaDB jdbc client ? Seems there is a jira card on it [https://jira.mariadb.org/browse/CONJ-348](https://jira.mariadb.org/browse/CONJ-348) Will try to use " useServerPrepStmts=false" in jdbc url… but, appreciate if any solution available.

---

<div class="post-metadata">

**Author:** ![balaji.ramaswamy](https://sea2.discourse-cdn.com/flex020/user_avatar/community.dremio.com/balaji.ramaswamy/32/843_2.png) [@balaji.ramaswamy](https://community.dremio.com/u/balaji.ramaswamy)\
**Post date:** [February 15, 2018, 6:17am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/8 "2018-02-15T06:17:57Z")

</div>

Hi @HLNA, Your stack seems to be slightly different from @JoyJava’s error stack. As we had replied in your other thread your stack is a known issue and will keep you updated in the fix.

@JoyJava

If the error is still happening, can you please share the query profile?

[How To Share A Query Profile](https://www.dremio.com/tutorials/share-query-profile/)

Thanks,  
@balaji.ramaswamy

---

<div class="post-metadata">

**Author:** ![HLNA](https://avatars.discourse-cdn.com/v4/letter/h/f1d935/32.png) [@HLNA](https://community.dremio.com/u/HLNA)\
**Post date:** [February 15, 2018, 6:29am UTC](https://community.dremio.com/t/could-not-send-query-when-reading-from-mysql/533/9 "2018-02-15T06:29:52Z")

</div>

Hi @balaji.ramaswamy … Sure,thanks. will wait. Meanwhile, is it possible to replace mariadb with mysql jar? or when will that support be available?
