[jira] [Created] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

2021-10-04 Thread Mehul Batra (Jira)
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:

[jira] [Created] (FLINK-24447) Bundle netty in flink-shade-zookeeper 3.5+

2021-10-04 Thread Chesnay Schepler (Jira)
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

[jira] [Created] (FLINK-24446) Casting from STRING to TIMESTAMP_TZ looses fractional seconds

2021-10-04 Thread Marios Trivyzas (Jira)
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

[jira] [Created] (FLINK-24445) Move RPC System packaging to package phase

2021-10-04 Thread Chesnay Schepler (Jira)
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

Re: The Apache Flink should pay more attention to ensuring API compatibility.

2021-10-04 Thread Arvid Heise
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

[jira] [Created] (FLINK-24444) OperatorCoordinatorSchedulerTest#shutdownScheduler fails with IllegalState

2021-10-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-2: Summary: OperatorCoordinatorSchedulerTest#shutdownScheduler fails with IllegalState Key: FLINK-2 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-24443) IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs fail with output mismatch

2021-10-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24443: Summary: IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs fail with output mismatch Key: FLINK-24443 URL: https://issues.apache.org/jira/browse/FLINK-24443

Re: [DISCUSS] FLIP-176: Unified Iteration to Support Algorithms (Flink ML)

2021-10-04 Thread David Morávek
Hi Yun, I did a quick pass over the design doc and it addresses all of the problems with the current iterations I'm aware of. It's great to see that you've been able to workaround the need of vectorized watermarks by giving up nested iterations (which IMO is more of an academic concept than