ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[SPARK-29687][SQL] Fix JDBC metrics counter data type

Browse source 
### What changes were proposed in this pull request?

Fix JDBC metrics counter data type. Related pull request [26109](https://github.com/apache/spark/pull/26109).

### Why are the changes needed?

Avoid overflow.

### Does this PR introduce any user-facing change?

No.

### How was this patch tested?

Exists UT.

Closes #26346 from ulysses-you/SPARK-29687.

Authored-by: ulysses <youxiduo@weidian.com>
Signed-off-by: Takeshi Yamamuro <yamamuro@apache.org>
This commit is contained in:
ulysses 2019-11-01 08:35:00 +09:00 committed by Takeshi Yamamuro
parent 888cc4601a
commit 8a8ac00271
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala
View file

@ -652,7 +652,7 @@ object JdbcUtils extends Logging {
}
}
val supportsTransactions = finalIsolationLevel != Connection.TRANSACTION_NONE
var totalRowCount = 0
var totalRowCount = 0L
try {
if (supportsTransactions) {
conn.setAutoCommit(false) // Everything in the same db transaction.