Metrics to data connectors

Hi, all, Is there any existing metrics implemented to any src/sink connectors? I am thinking to add some metrics to C* connector that might help to give a early sign of scalability problem (like back pressure) from data src / sink. I do not yet find any documentation regarding to adding connector

[jira] [Created] (FLINK-7633) Better documentation on C* sink on consistency guarantee

Michael Fong created FLINK-7633: --- Summary: Better documentation on C* sink on consistency guarantee Key: FLINK-7633 URL: https://issues.apache.org/jira/browse/FLINK-7633 Project: Flink Issue

[jira] [Created] (FLINK-7632) Better documentation on C* sink usage for Pojo and Tuples data types

Michael Fong created FLINK-7632: --- Summary: Better documentation on C* sink usage for Pojo and Tuples data types Key: FLINK-7632 URL: https://issues.apache.org/jira/browse/FLINK-7632 Project: Flink

Re: Using Maven Archetype Plugin 3.0+ to create flink-quickstart-java project

> release-1.3/quickstart/java_api_quickstart.html#create-project > > Afterwards you could update your dependencies (and add the Apache snapshot > repository) if you truly need the latest. > > Hope this helps! > > > On Sun, Sep 10, 2017 at 8:49 AM, Michael Fong > wrote:

Re: Using Maven Archetype Plugin 3.0+ to create flink-quickstart-java project

On Sun, Sep 10, 2017 at 6:57 AM, Michael Fong > wrote: > > > Hi, all, > > > > While trying out the examples from here > > <https://ci.apache.org/projects/flink/flink-docs- > release-1.4/quickstart/java_api_quickstart.html> > > and create maven project w/

Using Maven Archetype Plugin 3.0+ to create flink-quickstart-java project

Hi, all, While trying out the examples from here and create maven project w/ Maven Archetype Plugin. I've got a error complaining about [image: Inline image 1] This seems has something to do with Ma

Re: Quick start guide

Hi, Thanks for swift reply. I just created PR to fix this typo. Thanks. Regards, On Mon, Sep 4, 2017 at 4:31 PM, Aljoscha Krettek wrote: > Hi, > > Yes, I think this is wrong in the doc and should refer to the TaskManager > logs. > > Best, > Aljoscha > > > On

Quick start guide

Hi, I was following the quick start guide on official documents , and I came cross a line that caused a bit confusion. $ tail -f log/flink-*-jobmanager-*.out It is said the wordcount program would print

Re: mvn checkstyle error vs IDE based stylecheck

click apply.*"? > * > On 22.08.2017 14:53, Michael Fong wrote: > >> Hi, >> >> Thanks to your swift reply. >> >> IntelliJ complains about checkstyle rules with the following exception: >> >> org.infernus.idea.checkstyle.exception.C

Re: mvn checkstyle error vs IDE based stylecheck

image 1] On Tue, Aug 22, 2017 at 8:41 PM, Chesnay Schepler wrote: > The IDE setup guide you tried is what most people i know are using. > > Can you tell us how these didn't work for you? > > > On 22.08.2017 14:30, Michael Fong wrote: > >> Hi, all, >> >> >

mvn checkstyle error vs IDE based stylecheck

nce! Sincerely, Michael Fong

Re: How to build flink-dist.jar from source code

> On Fri, Aug 11, 2017 at 6:19 PM, Michael Fong > wrote: > > > Hi, > > > > I am new to Flink. I would like to know how to build the flink-dist.jar > > from source code, i.e. from the master branch from github. > > > > Could anyone show me the quickest way

How to build flink-dist.jar from source code

Hi, I am new to Flink. I would like to know how to build the flink-dist.jar from source code, i.e. from the master branch from github. Could anyone show me the quickest way to do so? Thanks in advance. Sincerely, Michael Fong