Re: [VOTE] Release flink-connector-cassandra 3.1.0, release candidate #2

+1 (non-binding) I've validated this RC: flink-connector-cassandra-3.1.0-rc2 at r61661 - The SHA512 hash is OK. - The source file is signed correctly. - The signature 0F79F2AFB2351BC29678544591F9C1EC125FD8DB is found in the KEYS file. - The source file is consistent with the Github tag v3.0.1-rc2,

Re: [ANNOUNCE] New Apache Flink PMC Member - Matthias Pohl

Congratulations Matthias -- very well-deserved, the community is lucky to have you <3 All my best, Ryan On Mon, Aug 7, 2023 at 3:04 PM Lincoln Lee wrote: > Congratulations! > > Best, > Lincoln Lee > > > Feifan Wang 于2023年8月7日周一 20:13写道： > > > Congrats Matthias! > > > > > > > > —— >

Re: [DISCUSS] FLIP-358: flink-avro enhancement and cleanup

Hey -- I have a certain knowledge of Avro, and I'd be willing to help out with some of these enhancements, writing tests and reviewing. I have a *lot* of Avro schemas available for validation! The FLIP looks pretty good and covers the possible cases pretty rigorously. I wasn't aware of some of th

Azure pipelines CI view permissions

Hey everyone, Has something changed in the configuration for the CI page? I can see the pipelines, but we can't see the list of recent / individual runs: https://dev.azure.com/apache-flink/apache-flink/_build That being said, we can still see the results of SUCCESS or FAILURE when a PR runs, so

Re: [ANNOUNCE] Release 1.18.0, release candidate #0

Hello! There's a security fix that probably should be applied to 1.18 in the next RC1 : https://github.com/apache/flink/pull/23461 (bump to snappy-java). Do you think this would be possible to include? All my best, Ryan [1]: https://issues.apache.org/jira/browse/FLINK-33149 "Bump snappy-java to

Re: FW: RE: Close orphaned/stale PRs

