This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push: new f4d40722fe NIFI-13168 Upgraded QuestDB from 7.3.7 to 7.4.2 This closes #8773 f4d40722fe is described below commit f4d40722fed9759efd5f609741b92c917ddf4a2b Author: exceptionfactory <exceptionfact...@apache.org> AuthorDate: Tue May 7 16:02:09 2024 -0500 NIFI-13168 Upgraded QuestDB from 7.3.7 to 7.4.2 This closes #8773 - Changed getSym() to getSymA() following QuestDB changes - Added WAL Table status check for Table Metadata lookup Signed-off-by: Joseph Witt <joew...@apache.org> --- nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/pom.xml | 2 +- .../apache/nifi/questdb/embedded/CursorBasedQueryRowContext.java | 2 +- .../org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java | 6 ++++-- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/pom.xml b/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/pom.xml index 93f7267f0e..4d37bbf03e 100644 --- a/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/pom.xml +++ b/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/pom.xml @@ -35,7 +35,7 @@ <dependency> <groupId>org.questdb</groupId> <artifactId>questdb</artifactId> - <version>7.3.7</version> + <version>7.4.2</version> </dependency> <dependency> <groupId>org.springframework</groupId> diff --git a/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/CursorBasedQueryRowContext.java b/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/CursorBasedQueryRowContext.java index 2c01cb840c..c99ecb6ba0 100644 --- a/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/CursorBasedQueryRowContext.java +++ b/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/CursorBasedQueryRowContext.java @@ -50,7 +50,7 @@ final class CursorBasedQueryRowContext implements QueryRowContext { @Override public String getString(final int position) { - return String.valueOf(actualRecord.getSym(position)); + return String.valueOf(actualRecord.getSymA(position)); } boolean hasNext() { diff --git a/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java b/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java index c71fa41c31..a1234c9bd6 100644 --- a/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java +++ b/nifi-extension-bundles/nifi-questdb-bundle/nifi-questdb/src/main/java/org/apache/nifi/questdb/embedded/EmbeddedDatabaseManager.java @@ -178,8 +178,10 @@ final class EmbeddedDatabaseManager implements DatabaseManager { for (final ManagedTableDefinition tableDefinition : context.getTableDefinitions()) { try { final TableToken tableToken = this.engine.get().getTableTokenIfExists(tableDefinition.getName()); - final TableRecordMetadata metadata = this.engine.get().getSequencerMetadata(tableToken); - metadata.close(); + if (tableToken.isWal()) { + final TableRecordMetadata metadata = this.engine.get().getSequencerMetadata(tableToken); + metadata.close(); + } client.execute(String.format("SELECT * FROM %S LIMIT 1", tableDefinition.getName())); } catch (final Exception e) {