(ignite-3) branch main updated: IGNITE-27123 Fixed failing streaming examples (#7085)

[sk0x50]

This is an automated email from the ASF dual-hosted git repository.

sk0x50 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 806817ba3c6 IGNITE-27123 Fixed failing streaming examples (#7085)
806817ba3c6 is described below

commit 806817ba3c6e8da31ff7a7526bb3d1311bb108db
Author: HR0027 <oneaboveall...@gmail.com>
AuthorDate: Fri Dec 5 14:46:01 2025 +0530

    IGNITE-27123 Fixed failing streaming examples (#7085)
    
    Co-authored-by: HR0027 <oneabove...@gmail.com>
---
 .../apache/ignite/example/streaming/DetectFailedEntriesExample.java | 5 +++++
 .../ignite/example/streaming/SingleTableDataStreamerExample.java    | 6 ++++++
 2 files changed, 11 insertions(+)

diff --git 
a/examples/java/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
 
b/examples/java/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
index 553c2784f5b..0f348eea0de 100644
--- 
a/examples/java/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
+++ 
b/examples/java/src/main/java/org/apache/ignite/example/streaming/DetectFailedEntriesExample.java
@@ -48,6 +48,8 @@ public class DetectFailedEntriesExample {
                     .autoFlushInterval(1000)
                     .retryLimit(16)
                     .build();
+            System.out.println("Creating Accounts table");
+            client.sql().execute(null, "CREATE TABLE IF NOT EXISTS ACCOUNTS 
(id INT PRIMARY KEY, name VARCHAR(255), balance BIGINT, active BOOLEAN);");
 
             RecordView<Account> view = client.tables()
                     .table("Accounts")
@@ -91,6 +93,9 @@ public class DetectFailedEntriesExample {
 
             /* Wait for background streaming to complete */
             streamerFut.join();
+
+            System.out.println("Dropping Accounts table.");
+            client.sql().execute(null, "DROP TABLE IF EXISTS ACCOUNTS;");
         }
     }
 }
\ No newline at end of file
diff --git 
a/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
 
b/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
index d679422c461..686c2de31e8 100644
--- 
a/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
+++ 
b/examples/java/src/main/java/org/apache/ignite/example/streaming/SingleTableDataStreamerExample.java
@@ -42,6 +42,9 @@ public class SingleTableDataStreamerExample {
         try (IgniteClient client = IgniteClient.builder()
                 .addresses("127.0.0.1:10800")
                 .build()) {
+            System.out.println("Creating Accounts table");
+            client.sql().execute(null, "CREATE TABLE IF NOT EXISTS ACCOUNTS 
(id INT PRIMARY KEY, name VARCHAR(255), balance BIGINT, active BOOLEAN);");
+
             RecordView<Account> view = 
client.tables().table("Accounts").recordView(Account.class);
 
             /* PUT entries into the table*/
@@ -56,6 +59,9 @@ public class SingleTableDataStreamerExample {
             /* Check that table doesnt contain data */
             verifyRemove(view);
 
+            System.out.println("Dropping Accounts table.");
+            client.sql().execute(null, "DROP TABLE IF EXISTS ACCOUNTS;");
+
         }
     }