Hey, this has been an interesting discussion -- this is something that has been on my mind as an open source contributor and committer (I'm not a Flink committer). A large number of open PRs doesn't _necessarily_ mean a project is unhealthy or has technical debt. If it's fun and easy to get your c

[VOTE] Add JSON encoding to Avro serialization

Hello! I'm reviewing a new feature of another contributor (Dale Lane) on FLINK-33058 that adds JSON-encoding in addition to the binary Avro serialization format. He addressed my original objections that JSON encoding isn't _generally_ a best practice for Avro messages. The discussion is pretty w

Re: [DISCUSS] Confluent Avro support without Schema Registry access

Hello! I took a look at FLINK-33045, which is somewhat related: In that improvement, the author wants to control who registers schemas. The Flink job would know the Avro schema to use, and would look up the ID to use in framing the Avro binary. It uses but never changes the schema registry. Here

Call for Presentations now open: Community over Code EU 2024

excellent platform for showcasing high-level projects and incubator initiatives in a visually engaging manner. We believe this will foster lively discussions and facilitate networking opportunities among participants. All my best, and thanks so much for your participation, Ryan Skraba (on be

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.2, release candidate #1

taged artifact ids for 3.0.2-1.17 and 3.0.2-1.18 - flink-connector-gcp-pubsub (.jar, -javadoc.jar, -sources.jar and .pom) - flink-connector-gcp-pubsub-parent (only .pom) I did a simple smoke test on an emulated Pub/Sub with the 1.18 version. All my best, Ryan Skraba

Re: [VOTE] Release flink-connector-opensearch v1.1.0, release candidate #1

Hello! +1 (non-binding) Thanks for the release! I've validated the source for the RC1: * flink-connector-opensearch-1.1.0-src.tgz at r64995 * The sha512 checksum is OK. * The source file is signed correctly. * The signature 0F79F2AFB2351BC29678544591F9C1EC125FD8DB is found in the KEYS file, and on

Re: Apicurio Avro format proposal

Hello David! In the FLIP, I'd be interested in knowing how the avro-apicurio and avro-confluent formats would differ! Outside of configuration options, are there different features? Would the two schema registry formats have a lot of common base that we could take advantage of? All my best, Rya

Re: Apicurio Avro format proposal

: https://github.com/apache/flink/pull/21805 "[FLINK-30721][avro-confluent-registry] Enable 8byte schema id" On Thu, Nov 23, 2023 at 10:48 AM Ryan Skraba wrote: > > Hello David! > > In the FLIP, I'd be interested in knowing how the avro-apicurio and > avro-conflue

Re: [DISCUSS] Confluent Avro support without Schema Registry access

gh the table schema, it lets you specify > > the shape of your data, allowing you to process it without requiring an > > external dependency. > > > > It seems to me that making it impossible to process Confluent Avro-encoded > > messages without access to an a

Re: [DISCUSS] Release flink-connector-parent v1.01

Hello! I've been following this discussion (while looking and building a lot of the connectors): +1 (non-binding) to doing a 1.1.0 release adding the configurability of surefire and jvm flags. Thanks for driving this! Ryan On Fri, Dec 15, 2023 at 2:06 PM Etienne Chauchot wrote: > > Hi PMC mem

Meet our keynote speakers and register to Community Over Code EU!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] * Merge with the ASF EUniverse!The registration for Community

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Awesome news for the community -- congratulations Alex (and Happy New Year everyone!) Ryan On Tue, Jan 2, 2024 at 2:55 PM Yun Tang wrote: > > Congratulation to Alex and Happy New Year everyone! > > Best > Yun Tang > > From: Rui Fan <1996fan...@gmail.com> > Sent:

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

Hello! +1 (non-binding) 1. Verified signature and SHA512 checksum in svn 2. Verified that the tag exists on the source git repository and is (mostly) identical to the source tar release - Some .-prefixed files like .idea/ and .gitignore in the repo under the tag that are not in the tar (but

Re: [DISCUSS] Retroactively externalize some connectors for 1.16

Hello -- this makes sense to me: removing connectors from 1.17 (but not the 1.16 branch) will still give users a long time to migrate. +1 (non-binding) Ryan On Fri, Dec 2, 2022 at 11:42 AM Dong Lin wrote: > Sounds good! > > +1 > > On Fri, Dec 2, 2022 at 5:58 PM Chesnay Schepler > wrote: > > >

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

Congratulations Lincoln! All my best, Ryan On Tue, Jan 10, 2023 at 9:37 AM yh z wrote: > Congratulations, Lincoln! > > Best regards, > Yunhong Zheng > > Biao Liu 于2023年1月10日周二 15:02写道： > > > Congratulations, Lincoln! > > > > Thanks, > > Biao /'bɪ.aʊ/ > > > > > > > > On Tue, 10 Jan 2023 at 14:5

Re: "Introduction to Apache Flink" presentation

Hello Joe -- sorry for the late reply, a colleague just showed me this. I don't know if you're aware, but there's an incubating project called Apache Training (Incubating) [1] that collects introductory and training materials for various Apache projects. All ASF committers have write permissions

Re: [DISCUSS] FLIP-299 Pub/Sub Lite Connector

Hello Daniel! Quite a while ago, I started porting the Pub/Sub connector (from an existing PR) to the new source API in the new flink-connector-gcp-pubsub repository [PR2]. As Martijn mentioned, there hasn't been a lot of attention on this connector; any community involvement would be appreciated

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.1, release candidate #1

Hello! +1 (non-binding) I've validated the source for the RC1: flink-connector-gcp-pubsub-3.0.1-src.tgz * The sha512 checksum is OK. * The source file is signed correctly. * The signature A5F3BCE4CBE993573EC5966A65321B8382B219AF is found in the KEYS file, and on https://keys.openpgp.org * The sou

Re: [VOTE] Release flink-connector-rabbitmq v3.0.1, release candidate #1

Hello! +1 (non-binding) I've validated the source for the RC1: flink-connector-rabbitmq-3.0.1-src.tgz * The sha512 checksum is OK. * The source file is signed correctly. * The signature A5F3BCE4CBE993573EC5966A65321B8382B219AF is found in the KEYS file, and on https://keys.openpgp.org * The sourc

Re: [VOTE] Release flink-connector-opensearch, release candidate #1

Hello! +1 (non-binding) I've validated the source for the RC1: flink-connector-opensearch-1.0.1-src.tgz * The sha512 checksum is OK. * The source file is signed correctly. * The signature A5F3BCE4CBE993573EC5966A65321B8382B219AF is found in the KEYS file, and on https://keys.openpgp.org * The sou

Wiki permissions

Hello! I updated some instructions that are useful for the apache-flink.slack.com #builds channel -- you used to be able to get instructions how to setup the Redirector extension from an old Slack comment. Since we only have a limited history with the free plan, I copied some into the Canvas for

Community over Code EU 2024: Start planning your trip!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] Dear community, We hope you are doing great, are you ready for Community Over Code EU? Check out the featured sessions, get your tickets with special discoun

Community over Code EU 2024: The countdown has started!

[Note: You're receiving this email because you are subscribed to one or more project dev@ mailing lists at the Apache Software Foundation.] We are very close to Community Over Code EU -- check out the amazing program and the special discounts that we have for you. Special discounts You still hav

Re: Re:Re: [ANNOUNCE] New Apache Flink Committer - Ingo Bürk

Congratulations Ingo! On Fri, Dec 3, 2021 at 8:17 AM Yun Tang wrote: > Congratulations, Ingo! > > Best > Yun Tang > > From: Yuepeng Pan > Sent: Friday, December 3, 2021 14:14 > To: dev@flink.apache.org > Cc: Ingo Bürk > Subject: Re:Re: [ANNOUNCE] New Apache Fl

Re: [DISCUSS] Looking for maintainers for Google PubSub connector or discuss next step

Hello, I'm familiar with the Pub/Sub connectors from the Apache Beam project, but quite a bit less so with Flink. This looks like a good learning opportunity, and I'd be interested in helping out here. If we decide to keep the connector, I can start taking a look at the next step: going through

Re: [DISCUSS] JUnit 5 Migration

Hello! I can help out with the effort -- I've got a bit of experience with JUnit 4 and 5 migration, and it looks like even with the AssertJ scripts there's going to be a lot of mechanical and manual work to be done. The migration document looks pretty comprehensive! For the remaining topics to b

Re: [DISCUSS] Enable scala formatting check

+1 for me -- I've used spotless and scalafmt together in the past, and especially appreciated how consistent it is between using on the command line and in the IDE. All my best, Ryan On Wed, Mar 2, 2022 at 11:19 AM Marios Trivyzas wrote: > +1 from me as well, Having a unified auto-formatter fo

Re: [ANNOUNCE] New Apache Flink Committer - David Morávek

Congratulations David! On Mon, Mar 7, 2022 at 9:54 AM Jan Lukavský wrote: > Congratulations David! > > Jan > > On 3/7/22 09:44, Etienne Chauchot wrote: > > Congrats David ! > > > > Well deserved ! > > > > Etienne > > > > Le 07/03/2022 à 08:47, David Morávek a écrit : > >> Thanks everyone! > >>

Re: [VOTE] FLIP-243: Dedicated Opensearch connectors

Hello! I'd like to add my non-binding +1 for this FLIP. Full disclosure: as a colleague of Andriy, I sometimes hear the gory details of divergence between Elasticsearch and OpenSearch. Objectively, this is a good reason to create independent OpenSearch connectors. As a side comment, while Ela

Re: [VOTE] FLIP-254 Redis Streams connector

Hello! There's quite a bit of existing code and it looks like there's interest and community willing to contribute to this connector with 2 implementations already in the flink-connector-redis repo[1]. There's a couple of points that should probably be fixed in the FLIP: some typos such as "provi

Re: [DISCUSS] Restructure FLIP pages with page properties

This sounds like an obvious improvement to save tedious labour -- at the same time, would this be something interesting to organize lists of FLIP pages around topics? If I'm interested in the connectors, for example. +1 and thanks, Ryan On Fri, Sep 16, 2022 at 12:53 PM Yun Tang wrote: > +1, t

dev@flink.apache.org

I had to write down a diagram to fully understand the discussion :D If I recall correctly, during the externalization discussion, the "price to pay" for the (many) advantages of taking connectors out of the main repo was to maintain and manually consult a compatibility matrix per connector. I'm no

dev@flink.apache.org

+1 non-binding! I've been following (and generally agreeing) with the thread -- it's a perfectly reasonable way to start, and I'm sure we can adjust the process if it turns out to be unsuitable or unexpected as the connectors evolve in their external repositories. On Thu, Oct 13, 2022 at 12:37 PM

Re: [Cassandra] source connector

There's definitely consensus on externalizing the flink connectors! I've been tracking the progress and I'd be happy to provide support on Cassandra if you'd like. There's some new information at https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development The first step

Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released

Excellent news -- welcome to the new era of easier, more timely and more feature-rich releases for everyone! Great job! Ryan On Thu, Nov 10, 2022 at 3:15 PM Leonard Xu wrote: > Thanks Chesnay and Martijn for the great work! I believe the > flink-connector-shared-utils[1] you built will help

Re: ASF Slack

I have to admit, I also (weakly) prefer a single workspace where possible. It's easy to miss (or just not look at) the apache-flink workspace because I didn't think of it. The spam and spam account issues are probably inevitable for any slack workspace as it grows, and we can probably reasonably e

[jira] [Created] (FLINK-32371) Bump snappy-java to 1.1.10.1

Ryan Skraba created FLINK-32371: --- Summary: Bump snappy-java to 1.1.10.1 Key: FLINK-32371 URL: https://issues.apache.org/jira/browse/FLINK-32371 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33149) Bump snappy-java to 1.1.10.4

Ryan Skraba created FLINK-33149: --- Summary: Bump snappy-java to 1.1.10.4 Key: FLINK-33149 URL: https://issues.apache.org/jira/browse/FLINK-33149 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33177) Memory leak in MockStreamingRuntimeContext

Ryan Skraba created FLINK-33177: --- Summary: Memory leak in MockStreamingRuntimeContext Key: FLINK-33177 URL: https://issues.apache.org/jira/browse/FLINK-33177 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33520) FileNotFoundException when running GPUDriverTest

Ryan Skraba created FLINK-33520: --- Summary: FileNotFoundException when running GPUDriverTest Key: FLINK-33520 URL: https://issues.apache.org/jira/browse/FLINK-33520 Project: Flink Issue Type

[jira] [Created] (FLINK-33627) Bump snappy-java to 1.1.10.4 in flink-statefun

Ryan Skraba created FLINK-33627: --- Summary: Bump snappy-java to 1.1.10.4 in flink-statefun Key: FLINK-33627 URL: https://issues.apache.org/jira/browse/FLINK-33627 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31674) [JUnit5 Migration] Module: flink-table-planner (BatchAbstractTestBase)

Ryan Skraba created FLINK-31674: --- Summary: [JUnit5 Migration] Module: flink-table-planner (BatchAbstractTestBase) Key: FLINK-31674 URL: https://issues.apache.org/jira/browse/FLINK-31674 Project: Flink

[jira] [Created] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions

Ryan Skraba created FLINK-34673: --- Summary: SessionRelatedITCase#testTouchSession failure on GitHub Actions Key: FLINK-34673 URL: https://issues.apache.org/jira/browse/FLINK-34673 Project: Flink

[jira] [Created] (FLINK-34717) BroadcastStateITCase failed fatally with 127 exit code

Ryan Skraba created FLINK-34717: --- Summary: BroadcastStateITCase failed fatally with 127 exit code Key: FLINK-34717 URL: https://issues.apache.org/jira/browse/FLINK-34717 Project: Flink Issue

[jira] [Created] (FLINK-34718) PartitionedWindowed

Ryan Skraba created FLINK-34718: --- Summary: PartitionedWindowed Key: FLINK-34718 URL: https://issues.apache.org/jira/browse/FLINK-34718 Project: Flink Issue Type: Bug Components: API

[jira] [Created] (FLINK-34719) StreamRecordTest#testWithTimestamp fails on Azure

Ryan Skraba created FLINK-34719: --- Summary: StreamRecordTest#testWithTimestamp fails on Azure Key: FLINK-34719 URL: https://issues.apache.org/jira/browse/FLINK-34719 Project: Flink Issue Type

[jira] [Created] (FLINK-34720) Deploy Maven Snapshot failed on AZP

Ryan Skraba created FLINK-34720: --- Summary: Deploy Maven Snapshot failed on AZP Key: FLINK-34720 URL: https://issues.apache.org/jira/browse/FLINK-34720 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34891) RemoteStorageScannerTest causes exit 239

Ryan Skraba created FLINK-34891: --- Summary: RemoteStorageScannerTest causes exit 239 Key: FLINK-34891 URL: https://issues.apache.org/jira/browse/FLINK-34891 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34911) ChangelogRecoveryRescaleITCase failed fatally with 127 exit code

Ryan Skraba created FLINK-34911: --- Summary: ChangelogRecoveryRescaleITCase failed fatally with 127 exit code Key: FLINK-34911 URL: https://issues.apache.org/jira/browse/FLINK-34911 Project: Flink

[jira] [Created] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server

Ryan Skraba created FLINK-34919: --- Summary: WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server Key: FLINK-34919 URL: https://issues.apache.org/jira/browse/FLINK-34919

[jira] [Created] (FLINK-34920) ZooKeeperLeaderRetrievalConnectionHandlingTest

Ryan Skraba created FLINK-34920: --- Summary: ZooKeeperLeaderRetrievalConnectionHandlingTest Key: FLINK-34920 URL: https://issues.apache.org/jira/browse/FLINK-34920 Project: Flink Issue Type

[jira] [Created] (FLINK-34963) Compilation error in ProcessFunctionTestHarnesses

Ryan Skraba created FLINK-34963: --- Summary: Compilation error in ProcessFunctionTestHarnesses Key: FLINK-34963 URL: https://issues.apache.org/jira/browse/FLINK-34963 Project: Flink Issue Type

[jira] [Created] (FLINK-35002) GitHub action/upload-artifact@v4 can timeout

Ryan Skraba created FLINK-35002: --- Summary: GitHub action/upload-artifact@v4 can timeout Key: FLINK-35002 URL: https://issues.apache.org/jira/browse/FLINK-35002 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35004) SqlGatewayE2ECase could not start container

Ryan Skraba created FLINK-35004: --- Summary: SqlGatewayE2ECase could not start container Key: FLINK-35004 URL: https://issues.apache.org/jira/browse/FLINK-35004 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35005) SqlClientITCase Failed to build JobManager image

Ryan Skraba created FLINK-35005: --- Summary: SqlClientITCase Failed to build JobManager image Key: FLINK-35005 URL: https://issues.apache.org/jira/browse/FLINK-35005 Project: Flink Issue Type

[jira] [Created] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure

Ryan Skraba created FLINK-35012: --- Summary: ChangelogNormalizeRestoreTest.testRestore failure Key: FLINK-35012 URL: https://issues.apache.org/jira/browse/FLINK-35012 Project: Flink Issue Type

[jira] [Created] (FLINK-35074) SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted

Ryan Skraba created FLINK-35074: --- Summary: SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted Key: FLINK-35074 URL: https://issues.apache.org/jira/browse/FLINK-35074 Project

[jira] [Created] (FLINK-35095) ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI

Ryan Skraba created FLINK-35095: --- Summary: ExecutionEnvironmentImplTest.testFromSource failure on GitHub CI Key: FLINK-35095 URL: https://issues.apache.org/jira/browse/FLINK-35095 Project: Flink

[jira] [Created] (FLINK-35146) CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan

Ryan Skraba created FLINK-35146: --- Summary: CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan Key: FLINK-35146 URL: https://issues.apache.org/jira/browse/FLINK-35146 Project: Flink

[jira] [Created] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

Ryan Skraba created FLINK-35175: --- Summary: HadoopDataInputStream can't compile with Hadoop 3.2.3 Key: FLINK-35175 URL: https://issues.apache.org/jira/browse/FLINK-35175 Project: Flink

[jira] [Created] (FLINK-35207) Kubernetes session E2E test fails to fetch packages.

Ryan Skraba created FLINK-35207: --- Summary: Kubernetes session E2E test fails to fetch packages. Key: FLINK-35207 URL: https://issues.apache.org/jira/browse/FLINK-35207 Project: Flink Issue

[jira] [Created] (FLINK-35276) SortCodeGeneratorTest.testMultiKeys fails on negative zero

Ryan Skraba created FLINK-35276: --- Summary: SortCodeGeneratorTest.testMultiKeys fails on negative zero Key: FLINK-35276 URL: https://issues.apache.org/jira/browse/FLINK-35276 Project: Flink

[jira] [Created] (FLINK-35284) Streaming File Sink end-to-end test times out

Ryan Skraba created FLINK-35284: --- Summary: Streaming File Sink end-to-end test times out Key: FLINK-35284 URL: https://issues.apache.org/jira/browse/FLINK-35284 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35335) StateCheckpointedITCase failed fatally with 127 exit code

Ryan Skraba created FLINK-35335: --- Summary: StateCheckpointedITCase failed fatally with 127 exit code Key: FLINK-35335 URL: https://issues.apache.org/jira/browse/FLINK-35335 Project: Flink

[jira] [Created] (FLINK-35339) Compilation timeout while building flink-dist

Ryan Skraba created FLINK-35339: --- Summary: Compilation timeout while building flink-dist Key: FLINK-35339 URL: https://issues.apache.org/jira/browse/FLINK-35339 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

Ryan Skraba created FLINK-35342: --- Summary: MaterializedTableStatementITCase test can check for wrong status Key: FLINK-35342 URL: https://issues.apache.org/jira/browse/FLINK-35342 Project: Flink

[jira] [Created] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests

Ryan Skraba created FLINK-35380: --- Summary: ResumeCheckpointManuallyITCase hanging on tests Key: FLINK-35380 URL: https://issues.apache.org/jira/browse/FLINK-35380 Project: Flink Issue Type

[jira] [Created] (FLINK-35381) LocalRecoveryITCase failure on deleting directory

Ryan Skraba created FLINK-35381: --- Summary: LocalRecoveryITCase failure on deleting directory Key: FLINK-35381 URL: https://issues.apache.org/jira/browse/FLINK-35381 Project: Flink Issue Type

[jira] [Created] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

Ryan Skraba created FLINK-35382: --- Summary: ChangelogCompatibilityITCase.testRestore fails with an NPE Key: FLINK-35382 URL: https://issues.apache.org/jira/browse/FLINK-35382 Project: Flink

[jira] [Created] (FLINK-35413) VertexFinishedStateCheckerTest causes exit 239

Ryan Skraba created FLINK-35413: --- Summary: VertexFinishedStateCheckerTest causes exit 239 Key: FLINK-35413 URL: https://issues.apache.org/jira/browse/FLINK-35413 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35418) EventTimeWindowCheckpointingITCase fails with an NPE

Ryan Skraba created FLINK-35418: --- Summary: EventTimeWindowCheckpointingITCase fails with an NPE Key: FLINK-35418 URL: https://issues.apache.org/jira/browse/FLINK-35418 Project: Flink Issue

[jira] [Created] (FLINK-35438) SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error

Ryan Skraba created FLINK-35438: --- Summary: SourceCoordinatorTest.testErrorThrownFromSplitEnumerator fails on wrong error Key: FLINK-35438 URL: https://issues.apache.org/jira/browse/FLINK-35438 Project

[jira] [Created] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

Ryan Skraba created FLINK-35446: --- Summary: FileMergingSnapshotManagerBase throws a NullPointerException Key: FLINK-35446 URL: https://issues.apache.org/jira/browse/FLINK-35446 Project: Flink

[jira] [Created] (FLINK-35499) EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing

Ryan Skraba created FLINK-35499: --- Summary: EventTimeWindowCheckpointingITCase times out due to Checkpoint expired before completing Key: FLINK-35499 URL: https://issues.apache.org/jira/browse/FLINK-35499

[jira] [Created] (FLINK-26736) [JUnit5 Migration] Module: flink-avro-confluent-registry

Ryan Skraba created FLINK-26736: --- Summary: [JUnit5 Migration] Module: flink-avro-confluent-registry Key: FLINK-26736 URL: https://issues.apache.org/jira/browse/FLINK-26736 Project: Flink Issue

[jira] [Created] (FLINK-27046) [JUnit5 Migration] Module: flink-*-glue-schema-registry

Ryan Skraba created FLINK-27046: --- Summary: [JUnit5 Migration] Module: flink-*-glue-schema-registry Key: FLINK-27046 URL: https://issues.apache.org/jira/browse/FLINK-27046 Project: Flink Issue

[jira] [Created] (FLINK-27059) [JUnit5 Migration] Module: flink-compress

Ryan Skraba created FLINK-27059: --- Summary: [JUnit5 Migration] Module: flink-compress Key: FLINK-27059 URL: https://issues.apache.org/jira/browse/FLINK-27059 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27885) [JUnit5 Migration] Module: flink-csv

Ryan Skraba created FLINK-27885: --- Summary: [JUnit5 Migration] Module: flink-csv Key: FLINK-27885 URL: https://issues.apache.org/jira/browse/FLINK-27885 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27970) [JUnit5 Migration] Module: flink-hadoop-buik

Ryan Skraba created FLINK-27970: --- Summary: [JUnit5 Migration] Module: flink-hadoop-buik Key: FLINK-27970 URL: https://issues.apache.org/jira/browse/FLINK-27970 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-27971) [JUnit5 Migration] Module: flink-json

Ryan Skraba created FLINK-27971: --- Summary: [JUnit5 Migration] Module: flink-json Key: FLINK-27971 URL: https://issues.apache.org/jira/browse/FLINK-27971 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25962) Flink generated Avro schemas can't be parsed using Python

Ryan Skraba created FLINK-25962: --- Summary: Flink generated Avro schemas can't be parsed using Python Key: FLINK-25962 URL: https://issues.apache.org/jira/browse/FLINK-25962 Project:

[jira] [Created] (FLINK-26232) [JUnit5 Migration] Module: flink-avro

Ryan Skraba created FLINK-26232: --- Summary: [JUnit5 Migration] Module: flink-avro Key: FLINK-26232 URL: https://issues.apache.org/jira/browse/FLINK-26232 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24476) Rename all ElasticSearch to Elasticsearch (without camel case)

Ryan Skraba created FLINK-24476: --- Summary: Rename all ElasticSearch to Elasticsearch (without camel case) Key: FLINK-24476 URL: https://issues.apache.org/jira/browse/FLINK-24476 Project: Flink

[jira] [Created] (FLINK-28449) [JUnit5 Migration] Module: flink-parquet

Ryan Skraba created FLINK-28449: --- Summary: [JUnit5 Migration] Module: flink-parquet Key: FLINK-28449 URL: https://issues.apache.org/jira/browse/FLINK-28449 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28522) [JUnit5 Migration] Module: flink-sequence-file

Ryan Skraba created FLINK-28522: --- Summary: [JUnit5 Migration] Module: flink-sequence-file Key: FLINK-28522 URL: https://issues.apache.org/jira/browse/FLINK-28522 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28542) [JUnit5 Migration] FileSystemBehaviorTestSuite

Ryan Skraba created FLINK-28542: --- Summary: [JUnit5 Migration] FileSystemBehaviorTestSuite Key: FLINK-28542 URL: https://issues.apache.org/jira/browse/FLINK-28542 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-29017) Some github links in released doc point to master

Ryan Skraba created FLINK-29017: --- Summary: Some github links in released doc point to master Key: FLINK-29017 URL: https://issues.apache.org/jira/browse/FLINK-29017 Project: Flink Issue Type

[jira] [Created] (FLINK-29036) Code examples on the Data Sources page have errors

Ryan Skraba created FLINK-29036: --- Summary: Code examples on the Data Sources page have errors Key: FLINK-29036 URL: https://issues.apache.org/jira/browse/FLINK-29036 Project: Flink Issue Type