Also there seems to be a problem in this class public final class Modules
When I am running Harness example it fails with the error
Exception in thread "main" java.lang.IllegalStateException: There are no
routers defined.
at
org.apache.flink.statefun.flink.core.StatefulFunctionsUniverseValidator.validate(StatefulFunctionsUniverseValidator.java:31)
at
org.apache.flink.statefun.flink.core.StatefulFunctionsJob.main(StatefulFunctionsJob.java:66)
at
org.apache.flink.statefun.flink.harness.Harness.start(Harness.java:128)
at
com.lightbend.flink.statefun.examples.greeter.HarnessRunner.main(HarnessRunner.java:18)
Which seems to be due to the fact that the method:
public static Modules loadFromClassPath() {
Returns no stageful functions - just IO modules
> On May 22, 2020, at 12:03 AM, Tzu-Li (Gordon) Tai <[email protected]> wrote:
>
> Hi,
>
> Sorry, I need to correct my comment on using the Kafka ingress / egress with
> the Harness.
>
> That is actually doable, by adding an extra dependency to
> `statefun-flink-distribution` in your Harness program.
> That pulls in all the other required dependencies required by the Kafka
> ingress / egress, such as the source / sink providers and Flink Kafka
> connectors.
>
> Cheers,
> Gordon
>
> On Fri, May 22, 2020 at 12:04 PM Tzu-Li (Gordon) Tai <[email protected]
> <mailto:[email protected]>> wrote:
> Are you getting an exception from running the Harness?
> The Harness should already have the required configurations, such as the
> parent first classloading config.
>
> Otherwise, if you would like to add your own configuration, use the
> `withConfiguration` method on the `Harness` class.
>
> On Fri, May 22, 2020 at 7:19 AM Boris Lublinsky
> <[email protected] <mailto:[email protected]>> wrote:
> Also, where do I put flint-conf.yaml in Idea to add additional required
> config parameter:
> classloader.parent-first-patterns.additional:
> org.apache.flink.statefun;org.apache.kafka;com.google.protobuf
>
>
>> On May 21, 2020, at 12:22 PM, Boris Lublinsky <[email protected]
>> <mailto:[email protected]>> wrote:
>>
>> Hi,
>> I am trying to run
>> https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-greeter-example
>>
>> <https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-greeter-example>
>> locally
>> using
>> https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-flink-harness-example
>>
>> <https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-flink-harness-example>
>>
>> And have several questions.
>> 1. It seems fairly straightforward to use it with in memory message
>> generators, but I can’t figure out how to add Kafka ingress/Egress so that I
>> can use it with Kafk
>> 2. GreetingModule already creates StatefulFunctionUniverse and so does
>> Harness. Is there a way to short circuit it and have Harness get
>> StatefulFunctionUniverse directly
>> 3. Is there an example on how to write Flink main for stageful function?
>> 4. Is there an example anywhere on how to run such examples in the IDE with
>> Kafka?
>> 5 There is a great stateful functions example
>> https://github.com/ververica/flink-statefun-workshop
>> <https://github.com/ververica/flink-statefun-workshop>, but its readme does
>> not really describe implementation and neither does this article,
>> referencing it
>> https://dev.to/morsapaes/flink-stateful-functions-where-to-start-2j39
>> <https://dev.to/morsapaes/flink-stateful-functions-where-to-start-2j39>. Is
>> there anything that describes this implementation?
>>
>
