2019-05-12 11:35:54 UTC - Nicolas Ha: Re: presto above - so I get further,
trying to publish an avro message and the topic seems to be picked up:
```show tables in pulsar."public/default";
ERROR: failed to open pager: Cannot run program "less": error=2, No such file
or directory
Table
--------------------
publish_test_topic
(1 row)```
then I try to select it ``` select * from
pulsar."public/default"."publish_test_topic";
Query 20190512_113013_00109_38vp7 failed: Table has no columns:
pulsar:PulsarTableHandle{connectorId=pulsar, schemaName=public/default,
tableName=publish_test_topic, topicName=publish_test_topic}
```
What does `Table has no columns` means?
After `.send()` my message, I can print the `BatchMessageIdImpl`fine (something
like “928:0:-1:0”)
----
2019-05-12 11:38:54 UTC - Nicolas Ha: I suppose since I use the
`Schema/AUTO_PRODUCE_BYTES` it means it doesn’t detect an avro message and
therefore doesn’t expose it to presto?
----
2019-05-12 11:41:30 UTC - Nicolas Ha: I tried this too ```select * from
publish_test_topic;
Query 20190512_113721_00126_38vp7 failed: line 1:15: Schema must be specified
when session schema is not set```
If this is the way to go - how am I supposed to specify the schema?
----
2019-05-12 19:43:42 UTC - Roland Divin: @Roland Divin has joined the channel
----
2019-05-13 06:49:38 UTC - Ruidong Li: @Ruidong Li has joined the channel
----
2019-05-13 07:28:35 UTC - Shivji Kumar Jha: Thanks @Matteo Merli
Would you want to do this in clientconfigurationdata then?
```
+private String authPluginClassName;
+private Map<String, String> authParams;
```
Alternatively, we could keep this context local to pulsar-flink:
1. keep authplugin and param as local variables in PulsarSourceBuilder
2. On build(), create an authentication instance
Which approach do you prefer for the community code? I will raise a PR if
required.
----
2019-05-13 07:33:51 UTC - Shivji Kumar Jha: this should be generic enough and
work with every client and every auth implementation type..
----
