[jira] [Commented] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

2019-09-17 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931901#comment-16931901 ] Elias Levy commented on FLINK-14111: Probable related to FLINK-10052. > Flink should be robust to

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-09-17 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931611#comment-16931611 ] Elias Levy commented on FLINK-12122: Till, that is a welcomed development. I am surprised this

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-09-16 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930672#comment-16930672 ] Elias Levy commented on FLINK-12122: What is the status of this issue?  It's has a serious negative

[jira] [Commented] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

2019-09-16 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930650#comment-16930650 ] Elias Levy commented on FLINK-14002: I am for that.  Alternatively, {{KafkaSerializationSchema}} and

[jira] [Commented] (FLINK-5312) Implement Standalone Setup v2.0

2019-09-13 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16929598#comment-16929598 ] Elias Levy commented on FLINK-5312: --- Curious about the reasoning behind the Won't Do resolution.  Is

[jira] [Commented] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

2019-09-13 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16929556#comment-16929556 ] Elias Levy commented on FLINK-14002: Came here to open just tis ticket. {{KeyedSerializationSchema}}

[jira] [Commented] (FLINK-14057) Add Remove Other Timers to TimerService

2019-09-12 Thread Elias Levy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928676#comment-16928676 ] Elias Levy commented on FLINK-14057: Could also add {{replaceProcessingTimeTimer}} and

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-07-22 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890276#comment-16890276 ] Elias Levy commented on FLINK-10052: The whole point of ZK is that it doesn't suffer from split

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2019-07-10 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882252#comment-16882252 ] Elias Levy commented on FLINK-10052: Dominik, any progress? > Tolerate temporarily suspended

[jira] [Commented] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

2019-07-10 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882251#comment-16882251 ] Elias Levy commented on FLINK-13189: This is a duplicate of FLINK-10052. > Fix the impact of

[jira] [Commented] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

2019-04-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808986#comment-16808986 ] Elias Levy commented on FLINK-12104: The {{flink-connector-kafka-0.11}} depends on the Kafka

[jira] [Created] (FLINK-12024) Bump universal Kafka connector to Kafka dependency to 2.2.0

2019-03-26 Thread Elias Levy (JIRA)
Elias Levy created FLINK-12024: -- Summary: Bump universal Kafka connector to Kafka dependency to 2.2.0 Key: FLINK-12024 URL: https://issues.apache.org/jira/browse/FLINK-12024 Project: Flink

[jira] [Created] (FLINK-11794) Allow compression of row format files created by StreamingFileSink

2019-03-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-11794: -- Summary: Allow compression of row format files created by StreamingFileSink Key: FLINK-11794 URL: https://issues.apache.org/jira/browse/FLINK-11794 Project: Flink

[jira] [Created] (FLINK-11520) Triggers should be provided the window state

2019-02-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-11520: -- Summary: Triggers should be provided the window state Key: FLINK-11520 URL: https://issues.apache.org/jira/browse/FLINK-11520 Project: Flink Issue Type:

[jira] [Created] (FLINK-11517) Inefficient window state access when using RocksDB state backend

2019-02-01 Thread Elias Levy (JIRA)
Elias Levy created FLINK-11517: -- Summary: Inefficient window state access when using RocksDB state backend Key: FLINK-11517 URL: https://issues.apache.org/jira/browse/FLINK-11517 Project: Flink

[jira] [Commented] (FLINK-11435) Different jobs same consumer group are treated as separate groups

2019-01-28 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754156#comment-16754156 ] Elias Levy commented on FLINK-11435: This is expected behavior.  Flink manages Kafka offsets itself.

[jira] [Commented] (FLINK-10460) DataDog reporter JsonMappingException

2019-01-26 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16753231#comment-16753231 ] Elias Levy commented on FLINK-10460: [~lining] as you can tell from the backtrace, that is not a

[jira] [Commented] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

2019-01-23 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749907#comment-16749907 ] Elias Levy commented on FLINK-11249: I believe that the open transactions are maintained.  The

[jira] [Commented] (FLINK-10493) Macro generated CaseClassSerializer considered harmful

2018-11-05 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675634#comment-16675634 ] Elias Levy commented on FLINK-10493: [~tzulitai] correct.  It is not evident that the Scala

[jira] [Commented] (FLINK-10520) Job save points REST API fails unless parameters are specified

2018-11-05 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675404#comment-16675404 ] Elias Levy commented on FLINK-10520: [~huide] as I said " the system is configured with a default

[jira] [Comment Edited] (FLINK-10617) Restoring job fails because of slot allocation timeout

2018-10-30 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668873#comment-16668873 ] Elias Levy edited comment on FLINK-10617 at 10/30/18 3:28 PM: -- I've

