Hi,
As a platform user, I want to integrate Flink SQL with the platform. The usage
scenario is：users register table/udf to catalog service, and then write SQL
scripts like: "insert into xxx select from xxx" through Web SQLEditor, the
platform need to validate the SQL script after each time the use
Hi，
I encountered an error while running the kafka sink demo in IDEA.
This is the complete code:
import java.util.Properties
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.runtime.state.filesystem.FsStateBackend
import
org.apache.flink.streaming.api.e
I think this is not the root cause of job failure, this task is caused by
other tasks failing. You can check the log of the first failed task.
2017-03-10 12:25 GMT+08:00 Govindarajan Srinivasaraghavan <
govindragh...@gmail.com>:
> Hi All,
>
> I see the below error after running my streaming job f
