You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ni...@apache.org on 2025/07/31 07:41:36 UTC
(ignite-extensions) 01/01: IGNITE-26044 Compilation fix
This is an automated email from the ASF dual-hosted git repository.
nizhikov pushed a commit to branch IGNITE-26044
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
commit 24576272ec7575602b5d34c2d66061b29588fd93
Author: Nikolay Izhikov <ni...@apache.org>
AuthorDate: Thu Jul 31 10:41:13 2025 +0300
IGNITE-26044 Compilation fix
---
.../cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java | 18 +++++++++++++++++-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
index fc87150d..afd0e659 100644
--- a/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
+++ b/modules/cdc-ext/src/test/java/org/apache/ignite/cdc/kafka/KafkaToIgniteMetadataUpdaterTest.java
@@ -21,9 +21,13 @@ import java.util.Collections;
import org.apache.ignite.IgniteException;
import org.apache.ignite.cdc.CdcConsumer;
import org.apache.ignite.cdc.TypeMapping;
+import org.apache.ignite.configuration.BinaryConfiguration;
import org.apache.ignite.internal.binary.BinaryContext;
+import org.apache.ignite.internal.binary.BinaryUtils;
import org.apache.ignite.internal.cdc.TypeMappingImpl;
import org.apache.ignite.internal.processors.metric.MetricRegistryImpl;
+import org.apache.ignite.internal.util.typedef.internal.CU;
+import org.apache.ignite.logger.NullLogger;
import org.apache.ignite.platform.PlatformType;
import org.apache.ignite.testframework.GridTestUtils;
import org.apache.ignite.testframework.ListeningTestLogger;
@@ -165,7 +169,19 @@ public class KafkaToIgniteMetadataUpdaterTest extends GridCommonAbstractTest {
/** */
private KafkaToIgniteMetadataUpdater metadataUpdater(KafkaToIgniteCdcStreamerConfiguration streamerCfg) {
- BinaryContext noOpCtx = new BinaryContext(log) {
+ BinaryContext noOpCtx = new BinaryContext(
+ BinaryUtils.cachingMetadataHandler(),
+ null,
+ null,
+ null,
+ null,
+ null,
+ null,
+ null,
+ CU.affinityFields(null),
+ BinaryConfiguration.DFLT_COMPACT_FOOTER,
+ NullLogger.INSTANCE
+ ) {
@Override public boolean registerUserClassName(int typeId, String clsName, boolean failIfUnregistered,
boolean onlyLocReg, byte platformId) {
return true;