Re: Advice - Drools in Flink

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

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

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

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

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

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

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

Re: Advice - Drools in Flink

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 -

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

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

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

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

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

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

Re: UDF in Flink table API

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

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: > >

Re: Adding a Histogram Metric

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

[jira] [Created] (FLINK-4110) Provide testing skeleton in quickstarts

Robert Metzger created FLINK-4110: - Summary: Provide testing skeleton in quickstarts Key: FLINK-4110 URL: https://issues.apache.org/jira/browse/FLINK-4110 Project: Flink Issue Type:

Re: Advice - Drools in Flink

Hi Anton, you mean - keeping working memory facts in Flink state and with each event throw them into stateless session? Can you elaborate a bit on your use case? What would be the state? Would it be for example some event aggregations, which would be filtered by the rules? maciek On

Re: Adding a Histogram Metric

Is there a ticket for supporting user defined counters? Thanks, Steve On Sat, Jun 18, 2016 at 8:18 AM, Steve Cosenza wrote: > Perfect! > > -Steve > > > On Saturday, June 18, 2016, Chesnay Schepler wrote: > >> it would be scoped and reported just like