[jira] [Updated] (FLINK-10617) Restoring job fails because of slot allocation timeout

2018-10-30 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-10617: --- Affects Version/s: 1.6.2 > Restoring job fails because of slot allocation timeout >

[jira] [Updated] (FLINK-10617) Restoring job fails because of slot allocation timeout

2018-10-30 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-10617: --- Priority: Critical (was: Major) > Restoring job fails because of slot allocation timeout >

[jira] [Commented] (FLINK-10617) Restoring job fails because of slot allocation timeout

2018-10-30 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668873#comment-16668873 ] Elias Levy commented on FLINK-10617: I've retested with 1.6.2 and have confirmed the issue still

[jira] [Commented] (FLINK-9061) Add entropy to s3 path for better scalability

2018-10-29 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16667437#comment-16667437 ] Elias Levy commented on FLINK-9061: --- Just a note to say that changes AWS made to S3 in July means that

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2018-10-23 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660864#comment-16660864 ] Elias Levy commented on FLINK-10052: [~Wosinsan] any progress on this issue? > Tolerate temporarily

[jira] [Created] (FLINK-10617) Restoring job fails because of slot allocation timeout

2018-10-19 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10617: -- Summary: Restoring job fails because of slot allocation timeout Key: FLINK-10617 URL: https://issues.apache.org/jira/browse/FLINK-10617 Project: Flink Issue

[jira] [Created] (FLINK-10520) Job save points REST API fails unless parameters are specified

2018-10-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10520: -- Summary: Job save points REST API fails unless parameters are specified Key: FLINK-10520 URL: https://issues.apache.org/jira/browse/FLINK-10520 Project: Flink

[jira] [Commented] (FLINK-10493) Macro generated CaseClassSerializer considered harmful

2018-10-04 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638834#comment-16638834 ] Elias Levy commented on FLINK-10493: This issue was noted [~tzulitai] back in June 2017 

[jira] [Created] (FLINK-10493) Macro generated CaseClassSerializer considered harmful

2018-10-04 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10493: -- Summary: Macro generated CaseClassSerializer considered harmful Key: FLINK-10493 URL: https://issues.apache.org/jira/browse/FLINK-10493 Project: Flink Issue

[jira] [Closed] (FLINK-10483) Can't restore from a savepoint even with Allow Non Restored State enabled

2018-10-04 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-10483. -- Resolution: Invalid > Can't restore from a savepoint even with Allow Non Restored State enabled >

[jira] [Created] (FLINK-10483) Can't restore from a savepoint even with Allow Non Restored State enabled

2018-10-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10483: -- Summary: Can't restore from a savepoint even with Allow Non Restored State enabled Key: FLINK-10483 URL: https://issues.apache.org/jira/browse/FLINK-10483 Project: Flink

[jira] [Created] (FLINK-10460) DataDog reporter JsonMappingException

2018-09-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10460: -- Summary: DataDog reporter JsonMappingException Key: FLINK-10460 URL: https://issues.apache.org/jira/browse/FLINK-10460 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10390) DataDog metric reporter leak warning

2018-09-21 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10390: -- Summary: DataDog metric reporter leak warning Key: FLINK-10390 URL: https://issues.apache.org/jira/browse/FLINK-10390 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10372) There is no API to configure the timer state backend

2018-09-19 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10372: -- Summary: There is no API to configure the timer state backend Key: FLINK-10372 URL: https://issues.apache.org/jira/browse/FLINK-10372 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-17 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617899#comment-16617899 ] Elias Levy commented on FLINK-10348: [~wind_ljy] Re: 1.  The problem is timestamp alignment.  

[jira] [Comment Edited] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-17 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16617899#comment-16617899 ] Elias Levy edited comment on FLINK-10348 at 9/17/18 5:48 PM: - [~wind_ljy]

[jira] [Commented] (FLINK-10348) Solve data skew when consuming data from kafka

2018-09-16 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616933#comment-16616933 ] Elias Levy commented on FLINK-10348: I would suggest the strategy employed by Kafka Streams, which

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-08-20 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586177#comment-16586177 ] Elias Levy commented on FLINK-10184: [~Jamalarm] this seems like a duplicate of FLINK-10011.  Can

[jira] [Commented] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

2018-08-13 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578792#comment-16578792 ] Elias Levy commented on FLINK-10133: [~Frefreak] this is likely the same issue as FLINK-10011.  If

[jira] [Created] (FLINK-10118) Queryable state MapState entry query

2018-08-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10118: -- Summary: Queryable state MapState entry query Key: FLINK-10118 URL: https://issues.apache.org/jira/browse/FLINK-10118 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10117) REST API for Queryable State

