You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ni...@apache.org on 2022/09/01 19:33:36 UTC
[pulsar] branch master updated: Cleanup test functions (#17376)
This is an automated email from the ASF dual-hosted git repository.
nicoloboschi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new d711e779558 Cleanup test functions (#17376)
d711e779558 is described below
commit d711e779558a85dca2b6943b8ec606523aaafc62
Author: Christophe Bornet <cb...@hotmail.com>
AuthorDate: Thu Sep 1 21:33:24 2022 +0200
Cleanup test functions (#17376)
---
.../java/org/apache/pulsar/functions/api/examples/RecordFunction.java | 1 -
.../java/org/apache/pulsar/tests/integration/io/TestLoggingSink.java | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/RecordFunction.java b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/RecordFunction.java
index 512c583e301..55adf848da5 100644
--- a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/RecordFunction.java
+++ b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/RecordFunction.java
@@ -38,7 +38,6 @@ public class RecordFunction implements Function<String, Record<String>> {
return context.newOutputRecordBuilder(Schema.STRING)
.destinationTopic(publishTopic)
.value(output)
- .schema(Schema.STRING)
.properties(properties)
.build();
}
diff --git a/tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestLoggingSink.java b/tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestLoggingSink.java
index 571eb6a9d1a..e6c7aa53874 100644
--- a/tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestLoggingSink.java
+++ b/tests/docker-images/java-test-functions/src/main/java/org/apache/pulsar/tests/integration/io/TestLoggingSink.java
@@ -36,7 +36,7 @@ public class TestLoggingSink implements Sink<GenericObject> {
@Override
public void open(Map<String, Object> config, SinkContext sinkContext) throws Exception {
logger = sinkContext.getLogger();
- String topic = (String) sinkContext.getSinkConfig().getConfigs().get("log-topic");
+ String topic = (String) config.getOrDefault("log-topic", "log-topic");
producer = sinkContext.getPulsarClient().newProducer(Schema.STRING)
.topic(topic)
.create();