Re: [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric

Hi, all: I have some question about LatencyGauge change to histogram metric. Whether such a scheme is feasible? I want to know the latest progress on the question of FLINK-7608. @zentol, you suggested that we should delay merging this PR by a week or 2, and now What should I do in my version 1.3

[jira] [Created] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

Elias Levy created FLINK-8352: - Summary: Flink UI Reports No Error on Job Submission Failures Key: FLINK-8352 URL: https://issues.apache.org/jira/browse/FLINK-8352 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8351) Canonical way to extract FoldingState QueryableStateStream

Raymond Tay created FLINK-8351: -- Summary: Canonical way to extract FoldingState QueryableStateStream Key: FLINK-8351 URL: https://issues.apache.org/jira/browse/FLINK-8351 Project: Flink Issue Ty

Re: Dynamic SessionWindow gaps

Sounds good, I'm on holiday at the moment. I'll get the ball rolling with a raised issue when I get in. Dyana On 2018-01-02 13:45, Aljoscha Krettek wrote: > Hi,> > > This sounds good! Could you please open a Jira Issue for this and then open a PR against that Jira issue?> > > Btw, I would sugges

[jira] [Created] (FLINK-8350) replace "taskmanager.tmp.dirs" with "env.io.tmp.dirs" for all components

Nico Kruber created FLINK-8350: -- Summary: replace "taskmanager.tmp.dirs" with "env.io.tmp.dirs" for all components Key: FLINK-8350 URL: https://issues.apache.org/jira/browse/FLINK-8350 Project: Flink

[jira] [Created] (FLINK-8349) Remove Yarn specific commands from YarnClusterClient

Till Rohrmann created FLINK-8349: Summary: Remove Yarn specific commands from YarnClusterClient Key: FLINK-8349 URL: https://issues.apache.org/jira/browse/FLINK-8349 Project: Flink Issue Type

[jira] [Created] (FLINK-8348) Print help for DefaultCLI

Till Rohrmann created FLINK-8348: Summary: Print help for DefaultCLI Key: FLINK-8348 URL: https://issues.apache.org/jira/browse/FLINK-8348 Project: Flink Issue Type: Sub-task Compon

Re: Dynamic SessionWindow gaps

Hi, Dyana dynamic gap is very useful feature, Agree with the suggestion of Aljoscha, looking forward the PR. Best, Jincheng 2018-01-02 21:45 GMT+08:00 Aljoscha Krettek : > Hi, > > This sounds good! Could you please open a Jira Issue for this and then > open a PR against that Jira issue? > > Btw,

[jira] [Created] (FLINK-8347) Make Cluster id typesafe

Till Rohrmann created FLINK-8347: Summary: Make Cluster id typesafe Key: FLINK-8347 URL: https://issues.apache.org/jira/browse/FLINK-8347 Project: Flink Issue Type: Sub-task Compone

Re: Dynamic SessionWindow gaps

Hi, This sounds good! Could you please open a Jira Issue for this and then open a PR against that Jira issue? Btw, I would suggest to implement this as a new type of assigner, something like DynamicSessionWindows. Best, Aljoscha > On 29. Dec 2017, at 20:54, Dyana Rose wrote: > > I have a us

Re: Need to restart flink job on yarn as supervisord does

Hi, I am using below restart strategy // Retry always env.setRestartStrategy(RestartStrategies.failureRateRestart( Integer.MAX_VALUE, // max failures per unit Time.of(20, TimeUnit.MINUTES), //time interval for measuring failure rate Time.of(10, TimeUnit.MINUTES) // delay )) But I am

[jira] [Created] (FLINK-8346) add S3 signature v4 workaround to docs

Nico Kruber created FLINK-8346: -- Summary: add S3 signature v4 workaround to docs Key: FLINK-8346 URL: https://issues.apache.org/jira/browse/FLINK-8346 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8345) Iterate over keyed state on broadcast side of connect with broadcast.

Kostas Kloudas created FLINK-8345: - Summary: Iterate over keyed state on broadcast side of connect with broadcast. Key: FLINK-8345 URL: https://issues.apache.org/jira/browse/FLINK-8345 Project: Flink

[jira] [Created] (FLINK-8344) Add support for HA to RestClusterClient

Till Rohrmann created FLINK-8344: Summary: Add support for HA to RestClusterClient Key: FLINK-8344 URL: https://issues.apache.org/jira/browse/FLINK-8344 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8343) Add support for job cluster deployment

Till Rohrmann created FLINK-8343: Summary: Add support for job cluster deployment Key: FLINK-8343 URL: https://issues.apache.org/jira/browse/FLINK-8343 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8342) Remove ClusterClient generic type argument from ClusterDescriptor

Till Rohrmann created FLINK-8342: Summary: Remove ClusterClient generic type argument from ClusterDescriptor Key: FLINK-8342 URL: https://issues.apache.org/jira/browse/FLINK-8342 Project: Flink

[jira] [Created] (FLINK-8341) Remove unneeded CommandLineOptions

Till Rohrmann created FLINK-8341: Summary: Remove unneeded CommandLineOptions Key: FLINK-8341 URL: https://issues.apache.org/jira/browse/FLINK-8341 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-8340) Do not pass Configuration and configuration directory to CustomCommandLine methods

Till Rohrmann created FLINK-8340: Summary: Do not pass Configuration and configuration directory to CustomCommandLine methods Key: FLINK-8340 URL: https://issues.apache.org/jira/browse/FLINK-8340 Proj

[jira] [Created] (FLINK-8339) Let CustomCommandLine return a ClusterDescriptor

Till Rohrmann created FLINK-8339: Summary: Let CustomCommandLine return a ClusterDescriptor Key: FLINK-8339 URL: https://issues.apache.org/jira/browse/FLINK-8339 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-8338) Make CustomCommandLines non static in CliFrontend

Till Rohrmann created FLINK-8338: Summary: Make CustomCommandLines non static in CliFrontend Key: FLINK-8338 URL: https://issues.apache.org/jira/browse/FLINK-8338 Project: Flink Issue Type: S

[jira] [Created] (FLINK-8337) GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable

Till Rohrmann created FLINK-8337: Summary: GatherSumApplyITCase.testConnectedComponentsWithObjectReuseDisabled instable Key: FLINK-8337 URL: https://issues.apache.org/jira/browse/FLINK-8337 Project: F