[jira] [Created] (FLINK-24456) Support bounded offset in the Kafka table connector

2021-10-05 Thread Haohui Mai (Jira)
Haohui Mai created FLINK-24456: -- Summary: Support bounded offset in the Kafka table connector Key: FLINK-24456 URL: https://issues.apache.org/jira/browse/FLINK-24456 Project: Flink Issue Type:

[jira] [Created] (FLINK-24455) FallbackAkkaRpcSystemLoader can't run through with

2021-10-05 Thread Aitozi (Jira)
Aitozi created FLINK-24455: -- Summary: FallbackAkkaRpcSystemLoader can't run through with Key: FLINK-24455 URL: https://issues.apache.org/jira/browse/FLINK-24455 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24454) Consolidate all CAST related test into the new CastFunctionITCase class

2021-10-05 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24454: --- Summary: Consolidate all CAST related test into the new CastFunctionITCase class Key: FLINK-24454 URL: https://issues.apache.org/jira/browse/FLINK-24454

Cannot run Flink tests in Azure Pipeline - S3 credentials

2021-10-05 Thread tashoyan
Hi dev, I have test failures irrelevant to my modifications ( https://issues.apache.org/jira/browse/FLINK-23972), but very annoying. Tests fail because they cannot properly use S3 credentials. Could someone help me to make those tests running? Examples:

[jira] [Created] (FLINK-24453) StaticFileServerHandler does not redirect

2021-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24453: Summary: StaticFileServerHandler does not redirect Key: FLINK-24453 URL: https://issues.apache.org/jira/browse/FLINK-24453 Project: Flink Issue

[jira] [Created] (FLINK-24452) Move REST API state into dispatcher

2021-10-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24452: Summary: Move REST API state into dispatcher Key: FLINK-24452 URL: https://issues.apache.org/jira/browse/FLINK-24452 Project: Flink Issue Type:

[jira] [Created] (FLINK-24451) Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService

2021-10-05 Thread Aitozi (Jira)
Aitozi created FLINK-24451: -- Summary: Replace the scattered objects with encapsulated LeaderInformation in DefaultLeaderElectionService Key: FLINK-24451 URL: https://issues.apache.org/jira/browse/FLINK-24451

[jira] [Created] (FLINK-24450) OuterJoinITCase fails on azure

2021-10-05 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24450: Summary: OuterJoinITCase fails on azure Key: FLINK-24450 URL: https://issues.apache.org/jira/browse/FLINK-24450 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24449) PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch

2021-10-05 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24449: Summary: PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch Key: FLINK-24449 URL: https://issues.apache.org/jira/browse/FLINK-24449

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

2021-10-05 Thread Yun Gao
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