Skip to content

Commit 75adfcd

Browse files
committed
Use NodeVersion instead of full Node in IcebergEnvironmentContext
1 parent 9505e4f commit 75adfcd

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergEnvironmentContext.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
package io.trino.plugin.iceberg;
1515

1616
import com.google.inject.Inject;
17-
import io.trino.spi.Node;
17+
import io.trino.plugin.hive.NodeVersion;
1818
import org.apache.iceberg.EnvironmentContext;
1919

2020
import static java.util.Objects.requireNonNull;
@@ -24,10 +24,10 @@
2424
public class IcebergEnvironmentContext
2525
{
2626
@Inject
27-
public IcebergEnvironmentContext(Node currentNode)
27+
public IcebergEnvironmentContext(NodeVersion nodeVersion)
2828
{
29-
requireNonNull(currentNode, "currentNode is null");
29+
requireNonNull(nodeVersion, "nodeVersion is null");
3030
EnvironmentContext.put(ENGINE_NAME, "trino");
31-
EnvironmentContext.put(ENGINE_VERSION, currentNode.getVersion());
31+
EnvironmentContext.put(ENGINE_VERSION, nodeVersion.toString());
3232
}
3333
}

0 commit comments

Comments
 (0)