Maxim Korolyov created FLINK-37244:
--
Summary: ScyllaDB support in Cassandra connector.
Key: FLINK-37244
URL: https://issues.apache.org/jira/browse/FLINK-37244
Project: Flink
Issue Type
Maxim Vershinin created FLINK-36090:
---
Summary: Bug with IngestDB restore operation for priority queue
state in backend
Key: FLINK-36090
URL: https://issues.apache.org/jira/browse/FLINK-36090
Maxim Malykhin created FLINK-17575:
--
Summary: KafkaException: Received exception when fetching the next
record from XXX-14. If needed, please seek past the record to continue
consumption.
Key: FLINK-17575
URL
Actually for such evictor to be useful the window should be sorted by some
field, usually event time. What do you think about adding sorted window
abstraction?
On Wed, Jul 6, 2016 at 11:36 AM, Aljoscha Krettek
wrote:
> @Maxim: That's perfect I didn't think about using Iterator
elements, int size, EvictorContext ctx);
}
Such API allows to abort iteration at any point and evict elements in any
order.
Thanks,
Maxim.
On Wed, Jul 6, 2016 at 9:04 AM, Vishnu Viswanath <
vishnu.viswanat...@gmail.com> wrote:
>
> Hi Aljoscha,
>
> Thanks. Yes the new interfac
es *and forward
requests to them.
Is there a better way to support my use case?
Thanks,
Maxim.
Maxim Dobryakov created FLINK-3797:
--
Summary: Restart flow button
Key: FLINK-3797
URL: https://issues.apache.org/jira/browse/FLINK-3797
Project: Flink
Issue Type: Improvement
Maxim Dobryakov created FLINK-3795:
--
Summary: Cancel button is hidden on MacBook Pro 13''
Key: FLINK-3795
URL: https://issues.apache.org/jira/browse/FLINK-3795
Project: Flink
Maxim Dobryakov created FLINK-3791:
--
Summary: Flink CLI must has arguments to specify zookeeper cluster
required to work with Standalone HA cluster
Key: FLINK-3791
URL: https://issues.apache.org/jira/browse
h
> Flink's accumulator mechanism;
> only a selection that will be aggregated locally and on the JobManager to
> display in the Dashboard.
>
> Out of curiosity, what metrics are you interested in?
>
>
> On 14.04.2016 20:59, Maxim wrote:
>
>> Hi!
>> I
sting Accumulators, but allow overriding it
to our internal reporting client.
Is it something that could be added to the Flink or there are other plans
for monitoring?
Thanks!
Maxim.
Maxim Dobryakov created FLINK-3726:
--
Summary: Error while reading configuration: Cannot read property 0
Key: FLINK-3726
URL: https://issues.apache.org/jira/browse/FLINK-3726
Project: Flink
Maxim Dobryakov created FLINK-3725:
--
Summary: Exception in thread "main" scala.MatchError: ... (of
class scala.Tuple4)
Key: FLINK-3725
URL: https://issues.apache.org/jira/browse/FLINK-3725
Maxim Dobryakov created FLINK-3638:
--
Summary: Invalid default ports in documentation
Key: FLINK-3638
URL: https://issues.apache.org/jira/browse/FLINK-3638
Project: Flink
Issue Type: Bug
tioned that changing parallelism is one of the high priority items for
this year. Has any work started on it? And would it support the type of
dynamic sources we have?
I could try adding such support myself if it would help to speed things up.
Thanks,
Maxim.
15 matches
Mail list logo
