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) {
