(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 422423424425426427428 ... 784

Topics (27406)

Replies

Last Post

Views

[jira] [Created] (FLINK-10785) Update FlinkKinesisConsumerMigrationTest for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10782) Update AbstractKeyedOperatorRestoreTestBase for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10783) Update WindowOperatorMigrationTest for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10781) Update BucketingSinkMigrationTest for Flink 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10780) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10779) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10778) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10777) Update TypeSerializerSnapshotMigrationITCase for Flink 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10776) Update migration tests for Flink 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10775) Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10773) Resume externalized checkpoint end-to-end test fails by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10772) create_binary_release.sh is broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10770) Some generated functions are not opened properly. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Release branch 1.7 has been created by Till Rohrmann

by Till Rohrmann

[jira] [Created] (FLINK-10769) port InMemoryExternalCatalog to java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10768) Move Calcite related code from TableEnvironment to CatalogManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10767) Update compatibility table for Flink 1.7 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10766) Add a link to flink-china.org in Flink website by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10765) Modify one of the s3 tests to use the Presto S3 s3p schema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10764) Add S3 entropy injection end-to-end/IT test by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10763) Cannot union streams of different types in the union method of DataStream class by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10762) Do not try to request partitions in SingleInputGate per getRecord by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10761) MetricGroup#getAllVariables can deadlock by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: Please please please review : Re: PubSub connector (FLINK-9311) by Niels Basjes-2

by Niels Basjes-2

Why dont't have a csv formatter for kafka table source by Jocean shi

by Till Rohrmann

[jira] [Created] (FLINK-10760) Create a command line tool to migrate meta objects specified in SQL client configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10759) Adapt SQL-client configuration file to specify external catalogs and default catalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10758) Refactor TableEnvironment so that all registration calls delegate to CatalogManager by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10757) TaskManagerProcessFailureStreamingRecoveryITCase failed to initialize the cluster entrypoint StandaloneSessionClusterEntrypoint. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Run Flink Natively On Kubernetes by isunjin

by Anand Swaminathan

[jira] [Created] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 422423424425426427428 ... 784