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
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
[
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
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
[
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.
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:
[
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
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
[
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
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
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
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:
[
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,
[
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
[
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
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
[
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
[
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
[
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
[
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
[
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
[
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
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
[
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
[
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
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
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
[
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
[
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
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
[
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
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
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
[
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
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
[
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
[
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
[
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
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
[
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
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
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
[
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
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
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
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:
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:
[
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
[
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
[
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
>
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
[
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
[
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
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
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
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
[
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
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:
[
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
[
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
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
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
[
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
>
[
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
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
[
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
[
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
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:
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
[
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}},
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
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:
[
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
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
[
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,
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
[
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
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
[
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
[
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
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
[
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
[
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
>
[
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
[
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
[
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
[
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
[
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
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
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
[
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
[
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
[
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
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
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:
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
[
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
[
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
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
[
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 - 100 of 165 matches
Mail list logo