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

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-20661) Elasticsearch6DynamicSinkITCase.testWritingDocuments test failed with ConnectException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20660) Time window operator with computed column triggers an exception in batch mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20659) YARNSessionCapacitySchedulerITCase.perJobYarnClusterOffHeap test failed with NPE by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20658) Make sure jdbc connection is established by target driver by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20656) Update docs for new KafkaSource connector. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20653) SharedState should be registered after PendingCheckpoint storeCheckpoint by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20652) Improve the document for making the user could write a DataStream job that could be execute in the batch execution mode. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Enforce common opinionated coding style using Spotless by Aljoscha Krettek-2

by Aljoscha Krettek-2

[jira] [Created] (FLINK-20651) Use Spotless/google-java-format for code formatting/enforcement by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20650) Rename "native-k8s" command to "generic" in docker-entrypoint.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20649) StreamTask closeAllOperators stuck by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20647) Use yield to generate output datas in ProcessFunction for Python DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20645) Extra space typo when assembling dynamic configs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20642) Introduce InternalRow to optimize Row used in Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20641) flink-connector-elasticsearch6 will deadlock by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20640) Use cython to optimize the logic of Python UDAF by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20639) Use list to optimize the Row used by Python UDAF intermediate results by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20638) Flink hive modules Function with the same name bug by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20637) Table convert to dataStream twice will result in two data streams by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20636) Require unaligned checkpoints to be disabled in StateFun applications by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[RESULT] [VOTE] Release 1.11.3, release candidate #2 by Xintong Song-2

by Xintong Song-2

[VOTE] Release 1.11.3, release candidate #2 by Xintong Song-2

by Xintong Song

[jira] [Created] (FLINK-20635) Scala REPL with java.lang.NoSuchMethod: Errorjava.lang.NoSuchMethodError by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20634) Flink with Scala 2.12 that scala shell is not supported still provides start-scala-shell.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20633) test_configuration. test_add_all test failed in py35 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-20632) Missing docker images for 1.12 releas by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Will job manager restarts lead to repeated savepoint restoration? by vishalovercome

by vishalovercome

[jira] [Created] (FLINK-20631) cannot find native-k8s when deploying flink using native kubernetes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 83848586878889 ... 778