Re: Advice - Drools in Flink

2016-06-23 Thread Maciek Próchniak
Hi Anton, I think I start to understand what you want to achieve. I would be a very interesting thing to do ;) If the drools are the piece that decides what is interesting and what is not, then probably also drools should be responisble for keeping state/aggregates - otherwise Flink would kee

[jira] [Created] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions

2016-06-23 Thread Josh Forman-Gornall (JIRA)
Josh Forman-Gornall created FLINK-4115: -- Summary: FsStateBackend filesystem verification can cause classpath exceptions Key: FLINK-4115 URL: https://issues.apache.org/jira/browse/FLINK-4115 Proje

[jira] [Created] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner

2016-06-23 Thread Chris Hogue (JIRA)
Chris Hogue created FLINK-4114: -- Summary: Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner Key: FLINK-4114 URL: https://issues.apache.org/jira/browse/FLINK-4114

[jira] [Created] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

2016-06-23 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4113: - Summary: Always copy first value in ChainedAllReduceDriver Key: FLINK-4113 URL: https://issues.apache.org/jira/browse/FLINK-4113 Project: Flink Issue Type: Bug

Re: Shading Plugin + Hadoop Dependency

2016-06-23 Thread Vijay Srinivasaraghavan
Hi Rob, I ran the build and now I could see the minikdc classes bundled in "flink-shaded-include-yarn-tests/target/flink-shaded-include-yarn-tests-1.1-SNAPSHOT.jar" location. cd /workspace/git-projects/flink/flink-shaded-hadoop/flink-shaded-include-yarn-tests $ jar tf target/flink-shaded-includ

Re: Advice - Drools in Flink

2016-06-23 Thread Anton
Hi Maciek Firstly, thanks for your replies and interest. It is really appreciated. I am familiar with Drools but am new to Flink. Whereas you seem familiar with both - so your feedback is really appreciated. On Thu, Jun 23, 2016 at 8:30 AM, Maciek Próchniak wrote: > > you mean - keeping working

[jira] [Created] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

2016-06-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4112: Summary: Replace SuppressRestartException with disabling RestartStrategy Key: FLINK-4112 URL: https://issues.apache.org/jira/browse/FLINK-4112 Project: Flink

[jira] [Created] (FLINK-4111) Flink Table & SQL doesn't work in very simple example

2016-06-23 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4111: -- Summary: Flink Table & SQL doesn't work in very simple example Key: FLINK-4111 URL: https://issues.apache.org/jira/browse/FLINK-4111 Project: Flink Issue Type: Bug

Re: [DISCUSS] Releasing Flink 1.1.0

2016-06-23 Thread Robert Metzger
Hi, it doesn't seem that there are volunteers for the RM, so I'll probably do it. I try to do the first release candidate (mostly for testing) next week (it depends on the JIRAs fixed by then) On Thu, Jun 16, 2016 at 10:56 PM, Henry Saputra wrote: > Thanks for the reply, @Max. I was not aware i

Re: Flink Table & SQL doesn't work in very simple example

2016-06-23 Thread Fabian Hueske
Hi Jark Wu, yes, that looks like a dependency issue. Can you open a JIRA for it set "Fix Version" to 1.1.0. This issue should be resolved for the 1.1 release. Thanks, Fabian 2016-06-22 3:52 GMT+02:00 Jark Wu : > Hi, > > > I’m trying to use Flink Table 1.1-SNAPSHOT where I want to use Table API

Re: UDF in Flink table API

2016-06-23 Thread Fabian Hueske
Hi Cody, actually, there is no functionality to add a UDF in the Table API / SQL. This feature is definitely on the roadmap but not implemented, yet. The related JIRA is FLINK-3097. In fact, the FunctionCatalog and FrameworkConfig should not be publicly accessible from the TableEnvironment, IMO.

Re: [Discuss] java.lang.UnsatisfiedLinkError

2016-06-23 Thread Till Rohrmann
Hi Vinay, maybe this http://stackoverflow.com/questions/22150417/hadoop-mapreduce-java-lang-unsatisfiedlinkerror-org-apache-hadoop-util-nativec might help you. Cheers, Till On Thu, Jun 23, 2016 at 5:15 AM, Vinay Patil wrote: > Hi All, > > Just an update on this: > > Setting the codec using Dat

Re: Adding a Histogram Metric

2016-06-23 Thread Till Rohrmann
Hi Steve, that should be the corresponding JIRA ticket [1]. I think Chesnay already opened a PR for this feature. I think it will be reviewed and probably merged next week. [1] https://issues.apache.org/jira/browse/FLINK-4093 Cheers, Till On Thu, Jun 23, 2016 at 4:33 AM, Steve Cosenza wrote: