(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 ... 9101112131415 ... 778

Topics (27217)

Replies

Last Post

Views

[jira] [Created] (FLINK-22988) Port TestingUtils to Java by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22987) Scala suffix check isn't working by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22985) sql syntax, NullPointerException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Security Vulnerabilities with Flink OpenJDK Docker Image by Daniel Moore

by Daniel Moore

[jira] [Created] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22983) Support lazy evaluation in Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22982) java.lang.ClassCastException when using Python UDF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22981) FlinkKafkaProducerMigrationTest.testRestoreProducer fail with timeout by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22979) JobMasterExecutionDeploymentReconciliationTest error while setting up logger by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22978) Flink Maintenance activities Documentation and Testcases for maintainance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22977) jobmanager.rpc.addresss does not support hostname with an underscore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Support specifying custom transactional.id prefix in FlinkKafkaProducer by zetaplusae

by zetaplusae

[DISCUSS] FLIP-172: Support custom transactional.id prefix in FlinkKafkaProducer by zetaplusae

by zetaplusae

Add control mode for flink by 刘建刚

by 刘建刚

[jira] [Created] (FLINK-22976) Whether to consider adding config-option to control whether to exclude record.key value from record.value value by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22975) Specify port or range for k8s service by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [table-walkthrough] docker-compose build issues by Lingfeng Pu

by Lingfeng Pu

[jira] [Created] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22973) Provide benchmark for unaligned checkpoints performance by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Lifecycle of ShuffleMaster and its Relationship with JobMaster and PartitionTracker by yingjie

by yingjie

Flink TM Heartbeat Timeout by Lu Niu

by Till Rohrmann

[jira] [Created] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22971) Initialization of Testcontainers unstable on Azure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Question About 'SHOW COLUMNS' statement in SQL by RocMarshal

by RocMarshal

[jira] [Created] (FLINK-22968) String type cannot be used when creating Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Definition of idle partitions by Arvid Heise-4

by Eron Wright-3

[jira] [Created] (FLINK-22967) CodeGenException: Unsupported cast for nested Decimals by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22966) NPE in StateAssignmentOperation when rescaling by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] Watermark propagation with Sink API by Eron Wright-3

by Eron Wright-3

[jira] [Created] (FLINK-22965) Association with remote system has failed, address is now gated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22964) Connector-base exposes dependency to flink-core. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 9101112131415 ... 778