Hi thekingofcity, Thanks for your interest! Unfortunately we don't have an example for online learning for now.
We are working on an online machine learning example. Hopefully it will be added here [1] in the next three weeks. [1] https://github.com/apache/flink-ml thekingofcity <kingofthec...@protonmail.com> 于2022年1月26日周三 16:47写道： > Hi, > > I want sink the model data (coefficient from the logsitic regression model > in my case) from the flink.ml.api.Model to print or file. I figure out the > way to sink it in the batch training mode but face the following exception > when the Estimator takes an UNBOUNDED datastream. > > ``` > Caused by: java.lang.IllegalStateException: There can be only a single > consumer in a FeedbackChannel. > at > org.apache.flink.statefun.flink.core.feedback.FeedbackChannel.registerConsumer(FeedbackChannel.java:79) > ``` > > This will happend if I dump it through the Table API like this: > > ``` > final TableDescriptor sinkDescriptor = TableDescriptor > .forConnector("print") > .schema(Schema > .newBuilder() > .column("coefficient", DataTypes.of(new > DenseVectorTypeInfo())) > .build() > ).build(); > tEnv.createTemporaryTable("ModelSink", sinkDescriptor); > model.getModelData()[0].executeInsert("ModelSink"); > ``` > > Looking for an example that can sink the model data in online training > mode. > > With many thanks, > thekingofcity > > -- best, Zhipeng
