Hi David,
Very thanks for the feedback and glad to see that we have the same opinions on
a lot of points of the
iteration! :)
And for the checkpoint, basically to support the checkpoint for a job with
feedback edges, we
need to also include the records on the feedback edges into the checkpoint
Mehul Batra created FLINK-24448:
---
Summary: Tumbling Window Not working with EPOOCH Time converted
using TO_TIMESTAMP_LTZ
Key: FLINK-24448
URL: https://issues.apache.org/jira/browse/FLINK-24448
Project:
Chesnay Schepler created FLINK-24447:
Summary: Bundle netty in flink-shade-zookeeper 3.5+
Key: FLINK-24447
URL: https://issues.apache.org/jira/browse/FLINK-24447
Project: Flink
Issue Type
Marios Trivyzas created FLINK-24446:
---
Summary: Casting from STRING to TIMESTAMP_TZ looses fractional
seconds
Key: FLINK-24446
URL: https://issues.apache.org/jira/browse/FLINK-24446
Project: Flink
Chesnay Schepler created FLINK-24445:
Summary: Move RPC System packaging to package phase
Key: FLINK-24445
URL: https://issues.apache.org/jira/browse/FLINK-24445
Project: Flink
Issue Type
Hi Jark,
I also don't see it as a blocker issue at all. If you want to access the
metric group across 1.13 and 1.14, you can use
(MetricGroup) context.getClass().getMethod("metricGroup").invoke(context)
But of course, you will not be able to access the new standardized metrics.
For that you will
Dawid Wysakowicz created FLINK-2:
Summary: OperatorCoordinatorSchedulerTest#shutdownScheduler fails
with IllegalState
Key: FLINK-2
URL: https://issues.apache.org/jira/browse/FLINK-2
Pr
Dawid Wysakowicz created FLINK-24443:
Summary: IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs
fail with output mismatch
Key: FLINK-24443
URL: https://issues.apache.org/jira/browse/FLINK-24443