Skip to content

Fix issue in streaming JDBC database #27212

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 18 commits into from
Jun 20, 2023
Merged
Changes from 4 commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
18c9e91
Fix issue in streaming JDBC database
akashkulk Jun 9, 2023
04b53ee
Merge branch 'master' into leak_revert
akashkulk Jun 13, 2023
7937029
Merge branch 'master' into leak_revert
akashkulk Jun 16, 2023
633efb5
Merge branch 'master' into leak_revert
akashkulk Jun 16, 2023
3a96501
Bump + publish
akashkulk Jun 16, 2023
4f6d0d5
Merge branch 'master' into leak_revert
akashkulk Jun 20, 2023
8daaa88
🤖 Auto format source-db2 code [skip ci]
octavia-squidington-iii Jun 20, 2023
c9e70bb
🤖 Auto format source-mssql code [skip ci]
octavia-squidington-iii Jun 20, 2023
b78786a
🤖 Auto format source-postgres-strict-encrypt code [skip ci]
octavia-squidington-iii Jun 20, 2023
1e2cb5a
🤖 Auto format source-postgres code [skip ci]
octavia-squidington-iii Jun 20, 2023
b0eed9b
🤖 Auto format source-mssql-strict-encrypt code [skip ci]
octavia-squidington-iii Jun 20, 2023
d4b61cf
🤖 Auto format source-oracle code [skip ci]
octavia-squidington-iii Jun 20, 2023
1dc1410
🤖 Auto format source-tidb code [skip ci]
octavia-squidington-iii Jun 20, 2023
2974388
🤖 Auto format source-snowflake code [skip ci]
octavia-squidington-iii Jun 20, 2023
1b37cbf
🤖 Auto format source-redshift code [skip ci]
octavia-squidington-iii Jun 20, 2023
41222bc
🤖 Auto format source-mysql code [skip ci]
octavia-squidington-iii Jun 20, 2023
489962b
🤖 Auto format source-mysql-strict-encrypt code [skip ci]
octavia-squidington-iii Jun 20, 2023
8a82a90
Merge branch 'master' into leak_revert
akashkulk Jun 20, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -107,9 +107,7 @@ public boolean tryAdvance(final Consumer<? super T> action) {
LOGGER.error("SQLState: {}, Message: {}", e.getSQLState(), e.getMessage());
streamException = e;
isStreamFailed = true;
// throwing an exception in tryAdvance() method lead to the endless loop in Spliterator and stream
// will never close
return false;
throw new RuntimeException(e);
}
}

Expand Down