2019-02-15 10:04:16 UTC - Ganga Lakshmanasamy: Hi, we are using AVRO object to
send our class object. Recently, we added a list object to the class and got an
error org.apache.avro.AvroRuntimeException: Can't find element type of
Collection. How do we pass collections as part of pulsar message? Is there any
other option available?
----
2019-02-15 10:08:05 UTC - Ali Ahmed: @Ganga Lakshmanasamy I don’t this has
anything to do with pulsar
----
2019-02-15 10:08:28 UTC - Ali Ahmed: java reflection can’t find the type of a
list that is a known limitation
----
2019-02-15 10:20:47 UTC - Ganga Lakshmanasamy: oh ok. So is passing collection
not possible then.
----
2019-02-15 10:22:23 UTC - Ali Ahmed: not directly I think people use tricks
like a pair object best ask the avro community
----
2019-02-15 11:00:06 UTC - Ganga Lakshmanasamy: sure. Thanks
----
2019-02-15 13:45:07 UTC - Andres: @Andres has joined the channel
----
2019-02-15 14:03:55 UTC - Ganga Lakshmanasamy: @Ravi
----
2019-02-15 20:00:06 UTC - Laurent Chriqui: @Laurent Chriqui has joined the
channel
----
2019-02-15 20:04:56 UTC - Laurent Chriqui: Hello. We are trying to publish a
Pulsar Function using this method <https://t.co/EkVioX5MAV>
We tried several classnames in the functions create syntax but Pulsar cannot
import it. What is the correct syntax for this case ? I tried
exclamation.RoutingFunction , exclamation.src.exclamation.RoutingFunction ,
src.exclamation.RoutingFunction ,...
----
2019-02-15 20:43:44 UTC - David Kjerrumgaard: What is the error message you are
seeing?
----
2019-02-15 21:55:45 UTC - Laurent Chriqui: Impossible to import....
----
2019-02-15 22:10:56 UTC - Ali Ahmed: @Laurent Chriqui can you post your
terminal commands and output, you can can also post log files here
----
2019-02-15 22:17:44 UTC - Grant Wu: @Laurent Chriqui Are you running this on a
standalone cluster?
----
2019-02-15 22:17:56 UTC - Grant Wu: I’ve had issues before where import
failures are misleading
----
2019-02-15 22:18:01 UTC - Laurent Chriqui: Yes standalone cluster
----
2019-02-15 22:18:03 UTC - Grant Wu: and actually refer to exceptions thrown
upon attempting to import the module that aren’t related to the class name
being wrong
----
2019-02-15 22:19:13 UTC - Grant Wu: `ROOT_DIR/logs/functions` ought to be a
thing, where ROOT_DIR is the root directory of the standalone Pulsar instance
----
2019-02-15 22:19:22 UTC - Grant Wu: like, `apache-pulsar-2.2.1` for example
----
2019-02-15 22:19:32 UTC - Laurent Chriqui: What is the correct classname when
importing a zip though? filename.ClassName? src.filename.ClassName ?
----
2019-02-15 22:19:44 UTC - Grant Wu: I haven’t worked with zipped Pulsar
functions, sorry
----
2019-02-15 22:19:56 UTC - Grant Wu: But the log files in that directory ought
to explain the issue more clearly
----
2019-02-15 22:20:26 UTC - Laurent Chriqui: Ok I'll look at that.
----
2019-02-15 22:20:33 UTC - Grant Wu: iirc they don’t actually show up in
`bin/pulsar standalone` stdout/err output
----
2019-02-15 22:20:52 UTC - Grant Wu: I remember feeling rather helpless until I
realized the logs were available elsewhere
----
2019-02-15 22:30:12 UTC - Ali Ahmed: I am cataloging suggestions for
improvements to the pulsar docker image for future versions
comments are welcome
<https://github.com/apache/pulsar/issues/3611>
----
2019-02-16 00:16:09 UTC - Ali Ahmed: @Laurent Chriqui hi there is your issue
resolved
----
2019-02-16 00:16:17 UTC - David Kjerrumgaard: @Grant Wu The function logs will
be under `pulsar/logs/functions/public/default/<function name>` directory
+1 : Grant Wu
----
2019-02-16 00:19:39 UTC - Ali Ahmed: @Laurent Chriqui for an example for
classname it depends on the module path
```
\\ for file exclamation_function.py
from pulsar import Function
# The classic ExclamationFunction that appends an exclamation at the end
# of the input
class ExclamationFunction(Function):
def __init__(self):
pass
def process(self, input, context):
return input + '!'
```
class name will be “exclamation_function.ExclamationFunction”
----
2019-02-16 08:12:34 UTC - Laurent Chriqui: @Ali Ahmed thank you. I don't have
my work computer with me so I'll look at the logs and post them here on Monday
if I can't resolve the bug.
----
