Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-11 20:45:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-13837 QueryRecord changes timezones of Timestamp field

Browse Source 
Signed-off-by: Matt Burgess <mattyb149@apache.org>

This closes #9341
This commit is contained in:
Mark Payne 2024-07-09 17:01:41 +02:00 committed by Matt Burgess
parent e720ccc309
commit 1d2b662a5f
3 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/MetricsSqlQueryService.java
View File

@ -188,6 +188,7 @@ public class MetricsSqlQueryService implements MetricsQueryService {
private CalciteConnection createConnection() {
final Properties properties = new Properties();
properties.put(CalciteConnectionProperty.LEX.camelName(), Lex.MYSQL_ANSI.name());
properties.put(CalciteConnectionProperty.TIME_ZONE, "UTC");
try {
final Connection connection = DriverManager.getConnection("jdbc:calcite:", properties);

1
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
View File

@ -417,6 +417,7 @@ public class QueryRecord extends AbstractProcessor {
private CalciteConnection createConnection() {
final Properties properties = new Properties();
properties.put(CalciteConnectionProperty.LEX.camelName(), Lex.MYSQL_ANSI.name());
properties.put(CalciteConnectionProperty.TIME_ZONE, "UTC");
try {
final Connection connection = DriverManager.getConnection("jdbc:calcite:", properties);

1
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/enrichment/SqlJoinCache.java
View File

@ -95,6 +95,7 @@ public class SqlJoinCache implements AutoCloseable {
private CalciteConnection createCalciteConnection() {
final Properties properties = new Properties();
properties.put(CalciteConnectionProperty.LEX.camelName(), Lex.MYSQL_ANSI.name());
properties.put(CalciteConnectionProperty.TIME_ZONE, "UTC");
try {
final Connection connection = DriverManager.getConnection("jdbc:calcite:", properties);