Re: [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer

Hi Fabian, You are right, the main thing we need to change for removing STREAM keyword is the table registration. If you would like, I can do a prototype. Hi Timo, I’m glad to contribute our work back to Flink. I will look into it and create JIRAs next days. - Jark Wu > 在

[DISCUSS][FLINK-3414] Scala API for CEP's pattern definition

Hi, Currently CEP supports API for pattern definition, but it is very similar to the Java one. Using Scala we could achieve much more concise API. In JIRA comment for this task I've described a proposal for how this API could look like: [1] Could you please review it and write your comments?

[DISCUSS] [FLINK-3950] Meter interface

Hi, I was working on the creating new Meter metric type, but I need some input to define a proper interface for it. Initial idea developed in this pull request [1] was to follow Dropwizard's meter interface, but zentol suggested that we may need a different interface for Flink use-cases. The

[jira] [Created] (FLINK-4459) Introduce SlotProvider to Scheduler

Till Rohrmann created FLINK-4459: Summary: Introduce SlotProvider to Scheduler Key: FLINK-4459 URL: https://issues.apache.org/jira/browse/FLINK-4459 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4457) Make the ExecutionGraph independent of Akka

Till Rohrmann created FLINK-4457: Summary: Make the ExecutionGraph independent of Akka Key: FLINK-4457 URL: https://issues.apache.org/jira/browse/FLINK-4457 Project: Flink Issue Type:

[jira] [Created] (FLINK-4456) Replace ActorGateway in RuntimeEnvironment by interface

Till Rohrmann created FLINK-4456: Summary: Replace ActorGateway in RuntimeEnvironment by interface Key: FLINK-4456 URL: https://issues.apache.org/jira/browse/FLINK-4456 Project: Flink Issue

[jira] [Created] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces

Till Rohrmann created FLINK-4455: Summary: Replace ActorGateways in NetworkEnvironment by interfaces Key: FLINK-4455 URL: https://issues.apache.org/jira/browse/FLINK-4455 Project: Flink

Re: [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer

Hi Jark, We can think about removing the STREAM keyword or not. In principle, Calcite should allow the same windowing syntax on streaming and static tables (this is one of the main goals of Calcite). The Table API can also distinguish stream and batch without the STREAM keyword by looking at the

[jira] [Created] (FLINK-4454) Lookups for JobManager address in config

Maximilian Michels created FLINK-4454: - Summary: Lookups for JobManager address in config Key: FLINK-4454 URL: https://issues.apache.org/jira/browse/FLINK-4454 Project: Flink Issue Type:

[jira] [Created] (FLINK-4453) Scala code example in Window documentation shows Java

Fabian Hueske created FLINK-4453: Summary: Scala code example in Window documentation shows Java Key: FLINK-4453 URL: https://issues.apache.org/jira/browse/FLINK-4453 Project: Flink Issue

[jira] [Created] (FLINK-4452) TaskManager network buffer guages

Greg Hogan created FLINK-4452: - Summary: TaskManager network buffer guages Key: FLINK-4452 URL: https://issues.apache.org/jira/browse/FLINK-4452 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4451) Throw exception when remote connection cannot be resolved

Till Rohrmann created FLINK-4451: Summary: Throw exception when remote connection cannot be resolved Key: FLINK-4451 URL: https://issues.apache.org/jira/browse/FLINK-4451 Project: Flink

[jira] [Created] (FLINK-4450) update storm version to 1.0.0

yuzhongliu created FLINK-4450: - Summary: update storm version to 1.0.0 Key: FLINK-4450 URL: https://issues.apache.org/jira/browse/FLINK-4450 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer

Hi Fabian, Timo, Sorry for the late response. Regarding Calcite’s StreamSQL syntax, what I concern is only the STREAM keyword and no agg-without-window. Which makes different syntax for streaming and static tables. I don’t think Flink should have a custom SQL syntax, but it’s better to have a

Re: [DISCUSS] Some thoughts about unify Stream SQL and Batch SQL grammer

On Tue, Aug 23, 2016 at 9:47 AM, Fabian Hueske wrote: > I drafted an API proposal a few months ago [2] and could convert this into > a FLIP to discuss the API and break it down into subtasks. > > What do you think? Sounds very reasonable :) +1

[jira] [Created] (FLINK-4449) Heartbeat Manager between ResourceManager and TaskExecutor

zhangjing created FLINK-4449: Summary: Heartbeat Manager between ResourceManager and TaskExecutor Key: FLINK-4449 URL: https://issues.apache.org/jira/browse/FLINK-4449 Project: Flink Issue Type: