dev@flink.apache.org, 2019-09

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

- [jira] [Created] (FLINK-13934) HistoryServerStaticFileServerHandlerTest failed on Travis - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/01 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13935) YarnPrioritySchedulingITCase fails on hadoop 2.4.1 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/01 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13936) NOTICE-binary is outdated - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/01 09:44:00 UTC, 0 replies.
- Re: CiBot Update - posted by Yun Tang <my...@live.com> on 2019/09/01 18:18:46 UTC, 1 replies.
- Re: Potential block size issue with S3 binary files - posted by Stephan Ewen <se...@apache.org> on 2019/09/01 19:42:05 UTC, 3 replies.
- Re: State of FLIPs - posted by Yu Li <ca...@gmail.com> on 2019/09/01 21:16:00 UTC, 1 replies.
- Re: [SURVEY] Is the default restart delay of 0s causing problems? - posted by Yu Li <ca...@gmail.com> on 2019/09/01 21:56:09 UTC, 6 replies.
- Re: [ANNOUNCE] Kinesis connector becomes part of Flink releases - posted by Yu Li <ca...@gmail.com> on 2019/09/01 22:03:37 UTC, 1 replies.
- Re: [DISCUSS] Releasing Flink 1.8.2 - posted by jincheng sun <su...@gmail.com> on 2019/09/02 00:10:07 UTC, 15 replies.
- Re: [DISCUSS] Simplify Flink's cluster level RestartStrategy configuration - posted by Becket Qin <be...@gmail.com> on 2019/09/02 01:05:45 UTC, 4 replies.
- Re: [DISCUSS] Flink Python User-Defined Function for Table API - posted by Shaoxuan Wang <ws...@gmail.com> on 2019/09/02 01:38:11 UTC, 16 replies.
- Re: [VOTE] FLIP-58: Flink Python User-Defined Function for Table API - posted by Shaoxuan Wang <ws...@gmail.com> on 2019/09/02 01:46:21 UTC, 3 replies.
- Re: [PROPOSAL] Force rebase on master before merge - posted by Zili Chen <wa...@gmail.com> on 2019/09/02 01:55:29 UTC, 0 replies.
- Re: How to handle Flink Job with 400MB+ Uberjar with 800+ containers ? - posted by Zhu Zhu <re...@gmail.com> on 2019/09/02 02:37:42 UTC, 1 replies.
- Re: [DISCUSS] FLIP-49: Unified Memory Configuration for TaskExecutors - posted by Xintong Song <to...@gmail.com> on 2019/09/02 03:13:52 UTC, 17 replies.
- Re: [DISCUSS] FLIP-53: Fine Grained Resource Management - posted by Xintong Song <to...@gmail.com> on 2019/09/02 03:50:45 UTC, 8 replies.
- [jira] [Created] (FLINK-13937) Fix the error of the hive connector dependency version - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2019/09/02 06:16:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-59: Enable execution configuration from Configuration object - posted by Dawid Wysakowicz <dw...@apache.org> on 2019/09/02 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13938) Use yarn public distributed cache to speed up containers launch - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/09/02 07:42:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-54: Evolve ConfigOption and Configuration - posted by Timo Walther <tw...@apache.org> on 2019/09/02 08:05:24 UTC, 16 replies.
- Re: [VOTE] FLIP-54: Evolve ConfigOption and Configuration - posted by vino yang <ya...@gmail.com> on 2019/09/02 08:07:35 UTC, 0 replies.
- Re: [DISCUSS] FLIP-60: Restructure the Table API & SQL documentation - posted by vino yang <ya...@gmail.com> on 2019/09/02 08:16:41 UTC, 6 replies.
- Build failure on flink-python - posted by Biao Liu <mm...@gmail.com> on 2019/09/02 08:24:21 UTC, 3 replies.
- Re: ClassLoader created by BlobLibraryCacheManager is not using context classloader - posted by Aljoscha Krettek <al...@apache.org> on 2019/09/02 09:02:00 UTC, 16 replies.
- Re: [DISCUSS] FLIP-55: Introduction of a Table API Java Expression DSL - posted by Timo Walther <tw...@apache.org> on 2019/09/02 09:37:10 UTC, 2 replies.
- Kafka Checkpointing weird behavior. - posted by Dominik Wosiński <wo...@gmail.com> on 2019/09/02 10:13:36 UTC, 0 replies.
- [jira] [Created] (FLINK-13939) pyflink ExecutionConfigTests#test_equals_and_hash test failed - posted by "vinoyang (Jira)" <ji...@apache.org> on 2019/09/02 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13940) S3RecoverableWriter causes job to get stuck in recovery - posted by "Jimmy Weibel Rasmussen (Jira)" <ji...@apache.org> on 2019/09/02 10:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13941) Prevent data-loss by not cleaning up small part files from S3. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/09/02 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13942) Add Overview page for Getting Started section - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/02 12:23:00 UTC, 0 replies.
- Re: [VOTE] FLIP-49: Unified Memory Configuration for TaskExecutors - posted by Xintong Song <to...@gmail.com> on 2019/09/02 13:08:38 UTC, 17 replies.
- [DISCUSS] FLIP-61 Simplify Flink's cluster level RestartStrategy configuration - posted by Till Rohrmann <tr...@apache.org> on 2019/09/02 20:56:28 UTC, 1 replies.
- [jira] [Created] (FLINK-13943) Provide api to convert flink table to java List - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/09/03 02:15:00 UTC, 0 replies.
- Re: [DISCUSS] Add ARM CI build to Flink (information-only) - posted by Xiyuan Wang <wa...@gmail.com> on 2019/09/03 02:38:48 UTC, 4 replies.
- [DISCUSS] Contribute Pulsar Flink connector back to Flink - posted by Yijie Shen <he...@gmail.com> on 2019/09/03 05:57:42 UTC, 43 replies.
- Re: [DISCUSS] FLIP-57 - Rework FunctionCatalog - posted by Kurt Young <yk...@gmail.com> on 2019/09/03 07:40:37 UTC, 70 replies.
- Please add me as contributor - posted by Jan Lukavský <je...@seznam.cz> on 2019/09/03 08:18:06 UTC, 3 replies.
- [jira] [Created] (FLINK-13944) Table.toAppendStream: InvalidProgramException: Table program cannot be compiled. - posted by "Stefano (Jira)" <ji...@apache.org> on 2019/09/03 09:40:00 UTC, 0 replies.
- [DISCUSS] FLIP-62: Set default restart delay for FixedDelay- and FailureRateRestartStrategy to 1s - posted by Till Rohrmann <tr...@apache.org> on 2019/09/03 09:41:24 UTC, 3 replies.
- Flink SQL - Support Computed Columns in DDL? - posted by Qi Luo <lu...@gmail.com> on 2019/09/03 10:18:50 UTC, 3 replies.
- [jira] [Created] (FLINK-13945) Vendor-repos Maven profile doesn't exist in flink-shaded - posted by "Elise Ramé (Jira)" <ji...@apache.org> on 2019/09/03 14:57:00 UTC, 0 replies.
- Re: [DISCUSS] Repository split - posted by Robert Metzger <rm...@apache.org> on 2019/09/03 16:45:45 UTC, 0 replies.
- Re: [DISCUSS] Reducing build times - posted by Robert Metzger <rm...@apache.org> on 2019/09/03 16:57:14 UTC, 7 replies.
- [jira] [Created] (FLINK-13946) Remove deactivated JobSession-related code. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/09/03 17:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13947) Check Hive shim serialization in Hive UDF wrapper classes and test coverage - posted by "Xuefu Zhang (Jira)" <ji...@apache.org> on 2019/09/03 19:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13948) Fix loss of state for Identical Windows merging after initial merge - posted by "Scott Waller (Jira)" <ji...@apache.org> on 2019/09/03 21:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13949) Delete deduplicating JobVertexDetailsInfo.VertexTaskDetail - posted by "lining (Jira)" <ji...@apache.org> on 2019/09/04 01:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13950) should report an error if hive table partition keys are not in the last schema fields - posted by "Hongtao Zhang (Jira)" <ji...@apache.org> on 2019/09/04 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13951) Unable to call limit without sort for batch mode - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/09/04 02:54:00 UTC, 0 replies.
- Re: [DISCUSS] META-FLIP: Sticking (or not) to a strict FLIP voting process - posted by Becket Qin <be...@gmail.com> on 2019/09/04 05:29:32 UTC, 0 replies.
- [jira] [Created] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/04 06:14:01 UTC, 0 replies.
- How to calculate one day's uv every minute by SQL - posted by 刘建刚 <li...@gmail.com> on 2019/09/04 06:49:50 UTC, 0 replies.
- FLIP-63: Rework table partition support - posted by JingsongLee <lz...@aliyun.com.INVALID> on 2019/09/04 07:11:01 UTC, 1 replies.
- [jira] [Created] (FLINK-13953) Facilitate enabling new Scheduler in MiniCluster Tests - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/09/04 07:30:00 UTC, 0 replies.
- [VOTE] FLIP-61 Simplify Flink's cluster level RestartStrategy configuration - posted by Till Rohrmann <tr...@apache.org> on 2019/09/04 09:05:00 UTC, 7 replies.
- [VOTE] FLIP-62: Set default restart delay for FixedDelay- and FailureRateRestartStrategy to 1s - posted by Till Rohrmann <tr...@apache.org> on 2019/09/04 09:06:30 UTC, 10 replies.
- [DISCUSS] Use static imports for test utilities or asserts. - posted by Yang Jeff <hi...@outlook.com> on 2019/09/04 09:12:26 UTC, 1 replies.
- Re: [DISCUSS] Flink client api enhancement for downstream project - posted by Zili Chen <wa...@gmail.com> on 2019/09/04 09:36:30 UTC, 13 replies.
- [jira] [Created] (FLINK-13954) Clean up ExecutionEnvironment / JobSubmission code paths - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/09/04 09:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13955) Integrate ContinuousFileReaderOperator with StreamTask mailbox execution model - posted by "Alex (Jira)" <ji...@apache.org> on 2019/09/04 10:47:00 UTC, 0 replies.
- Fine grained batch recovery vs. native libraries - posted by David Morávek <dm...@apache.org> on 2019/09/04 11:41:56 UTC, 3 replies.
- [jira] [Created] (FLINK-13956) Add sequence file format with repeated sync blocks - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2019/09/04 11:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13957) Redact passwords from dynamic properties on job submission - posted by "Matyas Orhidi (Jira)" <ji...@apache.org> on 2019/09/04 12:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13958) Job class loader may not be reused after batch job recovery - posted by "David Moravek (Jira)" <ji...@apache.org> on 2019/09/04 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13959) Consolidate DetachedEnvironment and ContextEnvironment - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/09/04 12:19:00 UTC, 0 replies.
- [DISCUSS] Support JSON functions in Flink SQL - posted by Xu Forward <fo...@gmail.com> on 2019/09/04 12:33:55 UTC, 10 replies.
- Storing offsets in Kafka - posted by Dominik Wosiński <wo...@gmail.com> on 2019/09/04 13:03:00 UTC, 3 replies.
- [jira] [Created] (FLINK-13960) Provide default implementation for deprecated HighAvailabilityServices.getWebMonitorLeaderRetriever - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/04 14:15:00 UTC, 0 replies.
- [DISCUSS] FLIP-64: Support for Temporary Objects in Table module - posted by Dawid Wysakowicz <dw...@apache.org> on 2019/09/04 14:20:01 UTC, 12 replies.
- [jira] [Created] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service) - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/04 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13963) Consolidate Hadoop file systems usage and Hadoop integration docs - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2019/09/04 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13962) Execution#taskRestore leaks if task fails before deploying - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/04 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13964) Remove usage of deprecated methods from MiniCluster - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/04 14:58:00 UTC, 0 replies.
- Re: instable checkpointing after migration to flink 1.8 - posted by Bekir Oguz <be...@persgroep.net> on 2019/09/04 15:37:55 UTC, 5 replies.
- [jira] [Created] (FLINK-13965) Keep hasDeprecatedKeys in ConfigOption and mark it with @Deprecated annotation - posted by "vinoyang (Jira)" <ji...@apache.org> on 2019/09/05 03:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13966) Jar sorting in collect_license_files.sh is locale dependent - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/05 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13967) Generate full binary licensing via collect_license_files.sh - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/05 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13968) Add travis check for the correctness of the binary licensing - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/05 07:32:00 UTC, 0 replies.
- [DISCUSS] Adding configure and close methods to the Kafka(De)SerializationSchema interfaces - posted by Gyula Fóra <gy...@gmail.com> on 2019/09/05 07:43:08 UTC, 2 replies.
- [jira] [Created] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/05 07:54:00 UTC, 0 replies.
- [ANNOUNCE] Flink Forward training registration closes on September 30th - posted by Fabian Hueske <fh...@gmail.com> on 2019/09/05 08:10:29 UTC, 0 replies.
- [jira] [Created] (FLINK-13970) Remove or move LifoSetQueue - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/05 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13971) Add TaskManager In org.apache.flink.runtime.rest.messages.JobVertexTaskManagersInfo.TaskManagersInfo - posted by "lining (Jira)" <ji...@apache.org> on 2019/09/05 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13972) Move PreviewPlanEnvironment to flink-tests - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/09/05 10:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13973) Checkpoint recovery failed after user set uidHash - posted by "Zhouyu Pei (Jira)" <ji...@apache.org> on 2019/09/05 10:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13974) isAssignable function return wrong result - posted by "forideal (Jira)" <ji...@apache.org> on 2019/09/05 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13975) Translate "Upcoming Events" on Chinese index.html - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/05 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13976) Make moder kafka E2E test runnable on Java 11 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/05 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13977) Adapt HighAvailabilityServices#getWebMonitorLeaderElectionService to #getClusterRestEndpointLeaderRetriever - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/05 13:55:00 UTC, 0 replies.
- [ANNOUNCE] Java 11 cron builds activated on master - posted by Chesnay Schepler <ch...@apache.org> on 2019/09/05 13:58:09 UTC, 2 replies.
- [jira] [Created] (FLINK-13978) Evaluate Azure Pipelines as a CI tool for Flink - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2019/09/05 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13979) Translate new streamfilesink docs to chinese - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2019/09/05 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13980) FLIP-49 Unified Memory Configuration for TaskExecutors - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13981) Introduce a switch for enabling the new task executor memory configurations - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13984) Separate on-heap and off-heap managed memory pools - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13985) Use native memory for managed memory. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13982) Implement memory calculation logics - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13983) Launch task executor with new memory calculation logics - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13986) Clean-up of legacy mode - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/06 02:55:00 UTC, 0 replies.
- [VOTE] FLIP-53: Fine Grained Operator Resource Management - posted by Xintong Song <to...@gmail.com> on 2019/09/06 03:16:52 UTC, 6 replies.
- [DISCUSS] FLIP-66: Support time attribute in SQL DDL - posted by Jark Wu <im...@gmail.com> on 2019/09/06 03:19:29 UTC, 11 replies.
- [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete - posted by JingsongLee <lz...@aliyun.com.INVALID> on 2019/09/06 04:20:25 UTC, 11 replies.
- [DISCUSS] FLIP-63: Rework table partition support - posted by JingsongLee <lz...@aliyun.com.INVALID> on 2019/09/06 05:21:45 UTC, 9 replies.
- [DISCUSS] Support customize state in customized KeyedStateBackend - posted by shimin yang <ys...@gmail.com> on 2019/09/06 05:27:22 UTC, 4 replies.
- [jira] [Created] (FLINK-13987) add new logs api, see more log files and can see logs by pages - posted by "lining (Jira)" <ji...@apache.org> on 2019/09/06 07:57:00 UTC, 1 replies.
- Is Flink documentation deployment script broken ? - posted by Jark Wu <im...@gmail.com> on 2019/09/06 09:44:42 UTC, 2 replies.
- [jira] [Created] (FLINK-13988) Remove legacy JobManagerMode - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/06 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13989) Remove legacy ClassloadingProps - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/06 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13990) Remove JobModificationException - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/06 10:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13991) Add git exclusion for 1.9+ features to 1.8 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/06 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/06 10:20:00 UTC, 0 replies.
- Checkpointing clarification - posted by Dominik Wosiński <wo...@gmail.com> on 2019/09/06 12:02:16 UTC, 5 replies.
- [jira] [Created] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2019/09/06 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13994) Translate "Getting Started" overview to Chinese - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/06 12:31:00 UTC, 0 replies.
- [VOTE] Release 1.8.2, release candidate #1 - posted by Jark Wu <im...@gmail.com> on 2019/09/06 12:47:36 UTC, 5 replies.
- [ANNOUNCE] Kostas Kloudas joins the Flink PMC - posted by Fabian Hueske <fh...@gmail.com> on 2019/09/06 12:55:49 UTC, 24 replies.
- [jira] [Created] (FLINK-13995) Fix shading of the licence information of netty - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2019/09/06 13:02:00 UTC, 0 replies.
- [DISCUSS] FLIP-67: Global partitions lifecycle - posted by Chesnay Schepler <ch...@apache.org> on 2019/09/06 13:16:00 UTC, 4 replies.
- [jira] [Created] (FLINK-13996) Maven instructions for 3.3+ do not cover all shading special cases - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/09/06 14:09:00 UTC, 0 replies.
- [DISCUSS] Features for Apache Flink 1.10 - posted by Gary Yao <ga...@apache.org> on 2019/09/06 15:06:27 UTC, 11 replies.
- [jira] [Created] (FLINK-13997) Remove legacy LeaderAddressAndId - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/06 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13998) Fix ORC test failure with Hive 2.0.x - posted by "Xuefu Zhang (Jira)" <ji...@apache.org> on 2019/09/06 19:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/07 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14000) Remove legacy ProcessShutDownThread - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/07 07:07:00 UTC, 0 replies.
- [DISCUSS] Supporting multiple Flink versions vs. tech debt - posted by David Morávek <dm...@apache.org> on 2019/09/07 10:32:22 UTC, 1 replies.
- [jira] [Created] (FLINK-14001) add a API to enable user to get the operator code generated by Flink engine - posted by "Dezhi Cai (Jira)" <ji...@apache.org> on 2019/09/07 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2019/09/07 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14003) Add access to customized state other than built in state types - posted by "Shimin Yang (Jira)" <ji...@apache.org> on 2019/09/08 08:52:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/33-36 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/09/08 16:33:07 UTC, 0 replies.
- [jira] [Created] (FLINK-14004) Define SourceReader interface to verify the integration with StreamOneInputProcessor - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/09/08 17:56:00 UTC, 0 replies.
- 确定取消 - posted by Lynn Chen <al...@163.com> on 2019/09/08 22:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14005) Support Hive version 2.2.0 - posted by "Xuefu Zhang (Jira)" <ji...@apache.org> on 2019/09/09 02:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14006) Add doc for how to using Java UDFs in Python API - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2019/09/09 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2019/09/09 03:24:00 UTC, 0 replies.
- [DISCUSS] Retrieval services in non-high-availability scenario - posted by Zili Chen <wa...@gmail.com> on 2019/09/09 07:16:07 UTC, 4 replies.
- [jira] [Created] (FLINK-14008) Flink Scala 2.12 binary distribution contains incorrect NOTICE-binary file - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/09 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14009) Cron jobs broken due to verifying incorrect NOTICE-binary file - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/09 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/09 08:15:00 UTC, 0 replies.
- Call for approving Elasticsearch 7.x connector - posted by vino yang <ya...@gmail.com> on 2019/09/09 08:38:09 UTC, 1 replies.
- [jira] [Created] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator - posted by "Alex (Jira)" <ji...@apache.org> on 2019/09/09 09:19:00 UTC, 0 replies.
- Re: [DISCUSS] StreamingFile with ParquetBulkWriter bucketing limitations - posted by Kostas Kloudas <kk...@gmail.com> on 2019/09/09 09:31:03 UTC, 1 replies.
- [jira] [Created] (FLINK-14012) Failed to start job for consuming Secure Kafka after the job cancel - posted by "Daebeom Lee (Jira)" <ji...@apache.org> on 2019/09/09 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14017) Support to start up Python worker in process mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14019) Python environment and dependency management - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14021) Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14022) Add validation check for places where Python ScalarFunction cannot be used - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14023) Support accessing job parameters in Python user-defined functions - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14024) Support use-defined metrics in Python user-defined functions - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14025) Support to run the Python worker in docker mode - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14026) Manage the resource of Python worker properly - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14027) Add documentation for Python user-defined functions - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14028) Support logging aggregation in Python user-defined functions - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/09 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14029) Update Flink's Mesos scheduling behavior to reject all expired offers - posted by "Piyush Narang (Jira)" <ji...@apache.org> on 2019/09/09 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14030) Nonequivalent conversion happens in Table planner - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/09/09 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14031) flink-examples should add blink dependency on flink-examples-table - posted by "Jimmy Wong (Jira)" <ji...@apache.org> on 2019/09/09 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/09/09 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2019/09/09 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final - posted by "Niels van Kaam (Jira)" <ji...@apache.org> on 2019/09/09 21:04:00 UTC, 0 replies.
- [DISCUSS] modular built-in functions - posted by Bowen Li <bo...@gmail.com> on 2019/09/09 23:19:41 UTC, 1 replies.
- [jira] [Created] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/09/10 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14036) function log(f0,f1) in Table API do not support decimal type - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/09/10 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14037) Deserializing the input/output formats failed: unread block data - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2019/09/10 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2019/09/10 02:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14039) Flink Kinesis consumer: configurable per-shard consumption rate when running in adaptive mode - posted by "Ying Xu (Jira)" <ji...@apache.org> on 2019/09/10 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14040) Enable a cron job to run MiniCluster tests for schedulerNG - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/10 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/10 09:43:00 UTC, 0 replies.
- How to implement grouping set in stream - posted by 刘建刚 <li...@gmail.com> on 2019/09/10 10:51:25 UTC, 1 replies.
- [jira] [Created] (FLINK-14042) Different RelDataTypes generated for same TemporalTableFunction - posted by "Yuval Itzchakov (Jira)" <ji...@apache.org> on 2019/09/10 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14043) SavepointMigrationTestBase is super slow - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/10 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14044) Reducing synchronization in AsyncWaitOperator - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2019/09/10 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14045) Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/09/10 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/09/10 15:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14047) Hide secret values when displaying user configuration/global job parameters in web UI - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/10 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2019/09/11 06:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14049) Update error message for failed partition updates to include task name - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/09/11 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14050) Refactor YarnClusterDescriptor inheritance - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/11 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14051) Deploy job cluster in attached mode - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/11 08:14:00 UTC, 0 replies.
- [DISCUSS] Drop older versions of Kafka Connectors (0.9, 0.10) for Flink 1.10 - posted by Stephan Ewen <se...@apache.org> on 2019/09/11 08:17:05 UTC, 0 replies.
- [jira] [Created] (FLINK-14052) Generalize AkkaOptions to RpcOptions - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/11 09:04:00 UTC, 0 replies.
- [ANNOUNCE] Zili Chen becomes a Flink committer - posted by Till Rohrmann <tr...@apache.org> on 2019/09/11 09:22:55 UTC, 23 replies.
- [jira] [Created] (FLINK-14053) blink planner dense_rank corner case bug - posted by "jackylau (Jira)" <ji...@apache.org> on 2019/09/11 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14054) Enable checkpointing via job configuration - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2019/09/11 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/11 18:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14056) AtOm+Electron+TypedE-Mail - posted by "KORAY DURGUT (Jira)" <ji...@apache.org> on 2019/09/11 21:19:00 UTC, 0 replies.
- Checkpoint metrics. - posted by Jamie Grier <jg...@lyft.com.INVALID> on 2019/09/11 23:17:53 UTC, 7 replies.
- [jira] [Created] (FLINK-14057) Add Remove Other Timers to TimerService - posted by "Jesse Anderson (Jira)" <ji...@apache.org> on 2019/09/12 01:09:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.8.2, release candidate #1 - posted by Jark Wu <im...@gmail.com> on 2019/09/12 02:28:32 UTC, 0 replies.
- [jira] [Created] (FLINK-14058) FLIP-53 Fine Grained Operator Resource Management - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/12 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/12 02:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14061) Introduce managed memory fractions to StreamConfig - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/12 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14062) Set managed memory fractions according to slot sharing groups - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/12 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14060) Set slot sharing groups according to pipelined regions - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/12 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/12 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14064) Support Project Push down to LookupableTableSource - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/09/12 05:23:00 UTC, 0 replies.
- Interested in contributing and looking for good first issues - posted by Anoop Hallur <an...@gmail.com> on 2019/09/12 05:23:09 UTC, 2 replies.
- [jira] [Created] (FLINK-14065) Log metric name when the metric fails on registration/unregistration - posted by "Zhilong Hong (Jira)" <ji...@apache.org> on 2019/09/12 06:38:00 UTC, 0 replies.
- Blink Planner HBaseUpsertTableSink Exception - posted by LakeShen <sh...@gmail.com> on 2019/09/12 06:39:23 UTC, 2 replies.
- [jira] [Created] (FLINK-14066) bug of building pyflink in master and 1.9.0 version - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/12 08:14:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-56: Dynamic Slot Allocation - posted by Xintong Song <to...@gmail.com> on 2019/09/12 09:03:55 UTC, 14 replies.
- [jira] [Created] (FLINK-14067) Decouple PlanExecutor from JSON plan generation - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/09/12 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14068) Use Java's Duration instead of Flink's Time - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/12 09:13:00 UTC, 0 replies.
- Re: [DISCUSS] Use Java's Duration instead of Flink's Time - posted by Zili Chen <wa...@gmail.com> on 2019/09/12 09:23:04 UTC, 1 replies.
- [jira] [Created] (FLINK-14069) Enable TimeUtils to parse all time units labels supported by scala Duration - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/12 10:33:00 UTC, 0 replies.
- [SURVEY] How many people are using customized RestartStrategy(s) - posted by Zhu Zhu <re...@gmail.com> on 2019/09/12 11:11:13 UTC, 13 replies.
- [jira] [Created] (FLINK-14070) Use TimeUtils to parse duration configs - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/12 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14071) [for Documents Improvement] Add explicit&recommend path where jars files should be put for pyflink development - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/12 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14072) Add a third-party maven repository for flink-shaded . - posted by "Jeff Yang (Jira)" <ji...@apache.org> on 2019/09/12 15:13:00 UTC, 0 replies.
- Retention policy | Memory management. - posted by srikanth flink <fl...@gmail.com> on 2019/09/13 07:43:28 UTC, 1 replies.
- [jira] [Created] (FLINK-14073) CalcITCase failed on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/13 07:55:00 UTC, 0 replies.
- Uncertain result when using group by in stream sql - posted by 刘建刚 <li...@gmail.com> on 2019/09/13 08:02:09 UTC, 1 replies.
- Flink stream python - posted by Milan Simaković <mi...@ibis-instruments.com> on 2019/09/13 08:08:14 UTC, 2 replies.
- [jira] [Created] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode. - posted by "Alexander Kasyanenko (Jira)" <ji...@apache.org> on 2019/09/13 08:47:00 UTC, 0 replies.
- How stable is FlinkSQL. - posted by srikanth flink <fl...@gmail.com> on 2019/09/13 13:24:40 UTC, 8 replies.
- [ANNOUNCE] Apache Flink 1.8.2 released - posted by Jark Wu <im...@gmail.com> on 2019/09/13 14:07:02 UTC, 3 replies.
- Re: Flink operators for Kubernetes - posted by Anand Swaminathan <as...@lyft.com.INVALID> on 2019/09/13 21:05:00 UTC, 1 replies.
- [jira] [Created] (FLINK-14075) Remove unnecessary resource close in JDBCOutputFormatTest.java - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/14 03:26:00 UTC, 0 replies.
- Use of loading flink-conf.yaml in Flink-sql client - posted by Dipanjan Mazumder <ja...@yahoo.com.INVALID> on 2019/09/14 08:33:12 UTC, 2 replies.
- [jira] [Created] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing - posted by "Jeffrey Martin (Jira)" <ji...@apache.org> on 2019/09/14 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14077) get java.util.ConcurrentModificationException when push metrics to PushGateway - posted by "zhangjun (Jira)" <ji...@apache.org> on 2019/09/15 03:38:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/37 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/09/15 11:34:22 UTC, 0 replies.
- [jira] [Created] (FLINK-14078) Introduce more JDBCDialect implementations - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/16 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14079) Full data type support in planner - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/16 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14081) Support precision of TimeType - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/16 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14080) Support precision of TimestampType - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/16 06:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14082) Support precision of DayTimeIntervalType and YearMonthIntervalType - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/16 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14083) Support StructuredType - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/16 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14084) Support ZonedTimestampType - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/16 06:18:00 UTC, 0 replies.
- Does Flink has Retention policy? - posted by srikanth flink <fl...@gmail.com> on 2019/09/16 06:49:03 UTC, 0 replies.
- [jira] [Created] (FLINK-14085) schema changes after using "create view" command via flink-table-sql-client - posted by "Junling (Jira)" <ji...@apache.org> on 2019/09/16 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14086) PrometheusReporterEndToEndITCase doesn't support ARM arch - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/09/16 08:15:00 UTC, 0 replies.
- [DISCUSS] FLIP 69 - Flink SQL DDL Enhancement - posted by Terry Wang <zj...@gmail.com> on 2019/09/16 08:46:35 UTC, 0 replies.
- [jira] [Created] (FLINK-14087) throws java.lang.ArrayIndexOutOfBoundsException when emiting the data using RebalancePartitioner. - posted by "luojiangyu (Jira)" <ji...@apache.org> on 2019/09/16 09:39:00 UTC, 0 replies.
- FLIP-24 / SQL GW - posted by Hanan Yehudai <ha...@radcom.com> on 2019/09/16 12:19:42 UTC, 1 replies.
- [jira] [Created] (FLINK-14088) Couchbase connector - sink with checkpointing support - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2019/09/16 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14089) SQL CLI doesn't support explain DMLs - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/09/16 13:12:00 UTC, 0 replies.
- Can I do a lookup in FlinkSQL? - posted by srikanth flink <fl...@gmail.com> on 2019/09/16 13:22:54 UTC, 2 replies.
- [jira] [Created] (FLINK-14090) FLIP-57 Rework FunctionCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/16 19:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14091) Job can not trigger checkpoint forever after zookeeper change leader - posted by "Peng Wang (Jira)" <ji...@apache.org> on 2019/09/17 02:01:00 UTC, 0 replies.
- Re: Add Bucket File System Table Sink - posted by Kurt Young <yk...@gmail.com> on 2019/09/17 02:57:23 UTC, 6 replies.
- [DISCUSS] FLIP-70 - Support Computed Column for Flink SQL - posted by Danny Chan <yu...@gmail.com> on 2019/09/17 03:31:33 UTC, 1 replies.
- [jira] [Created] (FLINK-14092) Upgrade Calcite version to 1.21 for Flink SQL - posted by "Danny Chan (Jira)" <ji...@apache.org> on 2019/09/17 03:45:00 UTC, 0 replies.
- 回复： Add Bucket File System Table Sink - posted by Jun Zhang <82...@qq.com> on 2019/09/17 03:45:41 UTC, 0 replies.
- [DISCUSS] FLIP-71 - E2E View support in Flink SQL - posted by Zhenghua Gao <do...@gmail.com> on 2019/09/17 03:51:39 UTC, 0 replies.
- [jira] [Created] (FLINK-14093) Java8 lambdas and exceptions lead to compile error - posted by "zzsmdfj (Jira)" <ji...@apache.org> on 2019/09/17 08:47:00 UTC, 0 replies.
- Is Idle state retention time in SQL client possible? - posted by srikanth flink <fl...@gmail.com> on 2019/09/17 09:01:37 UTC, 3 replies.
- [jira] [Created] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem - posted by "xymaqingxiang (Jira)" <ji...@apache.org> on 2019/09/17 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14095) Add Pravega in Flink ecosystem page - posted by "Yumin Zhou (Jira)" <ji...@apache.org> on 2019/09/17 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14096) Merge NewClusterClient into ClusterClient - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/17 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14097) Optimize AsyncWaitOperator to process more than one element per mailbox letter - posted by "Alex (Jira)" <ji...@apache.org> on 2019/09/17 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14098) Support multiple sql statements splitting by semicolon for TableEnvironment - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/17 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14099) SQL supports timestamp in Long - posted by "Zijie Lu (Jira)" <ji...@apache.org> on 2019/09/17 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14100) Introduce OracleDialect - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/17 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14101) Introduce SqlServerDialect - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/17 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14102) Introduce DB2Dialect - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/17 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14103) StreamTask refactoring: refine and improve exceptions passed to failExternally call - posted by "Alex (Jira)" <ji...@apache.org> on 2019/09/17 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14104) Bump Jackson to 2.9.9.3 - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/09/17 12:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-14105) Make flink-runtime scala-free - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/17 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14106) Make SlotManager pluggable - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/17 14:12:00 UTC, 0 replies.
- [VOTE] FLIP-56: Dynamic Slot Allocation - posted by Xintong Song <to...@gmail.com> on 2019/09/17 14:26:20 UTC, 11 replies.
- [jira] [Created] (FLINK-14107) Kinesis consumer record emitter may deadlock under event time alignment - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2019/09/17 17:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14108) Support for Confluent Kafka schema registry for Avro serialisation - posted by " Lasse Nedergaard (Jira)" <ji...@apache.org> on 2019/09/17 17:53:00 UTC, 0 replies.
- [DISCUSS] FLIP-68: Extend Core Table System with Modular Plugins - posted by Bowen Li <bo...@gmail.com> on 2019/09/17 18:25:01 UTC, 3 replies.
- [jira] [Created] (FLINK-14109) Improve javadocs and tests for high-availability backend - posted by "Brendan MacDonell (Jira)" <ji...@apache.org> on 2019/09/17 21:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure - posted by "Aaron Levin (Jira)" <ji...@apache.org> on 2019/09/17 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down - posted by "Aaron Levin (Jira)" <ji...@apache.org> on 2019/09/17 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart - posted by "Aaron Levin (Jira)" <ji...@apache.org> on 2019/09/17 21:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14113) Remove class JobWithJars - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/18 01:09:00 UTC, 0 replies.
- [PROPOSAL] Merge NewClusterClient into ClusterClient - posted by Zili Chen <wa...@gmail.com> on 2019/09/18 01:45:45 UTC, 7 replies.
- [VOTE] FLIP-63: Rework table partition support - posted by JingsongLee <lz...@aliyun.com.INVALID> on 2019/09/18 01:53:28 UTC, 11 replies.
- [jira] [Created] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient - posted by "TisonKun (Jira)" <ji...@apache.org> on 2019/09/18 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/18 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14116) Translate changes on Getting Started Overview to Chinese - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/18 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14117) Translate changes on documentation index page to Chinese - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/18 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/09/18 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14119) Clean idle state for RetractableTopNFunction - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/09/18 13:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/18 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14121) upgrade tocommons-compress:1.19 due to CVE - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2019/09/18 16:28:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-48: Pluggable Intermediate Result Storage - posted by Becket Qin <be...@gmail.com> on 2019/09/19 00:41:11 UTC, 2 replies.
- [jira] [Created] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2019/09/19 01:18:00 UTC, 0 replies.
- Confluence permission for FLIP creation - posted by Terry Wang <zj...@gmail.com> on 2019/09/19 02:09:29 UTC, 16 replies.
- [VOTE] FLIP-66: Support Time Attribute in SQL DDL - posted by Jark Wu <im...@gmail.com> on 2019/09/19 04:05:12 UTC, 1 replies.
- [jira] [Created] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6 - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2019/09/19 06:29:00 UTC, 0 replies.
- java8 lambdas and exceptions lead to compile error - posted by zz <zz...@gmail.com> on 2019/09/19 06:53:08 UTC, 3 replies.
- [jira] [Created] (FLINK-14124) potential memory leak in netty server - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2019/09/19 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14125) Display memory and CPU usage in the overview page - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/19 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14126) Elasticsearch Xpack Machine Learning doesn't support ARM - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/09/19 09:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14127) Better BackPressure Detection in WebUI - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/19 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14128) Remove the description of restart strategy customization - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/19 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14129) HiveTableSource should implement ProjectableTableSource - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/09/19 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14130) Remove ClusterClient.run() methods - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/09/19 15:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14131) Support choosing new version failover strategy via configuration - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/19 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14132) Extend core table system with modular plugins - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/19 21:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14133) Improve batch sql and hive integrate performance - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/20 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14134) Introduce LimitableTableSource to optimize limit - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/20 02:02:01 UTC, 0 replies.
- [jira] [Created] (FLINK-14135) Introduce vectorized orc InputFormat for blink runtime - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/20 02:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14136) Operator Topology and Metrics Inside Vertex - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14137) Show Attempt History in Vertex SubTask - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14138) Show Pending Slots in Job Detail - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14139) Fix potential memory leak of rest server when using session/standalone cluster - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/09/20 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14140) The Flink Logo Displayed in Flink Python Shell is Broken - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/09/20 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14141) Locate Jobs/SubTask/Vertex Running on TaskManager - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14142) Add more metrics to task manager list - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14143) Failed Attempt does not display in the timeline - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14144) Add Metric for job manager - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14145) getLatestCheckpoint returns wrong checkpoint - posted by "Ufuk Celebi (Jira)" <ji...@apache.org> on 2019/09/20 08:07:00 UTC, 0 replies.
- [DISCUSS] FLIP-72: Introduce Pulsar Connector - posted by Yijie Shen <he...@gmail.com> on 2019/09/20 08:16:08 UTC, 0 replies.
- [jira] [Created] (FLINK-14146) Introduce Pulsar connector - posted by "Yijie Shen (Jira)" <ji...@apache.org> on 2019/09/20 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14147) Reduce REST API Request/Response redundancy - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2019/09/20 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14148) Investigate pushing predicate/projection to underlying Hive input format - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/09/20 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14149) Introduce ZooKeeperLeaderElectionServiceNG - posted by "tison (Jira)" <ji...@apache.org> on 2019/09/20 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14150) Unnecessary __pycache__ directories appears in pyflink.zip - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/09/20 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14151) Add class for DocHashIDFVectorizerModelMapper. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/20 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14152) Add class for DocCountVectorizerMapper. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/20 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14154) Add the class for multivariate Gaussian Distribution. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/20 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14153) Add to BLAS a method that performs DenseMatrix and SparseVector multiplication. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/20 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14155) Add a wrapper class of a JSON library to provide the unified json format. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/20 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14156) Execute/run processing timer triggers taking into account operator level mailbox loops - posted by "Alex (Jira)" <ji...@apache.org> on 2019/09/20 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14157) Temporarily remove S3 StreamingFileSink end-to-end test - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/09/20 12:39:00 UTC, 0 replies.
- Re: [ANNOUNCEMENT] September 2019 Bay Area Apache Flink Meetup - posted by Xuefu Zhang <xu...@apache.org> on 2019/09/20 17:06:08 UTC, 0 replies.
- non-deserializable root cause in DeclineCheckpoint - posted by Jeffrey Martin <je...@gmail.com> on 2019/09/20 18:58:27 UTC, 6 replies.
- [FLINK-14076] non-deserializable root cause in DeclineCheckpoint - posted by Jeffrey Martin <je...@gmail.com> on 2019/09/20 19:23:27 UTC, 3 replies.
- [jira] [Created] (FLINK-14158) Update Mesos configs to add leaseOfferExpiration and declinedOfferRefuse durations - posted by "Piyush Narang (Jira)" <ji...@apache.org> on 2019/09/20 19:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right - posted by "jackylau (Jira)" <ji...@apache.org> on 2019/09/21 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14160) Extend Operations Playground with --backpressure option - posted by "David Anderson (Jira)" <ji...@apache.org> on 2019/09/21 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14161) wrong description of state - posted by "gaofeilong (Jira)" <ji...@apache.org> on 2019/09/21 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14162) Unify SchedulerOperations#allocateSlotsAndDeploy implementation for all scheduling strategies - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/22 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/22 08:50:00 UTC, 0 replies.
- Re: Best coding practises guide while programming using flink apis - posted by Terry Wang <zj...@gmail.com> on 2019/09/22 12:06:02 UTC, 0 replies.
- [DISCUSS] Add Bucket File System Connector - posted by Jun Zhang <82...@qq.com> on 2019/09/22 14:51:55 UTC, 1 replies.
- use of org.apache.flink.yarn.cli.FlinkYarnSessionCli in Flink Sql client - posted by Dipanjan Mazumder <ja...@yahoo.com.INVALID> on 2019/09/22 15:53:06 UTC, 2 replies.
- [ANNOUNCE] Weekly Community Update 2019/38 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/09/22 15:57:04 UTC, 0 replies.
- Re: How to prevent from launching 2 jobs at the same time - posted by Zili Chen <wa...@gmail.com> on 2019/09/23 03:09:42 UTC, 0 replies.
- [jira] [Created] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/23 03:19:00 UTC, 0 replies.
- Per Key Grained Watermark Support - posted by 廖嘉逸 <bu...@163.com> on 2019/09/23 04:16:12 UTC, 3 replies.
- [DISCUSS] Releasing Flink 1.9.1 - posted by Jark Wu <im...@gmail.com> on 2019/09/23 06:02:39 UTC, 25 replies.
- [jira] [Created] (FLINK-14165) HadoopRecoverableWriter do not support viewfs scheme - posted by "haoyuwen (Jira)" <ji...@apache.org> on 2019/09/23 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14166) Reuse cache from previous history server run - posted by "David Moravek (Jira)" <ji...@apache.org> on 2019/09/23 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14167) Move python-related scripts in flink-dist to flink-python - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/09/23 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14168) Remove unused BootstrapTools#generateTaskManagerConfiguration - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/23 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14169) Cleanup expired jobs from history server - posted by "David Moravek (Jira)" <ji...@apache.org> on 2019/09/23 10:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder - posted by "Bhagavan (Jira)" <ji...@apache.org> on 2019/09/23 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14171) Add 'SHOW USER FUNCTIONS' support in SQL CLI - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/23 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/09/23 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails - posted by "Benoît Paris (Jira)" <ji...@apache.org> on 2019/09/23 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2019/09/23 17:13:00 UTC, 0 replies.
- [VOTE] FLIP-68: Extend Core Table System with Modular Plugins - posted by Bowen Li <bo...@gmail.com> on 2019/09/23 17:25:25 UTC, 3 replies.
- [VOTE] FLIP-57: Rework FunctionCatalog - posted by Bowen Li <bo...@gmail.com> on 2019/09/23 18:29:32 UTC, 14 replies.
- Re: [DISCUSS] FLIP 69 - Flink SQL DDL Enhancement - posted by Bowen Li <bo...@gmail.com> on 2019/09/23 19:28:42 UTC, 3 replies.
- [jira] [Created] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM - posted by "Abhilasha Seth (Jira)" <ji...@apache.org> on 2019/09/23 22:02:00 UTC, 0 replies.
- [COMMITTER] repo locked due to synchronization issues - posted by Bowen Li <bo...@gmail.com> on 2019/09/23 22:04:13 UTC, 10 replies.
- [jira] [Created] (FLINK-14176) add taskmanager link in vertex‘s page of taskmanager - posted by "lining (Jira)" <ji...@apache.org> on 2019/09/24 01:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14177) Bump Curator to 3.5.5 - posted by "lamber-ken (Jira)" <ji...@apache.org> on 2019/09/24 01:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/09/24 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2019/09/24 03:11:00 UTC, 0 replies.
- Have trouble on running flink - posted by Russell Bie <Ru...@hotmail.com> on 2019/09/24 03:35:21 UTC, 1 replies.
- [jira] [Created] (FLINK-14180) Enable config of maximum capacity of FileArchivedExecutionGraphStore. - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/09/24 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent - posted by "jianlong miao (Jira)" <ji...@apache.org> on 2019/09/24 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14182) Make TimeUtils able to parse duration string with plural form labels - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/24 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14183) Remove unnecessary scala Duration usages in flink-runtime - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/24 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14184) Provide a stage listener API to be invoked per task manager - posted by "Stephen Connolly (Jira)" <ji...@apache.org> on 2019/09/24 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14185) AbstractServerTest failed on Travis - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/09/24 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14186) Nightly e2e-misc-jdk11 fails complaining unrecognized VM option - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/09/24 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14187) FLIP-56 Dynamic Slot Allocation - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14188) TaskExecutor derive and register with default slot resource profile - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14190) Extend SlotManager to support dynamic slot allocation on registered TaskExecutors. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14193) Update RestAPI / Web UI - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14192) Enable the dynamic slot allocation feature. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14191) Extend SlotManager to support dynamic slot allocation on pending task executors - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14194) Clean-up of legacy mode. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/09/24 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/09/24 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14196) Nightly e2e-sticky-hadoop2.8 fails due to NPE - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/09/24 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14197) Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows - posted by "Oliver Kostera (Jira)" <ji...@apache.org> on 2019/09/24 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14198) Add type options to all flink python API doc - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/09/24 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14199) Only use dedicated/named classes for mailbox letters. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2019/09/24 12:58:00 UTC, 0 replies.
- [DISCUSS] FLIP-73: Introducing Executors for job submission - posted by Kostas Kloudas <kk...@apache.org> on 2019/09/24 13:48:37 UTC, 9 replies.
- [jira] [Created] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side - posted by "Benoît Paris (Jira)" <ji...@apache.org> on 2019/09/24 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14201) SQL supports redis sink connector - posted by "Zijie Lu (Jira)" <ji...@apache.org> on 2019/09/25 05:10:00 UTC, 0 replies.
- FLINK-14108 - posted by Lasse Nedergaard <la...@gmail.com> on 2019/09/25 06:00:27 UTC, 1 replies.
- [jira] [Created] (FLINK-14202) Optimize the execution plan for Python Calc when there is a condition - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/25 07:26:00 UTC, 0 replies.
- How to corretly use checkstyle in IntelliJ IDEA - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/09/25 07:30:58 UTC, 2 replies.
- [jira] [Created] (FLINK-14203) add an abstract class for mappers with rich model. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/25 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14204) Add the model mapper for Gaussian Mixture model. - posted by "Xu Yang (Jira)" <ji...@apache.org> on 2019/09/25 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14205) Distinguish duplicate job submissions from other job submission errors - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/25 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14206) Make fullRestart metric to count fine grained restarts as well - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/25 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14207) YarnMiniCluster failed to start in YARNSessionFIFOSecuredITCase - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2019/09/25 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14208) Support Python UDF with parameters of constant values - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/25 10:10:00 UTC, 0 replies.
- [DISCUSS] Expose multiple level clients - posted by Zili Chen <wa...@gmail.com> on 2019/09/25 10:30:06 UTC, 2 replies.
- [DISCUSS] FLIP-74: Flink JobClient API - posted by Zili Chen <wa...@gmail.com> on 2019/09/25 10:31:26 UTC, 10 replies.
- [jira] [Created] (FLINK-14209) Add jackson-dataformat-xml to flink-shaded - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2019/09/25 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14210) influxdb reporter add connect timeout and write timeout config options for decrease timeout exception - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2019/09/25 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14211) Add jobManager address configuration for SqlClient - posted by "zhangwei (Jira)" <ji...@apache.org> on 2019/09/25 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14212) Support Python UDFs without arguments - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/25 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14213) Link from Flink website to Getting Started Overview page - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/25 13:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14214) Performance regression in TwoInputStreamOperator - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/09/25 15:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14215) Add Docs for TM and JM Environment Variable Setting - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2019/09/25 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14216) introduce temp system functions and APIs to FunctionCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/25 23:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14217) introduce temp functions and APIS to replace "userFunctions" in FunctionCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/25 23:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14218) support precise function reference - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/25 23:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14219) support ambiguous function reference - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/25 23:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14220) support drop and alter temp functions - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/25 23:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14221) support drop and alter temp system functions - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/25 23:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/26 01:26:00 UTC, 0 replies.
- [VOTE] FLIP-66: Support Time Attribute in SQL DDL (#2) - posted by Jark Wu <im...@gmail.com> on 2019/09/26 03:42:02 UTC, 4 replies.
- [DISCUSS] Flink Python UDF Environment and Dependency Management - posted by Wei Zhong <we...@gmail.com> on 2019/09/26 03:59:53 UTC, 2 replies.
- [jira] [Created] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/26 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/26 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14225) Travis is unable to parse of the secure environment variables - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/09/26 07:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/09/26 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14227) Add Razorpay to Chinese Powered By page - posted by "Fabian Hueske (Jira)" <ji...@apache.org> on 2019/09/26 10:06:00 UTC, 0 replies.
- A little help on (FLINK-1725) New Partitioner for better load balancing for skewed data - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/09/26 11:19:40 UTC, 0 replies.
- [jira] [Created] (FLINK-14228) The runtime support for Bounded[One|Multi]Input#endInput does not properly implement their semantics - posted by "Haibo Sun (Jira)" <ji...@apache.org> on 2019/09/26 11:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14229) Change the endinput call of the downstream operator to after the upstream operator closes - posted by "Haibo Sun (Jira)" <ji...@apache.org> on 2019/09/26 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14230) Change the endinput call of the downstream operator to after the upstream operator closes - posted by "Haibo Sun (Jira)" <ji...@apache.org> on 2019/09/26 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14231) Support the timers of the upstream operator with endInput properly - posted by "Haibo Sun (Jira)" <ji...@apache.org> on 2019/09/26 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14232) Support full restarts for DefaultScheduler (SchedulerNG) - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/26 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14233) All task state changes should be notified to SchedulingStrategy (SchedulerNG) - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/26 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14234) All partition consumable events should be notified to SchedulingStrategy (SchedulerNG) - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/26 13:02:00 UTC, 0 replies.
- Re: REST API / JarRunHandler: More flexibility for launching jobs - posted by Aljoscha Krettek <al...@apache.org> on 2019/09/26 14:15:11 UTC, 4 replies.
- [jira] [Created] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/09/26 14:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14236) Make LazyFromSourcesSchedulingStrategy do lazy scheduling only based on partition state - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/26 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14237) No need to rename shipped Flink jar - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/09/26 16:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14238) ParquetPojoInputFormat logging bug - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2019/09/26 17:06:00 UTC, 0 replies.
- [DISCUSS] Remove uncompleted YARNHighAvailabilityService - posted by Zili Chen <wa...@gmail.com> on 2019/09/27 01:23:13 UTC, 3 replies.
- [DISCUSS] FLIP-75: Flink Web UI Improvement Proposal - posted by Yadong Xie <vt...@gmail.com> on 2019/09/27 02:13:37 UTC, 7 replies.
- [jira] [Created] (FLINK-14239) Emitting the max watermark in StreamSource#run may cause it to arrive the downstream early - posted by "Haibo Sun (Jira)" <ji...@apache.org> on 2019/09/27 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14240) The configuration added via TableConfig#configuration should be added to GlobalJobParameters for the legacy planner - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/27 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14241) Add ARM installation step for flink e2e container test - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/09/27 03:52:00 UTC, 0 replies.
- Re: 订阅邮件 - posted by Dian Fu <di...@gmail.com> on 2019/09/27 05:14:53 UTC, 0 replies.
- [jira] [Created] (FLINK-14242) Collapse task names in job graph visualization if too long - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2019/09/27 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14243) flink hiveudf need some check whether it is using cache - posted by "jackylau (Jira)" <ji...@apache.org> on 2019/09/27 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14244) Use correct RestartBackoffTimetrategy in new DefaultScheduler - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/09/27 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14245) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/27 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/27 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14247) Use NoResourceAvailableException to wrap TimeoutException on slot allocation (Scheduler NG) - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/27 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14248) LazyFromSourcesSchedulingStrategy should support to tasks in terminal state - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/27 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14249) Rework table partition support - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14250) Introduce separate "bin/flink runpy" and remove python support from "bin/flink run" - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/09/27 13:06:00 UTC, 0 replies.
- [ANNOUNCE] Progress of Apache Flink 1.10 #1 - posted by Yu Li <ca...@gmail.com> on 2019/09/27 13:53:39 UTC, 0 replies.
- [jira] [Created] (FLINK-14251) Add FutureUtils#forward utility - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/27 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14252) Encapsulate Dispatcher services in DispatcherServices container - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/27 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14253) Add hash distribution and sort grouping only when dynamic partition insert - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14254) Introduce FileSystemOutputFormat - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 14:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14255) Introduce StreamingFileSystemSink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14256) Introduce FileSystemTableFactory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14257) Integrate csv to FileSystemTableFactory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14258) Integrate hive to FileSystemTableFactory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/27 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14259) Extract JobManagerRunner interface for improved testability - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/27 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14260) Remove Mockito usage from TestingJobManagerRunnerFactory - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/27 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14261) Add support for permanently fenced RpcEndpoints - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/27 15:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14262) support referencing function with fully/partially qualified names in SQL - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/27 18:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14263) Extract static method from ClusterClient to ClientUtils - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/09/28 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/09/28 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14265) Don't use ContinuousFileReaderOperator to support multiple paths - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/28 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14267) Introduce RowCsvOutputFormat to new CSV module - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/28 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/09/28 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14268) YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint - posted by "Lsw_aka_laplace (Jira)" <ji...@apache.org> on 2019/09/29 04:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14269) The close method does not work for UserDefinedFunction - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/29 07:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14270) new web ui should display more than 4 metrics - posted by "David Anderson (Jira)" <ji...@apache.org> on 2019/09/29 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14271) Deprecate legacy RestartPipelinedRegionStrategy - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/09/29 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14272) Support Blink planner for Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/09/29 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/09/29 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14274) RuntimeContext can be get from FunctionContext - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/09/29 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14275) Window Aggregate function support a RichFunction - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/09/29 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14276) Quickstarts Scala nightly end-to-end test fails on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 09:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14277) Replace InMemoryJobGraphStore with proper TestingJobGraphStore implementation - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14278) Pass in ioExecutor into AbstractDispatcherResourceManagerComponentFactory - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14279) The Table API code walkthrough should be translated into chinese. - posted by "gaofeilong (Jira)" <ji...@apache.org> on 2019/09/29 14:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-14280) Introduce DispatcherRunner for better separation of concerns - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 14:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14281) Introduce DispatcherRunner#getShutDownFuture - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14282) Simplify DispatcherResourceManagerComponent - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14283) Update Kinesis consumer documentation for watermarks and event time alignment - posted by "Thomas Weise (Jira)" <ji...@apache.org> on 2019/09/29 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14284) Add shut down future to Dispatcher - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14285) Simplify Dispatcher factories by removing generics - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14286) Remove Akka specific parsing logic from LeaderConnectionInfo - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14287) Decouple leader address from LeaderContender - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/29 17:14:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/39 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/09/29 19:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-14288) Add Py4j NOTICE for source release - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2019/09/30 01:16:00 UTC, 0 replies.
- Re: [DISCUSS] Best practice to run flink on kubernetes - posted by Yang Wang <da...@gmail.com> on 2019/09/30 03:13:22 UTC, 0 replies.
- [jira] [Created] (FLINK-14289) Remove Optional fields from RecordWriter relevant classes - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/09/30 03:15:00 UTC, 0 replies.
- [VOTE] Release 1.9.1, release candidate #1 - posted by Jark Wu <im...@gmail.com> on 2019/09/30 07:25:06 UTC, 0 replies.
- [jira] [Created] (FLINK-14290) Decouple plan translation from job execution/ClusterClient - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/09/30 07:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14291) Add unit tests for DefaultScheduler to test concurrent failover behavior - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/09/30 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14292) Provide terasort examples - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2019/09/30 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14293) Lazy execution of queries might produce wrong results - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/09/30 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14294) Nightly flink-quickstart-scala end-to-end test failed due to missing javax.tools.ToolProvider - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/09/30 12:25:00 UTC, 0 replies.
- [DISCUSS] FLIP-76: Unaligned checkpoints - posted by Arvid Heise <ar...@ververica.com> on 2019/09/30 12:31:01 UTC, 0 replies.
- [jira] [Created] (FLINK-14295) Nightly flink-runtime failed with java 11 - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/09/30 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14296) SqlNodes in the parser module should use an Optional for optional parameters - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/09/30 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key - posted by "Benoît Paris (Jira)" <ji...@apache.org> on 2019/09/30 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14298) Change LeaderContender#getAddress into LeaderContender#getDescription - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/30 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14299) Factor status and system metrics out of JobManagerMetricGroup - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/09/30 16:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14300) org.apache.flink.streaming.runtime.tasks.StreamTask#invoke leaks threads if org.apache.flink.streaming.runtime.tasks.OperatorChain fails to be constructed - posted by "Marcos Klein (Jira)" <ji...@apache.org> on 2019/09/30 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14301) add documentation for temp and temp system functions and new function resolution order - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/09/30 21:57:00 UTC, 0 replies.