[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

2016-07-22 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15389743#comment-15389743 ] Gary Yao commented on FLINK-4228: - We also want to use RocksDB with checkpointing to s3a. We would prefer

[jira] [Commented] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-07-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15387371#comment-15387371 ] Gary Yao commented on FLINK-4236: - See

[jira] [Created] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-07-20 Thread Gary Yao (JIRA)
Gary Yao created FLINK-4236: --- Summary: Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up Key: FLINK-4236 URL: https://issues.apache.org/jira/browse/FLINK-4236 Project:

[jira] [Created] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Gary Yao (JIRA)
Gary Yao created FLINK-7839: --- Summary: Creating Quickstart project for SNAPSHOT version fails Key: FLINK-7839 URL: https://issues.apache.org/jira/browse/FLINK-7839 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

2017-10-13 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7839: Description: The documentation on creating quickstart projects is broken for SNAPSHOT releases. For

[jira] [Assigned] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2017-10-12 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-5789: --- Assignee: Gary Yao > Make Bucketing Sink independent of Hadoop's FileSystem >

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2017-10-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209445#comment-16209445 ] Gary Yao commented on FLINK-5789: - [~till.rohrmann] I am not confident that this will make it into 1.4.

[jira] [Assigned] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2017-11-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-5789: --- Assignee: (was: Gary Yao) > Make Bucketing Sink independent of Hadoop's FileSystem >

[jira] [Assigned] (FLINK-7805) Add HA capabilities to YarnResourceManager

2017-11-28 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7805: --- Assignee: Gary Yao > Add HA capabilities to YarnResourceManager >

[jira] [Assigned] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-11-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7694: --- Assignee: Gary Yao (was: Bowen Li) > Port JobMetricsHandler to new REST handler >

[jira] [Updated] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-11-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7694: Labels: flip6 (was: ) > Port JobMetricsHandler to new REST handler >

[jira] [Updated] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-11-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7694: Component/s: Distributed Coordination > Port JobMetricsHandler to new REST handler >

[jira] [Updated] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-11-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7694: Description: Port {{org.apache.flink.runtime.rest.handler.legacy.metrics.JobMetricsHandler}} > Port

[jira] [Assigned] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-11-22 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7716: --- Assignee: Gary Yao (was: Hai Zhou UTC+8) > Port JobManagerMetricsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint

2017-11-22 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7717: --- Assignee: Gary Yao (was: Hai Zhou UTC+8) > Port TaskManagerMetricsHandler to new REST endpoint >

[jira] [Created] (FLINK-8143) Port SubtaskMetricsHandler to new REST endpoint

2017-11-23 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8143: --- Summary: Port SubtaskMetricsHandler to new REST endpoint Key: FLINK-8143 URL: https://issues.apache.org/jira/browse/FLINK-8143 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-8143) Port SubtaskMetricsHandler to new REST endpoint

2017-11-23 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8143: --- Assignee: Gary Yao > Port SubtaskMetricsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-11-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8176: --- Assignee: Gary Yao > Dispatcher does not start SubmittedJobGraphStore >

[jira] [Updated] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-11-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8176: Description: {{Dispatcher}} never calls start on its {{SubmittedJobGraphStore}} instance. Hence, when a

[jira] [Created] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-11-30 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8176: --- Summary: Dispatcher does not start SubmittedJobGraphStore Key: FLINK-8176 URL: https://issues.apache.org/jira/browse/FLINK-8176 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-11-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8176: Labels: flip-6 (was: ) > Dispatcher does not start SubmittedJobGraphStore >

[jira] [Updated] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-11-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7694: Description: Port {{org.apache.flink.runtime.rest.handler.legacy.metrics.JobMetricsHandler}} to new

[jira] [Created] (FLINK-8150) WebUI in FLIP-6 mode exposes TaskManagerConnection IDs as TaskManager IDs

2017-11-24 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8150: --- Summary: WebUI in FLIP-6 mode exposes TaskManagerConnection IDs as TaskManager IDs Key: FLINK-8150 URL: https://issues.apache.org/jira/browse/FLINK-8150 Project: Flink

[jira] [Updated] (FLINK-7694) Port JobMetricsHandler to new REST handler

2017-11-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7694: Labels: flip-6 (was: flip6) > Port JobMetricsHandler to new REST handler >

[jira] [Updated] (FLINK-8176) Dispatcher does not start SubmittedJobGraphStore

2017-11-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8176: Component/s: YARN > Dispatcher does not start SubmittedJobGraphStore >

[jira] [Assigned] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-14 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8234: --- Assignee: Gary Yao > Cache JobExecutionResult from finished JobManagerRunners >

[jira] [Updated] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable

2017-12-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8281: Description: {noformat} org.apache.flink.streaming.runtime.tasks.AsynchronousException:

[jira] [Assigned] (FLINK-8233) Retrieve ExecutionResult by REST polling

2017-12-15 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8233: --- Assignee: Gary Yao > Retrieve ExecutionResult by REST polling >

[jira] [Created] (FLINK-8269) Set netRuntime in JobExecutionResult

2017-12-15 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8269: --- Summary: Set netRuntime in JobExecutionResult Key: FLINK-8269 URL: https://issues.apache.org/jira/browse/FLINK-8269 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-19 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8234: Priority: Blocker (was: Major) > Cache JobExecutionResult from finished JobManagerRunners >

[jira] [Updated] (FLINK-8233) Retrieve ExecutionResult by REST polling

2017-12-19 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8233: Priority: Blocker (was: Major) > Retrieve ExecutionResult by REST polling >

[jira] [Created] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

2017-11-14 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8067: --- Summary: User code ClassLoader not set before calling ProcessingTimeCallback Key: FLINK-8067 URL: https://issues.apache.org/jira/browse/FLINK-8067 Project: Flink

[jira] [Created] (FLINK-8119) Cannot submit jobs to YARN Session in FLIP-6 mode

2017-11-21 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8119: --- Summary: Cannot submit jobs to YARN Session in FLIP-6 mode Key: FLINK-8119 URL: https://issues.apache.org/jira/browse/FLINK-8119 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

2017-11-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7718: --- Assignee: Gary Yao > Port JobVertixMetricsHandler to new REST endpoint >

[jira] [Updated] (FLINK-8119) Cannot submit jobs to YARN Session in FLIP-6 mode

2017-11-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8119: Labels: flip-6 (was: ) > Cannot submit jobs to YARN Session in FLIP-6 mode >

[jira] [Created] (FLINK-8120) Cannot access Web UI from YARN application overview in FLIP-6 mode

2017-11-21 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8120: --- Summary: Cannot access Web UI from YARN application overview in FLIP-6 mode Key: FLINK-8120 URL: https://issues.apache.org/jira/browse/FLINK-8120 Project: Flink

[jira] [Updated] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

2017-11-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7718: Description: Port {{JobVertexMetricsHandler}} to new REST endpoint. (was: Port {{JobVertixMetricsHandler}}

[jira] [Comment Edited] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-11-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261014#comment-16261014 ] Gary Yao edited comment on FLINK-7716 at 11/21/17 4:39 PM: --- [~yew1eb] This

[jira] [Commented] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

2017-11-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261014#comment-16261014 ] Gary Yao commented on FLINK-7716: - [~yew1eb] This ticket is similar to FLINK-7718 which I am currently

[jira] [Comment Edited] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-03 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237616#comment-16237616 ] Gary Yao edited comment on FLINK-7880 at 11/3/17 1:55 PM: -- I have further

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

2017-11-03 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237616#comment-16237616 ] Gary Yao commented on FLINK-7880: - I have further isolated the problem. The problem still appears even if

[jira] [Created] (FLINK-7960) ExecutionGraphRestartTest fails sporadically

2017-11-01 Thread Gary Yao (JIRA)
Gary Yao created FLINK-7960: --- Summary: ExecutionGraphRestartTest fails sporadically Key: FLINK-7960 URL: https://issues.apache.org/jira/browse/FLINK-7960 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-7960) ExecutionGraphRestartTest fails sporadically

2017-11-01 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-7960: --- Assignee: Gary Yao (was: Till Rohrmann) > ExecutionGraphRestartTest fails sporadically >

[jira] [Updated] (FLINK-7960) ExecutionGraphRestartTest fails sporadically

2017-11-01 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7960: Description: When running {{ExecutionGraphRestartTest}} as a whole, {{testConcurrentLocalFailAndRestart}}

[jira] [Updated] (FLINK-7960) ExecutionGraphRestartTest fails sporadically

2017-11-01 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7960: Description: When running {{ExecutionGraphRestartTest}} as a whole, {{testConcurrentLocalFailAndRestart}}

[jira] [Updated] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

2017-11-07 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8005: Description: *Problem Description* Classes in the user code jar cannot be loaded by the snapshot thread’s

[jira] [Updated] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

2017-11-07 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8005: Fix Version/s: 1.4.0 > Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues >

[jira] [Created] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

2017-11-07 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8005: --- Summary: Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues Key: FLINK-8005 URL: https://issues.apache.org/jira/browse/FLINK-8005 Project: Flink

[jira] [Assigned] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

2017-11-07 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8005: --- Assignee: Gary Yao > Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues >

[jira] [Updated] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8040: Description: Test {{ResourceGuard#testCloseBlockIfAcquired()}} fails sporadically with {noformat}

[jira] [Created] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-09 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8040: --- Summary: Test instability ResourceGuard#testCloseBlockIfAcquired Key: FLINK-8040 URL: https://issues.apache.org/jira/browse/FLINK-8040 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8040: --- Assignee: Stefan Richter > Test instability ResourceGuard#testCloseBlockIfAcquired >

[jira] [Updated] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8040: Description: Test {{ResourceGuard#testCloseBlockIfAcquired()}} fails sporadically with {noformat}

[jira] [Updated] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8040: Description: Test {{ResourceGuard#testCloseBlockIfAcquired()}} fails sporadically with {noformat}

[jira] [Updated] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8040: Description: Test {{ResourceGuard#testCloseBlockIfAcquired()}} fails sporadically with {noformat}

[jira] [Created] (FLINK-7978) Kafka011 exactly-once Producer sporadically fails to commit under high parallelism

2017-11-04 Thread Gary Yao (JIRA)
Gary Yao created FLINK-7978: --- Summary: Kafka011 exactly-once Producer sporadically fails to commit under high parallelism Key: FLINK-7978 URL: https://issues.apache.org/jira/browse/FLINK-7978 Project:

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

2017-10-21 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-5789: Fix Version/s: (was: 1.4.0) 1.5.0 > Make Bucketing Sink independent of Hadoop's

[jira] [Assigned] (FLINK-8300) Make JobExecutionResult accessible in per-job cluster mode

2017-12-20 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8300: --- Assignee: (was: Gary Yao) Summary: Make JobExecutionResult accessible in per-job cluster

[jira] [Created] (FLINK-8299) Retrieve ExecutionResult by REST polling

2017-12-20 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8299: --- Summary: Retrieve ExecutionResult by REST polling Key: FLINK-8299 URL: https://issues.apache.org/jira/browse/FLINK-8299 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-8233) Expose JobExecutionResult via HTTP

2017-12-20 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8233: Description: Expose {{JobExecutionResult}} from a finished Flink job via HTTP: * Add a new

[jira] [Updated] (FLINK-8233) Expose JobExecutionResult via HTTP

2017-12-20 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8233: Summary: Expose JobExecutionResult via HTTP (was: Retrieve ExecutionResult by REST polling) > Expose

[jira] [Updated] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-20 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8234: Description: In order to serve the {{JobExecutionResults}} we have to cache them in the {{Dispatcher}}

[jira] [Created] (FLINK-8300) Make JobExecutionResult accessible from JobMaster

2017-12-20 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8300: --- Summary: Make JobExecutionResult accessible from JobMaster Key: FLINK-8300 URL: https://issues.apache.org/jira/browse/FLINK-8300 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-8300) Make JobExecutionResult accessible from JobMaster

2017-12-20 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8300: Description: In order to serve the {{JobExecutionResults}} we have to cache them in the {{JobMaster}} after

[jira] [Assigned] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-05-07 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9261: --- Assignee: Gary Yao > Regression - Flink CLI and Web UI not working when SSL is enabled >

[jira] [Assigned] (FLINK-9190) YarnResourceManager sometimes does not request new Containers

2018-04-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9190: --- Assignee: Gary Yao (was: Sihua Zhou) > YarnResourceManager sometimes does not request new

[jira] [Updated] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-26 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9196: Description: When deploying on YARN in flip6 mode, the Flink binaries are not deleted from HDFS after the

[jira] [Updated] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-26 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9196: Description: When deploying on YARN in flip6 mode, the Flink binaries are not deleted from HDFS after the

[jira] [Updated] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-05-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9398: Description: See:

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-6160: Description: In case of a heartbeat timeout, the {{TaskExecutor}} closes the connection to the remote

[jira] [Assigned] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-6160: --- Assignee: Till Rohrmann (was: Gary Yao) > Retry JobManager/ResourceManager connection in case of

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-6160: Fix Version/s: 1.5.0 > Retry JobManager/ResourceManager connection in case of timeout >

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-6160: Affects Version/s: 1.6.0 > Retry JobManager/ResourceManager connection in case of timeout >

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-6160: Priority: Blocker (was: Major) > Retry JobManager/ResourceManager connection in case of timeout >

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-6160: Affects Version/s: 1.5.0 > Retry JobManager/ResourceManager connection in case of timeout >

[jira] [Assigned] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-6160: --- Assignee: Gary Yao > Retry JobManager/ResourceManager connection in case of timeout >

[jira] [Closed] (FLINK-8434) The new yarn resource manager should take over the running task managers after failover

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-8434. --- Resolution: Duplicate Fix Version/s: 1.5.0 > The new yarn resource manager should take over the

[jira] [Closed] (FLINK-8232) Create RestHandler for long running operations

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-8232. --- Resolution: Fixed > Create RestHandler for long running operations >

[jira] [Updated] (FLINK-6160) Retry JobManager/ResourceManager connection in case of timeout

2018-05-17 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-6160: Description: In case of a heartbeat timeout, the {{TaskExecutor}} closes the connection to the remote

[jira] [Assigned] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

2018-05-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8468: --- Assignee: (was: Gary Yao) > Make the connector to take advantage of AMQP features (routing key,

[jira] [Assigned] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties)

2018-05-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8468: --- Assignee: Gary Yao > Make the connector to take advantage of AMQP features (routing key, exchange >

[jira] [Created] (FLINK-9399) TPCHQuery3 fails due to Serialization issues

2018-05-18 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9399: --- Summary: TPCHQuery3 fails due to Serialization issues Key: FLINK-9399 URL: https://issues.apache.org/jira/browse/FLINK-9399 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9399) TPCHQuery3 example fails due to Serialization issues

2018-05-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9399: Summary: TPCHQuery3 example fails due to Serialization issues (was: TPCHQuery3 fails due to Serialization

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2018-06-06 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503691#comment-16503691 ] Gary Yao commented on FLINK-5486: - I don't see why this is needed. Flink callbacks are generally not

[jira] [Assigned] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

2018-05-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8718: --- Assignee: (was: Gary Yao) > Non-parallel DataStreamSource does not set max parallelism >

[jira] [Commented] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

2018-05-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492071#comment-16492071 ] Gary Yao commented on FLINK-8718: - Can this be fixed at all? > Non-parallel DataStreamSource does not set

[jira] [Commented] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16528614#comment-16528614 ] Gary Yao commented on FLINK-9649: - [~lishim] Actually, the config key \{{mesos.initial-tasks}} is not

[jira] [Assigned] (FLINK-9000) Add automated cluster framework tests

2018-07-02 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9000: --- Assignee: (was: Gary Yao) > Add automated cluster framework tests >

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

2018-06-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524649#comment-16524649 ] Gary Yao commented on FLINK-4534: - Is this really needed? Flink callbacks are generally not invoked

[jira] [Commented] (FLINK-9649) TaskManagers are not scheduled on Mesos

2018-06-27 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524647#comment-16524647 ] Gary Yao commented on FLINK-9649: - [~lishim] In FLIP-6 mode, resources are allocated dynamically:

[jira] [Commented] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown

2018-04-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459439#comment-16459439 ] Gary Yao commented on FLINK-9196: - [~yuqi] Your patch would not work if the application is submitted in

[jira] [Updated] (FLINK-9293) SlotPool should check slot id when accepting a slot offer with existing allocation id

2018-05-03 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-9293: Priority: Blocker (was: Major) > SlotPool should check slot id when accepting a slot offer with existing

[jira] [Created] (FLINK-7882) Writing to S3 from EMR fails with exception

2017-10-20 Thread Gary Yao (JIRA)
Gary Yao created FLINK-7882: --- Summary: Writing to S3 from EMR fails with exception Key: FLINK-7882 URL: https://issues.apache.org/jira/browse/FLINK-7882 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-7780) Integrate savepoint command into REST client

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-7780. --- Resolution: Fixed Re-opened to edit the labels. > Integrate savepoint command into REST client >

[jira] [Updated] (FLINK-7780) Integrate savepoint command into REST client

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-7780: Labels: flip-6 (was: ) > Integrate savepoint command into REST client >

[jira] [Closed] (FLINK-8231) Extend AbstractRestHandler to return response headers

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-8231. --- Resolution: Won't Do Not needed for now. > Extend AbstractRestHandler to return response headers >

[jira] [Assigned] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-8317: --- Assignee: Gary Yao > Enable Triggering of Savepoints via RestfulGateway >

[jira] [Updated] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8317: Description: Enable triggering of savepoints via RestfulGateway: * Add method to {{CompletableFuture

[jira] [Updated] (FLINK-8317) Enable triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8317: Description: Enable triggering of savepoints via RestfulGateway. (was: Enable triggering of savepoints via

[jira] [Updated] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

2017-12-24 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8317: Description: Enable triggering of savepoints in FLIP-6 mode via RestfulGateway: * Add method to

  1   2   3   4   5   6   7   8   9   10   >