[jira] [Created] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-06-08 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4035: - Summary: Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 Key: FLINK-4035 URL: https://issues.apache.org/jira/browse/FLINK-4035 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4050) FlinkKafkaProducer API Refactor

2016-06-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4050: - Summary: FlinkKafkaProducer API Refactor Key: FLINK-4050 URL: https://issues.apache.org/jira/browse/FLINK-4050 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-06-09 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322741#comment-15322741 ] Elias Levy commented on FLINK-4035: --- AFAIK there haven't been changes to the producer API in 0.10, just

[jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

2016-06-06 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4027: - Summary: FlinkKafkaProducer09 sink can lose messages Key: FLINK-4027 URL: https://issues.apache.org/jira/browse/FLINK-4027 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

2016-05-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305082#comment-15305082 ] Elias Levy commented on FLINK-3715: --- As mentioned on the Google doc, this may not be flexible enough.

[jira] [Created] (FLINK-3984) Event time of stream transformations is undocumented

2016-05-27 Thread Elias Levy (JIRA)
Elias Levy created FLINK-3984: - Summary: Event time of stream transformations is undocumented Key: FLINK-3984 URL: https://issues.apache.org/jira/browse/FLINK-3984 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4050) FlinkKafkaProducer API Refactor

2016-06-14 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15330889#comment-15330889 ] Elias Levy commented on FLINK-4050: --- I can get around it, it's just not very pretty code. A no-op

[jira] [Created] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-04-06 Thread Elias Levy (JIRA)
Elias Levy created FLINK-3710: - Summary: ScalaDocs for org.apache.flink.streaming.scala are missing from the web site Key: FLINK-3710 URL: https://issues.apache.org/jira/browse/FLINK-3710 Project: Flink

[jira] [Commented] (FLINK-3035) Redis as State Backend

2016-04-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15223577#comment-15223577 ] Elias Levy commented on FLINK-3035: --- This seems like a bad idea. Regis is not a strongly consistent

[jira] [Created] (FLINK-3692) Develop a Kafka state backend

2016-04-03 Thread Elias Levy (JIRA)
Elias Levy created FLINK-3692: - Summary: Develop a Kafka state backend Key: FLINK-3692 URL: https://issues.apache.org/jira/browse/FLINK-3692 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3946) State API Should Support Data Expiration

2016-05-20 Thread Elias Levy (JIRA)
Elias Levy created FLINK-3946: - Summary: State API Should Support Data Expiration Key: FLINK-3946 URL: https://issues.apache.org/jira/browse/FLINK-3946 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3947) Provide low level access to RocksDB state backend

2016-05-20 Thread Elias Levy (JIRA)
Elias Levy created FLINK-3947: - Summary: Provide low level access to RocksDB state backend Key: FLINK-3947 URL: https://issues.apache.org/jira/browse/FLINK-3947 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2016-08-11 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417522#comment-15417522 ] Elias Levy commented on FLINK-4326: --- That would be my expectation. Writing out the PID would be nice,

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-08-11 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417880#comment-15417880 ] Elias Levy commented on FLINK-4035: --- FWIW I generated a flink-connector-kafka-0.9_2.11-1.1.1.jar that

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-07-18 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15381798#comment-15381798 ] Elias Levy commented on FLINK-4035: --- Sorry. I am on a boat in the middle of Indonesia for a few weeks

[jira] [Created] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2016-08-05 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4326: - Summary: Flink start-up scripts should optionally start services on the foreground Key: FLINK-4326 URL: https://issues.apache.org/jira/browse/FLINK-4326 Project: Flink

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2016-08-08 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15412490#comment-15412490 ] Elias Levy commented on FLINK-4326: --- Not just systemd, but also upstart (my particular case, within an

[jira] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2017-01-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847345#comment-15847345 ] Elias Levy commented on FLINK-4326: --- Greg's proposal for {{flink-console.sh}} will do. The one thing I

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-19 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428567#comment-15428567 ] Elias Levy commented on FLINK-3710: --- As of 1.1.0 this is still broken. > ScalaDocs for

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-22 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15431438#comment-15431438 ] Elias Levy commented on FLINK-3710: --- That's better than the docs not being available at all. At the

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-23 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15433101#comment-15433101 ] Elias Levy commented on FLINK-3710: --- I hadn't noticed. Thanks for pointing it out. That will be

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

2016-09-02 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15459066#comment-15459066 ] Elias Levy commented on FLINK-3947: --- I'd go with the first choice, higher level abstractions for state

[jira] [Created] (FLINK-4558) Add support for synchronizing streams

2016-09-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4558: - Summary: Add support for synchronizing streams Key: FLINK-4558 URL: https://issues.apache.org/jira/browse/FLINK-4558 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4558) Add support for synchronizing streams

2016-09-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15455966#comment-15455966 ] Elias Levy commented on FLINK-4558: --- It should be noted that Flink already perform a similar function in

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

2016-09-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15456040#comment-15456040 ] Elias Levy commented on FLINK-3947: --- The use case us maintaining a large set of items as state for a

[jira] [Created] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

2016-08-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4497: - Summary: Add support for Scala tuples and case classes to Cassandra sink Key: FLINK-4497 URL: https://issues.apache.org/jira/browse/FLINK-4497 Project: Flink

[jira] [Created] (FLINK-4498) Better Cassandra sink documentation

2016-08-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4498: - Summary: Better Cassandra sink documentation Key: FLINK-4498 URL: https://issues.apache.org/jira/browse/FLINK-4498 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-4498) Better Cassandra sink documentation

2016-08-25 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-4498: -- Description: The Cassandra sink documentation is somewhat muddled and could be improved. For

[jira] [Commented] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

2016-08-26 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15439445#comment-15439445 ] Elias Levy commented on FLINK-4502: --- Chesnay, thanks for correcting me about the overwriting issue. I

[jira] [Created] (FLINK-4500) Cassandra sink can lose messages

2016-08-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4500: - Summary: Cassandra sink can lose messages Key: FLINK-4500 URL: https://issues.apache.org/jira/browse/FLINK-4500 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-4501) Cassandra sink can lose messages

2016-08-25 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-4501. - Resolution: Duplicate HTTP connection got reset and was submitted twice. > Cassandra sink can lose

[jira] [Created] (FLINK-4502) Cassandra connector documentation has misleading consistency guarantees

2016-08-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4502: - Summary: Cassandra connector documentation has misleading consistency guarantees Key: FLINK-4502 URL: https://issues.apache.org/jira/browse/FLINK-4502 Project: Flink

[jira] [Created] (FLINK-4501) Cassandra sink can lose messages

2016-08-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4501: - Summary: Cassandra sink can lose messages Key: FLINK-4501 URL: https://issues.apache.org/jira/browse/FLINK-4501 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6239) Sharing of State Across Operators

2017-04-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952466#comment-15952466 ] Elias Levy commented on FLINK-6239: --- If sharing state across operators is not feasible, then as a

[jira] [Created] (FLINK-6243) Continuous Joins: True Sliding Window Joins

2017-04-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6243: - Summary: Continuous Joins: True Sliding Window Joins Key: FLINK-6243 URL: https://issues.apache.org/jira/browse/FLINK-6243 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration

2017-04-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953761#comment-15953761 ] Elias Levy commented on FLINK-3089: --- Thanks for the clarification. It is curious that the

[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins

2017-04-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953798#comment-15953798 ] Elias Levy commented on FLINK-6243: --- Thanks for pointing out FLINK-5725. I did review the documentation

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

2017-03-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951948#comment-15951948 ] Elias Levy commented on FLINK-3947: --- MapState looks promising. That said, I note that it is not an

[jira] [Created] (FLINK-6239) Sharing of State Across Operators

2017-04-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6239: - Summary: Sharing of State Across Operators Key: FLINK-6239 URL: https://issues.apache.org/jira/browse/FLINK-6239 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3089) State API Should Support Data Expiration

2017-04-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952328#comment-15952328 ] Elias Levy commented on FLINK-3089: --- I gather that {{TimelyFlatMapFunction}} has been supplanted by the

[jira] [Created] (FLINK-7364) Log exceptions from user code in streaming jobs

2017-08-03 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7364: - Summary: Log exceptions from user code in streaming jobs Key: FLINK-7364 URL: https://issues.apache.org/jira/browse/FLINK-7364 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies

2017-07-13 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7178: - Summary: Datadog Metric Reporter Jar is Lacking Dependencies Key: FLINK-7178 URL: https://issues.apache.org/jira/browse/FLINK-7178 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4474) Add docs about Testing & Test Utilities

2017-07-20 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094948#comment-16094948 ] Elias Levy commented on FLINK-4474: --- Reupping this issue. There is a need for a section in the

[jira] [Created] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2017-07-27 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7286: - Summary: Flink Dashboard fails to display bytes/records received by sources Key: FLINK-7286 URL: https://issues.apache.org/jira/browse/FLINK-7286 Project: Flink

[jira] [Created] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select

2017-04-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6419: - Summary: Better support for CEP quantified conditions in PatternSelect.select Key: FLINK-6419 URL: https://issues.apache.org/jira/browse/FLINK-6419 Project: Flink

[jira] [Created] (FLINK-6418) Support for dynamic state changes in CEP patterns

2017-04-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6418: - Summary: Support for dynamic state changes in CEP patterns Key: FLINK-6418 URL: https://issues.apache.org/jira/browse/FLINK-6418 Project: Flink Issue Type:

[jira] [Created] (FLINK-6420) Cleaner CEP API to specify conditions between events

2017-04-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6420: - Summary: Cleaner CEP API to specify conditions between events Key: FLINK-6420 URL: https://issues.apache.org/jira/browse/FLINK-6420 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6472) BoundedOutOfOrdernessTimestampExtractor does not bound out of orderliness

2017-05-09 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002961#comment-16002961 ] Elias Levy commented on FLINK-6472: --- Ideally Flink would make available an abstract class similar to

[jira] [Commented] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select

2017-04-30 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15990560#comment-15990560 ] Elias Levy commented on FLINK-6419: --- NP. I'll mark mine as a duplicate. > Better support for CEP

[jira] [Closed] (FLINK-6419) Better support for CEP quantified conditions in PatternSelect.select

2017-04-30 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-6419. - Resolution: Duplicate > Better support for CEP quantified conditions in PatternSelect.select >

[jira] [Created] (FLINK-6472) BoundedOutOfOrdernessTimestampExtractor does not bound out of orderliness

2017-05-06 Thread Elias Levy (JIRA)
Elias Levy created FLINK-6472: - Summary: BoundedOutOfOrdernessTimestampExtractor does not bound out of orderliness Key: FLINK-6472 URL: https://issues.apache.org/jira/browse/FLINK-6472 Project: Flink

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

2017-09-13 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16165109#comment-16165109 ] Elias Levy commented on FLINK-4814: --- Wondering what is the status of this? The current state, as

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

2017-09-14 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16166576#comment-16166576 ] Elias Levy commented on FLINK-4814: --- Yes please. That would be helpful. I would suggest multiple

[jira] [Created] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard

2017-09-16 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7634: - Summary: Add option to create a savepoint while canceling a job in the dashboard Key: FLINK-7634 URL: https://issues.apache.org/jira/browse/FLINK-7634 Project: Flink

[jira] [Created] (FLINK-7641) Loss of JobManager in HA mode should not cause jobs to fail

2017-09-18 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7641: - Summary: Loss of JobManager in HA mode should not cause jobs to fail Key: FLINK-7641 URL: https://issues.apache.org/jira/browse/FLINK-7641 Project: Flink Issue

[jira] [Created] (FLINK-7640) Dashboard should display information about JobManager cluster in HA mode

2017-09-18 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7640: - Summary: Dashboard should display information about JobManager cluster in HA mode Key: FLINK-7640 URL: https://issues.apache.org/jira/browse/FLINK-7640 Project: Flink

[jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-09-15 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16168733#comment-16168733 ] Elias Levy commented on FLINK-7266: --- I am curious what the state of this is. It is still a problem on

[jira] [Created] (FLINK-7646) Restart failed jobs with configurable parallelism range

2017-09-19 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7646: - Summary: Restart failed jobs with configurable parallelism range Key: FLINK-7646 URL: https://issues.apache.org/jira/browse/FLINK-7646 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts

2017-10-04 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191552#comment-16191552 ] Elias Levy commented on FLINK-7687: --- And? > Clarify the master and slaves files are not necessary

[jira] [Commented] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts

2017-10-04 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16191491#comment-16191491 ] Elias Levy commented on FLINK-7687: --- The [The JobManager

[jira] [Created] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts

2017-09-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7687: - Summary: Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts Key: FLINK-7687 URL: https://issues.apache.org/jira/browse/FLINK-7687

[jira] [Created] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

2017-09-27 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7722: - Summary: MiniCluster does not appear to honor Log4j settings Key: FLINK-7722 URL: https://issues.apache.org/jira/browse/FLINK-7722 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

2017-09-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-7722. - Resolution: Not A Problem > MiniCluster does not appear to honor Log4j settings >

[jira] [Commented] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

2017-09-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183336#comment-16183336 ] Elias Levy commented on FLINK-7722: --- Aye. I figured out the issue was that I needed to call

[jira] [Created] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

2017-08-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7547: - Summary: o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable Key: FLINK-7547 URL: https://issues.apache.org/jira/browse/FLINK-7547 Project: Flink

[jira] [Commented] (FLINK-5880) Add documentation for object reuse for DataStream API

2017-12-19 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16297798#comment-16297798 ] Elias Levy commented on FLINK-5880: --- Came across here to open this issue after reading the latest [blog

[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins

2017-11-02 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16236751#comment-16236751 ] Elias Levy commented on FLINK-6243: --- [~StephanEwen] anything to review? > Continuous Joins: True

[jira] [Created] (FLINK-9272) DataDog API "counter" metric type is deprecated

2018-04-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9272: - Summary: DataDog API "counter" metric type is deprecated Key: FLINK-9272 URL: https://issues.apache.org/jira/browse/FLINK-9272 Project: Flink Issue Type:

[jira] [Created] (FLINK-9403) Documentation continues to refer to removed methods

2018-05-20 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9403: - Summary: Documentation continues to refer to removed methods Key: FLINK-9403 URL: https://issues.apache.org/jira/browse/FLINK-9403 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9403) Documentation continues to refer to removed methods

2018-05-20 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-9403: -- Description: {{org.apache.flink.api.common.ExecutionConfig}} no longer has the {{enableTimestamps}},

[jira] [Created] (FLINK-9440) Allow cancelation and reset of timers

2018-05-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9440: - Summary: Allow cancelation and reset of timers Key: FLINK-9440 URL: https://issues.apache.org/jira/browse/FLINK-9440 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function

2018-06-15 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9600: - Summary: Add DataStream transformation variants that pass timestamp to the user function Key: FLINK-9600 URL: https://issues.apache.org/jira/browse/FLINK-9600 Project:

[jira] [Commented] (FLINK-9450) Job hangs if S3 access it denied during checkpoints

2018-05-28 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492837#comment-16492837 ] Elias Levy commented on FLINK-9450: --- The logs show no errors.  Alas, we are using the JRE, so these

[jira] [Created] (FLINK-9450) Job hangs if S3 access it denied during checkpoints

2018-05-26 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9450: - Summary: Job hangs if S3 access it denied during checkpoints Key: FLINK-9450 URL: https://issues.apache.org/jira/browse/FLINK-9450 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8886) Job isolation via scheduling in shared cluster

2018-06-06 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503536#comment-16503536 ] Elias Levy commented on FLINK-8886: --- I am ok with having a separate issue for per job JVM isolation,

[jira] [Created] (FLINK-9495) Implement ResourceManager for Kubernetes

2018-06-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9495: - Summary: Implement ResourceManager for Kubernetes Key: FLINK-9495 URL: https://issues.apache.org/jira/browse/FLINK-9495 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16525331#comment-16525331 ] Elias Levy commented on FLINK-9662: --- I like the direction of this.  And as I mentioned in the other

[jira] [Created] (FLINK-9682) Add setDescription to execution environment and display it in the UI

2018-06-27 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9682: - Summary: Add setDescription to execution environment and display it in the UI Key: FLINK-9682 URL: https://issues.apache.org/jira/browse/FLINK-9682 Project: Flink

[jira] [Commented] (FLINK-9662) Task manager isolation for jobs

2018-06-26 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524278#comment-16524278 ] Elias Levy commented on FLINK-9662: --- I took a look at the design doc, but I am not sufficiently

[jira] [Commented] (FLINK-9272) DataDog API "counter" metric type is deprecated

2018-04-28 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16457827#comment-16457827 ] Elias Levy commented on FLINK-9272: --- I tried to find out before opening the issue, but I found no

[jira] [Created] (FLINK-7935) Metrics with user supplied scope variables

2017-10-26 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7935: - Summary: Metrics with user supplied scope variables Key: FLINK-7935 URL: https://issues.apache.org/jira/browse/FLINK-7935 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2017-10-27 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16222972#comment-16222972 ] Elias Levy commented on FLINK-7935: --- Possibly. It depends on whether you could add multiple metrics or

[jira] [Closed] (FLINK-9731) Kafka source subtask begins to consume from earliest offset

2018-07-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-9731. - Resolution: Invalid > Kafka source subtask begins to consume from earliest offset >

[jira] [Commented] (FLINK-9731) Kafka source subtask begins to consume from earliest offset

2018-07-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16532040#comment-16532040 ] Elias Levy commented on FLINK-9731: --- Closing as I suspect the error is on the Kafka side.  Logs

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2018-01-05 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314122#comment-16314122 ] Elias Levy commented on FLINK-7935: --- [~Zentol] thoughts? > Metrics with user supplied scope variables

[jira] [Commented] (FLINK-5627) Allow job specific externalized checkpoint dir

2018-01-10 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16321239#comment-16321239 ] Elias Levy commented on FLINK-5627: --- It would be nice to fix this issue. > Allow job specific

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2018-01-11 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16322789#comment-16322789 ] Elias Levy commented on FLINK-7935: --- So it seems the DD reporter needs to switch from

[jira] [Commented] (FLINK-7641) Loss of JobManager in HA mode should not cause jobs to fail

2018-02-23 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375179#comment-16375179 ] Elias Levy commented on FLINK-7641: --- I mean that if you have a standalone cluster in HA mode with

[jira] [Created] (FLINK-8751) Canceling a job results in a InterruptedException in the JM

2018-02-22 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8751: - Summary: Canceling a job results in a InterruptedException in the JM Key: FLINK-8751 URL: https://issues.apache.org/jira/browse/FLINK-8751 Project: Flink Issue

[jira] [Created] (FLINK-8752) ClassNotFoundException when using the user code class loader

2018-02-22 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8752: - Summary: ClassNotFoundException when using the user code class loader Key: FLINK-8752 URL: https://issues.apache.org/jira/browse/FLINK-8752 Project: Flink Issue

[jira] [Commented] (FLINK-8752) ClassNotFoundException when using the user code class loader

2018-02-22 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16373954#comment-16373954 ] Elias Levy commented on FLINK-8752: --- Some other information:  Cluster is configured in HA mode with S3

[jira] [Updated] (FLINK-8751) Canceling a job results in a InterruptedException in the TM

2018-02-23 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-8751: -- Description: Canceling a job results in the following exception reported by the TM:  {code:java} ERROR

[jira] [Commented] (FLINK-8751) Canceling a job results in a InterruptedException in the TM

2018-02-23 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16374525#comment-16374525 ] Elias Levy commented on FLINK-8751: --- Apologies.  I meant TM.  It was a long day.  I've amended the

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

2018-01-02 Thread Elias Levy (JIRA)
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-8311) Flink needs documentation for network access control

2017-12-22 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8311: - Summary: Flink needs documentation for network access control Key: FLINK-8311 URL: https://issues.apache.org/jira/browse/FLINK-8311 Project: Flink Issue Type:

[jira] [Created] (FLINK-8358) Hostname used by DataDog metric reporter is not configurable

2018-01-03 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8358: - Summary: Hostname used by DataDog metric reporter is not configurable Key: FLINK-8358 URL: https://issues.apache.org/jira/browse/FLINK-8358 Project: Flink Issue

[jira] [Commented] (FLINK-7935) Metrics with user supplied scope variables

2018-01-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16310189#comment-16310189 ] Elias Levy commented on FLINK-7935: --- It appears the Metric documentation has not been updated in the 1.5

[jira] [Commented] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode

2018-08-02 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566973#comment-16566973 ] Elias Levy commented on FLINK-10030: This is possibly related to FLINK-10011. > zookeeper jobgraphs

[jira] [Created] (FLINK-10037) Document details event time behavior in a single location

2018-08-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10037: -- Summary: Document details event time behavior in a single location Key: FLINK-10037 URL: https://issues.apache.org/jira/browse/FLINK-10037 Project: Flink Issue

[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins

2018-07-29 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561216#comment-16561216 ] Elias Levy commented on FLINK-6243: --- Rereading my initial description of the issue, I see that I make

  1   2   >