Member since
10-19-2016
151
Posts
59
Kudos Received
17
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
1777 | 03-22-2018 11:48 AM | |
2865 | 01-12-2018 06:25 PM | |
5117 | 01-12-2018 03:56 AM | |
7103 | 01-12-2018 03:38 AM | |
3661 | 01-02-2018 10:29 PM |
03-02-2017
11:25 PM
@Adedayo Adekeye Do you already have an active connection to Azure open? Sounds like the ports are already bounded as they should be from another place. Check for active SSH connections, or sandboxes actively running on Virtualbox/Docker.
... View more
03-02-2017
10:11 PM
@Adedayo Adekeye Heya, you mentioned deploying on Azure, but are SSH'ing into localhost? Try following this and see if it helps: https://hortonworks.com/hadoop-tutorial/port-forwarding-azure-sandbox/
... View more
03-01-2017
09:30 PM
Thanks @Patrick Picard Fixed! https://hortonworks.com/hadoop-tutorial/deploying-hortonworks-sandbox-on-microsoft-azure
... View more
02-01-2017
01:12 AM
What are suggested/recommended topic naming conventions? I've been influenced by period-separated templates I found on mailing lists like: <root_namespace>.<product>.<product_specific_hierarchy>
<app type>.<app name>.<data set name>.<stage of processing>
<organization_name>.<app_name>.<data_set_name>
... View more
01-24-2017
06:39 PM
Fantastic advice - thanks! That'll help immensely moving forward
... View more
01-24-2017
05:54 AM
2 Kudos
I'm able to make GET calls just fine, though the NiFi docs for PUT/POST are a bit cryptic. As I understand it, we need to call POST on /process-groups/{id}/process-groups to create a process group before we can upload a template. However, after reading through the API docs, I can't seem to figure out what is required in the body (API docs suggest everything is optional). I'll repeatedly get "Process group details must be specified" despite trying different requests. Anyone happen to have examples of creating a process group, preferably up to and including uploading a template?
I was using the following resources from Andrew and Matthew, but unfortunately not compatible with the new API.
https://github.com/aperepel/nifi-api-deploy
https://github.com/mattyb149/nifi-client
... View more
Labels:
- Labels:
-
Apache NiFi
01-17-2017
08:56 PM
Fantastic, that did the trick! Thank you
... View more
01-15-2017
09:16 AM
I have data that I want to serialize, and I currently have it laid out like so: val mySerializer: AvroSnapshotSerializer = schemaRegistryClient.getDefaultSerializer(...)
val myObj: GenericData.Record = new GenericData.Record(...)
val myMetadata: SchemaMetadata = new SchemaMetadata.Builder("NameOfMySchema")
.schemaGroup(...)
.description(...)
.etc.
val serializedObj = mySerializer.serializer(myObj, myMetadata) Assuming that I've already registered my schema (by hand or in another application), is there a way to use the Serializer's serialize() method without having to build the metadata all over again? Can I retrieve the a SchemaMetadata object from, say, the SchemaVersionInfo that I get with the following? schemaRegistryClient.getLatestSchemaVersionInfo("NameOfMySchema")
Having looked through the reference material and source code, I can't seem to find a way to get a copy of the metadata from without building it anew. Thanks! Edgar
... View more
Labels:
- Labels:
-
Schema Registry
01-11-2017
01:07 AM
Ah, gotcha. Will use that workaround - thanks!
... View more
01-11-2017
12:25 AM
1 Kudo
I’m working with NiFi WebSocket
processors, and I’d like to update connected clients as data makes its way
through the flow. Is there a way to
register WS connections in such a way where once data makes its way to a PutWebSocket processor, I can push to all registered clients automatically? Is this outside the scope of what NiFi may have been intended for? Thanks!
... View more
Labels:
- Labels:
-
Apache NiFi
- « Previous
- Next »