The pluggable architecture is great! (why Don't we call it Flink plugins?
my 2 cents)
It will be nice if we come up with an idea of what directory structure
should look like before start dumping connectors (plugins).
Also wonder what to do with versioning.
At some point, for example, Twitter v1 con
jun aoki created FLINK-3149:
---
Summary: mvn test fails on flink-runtime because curator classes
not found
Key: FLINK-3149
URL: https://issues.apache.org/jira/browse/FLINK-3149
Project: Flink
Thank you Robert, now I can assign myself.
On Wed, Nov 25, 2015 at 1:09 AM, Robert Metzger wrote:
> I added you as a contributor.
>
> On Wed, Nov 25, 2015 at 7:29 AM, jun aoki wrote:
>
> > Hi Henry, thank you for helping. My id is jaoki
> >
> > On Tue, Nov 24,
ning to work on it.
>
> - Henry
>
> On Tue, Nov 24, 2015 at 5:18 PM, jun aoki wrote:
> > So that I can assign myself to Flink jiras?
> >
> > --
> > -jun
>
--
-jun
So that I can assign myself to Flink jiras?
--
-jun
ig.html#file-systems
>
> The behavior we support right now is pretty much what people coming from
> the Hadoop world are used to, that's why it behaves the way it does.
>
> Greetings,
> Stephan
>
>
> On Sun, Nov 22, 2015 at 8:49 AM, jun aoki wrote:
>
> >
jun aoki created FLINK-3059:
---
Summary: Javadoc fix for DataSet.writeAsText()
Key: FLINK-3059
URL: https://issues.apache.org/jira/browse/FLINK-3059
Project: Flink
Issue Type: Bug
you really need a single output.
> >
> > On Fri, Nov 20, 2015, 21:27 Suneel Marthi wrote:
> >
> >> You can write to a single output file by setting parallelism == 1
> >>
> >> So final ExecutionEnvironment env = ExecutionEnvironment.
> >> createLo
Hi Flink community
I know I'm mistaken but could not find what I want.
final ExecutionEnvironment env =
ExecutionEnvironment.createLocalEnvironment();
DataSet data = env.readTextFile("file:///text1.txt");
FilterFunction filter = new MyFilterFunction(); // looks for a
line starts with "[ERROR]"
D
jun aoki created FLINK-3012:
---
Summary: Refactor boilerplate code of while and if statements in
DataSourceTask
Key: FLINK-3012
URL: https://issues.apache.org/jira/browse/FLINK-3012
Project: Flink
10 matches
Mail list logo
