You are viewing a plain text version of this content. The canonical link for it is here.

---

- [jira] [Created] (FLINK-18043) Translate "Scala API Extensions" page of "DataStream API" into Chinese - posted by "Yubin Li (Jira)" <ji...@apache.org> on 2020/06/01 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18044) Add the subtask index information to the SourceReaderContext. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/06/01 06:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR - posted by "Bartosz Krasiński (Jira)" <ji...@apache.org> on 2020/06/01 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18046) Decimal column stats not supported for Hive table - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/01 07:23:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/06/01 07:25:18 UTC, 11 replies.
- [jira] [Created] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect - posted by "pengnengsong (Jira)" <ji...@apache.org> on 2020/06/01 07:30:00 UTC, 0 replies.
- I want to contribute to Apache Flink - posted by 以梦为马 <po...@163.com> on 2020/06/01 09:06:26 UTC, 1 replies.
- [jira] [Created] (FLINK-18048) "--host" option could not take effect for standalone application cluster - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/01 09:27:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/22 - posted by Konstantin Knauf <kn...@apache.org> on 2020/06/01 10:21:51 UTC, 0 replies.
- [jira] [Created] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema - posted by "Zheng Hu (Jira)" <ji...@apache.org> on 2020/06/01 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/06/01 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18051) Fail Maven setup on AZP if download fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/01 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18052) Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/01 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18053) Savepoints do not preserve watermarks - posted by "Sergii Mikhtoniuk (Jira)" <ji...@apache.org> on 2020/06/02 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18054) Environment should provide API to resume from savepoint - posted by "Sergii Mikhtoniuk (Jira)" <ji...@apache.org> on 2020/06/02 02:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18055) Catalog does not exist in SQL Client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/06/02 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists. - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/06/02 05:55:01 UTC, 0 replies.
- Questions around MemoryStateBackend size limits - posted by vishalovercome <vi...@moengage.com> on 2020/06/02 05:58:57 UTC, 1 replies.
- [jira] [Created] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2> - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/02 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18058) MesosResourceManagerTest.testWorkerStarted:656 » NullPointer - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/02 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18059) Can not execute create/drop catalog statement in sql client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/06/02 06:35:00 UTC, 0 replies.
- Re: MODERATE for dev@flink.apache.org - posted by Henry Saputra <he...@gmail.com> on 2020/06/02 07:11:34 UTC, 0 replies.
- [jira] [Created] (FLINK-18060) Add notice for heap-based state backend of state access reference problem - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/06/02 07:29:00 UTC, 0 replies.
- [Discussion] flink elasticsearch connector supports - posted by Jacky Lau <li...@gmail.com> on 2020/06/02 07:52:27 UTC, 10 replies.
- [jira] [Created] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/06/02 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18062) prometheus metrics reporter support custom labels - posted by "Luke Sun (Jira)" <ji...@apache.org> on 2020/06/02 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18063) Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner#processEndOfPartition - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/06/02 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18064) Update documentation taking unaligned checkpoints into the account - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/02 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18065) Add documentation for new scalar/table functions - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/02 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18066) Add documentation for how to develop a new table source/sink - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/02 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18067) Invalid default value for yarnMinAllocationMB in YarnClusterDescriptor - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/06/02 10:11:00 UTC, 0 replies.
- Re: [DISCUSS] Stability guarantees for @PublicEvolving classes - posted by Till Rohrmann <tr...@apache.org> on 2020/06/02 10:19:24 UTC, 0 replies.
- Re: [DISCUSS] (Document) Backwards Compatibility of Savepoints - posted by Yun Tang <my...@live.com> on 2020/06/02 10:20:25 UTC, 4 replies.
- Re: [NOTICE] Release guide updated for updating japicmp configuration - posted by Till Rohrmann <tr...@apache.org> on 2020/06/02 10:20:38 UTC, 0 replies.
- [jira] [Created] (FLINK-18068) Job stuck after IllegalStateException in scheduling - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/06/02 10:21:00 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink-shaded 11.0 released - posted by Till Rohrmann <tr...@apache.org> on 2020/06/02 10:21:03 UTC, 1 replies.
- [jira] [Created] (FLINK-18069) Scaladocs not building since inner Java interfaces cannot be recognized - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/06/02 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18070) Time attribute been materialized after sub graph optimize - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/06/02 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/02 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18072) HBaseLookupFunction can not work with new internal data structure RowData - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/06/02 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18073) AvroRowDataSerializationSchema is not always serializable - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/02 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/06/02 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18075) Kafka connector does not call open method of (de)serialization schema - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/02 19:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18076) Sql client uses wrong class loader when parsing queries - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/06/02 21:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18077) E2E tests manually for Hive streaming source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/03 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18078) E2E tests manually for Hive streaming dim join - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/03 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18079) KafkaShuffle Manual Tests - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/06/03 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/03 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18081) Fix broken links in "Kerberos Authentication Setup and Configuration" doc - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/03 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18082) UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/03 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18083) DDL TIMESTAMP(9) defined on HBase table lost nano seconds - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/06/03 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18084) Create documentation for the Application Mode - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2020/06/03 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/03 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18086) Migrate SQLClientKafkaITCase to use DDL and new options to create tables - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/03 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/03 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18088) Umbrella for features testing in release-1.11.0 - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/06/03 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/06/03 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18090) Support RowKind in Row.toString - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/03 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18091) Test Relocatable Savepoints - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/06/03 12:43:00 UTC, 0 replies.
- [DISCUSS] Leverage Maven Wrapper - posted by tison <wa...@gmail.com> on 2020/06/03 13:48:07 UTC, 1 replies.
- [jira] [Created] (FLINK-18092) E2E tests manually for HBase - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/03 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18093) E2E tests manually for Elasticsearch Sink - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/03 17:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18094) Index offset not consistent in CheckpointedInputGate for unaligned checkpoints. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/06/03 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18095) Custom Execution Environment for TableEnvironment - posted by "Satyam Shekhar (Jira)" <ji...@apache.org> on 2020/06/03 18:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18096) Generated avro formats should support user specified name and namespace - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/03 20:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18097) History server doesn't clean all job json files - posted by "Milan Nikl (Jira)" <ji...@apache.org> on 2020/06/03 20:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18098) Legacy Task application are missing app.run.id for both batch & stream mode - posted by "Sanil Jain (Jira)" <ji...@apache.org> on 2020/06/04 01:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18099) Release guard for PyFlink - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18100) Test different user-defined metrics for Python UDF - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18102) Test Pandas UDF support - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18103) Test Pandas DataFrame and Flink Table conversion - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18104) Test pyflink on windows - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18105) Test submitting Java SQL job with Python UDF - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18106) Tests Python UDTF support - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18107) Performance tests for PyFlink UDFs - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18108) Wheel package consistency checks - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/06/04 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18109) Manually test external resource framework with GPUDriver - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/04 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18110) Bucket Listener in StreamingFileSink should notify for buckets detected to be inactive at recovery - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/06/04 03:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18111) LATERAL query failed when use create view syntax - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/06/04 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18112) Single Task Failure Recovery Prototype - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/06/04 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18113) Single Task Failure Recovery API Abstraction - posted by "Yuan Mei (Jira)" <ji...@apache.org> on 2020/06/04 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18114) Expose more details in logs for debugging bulk slot allocation failures - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/06/04 04:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18115) StabilityTest - posted by "Aihua Li (Jira)" <ji...@apache.org> on 2020/06/04 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18116) E2E performance test - posted by "Aihua Li (Jira)" <ji...@apache.org> on 2020/06/04 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18117) "Kerberized YARN per-job on Docker test" "Could not start hadoop cluster." - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18118) Some SQL Jobs with two input operators are loosing data with unaligned checkpoints - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/04 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18119) Fix unlimitedly growing state for time range bounded over aggregate - posted by "Hyeonseop Lee (Jira)" <ji...@apache.org> on 2020/06/04 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18120) Don't expand documentation sections by default - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/06/04 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18121) Support creating Docker image from local Flink distribution - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/06/04 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18122) Kubernetes test fails with "error: timed out waiting for the condition on jobs/flink-job-cluster" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18123) KubernetesClusterDescriptorTest.testDeployApplicationCluster:135->checkUpdatedConfigAndResourceSetting:194 expected: but was: - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18124) Add documentation for new FLIP-27 source interface - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/06/04 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18125) Skip CI execution on documentation pull requests - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18126) Correct the exception handling of the Python CompletableFuture - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/04 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18127) Streamline manual execution of Java E2E tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/04 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18129) Unhandled exception stack trace from DispatcherRestEndpoint when deploying Kubernetes session cluster - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/06/04 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18130) File name conflict for different jobs in filesystem/hive sink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/04 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18133) Add documentation for the new Avro format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/04 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18132) Add documentation for the new CSV format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/04 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18131) Add documentation for the new JSON format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/04 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18134) Add documentation for the Debezium format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/04 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18135) Add documentation for the Canal format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/04 14:42:01 UTC, 0 replies.
- Interest registration for Documentation task relating Table API & SQL - posted by abdul basit <ab...@gmail.com> on 2020/06/04 15:56:29 UTC, 4 replies.
- [jira] [Created] (FLINK-18136) Don't start channel state writing for savepoints (RPC) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/06/04 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18137) JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint fails with AskTimeoutException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 17:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18138) KeyedComplexChainTest.testMigrationAndRestore fails with AskTimeoutException on CI - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/04 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18139) Unaligned checkpoints checks wrong channels for inflight data. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/06/04 20:40:00 UTC, 0 replies.
- 订阅 flink 开发列表 - posted by Jake <ft...@qq.com> on 2020/06/05 02:06:00 UTC, 2 replies.
- [jira] [Created] (FLINK-18140) Add documentation for ORC format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/05 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18141) Add documentation for Parquet format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/05 02:50:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions - posted by Jingsong Li <ji...@gmail.com> on 2020/06/05 03:13:58 UTC, 6 replies.
- [jira] [Created] (FLINK-18142) Wrong state names in HiveContinuousMonitoringFunction - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/05 04:23:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink Committer - Xintong Song - posted by Becket Qin <be...@gmail.com> on 2020/06/05 04:44:47 UTC, 33 replies.
- [jira] [Created] (FLINK-18143) Fix Python meter metric not correct problem - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/06/05 05:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18144) State TTL configuration can't be set in SQL CLI - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/05 06:04:00 UTC, 0 replies.
- 回复：[ANNOUNCE] New Apache Flink Committer - Xintong Song - posted by "杨弢(杨弢)" <ya...@alibaba-inc.com> on 2020/06/05 06:07:03 UTC, 0 replies.
- [jira] [Created] (FLINK-18145) Segment optimization does not work ? - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/06/05 06:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18146) The note of  StreamingJobGraphGenerator#createJobGraph has a misspelling - posted by "ZhuShang (Jira)" <ji...@apache.org> on 2020/06/05 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18147) Orc document display is disordered - posted by "Shuai Xia (Jira)" <ji...@apache.org> on 2020/06/05 07:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18148) "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop() - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/05 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18149) Taskmanager logs could not show up in native K8s deployment - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/05 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata - posted by "Julius Michaelis (Jira)" <ji...@apache.org> on 2020/06/05 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/06/05 11:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18152) Master starts despite IllegalConfigurationException - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/05 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18153) flink-daemon does not detect errors if JVM crashes immediately - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/05 11:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18154) Unhelpful error message if heap.size takes up signficant portion of process.size - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/05 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18155) Disable Log4j's JMX for (integration)tests - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/05 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18156) Misleading error message if derived JVM overhead is too small - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/05 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18157) Jobstore size check compares against offHeapMemory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/05 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18158) Add a utility to create a DDL statement from avro schema - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/06/05 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18159) Add support for trimming stack traces in user-facing components - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/05 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18160) YARN session logs about HADOOP_CONF_DIR even though HADOOP_CLASSPATH containing a config is set - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/05 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18161) Changing parallelism is not possible in sql-client.sh - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/05 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18162) AddSplitEvents should serialize the splits into bytes. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/06/05 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18163) Should be volatile: network.api.writer.RecordWriter.flusherException - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/06/05 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18164) null <> 'str' should be true - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/06/05 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18165) When savingpoint is restored, select the checkpoint directory and stateBackend - posted by "Xinyuan Liu (Jira)" <ji...@apache.org> on 2020/06/06 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18166) JAVA_HOME is not read from .bashrc when start flink - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/06 07:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18167) Flink Job hangs there when one vertex is failed and another is cancelled. - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2020/06/06 07:41:00 UTC, 0 replies.
- Google Season of Docs Contribution - posted by Aman Singal <am...@gmail.com> on 2020/06/06 12:57:04 UTC, 1 replies.
- Flink not restoring from checkpoint when job manager fails even with HA through zookeeper - posted by "Kathula, Sandeep" <Sa...@intuit.com.INVALID> on 2020/06/06 20:38:11 UTC, 2 replies.
- [jira] [Created] (FLINK-18168) Error results when use UDAF with Object Array return type - posted by "Zou (Jira)" <ji...@apache.org> on 2020/06/07 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18169) ES6 sql sink should allow users to configure basic authentication parameters - posted by "haoyuwen (Jira)" <ji...@apache.org> on 2020/06/07 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18170) E2E tests manually for PostgresCatalog - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/06/08 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18171) Do not take client side config options to cluster - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/08 03:26:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/06/08 03:55:37 UTC, 0 replies.
- [jira] [Created] (FLINK-18172) Select bounded source not work in SQL-CLI with streaming mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/08 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18173) Bundle flink-csv,flink-json,flink-avro jars in lib - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/08 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18174) EventTimeWindowCheckpointingITCase crashes with exit code 127 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/08 06:26:00 UTC, 0 replies.
- [DISCUSS] Add Japanese translation of the flink.apache.org website - posted by Robert Metzger <rm...@apache.org> on 2020/06/08 07:44:35 UTC, 9 replies.
- [jira] [Created] (FLINK-18175) Add human readable summary for configured and derived memory sizes. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/06/08 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18176) Add supplement for file system connector document - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/06/08 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18177) Document all YAML format versions for Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/06/08 09:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18178) flink-training exercises don't build with Eclipse - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/06/08 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18179) Apply AggregateProjectPullUpConstantsRule after WindowPropertiesRules - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/06/08 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18180) unify the logic of time attribute derivation for both batch and streaming - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/06/08 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18181) StreamingFileCommitter should not use fs modification time for proc committer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/08 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18182) Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1 - posted by "Tom Wells (Jira)" <ji...@apache.org> on 2020/06/08 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18183) what's the meaning of different color in FLINK web UI slots? - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/08 10:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18184) Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' - posted by "mzz (Jira)" <ji...@apache.org> on 2020/06/08 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18185) Confusing ValidationExcetion in DataGenTableSourceFactory - posted by "Konstantin Knauf (Jira)" <ji...@apache.org> on 2020/06/08 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18186) Various updates of Kubernetes standalone document - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/08 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18187) CheckPubSubEmulatorTest failed on azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/06/08 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18188) Document asymmetric allocation of Flink memory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/08 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18189) Incorrect size check for sumof heap/non-heap memory - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/08 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18190) Document implications on derived memory values when configuring meta space - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/08 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18191) Rename new Master memory options to start with "master" prefix - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/08 16:11:00 UTC, 0 replies.
- Re: Interested in applying as a technical writer - posted by Marta Paes Moreira <ma...@ververica.com> on 2020/06/08 16:56:19 UTC, 4 replies.
- [jira] [Created] (FLINK-18192) Upgrade to Avro version 1.9.1 from 1.8.2 - posted by "Lucas Heimberg (Jira)" <ji...@apache.org> on 2020/06/08 19:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18193) Replace all documentation self links with {% link %} tag - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/08 19:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18194) Update Table API Walkthrough - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/08 19:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18195) Remove references to Expressions.interval(Duration) - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/06/08 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing - posted by "Kai Chen (Jira)" <ji...@apache.org> on 2020/06/09 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18197) Add more logs for hive streaming integration - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/09 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18198) Translate "HBase SQL Connector"page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/09 05:33:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/09 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18200) Replace the deprecated interfaces with the new interfaces in the tests and examples - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/09 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18201) Support create_function in Python Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/09 05:47:00 UTC, 0 replies.
- [ANNOUNCE] New Flink Committer: Benchao Li - posted by Jark Wu <im...@gmail.com> on 2020/06/09 06:10:20 UTC, 30 replies.
- Flink on Kubes -- issues - posted by Ramya Ramamurthy <ha...@gmail.com> on 2020/06/09 06:45:32 UTC, 8 replies.
- [jira] [Created] (FLINK-18202) Introduce PB format - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/06/09 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18203) Reduce objects usage in redistributing union states - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/06/09 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18204) NullPointerException when materialize checkpoint - posted by "shengsheng lin (Jira)" <ji...@apache.org> on 2020/06/09 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18205) Mitigate the use of reflection in HadoopModule - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/09 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18206) The timestamp is displayed incorrectly - posted by "JasonLee (Jira)" <ji...@apache.org> on 2020/06/09 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18207) RowGenerator in datagen factory should implement snapshotState - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/09 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18208) flink es connector exists 2 Spelling mistakes - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/06/09 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18209) Replace "charged" words in the Flink codebase. - posted by "Marta Paes Moreira (Jira)" <ji...@apache.org> on 2020/06/09 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18210) The tmpdir will be clean up when stop historyserver - posted by "JieFang.He (Jira)" <ji...@apache.org> on 2020/06/09 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2020/06/09 09:18:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 2.1.0 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/06/09 09:56:09 UTC, 0 replies.
- [jira] [Created] (FLINK-18212) Init lookup join failed when use udf on lookup table - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/06/09 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18213) refactor kafka sql connector to use just one shade to compatible 0.10.0.2 + - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/06/09 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18215) BashJavaUtils logging message should include log level - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/09 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18214) Incorrect warning if jobstore.cache-size exceeds heap size - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/09 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18216) "Start time" column should not expand if a job is running - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/09 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18217) config.sh#extractExecutionResults does not fail on empty input - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/09 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18218) Add yarn perjob, java dependency management e2e tests for pyflink. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/06/09 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18219) Improve exception if jar submission hits OOM - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/09 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18220) Improve exception if finalizeOnmaster hits OOM - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/09 13:24:00 UTC, 0 replies.
- [Discuss] Migrate walkthroughs to flink-playgrounds for 1.11 - posted by Seth Wiesman <sj...@gmail.com> on 2020/06/09 14:06:46 UTC, 6 replies.
- [Reminder] Prefer {% link %} tag in documentation - posted by Seth Wiesman <sj...@gmail.com> on 2020/06/09 14:20:35 UTC, 15 replies.
- [jira] [Created] (FLINK-18221) SQL client YAML validation incomplete - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/09 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18222) "Avro Confluent Schema Registry nightly end-to-end test" unstable with "Kafka cluster did not start after 120 seconds" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/09 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18223) AvroSerializer does not correctly instantiate GenericRecord - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2020/06/09 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18224) Add document about sql client's tableau result mode - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/06/10 02:45:00 UTC, 0 replies.
- Re: NoSuchMethodError: org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.(Ljava/lang/String;Lorg/apache/flink/fs/s3presto/common/HadoopConfigLoader - posted by Guowei Ma <gu...@gmail.com> on 2020/06/10 02:58:10 UTC, 0 replies.
- [jira] [Created] (FLINK-18225) Add collect method in the Python TableResult - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/10 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18226) ResourceManager requests unnecessary new workers if previous workers are allocated but not registered. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/06/10 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18227) official example stuck in flink shell(local mode) - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/10 03:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18228) Release pending pods/containers timely when pending slots changed - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/10 05:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18229) Pending worker requests should be properly cleared - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/06/10 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18230) Table API has no Functions like sparkSQL explode - posted by "mzz (Jira)" <ji...@apache.org> on 2020/06/10 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18231) flink kafka connector exists same qualified class name, whch will cause conflicts when user has all the versions of flink-kafka-connector - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/06/10 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18232) Hive streaming source reuse row bug and split len can not be -1 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/10 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18233) TaskExecutorSubmissionTest unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/10 06:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18234) Implicit type conversion in join condition - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/06/10 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/10 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18236) flink elasticsearch IT test ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/06/10 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18237) IllegalArgumentException when reading filesystem partitioned table with stream mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/10 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/10 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18239) Kubernetes e2e test fails with "Kubernetes 1.18.3 requires conntrack to be installed in root's path" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/10 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18240) Correct remainder function usage in documentation or allow % operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/10 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/06/10 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18242) Custom OptionsFactory in user code not working when configured via code - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/06/10 11:26:00 UTC, 0 replies.
- Regarding GSOD opportunity at Apache Flink - posted by "Aditya Kumar Hurkat 4-Yr B.Tech. Mining Engg., IIT (BHU) Varanasi" <ad...@iitbhu.ac.in.INVALID> on 2020/06/10 12:01:13 UTC, 4 replies.
- [DISCUSS] Update our EditorConfig file - posted by Aljoscha Krettek <al...@apache.org> on 2020/06/10 12:38:47 UTC, 4 replies.
- [jira] [Created] (FLINK-18243) Flink SQL (1.10.0) to elasticsearch 5.6 - posted by "颖 (Jira)" <ji...@apache.org> on 2020/06/10 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18244) Support setup customized system environment before submitting test job - posted by "ShenDa (Jira)" <ji...@apache.org> on 2020/06/11 02:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18245) Support to parse -1 for MemorySize and Duration ConfigOption - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/11 04:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18246) PyFlink e2e fails with java version mismatch on JDK11 nightly build - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/11 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18247) Unstable test: TableITCase.testCollectWithClose:122 expected: but was: - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/11 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18248) Update data type documentation for 1.11 - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/11 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18249) Cannot create index by time field？ - posted by "zouwenlong (Jira)" <ji...@apache.org> on 2020/06/11 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18250) Enrich OOM error messages with more details in ClusterEntrypoint - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/06/11 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18251) Cannot create index by time field？ - posted by "zouwenlong (Jira)" <ji...@apache.org> on 2020/06/11 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18252) Resuming Savepoint (file, async, no parallelism change) end-to-end test fails with unaligned checkpoint enabled - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/06/11 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18253) Add filesystem documentation for Avro - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/11 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18254) Add documentation for primary key syntax - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/11 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18255) Add API annotations to RocksDB user-facing classes - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/06/11 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18256) Hadoop is bundled in flink-orc exceptionally - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/06/11 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18257) MasterStateSnapshot future may not be completed - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/06/11 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18258) Implement SHOW PARTITIONS for Hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/11 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18259) HeartbeatManagerTest.testHeartbeatCluster unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/11 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18260) Asynchronous Sinks - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2020/06/11 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18261) flink-orc and flink-parquet have invalid NOTICE file - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/11 17:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18262) PyFlink end-to-end test stalls - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/11 18:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18263) Allow external checkpoints to be persisted even when the job is in "Finished" state. - posted by "Mark Cho (Jira)" <ji...@apache.org> on 2020/06/11 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18264) Translate the "External Resource Framework" page into Chinese - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/12 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18265) Hidden files should be ignored when the filesystem table searches for partitions - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/12 03:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18266) 在表中使用proctime时，如果sql中不对强转，任务输出有问题 - posted by "liqi316 (Jira)" <ji...@apache.org> on 2020/06/12 03:21:00 UTC, 0 replies.
- request create flip permission for flink es bounded source/lookup source connector - posted by Jacky Lau <li...@gmail.com> on 2020/06/12 03:37:53 UTC, 0 replies.
- [jira] [Created] (FLINK-18267) Missing NOTICE file in flink-examples-streaming - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/12 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18268) Correct Table API in Temporal table docs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/06/12 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18269) ContinuousFileReaderOperator also supports monitoring subdirectories - posted by "Yun Gao (Jira)" <ji...@apache.org> on 2020/06/12 04:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18270) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/12 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18271) Move run-nightly-tests.sh - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/12 06:11:00 UTC, 0 replies.
- Re: request create flip permission for flink es bounded source/lookup source connector - posted by Jark Wu <im...@gmail.com> on 2020/06/12 07:01:01 UTC, 5 replies.
- [jira] [Created] (FLINK-18272) FileSystemLookupFunction can fail if the file gets updated/deleted while cache is reloaded - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/12 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18273) Test and document remote cluster submission in SQL Client - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/12 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18274) document example error - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/12 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18275) Register the DataStream as table how to write multiple fields - posted by "robert (Jira)" <ji...@apache.org> on 2020/06/12 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18276) NullPointerException when closing KafkaConsumer - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/06/12 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18277) Elasticsearch6DynamicSink#asSummaryString() return identifier typo - posted by "Qishang Zhong (Jira)" <ji...@apache.org> on 2020/06/12 13:14:00 UTC, 0 replies.
- Re: [DISCUSS] Semantics of our JIRA fields - posted by Robert Metzger <rm...@apache.org> on 2020/06/12 13:44:00 UTC, 1 replies.
- [jira] [Created] (FLINK-18278) Translate new documenation homepage - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/12 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18279) Simplify table overview page - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/06/12 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18280) Kotlin adapters for Flink types? - posted by "Marshall Pierce (Jira)" <ji...@apache.org> on 2020/06/12 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18281) Add WindowStagger into all Tumbling and Sliding Windows - posted by "Teng Hu (Jira)" <ji...@apache.org> on 2020/06/12 17:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18282) retranslate the documentation home page - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/06/12 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18283) [Javdoc] Update outdated Javadoc for clear method of ProcessWindowFunction - posted by "Abhijit Shandilya (Jira)" <ji...@apache.org> on 2020/06/13 01:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18284) No appenders could be found for logger - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/13 07:59:00 UTC, 0 replies.
- Moving in and Modify Dependency Source - posted by Austin Cawley-Edwards <au...@gmail.com> on 2020/06/13 20:40:50 UTC, 4 replies.
- [jira] [Created] (FLINK-18285) solution for 'For input string: “0x100” ' make bash command 'reset' fail to work - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/14 02:57:00 UTC, 0 replies.
- Interested in contributing to Apache Flink - posted by Vivin Peris <vi...@gmail.com> on 2020/06/14 13:50:11 UTC, 1 replies.
- [jira] [Created] (FLINK-18286) Implement type inference for functions on composite types - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/06/14 16:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-18287) Fix the documentation of Python Table API in SQL pages - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/15 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18288) WEB UI failure in Flink1.12 - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/15 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18289) UDF notify checkpoint aborted interface not work - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/06/15 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18290) Kafka011ProducerExactlyOnceITCase sometimes crashes with exit code 239 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/15 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18291) Streaming File Sink s3 end-to-end test stalls - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/15 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18292) Savepoint for job error - posted by "Kayo (Jira)" <ji...@apache.org> on 2020/06/15 07:15:00 UTC, 0 replies.
- Flink 1.10 with GCS for checkpoints - posted by Ramya Ramamurthy <ha...@gmail.com> on 2020/06/15 08:44:29 UTC, 1 replies.
- [jira] [Created] (FLINK-18293) TaskExecutor offering non empty slots can lead to resource violation - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/06/15 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18294) Log java processes and disk space after each e2e test - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/15 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18295) Remove the hack logics of result consumers - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/06/15 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18296) Add support for datetype TIMESTAMP_WITH_LOCAL_ZONE for Json format - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/06/15 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18297) SQL client: setting execution.type to invalid value shuts down the session - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/06/15 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18298) Rename TableResult headers of SHOW statements - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/06/15 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18299) Add keyword in json format to parse timestamp in different standard - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/06/15 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18300) SQL Client doesn't support ALTER VIEW - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/15 09:59:00 UTC, 0 replies.
- [DISCUSS] Re-renaming "Flink Master" back to JobManager - posted by Aljoscha Krettek <al...@apache.org> on 2020/06/15 10:56:53 UTC, 5 replies.
- [jira] [Created] (FLINK-18301) Backup Kafka logs on e2e failure - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/15 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18302) Sql client uses wrong class loader when execute INSERT statements - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/15 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18303) Filesystem connector doesn't flush part files after rolling interval - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/15 12:39:00 UTC, 0 replies.
- [DISCUSS] SQL Syntax for Table API StatementSet - posted by Fabian Hueske <fh...@gmail.com> on 2020/06/15 12:49:27 UTC, 7 replies.
- [jira] [Created] (FLINK-18304) Document default reporter interval - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/15 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18305) Add interval configuration too all reporter examples that support it - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/15 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18306) how to satisfy the node-sass dependency when compiling runtime-web? - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/15 13:28:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/23-24 - posted by Konstantin Knauf <kn...@apache.org> on 2020/06/15 13:47:04 UTC, 0 replies.
- NullPointer Exception while trying to access or read ReadOnly ctx in processElement method in KeyedBroadCastProcessFunction in Apache Flink - posted by "bujjirahul45 ." <ra...@gmail.com> on 2020/06/15 14:21:02 UTC, 0 replies.
- Any python example with json data from Kafka using flink-statefun - posted by Sunil Sattiraju <su...@gmail.com> on 2020/06/15 14:22:21 UTC, 4 replies.
- [jira] [Created] (FLINK-18307) Replace "slave" file name with "workers" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/06/15 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18308) KafkaProducerTestBase->Kafka011ProducerExactlyOnceITCase. testExactlyOnceCustomOperator hangs in Azure - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/06/15 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18309) Recommend avoiding uppercase to emphasise statements in doc style - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/06/15 15:23:00 UTC, 0 replies.
- Rest handler redirect problem - posted by Wong Lucent <ma...@live.cn> on 2020/06/15 17:01:51 UTC, 2 replies.
- [jira] [Created] (FLINK-18310) Failure while parsing reporter interval does not reliably revert back to default - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/15 17:58:00 UTC, 0 replies.
- Does FlinkKinesisConsumer not retry on NoHttpResponseException? - posted by "Singh Aulakh, Karanpreet KP" <ka...@amazon.com.INVALID> on 2020/06/16 00:54:07 UTC, 0 replies.
- [jira] [Created] (FLINK-18311) StreamingKafkaITCase stalls indefinitely - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/16 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18312) SavepointStatusHandler and StaticFileServerHandler not redirect - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2020/06/16 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18313) Hive dialect doc should mention that views created in Flink cannot be used in Hive - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/16 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18314) There are some problems in docs - posted by "jinxin (Jira)" <ji...@apache.org> on 2020/06/16 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18315) Insert into partitioned table can fail with values - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/06/16 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18316) Add a dynamic state registration primitive for Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/06/16 04:28:00 UTC, 0 replies.
- Request for assignment: FLINK-18119 Fix unlimitedly growing state for ... - posted by Hyeonseop Lee <pr...@gmail.com> on 2020/06/16 04:53:21 UTC, 1 replies.
- [jira] [Created] (FLINK-18317) Verify dependencies licencses in Flink 1.11 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/16 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18318) Flink ML - posted by "Dimitris Vogiatzidakis (Jira)" <ji...@apache.org> on 2020/06/16 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18319) Lack LICENSE.protobuf in flink-sql-orc - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/16 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18320) flink-sql-connector-hive modules should merge hive-exec dependencies - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/16 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18321) AbstractCloseableRegistryTest.testClose unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/16 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18322) Fix unstable ExecutorNotifierTest#testExceptionInHandler. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/06/16 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18323) Implement a Kafka Source based on new Source API - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/06/16 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18324) Translate updated data type and function page into Chinese - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/16 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18325) SqlMapTypeNameSpec#unparse may throw NPE - posted by "Jiatao Tao (Jira)" <ji...@apache.org> on 2020/06/16 10:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-18326) Kubernetes NOTICE issues - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18328) Blink planner NOTICE issues - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18327) ML NOTICE issues - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18329) Runtime NOTICE issues - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18330) Python NOTICE issues - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18331) Hive NOTICE issues - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18332) Add error message to precondition in KeyGroupPartitionedPriorityQueue - posted by "tartarus (Jira)" <ji...@apache.org> on 2020/06/16 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18333) UnsignedTypeConversionITCase failed caused by MariaDB4j "Asked to waitFor Program" - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/16 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18334) Exclude .dumpstream files that only contain JAVA_TOOL_OPTIONS logging - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18335) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted time outs - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/16 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18336) CheckpointFailureManager forgets failed checkpoints after a successful one - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/06/16 15:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18337) Introduce TableResult#await method to wait data ready - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/06/16 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18338) RocksDB tests crash the JVM on CI - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/16 18:03:00 UTC, 0 replies.
- [ANNOUNCE] Yu Li is now part of the Flink PMC - posted by jincheng sun <su...@gmail.com> on 2020/06/17 01:15:02 UTC, 31 replies.
- Flink Table program cannot be compiled when enable checkpoint of StreamExecutionEnvironment - posted by 杜斌 <du...@gmail.com> on 2020/06/17 02:29:50 UTC, 8 replies.
- [jira] [Created] (FLINK-18339) ValidationException exception that field typeinformation in TableSchema and in TableSource return type for blink - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/06/17 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18340) Support directly providing bytes instead of a Protobuf messages when writing to Kafka / Kinesis with the Python SDK - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/06/17 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/17 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18342) SQLParser can not parse ROW() if it contains UDF - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/06/17 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18343) Enable DEBUG logging for java e2e tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/17 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18344) Avoid wrong check with shardId in DynamoDB Streams - posted by "Javier Garcia (Jira)" <ji...@apache.org> on 2020/06/17 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18345) Support filter push down for lookup table source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/17 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18346) Support partition pruning for lookup table source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/06/17 09:53:00 UTC, 0 replies.
- Any good comparison on FSM of Flink vs Akka? - posted by Rohit R <le...@gmail.com> on 2020/06/17 10:10:36 UTC, 4 replies.
- Which is Best option between Flink or Flink Stateful Functions or Akka FSM for State Use-cases? - posted by Rohit R <le...@gmail.com> on 2020/06/17 11:06:22 UTC, 0 replies.
- [jira] [Created] (FLINK-18347) Error java.lang.NoSuchFieldError: NO_INTS - posted by "lining (Jira)" <ji...@apache.org> on 2020/06/17 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18348) RemoteInputChannel should checkError before checking partitionRequestClient - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/06/17 12:34:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.11.0, release candidate #2 - posted by Piotr Nowojski <pn...@apache.org> on 2020/06/17 13:29:04 UTC, 17 replies.
- [jira] [Created] (FLINK-18349) Add Flink 1.11 release notes to documentation - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/17 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18350) [1.11.0] jobmanager complains `taskmanager.memory.process.size` missing - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2020/06/17 18:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18351) ModuleManager creates a lot of duplicate/similar log messages - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/17 20:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe - posted by "Marcos Klein (Jira)" <ji...@apache.org> on 2020/06/17 23:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18353) [1.11.0] maybe document jobmanager behavior change regarding -XX:MaxDirectMemorySize - posted by "Steven Zhen Wu (Jira)" <ji...@apache.org> on 2020/06/18 01:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18354) when use ParquetAvroWriters.forGenericRecord(Schema schema) error java.lang.ClassCastException: org.apache.flink.api.java.tuple.Tuple2 cannot be cast to org.apache.avro.generic.IndexedRecord - posted by "Yangyingbo (Jira)" <ji...@apache.org> on 2020/06/18 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18355) Simplify tests of SlotPoolImpl - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/06/18 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18356) Exit code 137 returned from process when testing pyflink - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/18 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/18 07:05:00 UTC, 0 replies.
- [DISCUSS] Sql-client lack support for new features - posted by Jingsong Li <ji...@gmail.com> on 2020/06/18 07:18:48 UTC, 3 replies.
- [jira] [Created] (FLINK-18358) TableEnvironmentITCase.testSqlUpdateAndToDataSetWithTableSource:245 unstable: result mismatch - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/18 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18359) Improve error-log strategy for Elasticsearch sink for large data documentId conflict when using create mode for `insert ignore` semantics - posted by "rinkako (Jira)" <ji...@apache.org> on 2020/06/18 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18360) Flink History Server doesn't show correctly table of Completed jobs when there are no archived jobs are in the archive directory - posted by "Jindrich Vimr (Jira)" <ji...@apache.org> on 2020/06/18 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18361) Support username and password options for new Elasticsearch connector - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/06/18 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18362) Shipping jdk by shipping archive - posted by "Noah (Jira)" <ji...@apache.org> on 2020/06/18 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18363) Add user classloader to context in DeSerializationSchema - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/18 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18364) A streaming sql cause "org.apache.flink.table.api.ValidationException: Type TIMESTAMP(6) of table field 'rowtime' does not match with the physical type TIMESTAMP(3) of the 'rowtime' field of the TableSink consumed type" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/18 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18365) The same sql in a batch env and a streaming env has different value. - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/18 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18366) Track E2E test durations centrally - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/18 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18367) Flink HA Mode in Kubernetes. Fencing token not set - posted by "An (Jira)" <ji...@apache.org> on 2020/06/18 13:21:00 UTC, 0 replies.
- [DISCUSS] Upgrade HBase connector to 2.2.x - posted by Gyula Fóra <gy...@gmail.com> on 2020/06/18 13:25:26 UTC, 3 replies.
- [jira] [Created] (FLINK-18368) HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest.createHDFS fails with "Running in secure mode, but config doesn't have a keytab" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/18 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18369) TableEnvironmentITCase.testStatementSetWithSameSinkTableNames failed on azure - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/18 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18370) Test Flink on Azure-hosted VMs nightly - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/06/18 17:25:00 UTC, 0 replies.
- S3 Checkpointing taking long time with stateful operations - posted by "Kathula, Sandeep" <Sa...@intuit.com.INVALID> on 2020/06/19 01:21:10 UTC, 1 replies.
- [jira] [Created] (FLINK-18371) NPE of "org.apache.flink.table.data.util.DataFormatConverters$BigDecimalConverter.toExternalImpl(DataFormatConverters.java:680)" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/19 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18372) NullPointerException can happen in SlotPoolImpl#maybeRemapOrphanedAllocation - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/06/19 05:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18373) Drop performance unit tests in RocksDB state backend module - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/06/19 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18374) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart produced no output for 900 seconds - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/19 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18375) Crashed tests at org.apache.maven.plugin.surefire.booterclient.forkstarter.fork - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 06:56:00 UTC, 0 replies.
- Re: [DISCUSS] Drop connectors for 5.x and restart the flink es source connector - posted by Jark Wu <im...@gmail.com> on 2020/06/19 07:53:20 UTC, 0 replies.
- [jira] [Created] (FLINK-18376) java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction - posted by "LakeShen (Jira)" <ji...@apache.org> on 2020/06/19 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18377) Rename "Flink Master" back to JobManager in documentation - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/06/19 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18378) CatalogManager checks for CatalogTableImpl instead of CatalogTable - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2020/06/19 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18379) Introduce asynchronous UDF/UDTF - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/06/19 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18380) Add a table source example - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/19 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18381) Update Jekyll to 4.0.1 - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/06/19 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18382) Translate "Kafka SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18383) Translate "JDBC SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18385) Translate "DataGen SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18384) Translate "Elasticsearch SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18387) Translate "BlackHole SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18386) Translate "Print SQL Connector" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18388) Translate "CSV Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18389) Translate all SQL connector pages into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18390) Translate "JSON Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18391) Translate "Avro Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18392) Translate "Debezium Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18394) Translate "Parquet Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18393) Translate "Canal Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18395) Translate "ORC Format" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18396) Translate "Formats Overview" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18397) Translate "Table & SQL Connectors Overview" page into Chinese - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/19 14:28:00 UTC, 0 replies.
- [Announce] Flink Forward Call for Proposals Extended - posted by Seth Wiesman <sj...@gmail.com> on 2020/06/19 14:54:00 UTC, 2 replies.
- [jira] [Created] (FLINK-18398) ElasticSearch unavailibility causes TM shutdown - posted by "Alexander Fedulov (Jira)" <ji...@apache.org> on 2020/06/19 15:30:00 UTC, 0 replies.
- adding s3 object metadata while using StreamFileSink - posted by dhurandar S <dh...@gmail.com> on 2020/06/19 19:19:38 UTC, 1 replies.
- Apply contributor - posted by Shiwei Qin <qi...@gmail.com> on 2020/06/20 02:59:54 UTC, 1 replies.
- Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL - posted by Leonard Xu <xb...@gmail.com> on 2020/06/20 15:08:34 UTC, 11 replies.
- [jira] [Created] (FLINK-18399) TableResult#print can not print the result of unbounded stream query - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/06/20 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18400) A streaming sql has "java.lang.NegativeArraySizeException" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/22 00:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18401) A streaming sql has "Sort on a non-time-attribute field is not supported" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/22 00:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18402) NullPointerException in org.apache.flink.api.common.typeutils.base.GenericArraySerializer.copy(GenericArraySerializer.java:96) - posted by "zhoupeijie (Jira)" <ji...@apache.org> on 2020/06/22 03:20:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/25 - posted by Konstantin Knauf <kn...@apache.org> on 2020/06/22 07:35:04 UTC, 0 replies.
- [jira] [Created] (FLINK-18403) Ensure that only exactly once checkpointing can be unaligned - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/06/22 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18404) Make unaligned checkpoints rescalable - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/06/22 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18405) Add watermark support for unaligned checkpoints - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/06/22 08:18:00 UTC, 0 replies.
- [DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers - posted by "Cranmer, Danny" <cr...@amazon.com.INVALID> on 2020/06/22 09:27:48 UTC, 7 replies.
- [jira] [Created] (FLINK-18406) Annotate DualKeyLinkedMap with @Nullable annotation - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/06/22 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18407) NPE in SlotPoolImpl.maybeRemapOrphanedAllocation if no pending request is registered - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/06/22 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18408) BinaryRowData should use de-/serialization method of MemorySegment with explicit endianness - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/06/22 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18409) The FilterJoinRule.FILTER_ON_JOIN optimizer rule cause 'Join With a Temporal Table' not working properly - posted by "Yuhao Zhao (Jira)" <ji...@apache.org> on 2020/06/22 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18410) Flink SQL filesystem connector class name correct - posted by "dalongliu (Jira)" <ji...@apache.org> on 2020/06/22 13:01:00 UTC, 0 replies.
- Could someone help me to review PR[12727]? - posted by Roc Marshal <fl...@126.com> on 2020/06/23 02:00:00 UTC, 3 replies.
- [jira] [Created] (FLINK-18411) release-1.11 compile failed - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2020/06/23 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18412) JdbcFullTest failed to compile on 1.11 - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/23 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18413) TableResult.collect should throw exception if user does not enable checkpointing in streaming mode - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/06/23 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18414) Kafka Json connector in Table API support more option - posted by "DuBin (Jira)" <ji...@apache.org> on 2020/06/23 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18415) Support TableResult#collect in the Python Table API to align with the Java Table API - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/23 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18416) Deprecate TableEnvironment#connect API - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/06/23 10:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-18417) Support List as a conversion class for ARRAY - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/23 13:27:00 UTC, 0 replies.
- [DISCUSS] Cross-version compatibility guarantees of Flink Modules/Jars - posted by Aljoscha Krettek <al...@apache.org> on 2020/06/23 13:32:40 UTC, 5 replies.
- [jira] [Created] (FLINK-18418) document example error - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/23 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18419) Can not create a catalog - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/06/23 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18420) SQLClientHBaseITCase.testHBase failed with "ArgumentError: wrong number of arguments (0 for 1)" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/24 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18421) Elasticsearch (v6.3.1) sink end-to-end test instable - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/24 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18422) Update Prefer tag in documentation 'Fault Tolerance training lesson' - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2020/06/24 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18423) Fix Prefer tag in document "Detecting Patterns" page of "Streaming Concepts" - posted by "Roc Marshal (Jira)" <ji...@apache.org> on 2020/06/24 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18424) How does standalone mode not rely on distributed state storage - posted by "Echo Lee (Jira)" <ji...@apache.org> on 2020/06/24 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18425) GenericArrayData cannot convert object arrays to primitive arrays - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/06/24 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18426) Incompatible deprecated key type for registration cluster options - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/06/24 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18427) Job failed under java 11 - posted by "Zhang Hao (Jira)" <ji...@apache.org> on 2020/06/24 08:28:00 UTC, 0 replies.
- Hi! - posted by 郭海帅 <gu...@foxmail.com> on 2020/06/24 09:58:56 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.11.0, release candidate #3 - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/06/24 11:48:50 UTC, 3 replies.
- [jira] [Created] (FLINK-18428) StreamExecutionEnvironment#continuousSource() method should be renamed to source() - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/06/24 12:33:01 UTC, 0 replies.
- [VOTE] Release 1.11.0, release candidate #3 - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/06/24 15:03:12 UTC, 3 replies.
- [jira] [Created] (FLINK-18429) Add default method for CheckpointListener.notifyCheckpointAborted(checkpointId) - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/06/24 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18430) Upgrade stability to @Public for CheckpointedFunction and CheckpointListener - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/06/24 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18431) Provide default empty implementation of notifyCheckpointAborted - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/06/24 16:20:00 UTC, 0 replies.
- Unaligned checkpoints enabled by default for Flink CI builds on master - posted by Arvid Heise <ar...@ververica.com> on 2020/06/24 19:28:27 UTC, 0 replies.
- [jira] [Created] (FLINK-18432) add open and close methods for ElasticsearchSinkFunction interface - posted by "rinkako (Jira)" <ji...@apache.org> on 2020/06/24 20:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18433) 1.11 has a regression - posted by "Aihua Li (Jira)" <ji...@apache.org> on 2020/06/25 00:08:00 UTC, 0 replies.
- [FLINK-17073] checkpoint backpressure design doc - posted by Etienne Chauchot <ec...@apache.org> on 2020/06/25 07:56:47 UTC, 0 replies.
- [jira] [Created] (FLINK-18434) Can not select fields with JdbcCatalog - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/06/25 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18435) Allow reporter factories to intercept reflection-based instantiation attempts - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/06/26 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18436) how to implement the class `MyTupleReducer`in flink official document - posted by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/27 03:57:00 UTC, 0 replies.
- Is Flink HIPAA certified - posted by Prasanna kumar <pr...@gmail.com> on 2020/06/27 07:41:23 UTC, 0 replies.
- Distributed Anomaly Detection using MIDAS - posted by Shivin Srivastava <sh...@comp.nus.edu.sg> on 2020/06/27 09:12:56 UTC, 0 replies.
- [jira] [Created] (FLINK-18437) Table API has no Functions like sparkSQL explode - posted by "mzz (Jira)" <ji...@apache.org> on 2020/06/28 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18438) TaskManager start failed - posted by "JohnSiro (Jira)" <ji...@apache.org> on 2020/06/28 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18439) Update sql client jar url in docs - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/06/28 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18440) ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions - posted by "LakeShen (Jira)" <ji...@apache.org> on 2020/06/28 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18441) support Local-Global Aggregation with LastValue Funciton - posted by "wangpeibin (Jira)" <ji...@apache.org> on 2020/06/28 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18442) Move `testSessionWindowsWithContinuousEventTimeTrigger` to `ContinuousEventTimeTriggerTest` - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2020/06/28 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18443) The operator name select: (ip, ts, count, environment.access AS access, environment.brand AS brand, sid, params.adid AS adid, eventid) exceeded the 80 characters length limit and was truncated - posted by "mzz (Jira)" <ji...@apache.org> on 2020/06/29 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18444) KafkaITCase.testMultipleSourcesOnePartition failed with "Failed to send data to Kafka: Failed to send data to Kafka: This server does not host this topic-partition" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/29 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18445) Short circuit join condition for lookup join - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/06/29 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18446) Flink SQL CEP can no recognize keywords MATCH_RECOGINZE from Joins - posted by "franklin DREW (Jira)" <ji...@apache.org> on 2020/06/29 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18447) Add 'flink-connector-base' to 'flink-dist' - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/06/29 09:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-18448) Update Google Cloud PubSub dependencies - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/06/29 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API - posted by "Shengkai Fang (Jira)" <ji...@apache.org> on 2020/06/29 12:53:00 UTC, 0 replies.
- Announcing ApacheCon @Home 2020 - posted by Rich Bowen <rb...@apache.org> on 2020/06/29 12:54:01 UTC, 0 replies.
- Is it possible to create an Apache Beam (in python) IO connector for RabbitMQ? - posted by Jonathan Figueroa <j0...@gmail.com> on 2020/06/29 21:23:57 UTC, 0 replies.
- [jira] [Created] (FLINK-18450) Add watermark alignment logic to SourceReaderBase. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/06/30 00:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18451) Flink HA on yarn may appear TaskManager double running when HA is restored - posted by "ming li (Jira)" <ji...@apache.org> on 2020/06/30 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18452) Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration - posted by "Weike Dong (Jira)" <ji...@apache.org> on 2020/06/30 03:41:00 UTC, 0 replies.
- Flaws in RetractableTopNFunction.ComparatorWrapper#equals method prevent state access after restoration - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2020/06/30 03:51:40 UTC, 1 replies.
- [jira] [Created] (FLINK-18453) Stack overflow of AggregateITCase#testAggregationCodeSplit on Azure - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/06/30 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18454) Add a code contribution section about how to look for what to contribute - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/06/30 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-18455) Building with JDK 9+ leads to problems on JDK 8 - posted by "Niels Basjes (Jira)" <ji...@apache.org> on 2020/06/30 09:07:00 UTC, 0 replies.
- [VOTE] Release 1.11.0, release candidate #4 - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/06/30 10:17:41 UTC, 1 replies.
- Flink JDK compatibility problem. - posted by Niels Basjes <Ni...@basjes.nl> on 2020/06/30 11:01:51 UTC, 3 replies.
- [jira] [Created] (FLINK-18456) CompressionFactoryITCase.testWriteCompressedFile fails with "expected:<1> but was:<2>" - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/06/30 23:44:00 UTC, 0 replies.