2018-08-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10117: -- Summary: REST API for Queryable State Key: FLINK-10117 URL: https://issues.apache.org/jira/browse/FLINK-10117 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10098) Programmatically select timer storage backend

2018-08-07 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10098: -- Summary: Programmatically select timer storage backend Key: FLINK-10098 URL: https://issues.apache.org/jira/browse/FLINK-10098 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors

2018-08-06 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570371#comment-16570371 ] Elias Levy commented on FLINK-10067: Kafka clients are compatible with lower version servers and

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

2018-08-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16569040#comment-16569040 ] Elias Levy commented on FLINK-8545: --- [~hequn8128] are you still working on this feature? > Implement

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

2018-08-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568955#comment-16568955 ] Elias Levy commented on FLINK-9600: --- [~aljoscha] I am aware of {{ProcessFunction}}, but I consider it

[jira] [Commented] (FLINK-9720) Introduce ResourceTag class for tag support in scheduling

2018-08-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568928#comment-16568928 ] Elias Levy commented on FLINK-9720: --- This is show as fixed in 1.6.0 but has not been committed. >

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

2018-08-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568927#comment-16568927 ] Elias Levy commented on FLINK-9662: --- This is show as fixed in 1.6.0, but AFAIK nothing has been

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2018-08-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568832#comment-16568832 ] Elias Levy edited comment on FLINK-10052 at 8/3/18 9:46 PM: [~till.rohrmann]

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

2018-08-03 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16568832#comment-16568832 ] Elias Levy commented on FLINK-10052: [~till.rohrmann] as I mentioned in FLINK-10011, it may not be

[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-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] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-08-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566032#comment-16566032 ] Elias Levy commented on FLINK-10011: [~azagrebin] I don't think they are the same issue. The issue

[jira] [Updated] (FLINK-9575) Potential race condition when removing JobGraph in HA

2018-08-01 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy updated FLINK-9575: -- Description: When we are removing the _JobGraph_ from _JobManager_ for example after invoking 

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564573#comment-16564573 ] Elias Levy commented on FLINK-10011: [~trohrm...@apache.org] what do you think? > Old job

[jira] [Comment Edited] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564569#comment-16564569 ] Elias Levy edited comment on FLINK-10011 at 8/1/18 12:48 AM: - It appears

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564569#comment-16564569 ] Elias Levy commented on FLINK-10011: It appears that it may not be necessary to replace the

[jira] [Created] (FLINK-10011) Old job resurrected during HA failover

2018-07-31 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10011: -- Summary: Old job resurrected during HA failover Key: FLINK-10011 URL: https://issues.apache.org/jira/browse/FLINK-10011 Project: Flink Issue Type: Bug

[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

[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=16561215#comment-16561215 ] Elias Levy commented on FLINK-6243: --- Stephan, thanks for bringing FLINK-8478 to my attention.  Alas,

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

2018-07-25 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555933#comment-16555933 ] Elias Levy commented on FLINK-9953: --- This is a duplicate of FLINK-9495. > Active Kubernetes

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

2018-07-04 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533142#comment-16533142 ] Elias Levy commented on FLINK-6239: --- For our particular use case having a single operator that is owner

[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] [Updated] (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 updated FLINK-9731: -- Description: On Jun 30th 2018, at 9:35 am UTC, the Kafka source in subtask 7 in a Flink job instance

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

2018-07-03 Thread Elias Levy (JIRA)
Elias Levy created FLINK-9731: - Summary: Kafka source subtask begins to consume from earliest offset Key: FLINK-9731 URL: https://issues.apache.org/jira/browse/FLINK-9731 Project: Flink Issue

[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] [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-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-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] [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] [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-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] [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-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] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-04-06 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16428676#comment-16428676 ] Elias Levy commented on FLINK-6756: --- Just ran into this, any progress? > Provide RichAsyncFunction to

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

2018-03-19 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405753#comment-16405753 ] Elias Levy commented on FLINK-8886: --- Thanks.  I am aware of YARN, but we do want to manage YARN just to

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

2018-03-06 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8886: - Summary: Job isolation via scheduling in shared cluster Key: FLINK-8886 URL: https://issues.apache.org/jira/browse/FLINK-8886 Project: Flink Issue Type:

[jira] [Created] (FLINK-8844) Export job jar file name or job version property via REST API

2018-03-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-8844: - Summary: Export job jar file name or job version property via REST API Key: FLINK-8844 URL: https://issues.apache.org/jira/browse/FLINK-8844 Project: Flink Issue

[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] [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] [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-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] [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] [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] [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-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-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] [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] [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] [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] [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] [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

  1   2   >