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

---

- [jira] [Created] (FLINK-14997) Avoid to call unnecessary delete within RocksDBState's mergeNamespaces implementation - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/12/01 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-14998) Remove FileUtils#deletePathIfEmpty - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/12/01 16:31:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/48 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/12/01 16:47:01 UTC, 0 replies.
- Re: [VOTE] Setup a security@flink.apache.org mailing list - posted by Becket Qin <be...@gmail.com> on 2019/12/02 01:28:28 UTC, 5 replies.
- [jira] [Created] (FLINK-14999) sub-plan reuse should consider - posted by "godfrey he (Jira)" <ji...@apache.org> on 2019/12/02 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15000) Metrics is very slow when parallelism is over 1000 - posted by "fa zheng (Jira)" <ji...@apache.org> on 2019/12/02 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15001) The digest of sub-plan reuse should contain RelNode's trait - posted by "godfrey he (Jira)" <ji...@apache.org> on 2019/12/02 02:56:00 UTC, 0 replies.
- Re: [DISCUSS] Disable conversion between TIMESTAMP and Long in parameters and results of UDXs - posted by Zhenghua Gao <do...@gmail.com> on 2019/12/02 03:01:11 UTC, 0 replies.
- [jira] [Created] (FLINK-15002) Add catalog API to get partition by filter - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/02 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15003) Use embedded mode to improve hive test performance - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/02 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15004) Choose SortMergeJoin instead of HashJoin if the statistics is unknown - posted by "godfrey he (Jira)" <ji...@apache.org> on 2019/12/02 03:29:00 UTC, 0 replies.
- Re: Re: [DISCUSS] Support JSON functions in Flink SQL - posted by Jingsong Li <ji...@gmail.com> on 2019/12/02 03:40:32 UTC, 6 replies.
- [jira] [Created] (FLINK-15005) Change CatalogTableStats.UNKNOW and HiveStatsUtil stats default value - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/02 03:51:00 UTC, 0 replies.
- Re: [VOTE] Release 1.8.3, release candidate #1 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/02 06:12:54 UTC, 0 replies.
- "Fundamentals of Apache Flink" guide for Apache Flink - posted by Deeksha Thakkar <de...@packt.com.INVALID> on 2019/12/02 06:13:37 UTC, 0 replies.
- [VOTE] FLIP-88: PyFlink User-Defined Function Resource Management - posted by Dian Fu <di...@gmail.com> on 2019/12/02 06:34:25 UTC, 7 replies.
- [DISCUSS] Improve the Pyflink command line options (Adjustment to FLIP-78) - posted by Wei Zhong <we...@gmail.com> on 2019/12/02 07:26:13 UTC, 9 replies.
- Re: [DISCUSS] PyFlink User-Defined Function Resource Management - posted by Jingsong Lee <lz...@apache.org> on 2019/12/02 07:47:01 UTC, 5 replies.
- [jira] [Created] (FLINK-15006) Add option to close shuffle when dynamic partition inserting - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/02 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15007) Flink on YARN does not request required TaskExecutors in some cases - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/02 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15008) Tests in flink-yarn-tests fail with ClassNotFoundException (JDK11) - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/02 10:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15009) Add a utility for creating type inference logic via reflection - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2019/12/02 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15010) Temp directories flink-netty-shuffle-* are not cleaned up - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/12/02 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15011) RocksDB temp directory not cleaned up - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/12/02 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15012) Checkpoint directory not cleaned up - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/12/02 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15013) Flink (on YARN) sometimes needs too many slots - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/02 13:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15014) Refactor KeyedStateInputFormat to support multiple types of user functions - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2019/12/02 14:39:00 UTC, 0 replies.
- [DISCUSS] Drop vendor specific deployment documentation. - posted by Seth Wiesman <sj...@gmail.com> on 2019/12/02 17:34:33 UTC, 16 replies.
- [jira] [Created] (FLINK-15015) add documentation for using orc reader in hive connector - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/02 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15016) Remove unused dependency - posted by "César Soto Valero (Jira)" <ji...@apache.org> on 2019/12/02 20:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15017) add a thrift jdbc/odbc server for Flink - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/02 20:41:00 UTC, 2 replies.
- [jira] [Created] (FLINK-15018) Add event time page to Concepts - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2019/12/02 20:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15019) publish blog and document Flink-Hive benchmark v.s. Hive on MR/Tez - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/02 20:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15020) Support timestamp type in hive - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/03 02:23:00 UTC, 0 replies.
- [VOTE] Release 1.8.3, release candidate #2 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/03 02:29:05 UTC, 4 replies.
- [jira] [Created] (FLINK-15021) Refactor to remove channelWritabilityChanged from PartitionRequestQueue - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/03 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15022) E2E View support in FLINK SQL - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/03 03:17:00 UTC, 0 replies.
- Re: [DISCUSS] Make Managed Memory always off-heap (Adjustment to FLIP-49) - posted by Xintong Song <to...@gmail.com> on 2019/12/03 03:21:33 UTC, 0 replies.
- [jira] [Created] (FLINK-15023) Remove on-heap managed memory - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/03 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15024) System classloader memory leak after loading too many codegen classes. - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/12/03 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15025) The license and notice is not correct for the flink-python module - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/03 05:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15026) Support database DDLs in SQL CLI - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/03 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15027) Support alter table DDLs in SQL CLI - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/03 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15028) YARNSessionFIFOSecuredITCase test failed with java11 on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/03 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15029) Dependency shading of table modules test failed on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/03 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15030) Potential deadlock for bounded blocking ResultPartition. - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/12/03 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15031) Calculate required shuffle memory cases before allocating slots in resources specified - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/12/03 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15032) Remove the eagerly serialization from `RemoteRpcInvocation` - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2019/12/03 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15033) Remove unused RemoteEnvirnment.executeRemotely() (FLINK-11048) - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/03 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15034) Bump FRocksDB version for memory control - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/12/03 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15035) Introduce unknown memory setting to table in blink planner - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/03 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15036) Container startup error will be handled out side of the YarnResourceManager's main thread - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/12/03 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15037) Introduce LimittingMemoryManager as operator scope MemoyManager - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/12/03 11:06:00 UTC, 0 replies.
- [DISCUSS] Drop RequiredParameters and OptionType - posted by Stephan Ewen <se...@apache.org> on 2019/12/03 11:30:42 UTC, 3 replies.
- [jira] [Created] (FLINK-15038) Get field DataType of TableSchema should return DataType with default conversion class - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/03 12:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15039) Remove default close() implementation from ClusterClient - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/03 13:18:00 UTC, 0 replies.
- Re: [DISCUSS] Stateful Functions - Contribution Details - posted by Robert Metzger <rm...@apache.org> on 2019/12/03 13:31:34 UTC, 1 replies.
- [jira] [Created] (FLINK-15040) Open function is not called in UDF AggregateFunction - posted by "LI Guobao (Jira)" <ji...@apache.org> on 2019/12/03 13:39:00 UTC, 0 replies.
- [DISCUSS] Voting from apache.org addresses - posted by Dawid Wysakowicz <dw...@apache.org> on 2019/12/03 14:15:45 UTC, 13 replies.
- [jira] [Created] (FLINK-15041) Remove default close() implementation from JobClient - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/03 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15042) Fix python compatibility by excluding the Env.executeAsync() (FLINK-14854) - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/03 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15043) Possible thread leak in task manager - posted by "Jordan Hatcher (Jira)" <ji...@apache.org> on 2019/12/03 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15044) Clean up TpcdsResultComparator - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/03 20:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15045) SchedulerBase should only log the RestartStrategy in legacy scheduling mode - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/03 21:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15046) Add guideline on how to report security issues - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/04 03:09:00 UTC, 0 replies.
- I love Flink - posted by 博奇 <zh...@dingtalk.com.INVALID> on 2019/12/04 03:18:01 UTC, 2 replies.
- Re: [DISCUSS] Expose or setup a security@flink.apache.org mailing list for security report and discussion - posted by Dian Fu <di...@gmail.com> on 2019/12/04 03:45:24 UTC, 1 replies.
- Re: [DISCUSS] FLIP-72: Introduce Pulsar Connector - posted by Becket Qin <be...@gmail.com> on 2019/12/04 04:12:29 UTC, 4 replies.
- [jira] [Created] (FLINK-15047) YarnDistributedCacheITCase is unstable - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/04 05:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15048) Properly set internal.jobgraph-path when deploy job cluster - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/04 06:20:00 UTC, 0 replies.
- Re: Building with Hadoop 3 - posted by vino yang <ya...@gmail.com> on 2019/12/04 06:21:25 UTC, 3 replies.
- Re: [DISCUSS] FLIP-27: Refactor Source Interface - posted by Becket Qin <be...@gmail.com> on 2019/12/04 06:38:36 UTC, 28 replies.
- [jira] [Created] (FLINK-15049) Compile bug when hash join with timestamp type key - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/04 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15050) DataFormatConverters will fail when timestamp type precision more than 3 - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/04 07:50:00 UTC, 0 replies.
- Re: [DISCUSS] Add N-Ary Stream Operator - posted by Piotr Nowojski <pi...@ververica.com> on 2019/12/04 09:24:46 UTC, 7 replies.
- [DISCUSS] Migrate build infrastructure from Travis CI to Azure Pipelines - posted by Robert Metzger <rm...@apache.org> on 2019/12/04 10:36:15 UTC, 16 replies.
- [jira] [Created] (FLINK-15051) Typo in RocksDBStateBackend getNumberOfTransferingThread - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/04 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15052) sql client doesn't clear previous job graph - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/04 12:16:00 UTC, 0 replies.
- [DISCUSS] Drop Kafka 0.8/0.9 - posted by Chesnay Schepler <ch...@apache.org> on 2019/12/04 12:57:01 UTC, 13 replies.
- [jira] [Created] (FLINK-15053) Configurations with values contains space may cause TM failures on Yarn - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/04 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15054) Add FAQ section to IntelliJ setup - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/12/04 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15055) YarnDistributedCacheITCase does not generate logs. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/04 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15056) Python test: ExecutionEnvironmentCompletenessTests.test_completeness failed - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2019/12/04 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15057) Set taskmanager.memory.total-process.size in jepsen tests - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/04 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15058) Log required config keys if TaskManager memory configuration is invalid - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/04 17:19:00 UTC, 0 replies.
- Re: Checkpointing under backpressure - posted by Thomas Weise <th...@apache.org> on 2019/12/04 20:06:50 UTC, 0 replies.
- [jira] [Created] (FLINK-15059) DataTypeExtractorTest fails on travis - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/12/04 22:26:00 UTC, 0 replies.
- [VOTE] FLIP-27 - Refactor Source Interface - posted by Becket Qin <be...@gmail.com> on 2019/12/05 00:05:10 UTC, 1 replies.
- Re: [DISCUSS] Multi-topics consuming from KafkaTableSource - posted by leo <le...@qq.com> on 2019/12/05 01:00:19 UTC, 0 replies.
- [VOTE] Multi-topics consuming from KafkaTableSource - posted by leo <le...@qq.com> on 2019/12/05 01:07:22 UTC, 2 replies.
- [jira] [Created] (FLINK-15060) Add aarch64 support for tpcds e2e test - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/12/05 01:53:00 UTC, 0 replies.
- [VOTE] Improve the Pyflink command line options (Adjustment to FLIP-78) - posted by Wei Zhong <we...@gmail.com> on 2019/12/05 02:44:53 UTC, 6 replies.
- [jira] [Created] (FLINK-15061) create/alter table/databases properties should be case sensitive stored in catalog - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/05 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15062) Orc reader should use java.sql.Timestamp to read for respecting time zone - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/05 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15063) input group and output group of the task metric are reversed - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/05 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15064) Remove XmlOutput util class in blink planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/05 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15065) RocksDB configurable options doc description error - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2019/12/05 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15066) Cannot run multiple `insert into csvTable values ()` - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/05 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15067) Pass execution configuration from TableEnvironment to StreamExecutionEnvironment - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/12/05 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15068) Disable RocksDB's local LOG by default - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/12/05 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15069) Supplement the compression case for benchmark - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/05 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15070) Supplement the case of bounded blocking partition for benchmark - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/05 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15071) YARN vcore capacity check can not pass when use large slotPerTaskManager - posted by "huweihua (Jira)" <ji...@apache.org> on 2019/12/05 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15072) Hijack executeAsync instead of execute in context environment - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/05 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15073) sql client fails to run same query multiple times - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/05 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15074) Connection timed out, Standalone - posted by "gameking (Jira)" <ji...@apache.org> on 2019/12/05 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15075) Can not run "create table" in IT Case with expressions in TableSchema because the copied ParameterScope can not been seen - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/05 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15076) Source thread should be interrupted during the Task cancellation - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/12/05 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15077) Support Semi/Anti LookupJoin in Blink planner - posted by "Jing Zhang (Jira)" <ji...@apache.org> on 2019/12/05 11:42:00 UTC, 0 replies.
- [DISCUSS] Drop Heap Backend Synchronous snapshots - posted by Stephan Ewen <se...@apache.org> on 2019/12/05 12:06:25 UTC, 4 replies.
- [jira] [Created] (FLINK-15078) Report Python version exceptions in time - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2019/12/05 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15079) BashJavaUtilsTest fails when running in a clean directory - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/12/05 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15080) Deploy OSS filesystem to maven central - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/12/05 13:11:00 UTC, 0 replies.
- [VOTE] Release 1.8.3, release candidate #3 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/05 13:38:42 UTC, 10 replies.
- [jira] [Created] (FLINK-15081) Translate "Concepts & Common API" page of Table API into Chinese - posted by "Steve OU (Jira)" <ji...@apache.org> on 2019/12/05 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15082) Mesos App Master does not respect taskmanager.memory.total-process.size - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/05 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15083) Fix connectors only pick physical fields from TableSchema - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/05 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15084) Let MemoryManager allocate and track shared memory resources - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/05 16:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15085) History server overview page fails loading because of web-submit feature not in the config - posted by "chaganti spurthi (Jira)" <ji...@apache.org> on 2019/12/05 20:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15086) JobCluster may not be shutdown if executeAsync called - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/06 01:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15087) JobManager is forced to shutdown JVM due to temporary loss of zookeeper connection - posted by "Abdul Qadeer (Jira)" <ji...@apache.org> on 2019/12/06 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15088) "misc" build fail on travis-ci - posted by "Dezhi Cai (Jira)" <ji...@apache.org> on 2019/12/06 05:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15089) Pulsar Catalog - posted by "Yijie Shen (Jira)" <ji...@apache.org> on 2019/12/06 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15090) Reverse the dependency from flink-streaming-java to flink-client - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/06 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15091) JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/06 07:04:00 UTC, 0 replies.
- [RESULT] [VOTE] FLIP-88: PyFlink User-Defined Function Resource Management - posted by Dian Fu <di...@gmail.com> on 2019/12/06 07:04:34 UTC, 0 replies.
- [jira] [Created] (FLINK-15092) Using sql-client excute sql(select sum(cast(null as int)) from t123;) has a TableException - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/06 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15093) FLINK-13708 still exist in StreamExecutionEnvironment - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/12/06 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15094) Warning about using private constructor of java.nio.DirectByteBuffer in Java 11 - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2019/12/06 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15095) bridge table schema's primary key to metadata handler in blink planner - posted by "godfrey he (Jira)" <ji...@apache.org> on 2019/12/06 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15096) Do not use GlobalJobParameters to pass system configuration - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/12/06 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15097) flink can not use user specified hdfs conf - posted by "qian wang (Jira)" <ji...@apache.org> on 2019/12/06 09:26:00 UTC, 0 replies.
- [DISCUSS] Adding e2e tests for Flink's Mesos integration - posted by Yangze Guo <ka...@gmail.com> on 2019/12/06 10:05:14 UTC, 10 replies.
- [jira] [Created] (FLINK-15098) CsvTableSink has no properties of a OVERWRITE mode to write, but the exception hint the user use it when a file or directory already exists - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/06 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15099) Implement OperatorEvent passing RPC. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2019/12/06 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15100) Add the interface and base implementation for SourceReader. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2019/12/06 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15101) Add the interface for SpiltEnumerator and implementation for SourceCoordinator - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2019/12/06 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15102) Allow users to construct a DataStream from a new Source API - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2019/12/06 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/12/06 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15104) Performance regression on 4.12.2019 in RocksDB benchmarks - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/12/06 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/06 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15106) Hive 3.x tests leave metastore_db folder under build directory - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/06 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15107) SQL-CLI can not execute insert into statement with lowercase "INSERT INTO" keyword - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/06 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15109) InternalTimerServiceImpl references restored state after use, taking up resources unnecessarily - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2019/12/06 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15108) SQL-CLI can not execute same query multiple times - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/06 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15110) Support exclusions for variables - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/12/06 14:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15111) java.lang.RuntimeException for KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPartitionDiscoverer.java:80) when using SASL_SSL - posted by "Hunter Kempf (Jira)" <ji...@apache.org> on 2019/12/06 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15112) NPE when trying to join on two temporal tables in a single query - posted by "Chris Miller (Jira)" <ji...@apache.org> on 2019/12/06 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15113) fs.azure.account.key not hidden from global configuration - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/12/06 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15114) Add execute result info for alter/create/drop database in sql client. - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/06 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15115) Drop Kafka 0.8/0.9 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/12/06 17:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15116) Make JobClient stateless, remove AutoCloseable - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/06 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15117) JoinITCase.testFullJoinWithLeftLocalPred fails - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/06 18:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15118) Make flink-scala-shell use Executors - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/06 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15119) Remove PlanExecutor and its subclasses - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/06 18:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15120) Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/06 18:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15121) Add public constructor/getter for execution environments that takes Configuration - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/06 22:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15122) Reusing record object in StreamTaskNetworkInput - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/07 10:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner - posted by "godfrey he (Jira)" <ji...@apache.org> on 2019/12/07 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15124) types with precision can't be executed in sql client with blink planner - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/08 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15125) PROCTIME() computed column defined in CREATE TABLE doesn't work - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/08 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15126) migrate "show functions" from sql cli to sql parser - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/08 05:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15127) rename CreateFunctionOperation, DropFunctionOperation, AlterFunctionOperation to CreateCatalogFunctionOperation, DropCatalogFunctionOperation, AlterCatalogFunctionOperation - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/08 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15128) Document support for Hive timestamp type - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/08 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15129) Return JobClient instead of JobClient Future from executeAsync() - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/08 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15130) Drop "RequiredParameters" and "Options" - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/08 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15131) Add Source API classes - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2019/12/08 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15132) Checkpoint Coordinator does Checkpoint I/O in JobMaster Main Thread - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/08 15:23:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/49 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/12/08 17:37:31 UTC, 0 replies.
- [jira] [Created] (FLINK-15133) support sql_alchemy in Flink for broader python sql integration - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/08 23:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-15134) Delete temporary files created in YarnClusterDescriptor - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/09 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15135) Adding e2e tests for Flink's Mesos integration - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/09 02:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15136) Update the Chinese version of "Working with state" - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/12/09 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15137) Improve schema derivation for Avro format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/09 02:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15138) Add e2e Test for PyFlink - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2019/12/09 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)' - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/12/09 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15140) Shuffle data compression does not work with BroadcastRecordWriter. - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/12/09 05:18:00 UTC, 0 replies.
- Reminder: Clean up 1.10.0 open issues - posted by Yu Li <ca...@gmail.com> on 2019/12/09 06:13:09 UTC, 0 replies.
- [jira] [Created] (FLINK-15141) Using decimal type in a sink table, the result returns a not match ValidationException - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/09 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15142) Extend Redis Sink Connector to Redis Streams - posted by "Guy Korland (Jira)" <ji...@apache.org> on 2019/12/09 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15143) Create document for FLIP-49 TM memory model and configuration guide - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/09 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15144) Document performance related changes caused by FLIP-49 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/12/09 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15145) Tune default values for FLIP-49 TM memory configurations with real production jobs. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/09 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15146) The value of `cleanupSize` should be grater than 0 for `IncrementalCleanupStrategy` - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2019/12/09 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15147) Add doc for alter table set properties and rename table - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/09 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15148) Add doc for create/drop/alter database ddl - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/09 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15149) Merge InputTypeStrategy and InputTypeValidator - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2019/12/09 09:30:00 UTC, 0 replies.
- [NOTICE] CiBot/Travis/Azure - posted by Chesnay Schepler <ch...@apache.org> on 2019/12/09 09:40:22 UTC, 0 replies.
- [jira] [Created] (FLINK-15150) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/12/09 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15151) Use new type system in TableSourceUtil.computeIndexMapping of blink planner - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2019/12/09 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning - posted by "Feng Jiajie (Jira)" <ji...@apache.org> on 2019/12/09 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15153) Service selector needs to contain jobmanager component label - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/12/09 11:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-15154) Change Flink binding addresses in local mode - posted by "Andrea Cardaci (Jira)" <ji...@apache.org> on 2019/12/09 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15155) Join with a LookupableTableSource: the defined order lookup keys are inconsistent - posted by "Rockey Cui (Jira)" <ji...@apache.org> on 2019/12/09 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15156) Warn user if System.exit() is called in user code - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2019/12/09 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15157) Make ScalaShell ensureYarnConfig() and fetchConnectionInfo() public - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/09 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15158) Why convert integer to bigdecimal for formart-json when kafka is used - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2019/12/09 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15159) the string of json is mapped to VARCHAR or STRING? - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2019/12/09 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15160) Clean up is not applied if there are no incoming events for a key. - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/12/09 13:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15161) Introduce TypeTransformation interface and basic transformations - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/09 15:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15162) Merge Java and Scala ClosureCleaner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2019/12/09 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15163) japicmp should use 1.9 as the old version - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/09 16:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15164) Introduce ParquetColumnarRowSplitReader to parquet format - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2019/12/09 17:06:00 UTC, 0 replies.
- Re: [ANNOUNCE] Feature freeze for Apache Flink 1.10.0 release - posted by Gary Yao <ga...@ververica.com> on 2019/12/09 17:28:59 UTC, 5 replies.
- [DISCUSS] Flink Docs Style Guide Review - posted by Seth Wiesman <sj...@gmail.com> on 2019/12/09 17:40:50 UTC, 1 replies.
- [DISCUSS] FLIP-85: Delayed Job Graph Generation - posted by Peter Huang <hu...@gmail.com> on 2019/12/09 18:36:46 UTC, 18 replies.
- [jira] [Created] (FLINK-15165) Flink Hive Upsert Support - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2019/12/09 19:28:00 UTC, 0 replies.
- [RESULT][VOTE] Improve the Pyflink command line options (Adjustment to FLIP-78) - posted by Wei Zhong <we...@gmail.com> on 2019/12/10 03:04:29 UTC, 0 replies.
- [jira] [Created] (FLINK-15166) Shuffle data compression wrongly decrease the buffer reference count. - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2019/12/10 04:12:00 UTC, 0 replies.
- Re: SQL for Avro GenericRecords on Parquet - posted by Peter Huang <hu...@gmail.com> on 2019/12/10 05:26:00 UTC, 0 replies.
- Flink SQL Kafka topic DDL ,the kafka' json field conflict with flink SQL Keywords - posted by LakeShen <sh...@gmail.com> on 2019/12/10 06:05:50 UTC, 0 replies.
- 回复：Flink SQL Kafka topic DDL ,the kafka' json field conflict with flinkSQL Keywords - posted by "lucas.wu" <lu...@xiaoying.com> on 2019/12/10 06:12:24 UTC, 0 replies.
- Re: Flink SQL Kafka topic DDL ,the kafka' json field conflict with flinkSQL Keywords - posted by LakeShen <sh...@gmail.com> on 2019/12/10 06:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-15167) SQL CLI library option doesn't work for Hive connector - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/10 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2019/12/10 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/12/10 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15170) WebFrontendITCase.testCancelYarn fails on travis - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2019/12/10 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15171) Performance regression in serialisation benchmarks - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/12/10 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15172) optimize the operator algorithm to lazily allocate memory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/10 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15173) perjob on yarn appcluster shutdown depend on CliFrontend - posted by "xiaodao (Jira)" <ji...@apache.org> on 2019/12/10 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15174) FLINK security using PKI mutual auth needs certificate pinning or Private CA - posted by "Bhagavan (Jira)" <ji...@apache.org> on 2019/12/10 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15175) syntax not supported in SQLClient for TPCDS queries - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2019/12/10 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15176) Add '--job-classname' to flink-container 'job-cluster-job.yaml.template' - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2019/12/10 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15177) Migrate RocksDB Configurable Options to new type safe config options - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/10 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15178) Task crash due to mmap allocation failure for BLOCKING shuffle - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/12/10 12:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15179) Kubernetes should not have a CustomCommandLine. - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/10 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15180) Docs say to use Kinesis profile which no longer exists - posted by "Patrick Fletcher (Jira)" <ji...@apache.org> on 2019/12/10 19:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15181) Minor doc correction - posted by "Mans Singh (Jira)" <ji...@apache.org> on 2019/12/10 22:35:00 UTC, 0 replies.
- [DISCUSS] Register user jar files in {Stream}ExecutionEnvironment - posted by 50man <co...@onlyapp.cn> on 2019/12/11 01:16:51 UTC, 2 replies.
- [jira] [Created] (FLINK-15182) Add FileTableSink based on StreamingFileSink - posted by "ShenDa (Jira)" <ji...@apache.org> on 2019/12/11 02:22:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.8.3, release candidate #3 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/11 02:29:32 UTC, 5 replies.
- [jira] [Created] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/11 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15184) write guest post for Flink-Hive integration for AWS and Cloudera - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 03:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15185) Hive sink can not run in standalone mode - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/11 03:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15186) Column names and nullability mismatch when querying CatalogViews - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/11 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15187) Reuse LocalBufferPool for FileBufferReader in blocking partition - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/11 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15188) add builder for catalog objects - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15189) add documentation for catalog view and hive view - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15190) add documentation for DDL in FLIP-69 - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 06:35:00 UTC, 0 replies.
- Re: [DISCUSS] Support configure remote flink user jar In k8s per-job mode - posted by Yang Wang <da...@gmail.com> on 2019/12/11 06:49:53 UTC, 0 replies.
- [jira] [Created] (FLINK-15191) Fix can't create table source for Kafka if watermark or computed column is defined - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/11 06:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15193) Move DDL to first tab in table connector page - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/11 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15194) Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/12/11 08:41:00 UTC, 0 replies.
- [DISCUSS] Overwrite and partition inserting support in 1.10 - posted by Jingsong Li <ji...@gmail.com> on 2019/12/11 09:29:10 UTC, 15 replies.
- [jira] [Created] (FLINK-15195) Remove unu - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/11 11:00:00 UTC, 0 replies.
- Re: Open Method is not being called in case of AggregateFunction UDFs - posted by Timo Walther <tw...@apache.org> on 2019/12/11 11:01:06 UTC, 0 replies.
- [jira] [Created] (FLINK-15196) The mesos.resourcemanager.tasks.cpus configuration does not work as expectation - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/11 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15197) Add resource related config options to dynamical properties for Kubernetes - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/12/11 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15198) Remove deprecated mesos.resourcemanager.tasks.mem in 1.11 - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2019/12/11 12:55:00 UTC, 0 replies.
- [DISCUSS] Need feedback on Azure-based build system - posted by Robert Metzger <rm...@apache.org> on 2019/12/11 13:32:12 UTC, 7 replies.
- [jira] [Created] (FLINK-15199) Benchmarks are not compiling - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2019/12/11 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15200) legacy planner cannot deal Type with precision like DataTypes.TIMESTAMP(3) in TableSourceUtil - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/11 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15201) Remove verifications in detach execution - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/11 16:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15202) Increment metric when Interval Join record is late - posted by "Chris Gillespie (Jira)" <ji...@apache.org> on 2019/12/11 17:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15203) rephrase Hive's data types doc - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 20:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15204) add documentation for Flink-Hive timestamp conversions in table and udf - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 20:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15205) add doc and exmaple of INSERT OVERWRITE and insert into partitioned table for Hive connector - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/11 20:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15206) support dynamic catalog table for unified SQL job - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/12 00:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15207) japicmp reference version is stale - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/12 00:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15208) support client to submit both an online streaming job and an offline batch job based on dynamic catalog table - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/12 01:02:45 UTC, 0 replies.
- [jira] [Created] (FLINK-15209) DDL with computed column didn't work for some of the connectors - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/12 01:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15210) Move java files in flink-sql-parser module package org.apache.calcite.sql to org.apache.flink.sql.parser.type - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/12 02:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15211) Web UI request url for watermark is too long in large parallelism - posted by "fa zheng (Jira)" <ji...@apache.org> on 2019/12/12 02:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15212) PROCTIME attribute causes problems with timestamp times before 1900 ? - posted by "Rockey Cui (Jira)" <ji...@apache.org> on 2019/12/12 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15213) The conversion between java.sql.Timestamp and long is not asymmetric - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2019/12/12 06:17:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.8.3 released - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/12 06:24:58 UTC, 8 replies.
- [jira] [Created] (FLINK-15214) Adding multiple submission e2e test for Flink's Mesos integration - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/12 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15215) Not able to provide a custom AWS credentials provider with flink-s3-fs-hadoop - posted by "Arjun Prakash (Jira)" <ji...@apache.org> on 2019/12/12 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15216) Can't use rocksdb with hdfs filesystem with flink-s3-fs-hadoop - posted by "Tank (Jira)" <ji...@apache.org> on 2019/12/12 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15217) 'java.time.LocalDate' should support for the CSV input format. - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/12 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15218) java.lang.NoClassDefFoundError: org/apache/flink/table/sources/TableSource - posted by "tyler fan (Jira)" <ji...@apache.org> on 2019/12/12 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15219) LocalEnvironment is not initializing plugins - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2019/12/12 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15220) Add startFromTimestamp in KafkaTableSource - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2019/12/12 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15221) supporting Exactly-once for table APi - posted by "chaiyongqiang (Jira)" <ji...@apache.org> on 2019/12/12 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15222) Move state benchmark utils into core repository - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/12 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15223) Csv connector should unescape delimiter parameter character - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/12 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15224) Resource requirements are not respected when fulfilling a slot request with unresolvedRootSlots from a SlotSharingManager - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/12/12 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15225) LeaderChangeClusterComponentsTest#testReelectionOfDispatcher occasionally requires 30 seconds - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2019/12/12 13:31:00 UTC, 0 replies.
- [DISCUSS] Improve documentation / tooling around security of Flink - posted by Robert Metzger <rm...@apache.org> on 2019/12/12 16:45:08 UTC, 3 replies.
- [jira] [Created] (FLINK-15226) Running job with application parameters fails on a job cluster - posted by "Biju Nair (Jira)" <ji...@apache.org> on 2019/12/12 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15227) Fix broken documentation build - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2019/12/12 20:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15228) Drop vendor specific deployment documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2019/12/12 21:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15229) DDL for kafka connector following documentation doesn't work - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 01:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15230) flink1.9.1 table API JSON schema array type exception - posted by "kevin (Jira)" <ji...@apache.org> on 2019/12/13 03:02:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP policy for introducing config option keys - posted by Jark Wu <im...@gmail.com> on 2019/12/13 04:02:14 UTC, 0 replies.
- [jira] [Created] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2019/12/13 04:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/13 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15233) Improve Kafka connector properties make append update-mode as default - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/13 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15234) hive table created from flink catalog table cannot have null properties in parameters - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15235) create a Flink distribution for hive that includes all Hive dependencies - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15236) Add a safety net for concurrent checkpoints on TM side - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/12/13 05:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15237) CsvTableSource and ref class better to Extract into a module - posted by "xiaodao (Jira)" <ji...@apache.org> on 2019/12/13 06:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15238) A sql can't generate a valid execution plan - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/13 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15239) TM Metaspace memory leak - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/13 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15240) is_generic key is missing for Flink table stored in HiveCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15241) Revert the unexpected change for the configuration of Mesos CPU cores - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/13 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15242) Add doc to introduce ddls or dmls supported by sql cli - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/13 08:34:00 UTC, 0 replies.
- [DISCUSS] have separate Flink distributions with built-in Hive dependencies - posted by Bowen Li <bo...@gmail.com> on 2019/12/13 08:44:02 UTC, 13 replies.
- [jira] [Created] (FLINK-15243) Add documentation about how to set line feed as delimiter for csv format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/13 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15244) FileUtils#deleteDirectoryQuietly will delete files in the symbolic link which point to a directory - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/12/13 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15245) Flink running in one cluster cannot write data to Hive tables in another cluster - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/13 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15246) Query result schema: [EXPR$0: TIMESTAMP(6) NOT NULL] not equal to TableSink schema: [EXPR$0: TIMESTAMP(3)] - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/13 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/13 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15248) FileUtils#compressDirectory behaves buggy when processing relative directory path - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2019/12/13 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15249) Improve PipelinedRegions calculation with Union Set - posted by "Chongchen Chen (Jira)" <ji...@apache.org> on 2019/12/13 13:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15250) Docs of Table Connect to External Systems is outdate and need to fix - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/13 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15251) Fabric8FlinkKubeClient doesn't work if ingress has hostname but no IP - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/13 16:38:00 UTC, 0 replies.
- [ANNOUNCE] Zhu Zhu becomes a Flink committer - posted by Till Rohrmann <tr...@apache.org> on 2019/12/13 16:51:14 UTC, 41 replies.
- [jira] [Created] (FLINK-15252) Heartbeat with large accumulator payload may cause instable clusters - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2019/12/13 18:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15253) Accumulators are not checkpointed - posted by "Maximilian Michels (Jira)" <ji...@apache.org> on 2019/12/13 18:41:00 UTC, 0 replies.
- Large intervaljoin related question - posted by Chen Qin <qi...@gmail.com> on 2019/12/13 19:24:41 UTC, 0 replies.
- [jira] [Created] (FLINK-15254) hive module cannot be named "hive" - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 20:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15255) document how to create Hive table from java API and DDL - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 20:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15256) unable to drop table in HiveCatalogITCase - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 20:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15257) convert HiveCatalogITCase.testCsvTableViaAPI() to use blink planner - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 21:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15258) HiveModuleFactory doesn't take hive-version - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 21:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/13 22:45:00 UTC, 0 replies.
- join - posted by zgq25302111 <zg...@126.com> on 2019/12/14 09:16:20 UTC, 0 replies.
- [jira] [Created] (FLINK-15260) Uniformize Kubernetes executor name with the rest - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/14 12:37:00 UTC, 0 replies.
- Worst-case optimal join processing on Streams - posted by Laurens VIJNCK <la...@uhasselt.be> on 2019/12/14 14:52:26 UTC, 1 replies.
- [jira] [Created] (FLINK-15261) add dedicated documentation for blink planner - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/15 06:45:00 UTC, 0 replies.
- NPE in blink planner code gen - posted by Benchao Li <li...@gmail.com> on 2019/12/15 08:17:35 UTC, 3 replies.
- [jira] [Created] (FLINK-15262) kafka connector doesn't read from beginning immediately when 'connector.startup-mode' = 'earliest-offset' - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/15 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15263) add dedicated page for HiveCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/15 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15264) Job Manager TASK_SLOTS_TOTAL metrics does not shows the Job ID - posted by "xiaogang zhou (Jira)" <ji...@apache.org> on 2019/12/15 13:07:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/50 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/12/15 15:36:15 UTC, 3 replies.
- [jira] [Created] (FLINK-15265) Remove "-executor" suffix from executor names - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2019/12/15 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15266) NPE in blink planner code gen - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2019/12/16 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15267) Streaming SQL end-to-end test (Blink planner) fails on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/16 05:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15268) Shaded Hadoop S3A end-to-end test fails on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/16 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15269) Fix hive dialect limitation to overwrite and partition syntax - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/16 05:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15270) Add documentation about how to specify third-party dependencies via API for Python UDFs - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/16 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15271) Add documentation about the Python environment requirements - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/16 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15272) Better error message when insert partition with values - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/16 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15273) Complete and Update Documentation - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/16 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15274) Update Filesystem documentation to reflect changes in shading - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/16 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15275) Update CLI documentation to include only current valid options - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/16 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15276) Update CLI documentation to reflect the addition of the ExecutorCLI - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/16 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15277) Update SQL DDL document to add syntax and example of computed column - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2019/12/16 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15278) Update StreamingFileSink documentation - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/16 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15279) Document new `executeAsync()` method and the newly introduced `JobClient` - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/16 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15280) Checkpoint end-to-end test failed - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2019/12/16 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15281) Map Flink's TypeInference to Calcite's interfaces - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2019/12/16 09:23:00 UTC, 0 replies.
- Documentation tasks for release-1.10 - posted by Kostas Kloudas <kk...@apache.org> on 2019/12/16 09:29:05 UTC, 2 replies.
- [jira] [Created] (FLINK-15282) Remove ParameterScope in blink planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/16 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15283) Scala version of TableSinkUtils has a problem when validating sinks. - posted by "roland wang (Jira)" <ji...@apache.org> on 2019/12/16 09:59:00 UTC, 2 replies.
- [jira] [Created] (FLINK-15284) Sql error (Failed to push project into table source!) - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/16 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15285) Resuming Externalized Checkpoint (file, async, no parallelism change) E2E test fails on Travis - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/16 12:47:00 UTC, 0 replies.
- [DISCUSS] Deal with the timers better before closing operators - posted by Haibo Sun <su...@163.com> on 2019/12/16 13:29:15 UTC, 1 replies.
- [DISCUSS] Flink docs vendor table - posted by Seth Wiesman <sj...@gmail.com> on 2019/12/16 16:52:18 UTC, 10 replies.
- [jira] [Created] (FLINK-15286) Managed Memory Option for RocksDB not picked up from config - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/16 20:56:00 UTC, 0 replies.
- Processing events based on weights - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2019/12/17 04:20:31 UTC, 1 replies.
- [jira] [Created] (FLINK-15287) Vectorized orc reader fails with Hive 2.0.1 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/17 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15288) Starting jobmanager pod should respect containerized.heap-cutoff - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/12/17 07:35:00 UTC, 0 replies.
- Potential side-effect of connector code to JM/TM - posted by Yingjie Cao <ke...@gmail.com> on 2019/12/17 07:43:27 UTC, 6 replies.
- [jira] [Created] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation". - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/17 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/17 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15291) Rename WatermarkSepc#getWatermarkExpressionString to getWatermarkExpr - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/17 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15292) Rename Executor interface to PipelineExecutor - posted by "Kostas Kloudas (Jira)" <ji...@apache.org> on 2019/12/17 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15293) Document new RocksDB memory configuration - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2019/12/17 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15294) Deprecate CustomCommandLine - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/17 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15295) Mark CustomCommandLine and its subclass as deprecated - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/17 09:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15296) Support print executor-specific help information from CLI - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/17 09:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15297) Do not throw exception if YARN Application switched to FINISHED immediately after deployed in YarnClusterDescriptor#startAppMaster - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/17 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15298) Wrong dependences in the DataStream API tutorial (the wiki-edits example) - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2019/12/17 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15299) Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to flink-test-utils - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/17 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15300) Shuffle memory fraction sanity check does not account for its min/max limit - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2019/12/17 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15301) Flink Kinesis AsyncRecordEmitter needs to handle unchecked exception gracefully - posted by "Ying Xu (Jira)" <ji...@apache.org> on 2019/12/17 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15302) properties in create table DDL need to be backward compatible - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/17 20:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15303) support predicate pushdown for sources in hive connector - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/17 20:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15304) Remove unexpected Hadoop dependency from Flink's Mesos integration - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/18 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15305) MemoryMappedBoundedDataTest fails with IOException on ppc64le - posted by "Siddhesh Ghadi (Jira)" <ji...@apache.org> on 2019/12/18 05:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15306) Adjust the default netty transport option from nio to auto - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/18 05:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15307) Subclasses of FailoverStrategy are easily confused with implementation classes of RestartStrategy - posted by "andrew.D.lin (Jira)" <ji...@apache.org> on 2019/12/18 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1 - posted by "Feng Jiajie (Jira)" <ji...@apache.org> on 2019/12/18 07:43:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.9.2 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/18 07:43:40 UTC, 4 replies.
- [jira] [Created] (FLINK-15309) Execute sql appear "NumberFormatException: Zero length BigInteger" - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/18 07:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15310) A timestamp result get by a select sql and a csvsink sql is different - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/18 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15311) Lz4BlockCompressionFactory should use native compressor instead of java unsafe - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/18 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15312) Remove PlanExposingEnvironment - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/18 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15313) Can not insert decimal with precision into sink using TypeInformation - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/18 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15314) To refactor duplicated code in TaskManagerDetailsHandler#createTaskManagerMetricsInfo - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/18 10:32:01 UTC, 0 replies.
- [jira] [Created] (FLINK-15315) Add test case for rest - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/18 10:40:00 UTC, 0 replies.
- Re: [Question] How to use different filesystem between checkpoint data and user data sink - posted by vino yang <ya...@gmail.com> on 2019/12/18 10:46:33 UTC, 2 replies.
- [jira] [Created] (FLINK-15316) SQL Client end-to-end test (Old planner) failed on Travis - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/18 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15317) State TTL Heap backend end-to-end test fails on Travis - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2019/12/18 11:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le - posted by "Siddhesh Ghadi (Jira)" <ji...@apache.org> on 2019/12/18 11:42:01 UTC, 0 replies.
- [jira] [Created] (FLINK-15319) flink-end-to-end-tests-common-kafka fails due to timeout - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/12/18 12:44:00 UTC, 0 replies.
- [DISCUSS] Drop vendor specific repositories from pom.xml - posted by Till Rohrmann <tr...@apache.org> on 2019/12/18 15:50:48 UTC, 3 replies.
- [DISCUSS] What parts of the Python API should we focus on next ? - posted by jincheng sun <su...@gmail.com> on 2019/12/19 02:20:08 UTC, 3 replies.
- [jira] [Created] (FLINK-15320) JobManager crash in the model of standalone - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/19 02:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15321) The result of sql(SELECT concat('a', cast(null as varchar), 'c');) is NULL; - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/19 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15322) Parquet test fails with Hive versions prior to 1.2.0 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/19 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15323) SQL Client end-to-end test (Old planner) failed on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/19 07:48:00 UTC, 0 replies.
- Re: [Question] How to use different filesystem between checkpointdata and user data sink - posted by Piotr Nowojski <pi...@ververica.com> on 2019/12/19 08:29:06 UTC, 0 replies.
- [jira] [Created] (FLINK-15324) Make MesosResourceManager inherit from ActiveResourceManager - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/19 08:44:00 UTC, 0 replies.
- apply for permission - posted by 魁 <zh...@vip.qq.com> on 2019/12/19 09:02:45 UTC, 1 replies.
- [jira] [Created] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2019/12/19 09:38:00 UTC, 0 replies.
- [DISCUSS] Some feedback after trying out the new FLIP-49 memory configurations - posted by Stephan Ewen <se...@apache.org> on 2019/12/19 10:02:58 UTC, 14 replies.
- [jira] [Created] (FLINK-15326) Add document description for DECIMAL(38, 18) when the sink table uses json schema - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2019/12/19 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2019/12/19 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15328) Change the page of taskmanager's metric according to flip-49 - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/19 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15329) Incorrect comment for MemoryManager#availableMemory - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/19 11:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15330) org.apache.flink.fs.s3hadoop.HadoopS3RecoverableWriterITCase.testCallingDeleteObjectTwiceDoesNotThroughException() fails with AssertionError - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2019/12/19 11:37:00 UTC, 0 replies.
- [DISCUSS] Integrate Flink Docker image publication into Flink release process - posted by Patrick Lucas <pa...@ververica.com> on 2019/12/19 13:20:32 UTC, 2 replies.
- [jira] [Created] (FLINK-15331) Create a table from a changelog - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2019/12/19 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15332) Jepsen tests are broken due to copying un-relocated flink-s3-fs-hadoop* into lib - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/12/19 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/19 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15334) Fix schemaValidator because properties mapping may change if user defined generated columns before custom columns - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/19 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15335) add-dependencies-for-IDEA not working anymore and dangerous in general - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2019/12/19 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15336) Support temporal table function outer joins - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2019/12/19 15:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15337) Add vendor table to documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2019/12/20 01:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15338) TM Metaspace memory leak when submitting PyFlink UDF jobs multiple times - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2019/12/20 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15339) Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/20 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15340) Remove the executor of pipelined compression benchmark - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/20 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15341) Reset context classload in PackagedProgramUtils#createJobGraph - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/20 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15342) Verify querying Hive view - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/20 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator - posted by "jocean.shi (Jira)" <ji...@apache.org> on 2019/12/20 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15344) Update limitations in hive udf document - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/20 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15345) CurrentExecution and priorExecutions are inconsistent in the test case - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/20 08:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15346) OldCsvValidator has no property of "emptyColumnAsNull". - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/20 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15347) ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange failed on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2019/12/20 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15348) Fix orc optimization for version less than 2.3 by introducing orc shim - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/20 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15349) add Catalog DDL support in FLIP-69 - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/20 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15350) develop JDBCCatalog to connect to relational databases - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/20 23:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15352) develop MySQLJDBCCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/21 00:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15351) develop PostgresJDBCCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/21 00:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15353) develop AbstractJDBCCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/21 00:02:00 UTC, 0 replies.
- [DISCUSS] FLIP-90: Support SQL 2016-2017 JSON functions in Flink SQL - posted by Forward Xu <fo...@gmail.com> on 2019/12/21 00:15:37 UTC, 10 replies.
- [jira] [Created] (FLINK-15354) Start and stop minikube only in kubernetes related e2e tests - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/12/21 04:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2019/12/21 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15356) Add applicationId to existing flink metrics running on yarn - posted by "Forward Xu (Jira)" <ji...@apache.org> on 2019/12/21 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15357) schema created by JsonRowSchemaConverter are not suitable for TableEnv.sqlQuery table schema - posted by "巫旭阳 (Jira)" <ji...@apache.org> on 2019/12/21 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15358) [configuration] the flink conf yaml file will skip the rest of value after a `#` comment sign - posted by "BlaBlabla (Jira)" <ji...@apache.org> on 2019/12/22 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15359) Remove unused YarnConfigOptions - posted by "Zili Chen (Jira)" <ji...@apache.org> on 2019/12/22 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15360) Yarn e2e test is broken with building docker image - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/12/22 10:34:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/51 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/22 15:34:23 UTC, 0 replies.
- [DISCUSS] Correct the terminology of "Time-windowed Join" to "Interval Join" in Table API & SQL - posted by Jark Wu <im...@gmail.com> on 2019/12/23 03:41:39 UTC, 4 replies.
- Flink On K8s, build docker image very slowly, is there some way to make it faster? - posted by LakeShen <sh...@gmail.com> on 2019/12/23 06:45:42 UTC, 2 replies.
- [jira] [Created] (FLINK-15361) ParquetTableSource should pass predicate in projectFields - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/23 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector - posted by "vinoyang (Jira)" <ji...@apache.org> on 2019/12/23 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15363) Hbase connector do not support datatypes with precision like TIMESTAMP(9) and DECIMAL(10,4) - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/23 12:45:00 UTC, 0 replies.
- Watermark options for TwoInputStreamOperator - posted by Jocean shi <jo...@gmail.com> on 2019/12/23 13:46:45 UTC, 4 replies.
- [jira] [Created] (FLINK-15364) Introduce streaming task using heap backend e2e tests for Mesos - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/24 02:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15365) Introduce streaming task using rocksDB backend e2e tests for Mesos - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/24 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15366) Dimension table do not support computed column - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/24 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15367) Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15368) Add end-to-end test for controlling RocksDB memory usage - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/24 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15369) MiniCluster use fixed network / managed memory sizes by defualt - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15370) Configured write buffer manager actually not take effect in RocksDB's DBOptions - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/12/24 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15371) Change FLIP-49 memory configurations to use the new memory type config options - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15372) Use shorter config keys for FLIP-49 total memory config options - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15373) Update descriptions for framework / task off-heap memory config options - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15374) Update descriptions for jvm overhead config options - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15375) Improve MemorySize to print / parse with better readability. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 03:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/24 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15377) Mesos WordCount test fails on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/24 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2019/12/24 06:51:00 UTC, 0 replies.
- Apply for contributor permission - posted by 余贤圣 <as...@163.com> on 2019/12/24 07:12:37 UTC, 7 replies.
- [jira] [Created] (FLINK-15379) JDBC connector return wrong value if defined dataType contains precision - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/24 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15380) Unable to set number of TM and number of Slot for MiniCluster in Scala shell - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/12/24 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15381) INSERT INTO VALUES statement fails if a cast project is applied - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/24 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15382) Flink failed generating python config docs - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/24 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15383) StreamExecSink should use sink Schema field name rather than query Schema field name - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/24 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/12/24 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15385) Translate "Concepts & Common API" page of Table API into Chinese - posted by "Steve OU (Jira)" <ji...@apache.org> on 2019/12/24 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15386) SingleJobSubmittedJobGraphStore.putJobGraph has a logic error - posted by "Ethan Li (Jira)" <ji...@apache.org> on 2019/12/24 16:06:00 UTC, 0 replies.
- apply for contribute - posted by pu zhang <pa...@gmail.com> on 2019/12/24 16:12:37 UTC, 1 replies.
- [jira] [Created] (FLINK-15387) Expose missing RocksDB properties out via RocksDBNativeMetricOptions - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2019/12/24 17:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15388) The assigned slot bae00218c818157649eb9e3c533b86af_32 was removed. - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2019/12/25 03:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15389) JDBCUpsertOutputFormat no need to create schedule flush when flushMaxSize = 1 - posted by "xiaodao (Jira)" <ji...@apache.org> on 2019/12/25 03:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15390) List/Map/Struct support for vectorized orc reader - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/25 06:46:00 UTC, 0 replies.
- Apply for contributing to Apache Flink - posted by hechao <13...@163.com> on 2019/12/25 08:24:07 UTC, 1 replies.
- [jira] [Created] (FLINK-15391) DATE and TIMESTAMP partition columns don't work - posted by "Rui Li (Jira)" <ji...@apache.org> on 2019/12/25 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15392) SqlClient - posted by "liupengcheng (Jira)" <ji...@apache.org> on 2019/12/25 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/12/25 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15394) in yarn mode, jobmanager fails to start in case of rest.port conflict. - posted by "watters.wang (Jira)" <ji...@apache.org> on 2019/12/26 02:10:00 UTC, 0 replies.
- Flink 1.9 SQL Kafka Connector，Json format，how to deal with not json message? - posted by LakeShen <sh...@gmail.com> on 2019/12/26 03:43:53 UTC, 1 replies.
- [jira] [Created] (FLINK-15395) No API for execute insert into statement - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/12/26 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15396) Support to ignore parse errors for JSON format - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/26 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15397) Streaming and batch has different value in the case of count function - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/26 06:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15398) Correct catalog doc example mistake - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/26 07:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15399) Join with a LookupableTableSource：java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type - posted by "Rockey Cui (Jira)" <ji...@apache.org> on 2019/12/26 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15400) elasticsearch sink support dynamic index. - posted by "ouyangwulin (Jira)" <ji...@apache.org> on 2019/12/26 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15401) Planner should set sink field names to setKeyFields of upsert sink - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/26 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15402) Add disable quote character feature for serializing row to csv format - posted by "Peng (Jira)" <ji...@apache.org> on 2019/12/26 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15403) 'State Migration end-to-end test from 1.6' is unstable on travis. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2019/12/26 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15404) How to insert hive table for different catalog - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2019/12/26 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15405) Make Yarn staging directory configurable - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2019/12/26 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap - posted by "Darcy Lin (Jira)" <ji...@apache.org> on 2019/12/26 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15407) Add document to explain how to write a table with PK - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/26 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15408) Interval join support no equi-condition - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/12/26 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/12/26 14:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15410) Solace JCSMP connectors - posted by "Leonid Ilyevsky (Jira)" <ji...@apache.org> on 2019/12/26 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15411) HiveCatalog can't prune partition on DATE/TIMESTAMP columns - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2019/12/26 18:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/27 01:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15413) ScalarOperatorsTest failed in travis - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/27 02:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-15414) KafkaITCase#prepare failed in travis - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2019/12/27 02:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed - posted by "hiliuxg (Jira)" <ji...@apache.org> on 2019/12/27 03:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel - posted by "Zhenqiu Huang (Jira)" <ji...@apache.org> on 2019/12/27 06:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15417) Remove the docker volume or mount when starting Mesos e2e cluster - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/27 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15418) StreamExecMatchRule not set FlinkRelDistribution - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2019/12/27 07:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-15419) Validate SQL syntax not need to depend on connector jar - posted by "Kaibo Zhou (Jira)" <ji...@apache.org> on 2019/12/27 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15420) Cast string to timestamp will loose precision - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2019/12/27 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2019/12/27 07:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15422) Expose Jvm Metaspace、Compressed Class Space、Eden Space、Survivor Space、Old Gen metric - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/27 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15423) Show the detail of submitting job fail - posted by "lining (Jira)" <ji...@apache.org> on 2019/12/27 09:20:00 UTC, 0 replies.
- What is the suggested way to validate SQL? - posted by Kaibo Zhou <zk...@gmail.com> on 2019/12/27 09:43:53 UTC, 3 replies.
- [jira] [Created] (FLINK-15424) Make all AppendingState#add respect the java doc - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/12/27 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15425) update outdated document of Connect to External Systems - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2019/12/27 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15426) TPC-DS end-to-end test (Blink planner) fails on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/27 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15427) State TTL RocksDb backend end-to-end test stalls on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/27 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15428) Avro Confluent Schema Registry nightly end-to-end test fails on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2019/12/27 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15429) read hive table null value of timestamp type will throw an npe - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2019/12/27 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15430) Fix Java 64K method compiling limitation for blink planner. - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2019/12/28 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2019/12/28 07:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15432) JDBCOutputFormat add flushInterval just like JDBCUpsertOutputFormat - posted by "xiaodao (Jira)" <ji...@apache.org> on 2019/12/28 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15433) flink-hbase add kerberos support - posted by "xiaodao (Jira)" <ji...@apache.org> on 2019/12/28 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15434) testResourceManagerConnectionAfterRegainingLeadership test fail when run azure - posted by "hailong wang (Jira)" <ji...@apache.org> on 2019/12/28 23:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15435) ExecutionConfigTests.test_equals_and_hash in pyFlink fails when cpu core numbers is 6 - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2019/12/29 10:33:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2019/52 - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/29 12:29:17 UTC, 0 replies.
- [jira] [Created] (FLINK-15436) Add a hook of deserialized for pojo state object. - posted by "xiemeilong (Jira)" <ji...@apache.org> on 2019/12/30 05:56:00 UTC, 0 replies.
- Re: Error:java: 无效的标记: --add-exports=java.base/sun.net.util=ALL-UNNAMED - posted by Jark Wu <im...@gmail.com> on 2019/12/30 07:32:11 UTC, 0 replies.
- [jira] [Created] (FLINK-15437) Start session with property of "-Dtaskmanager.memory.process.size" not work - posted by "xiaojin.wy (Jira)" <ji...@apache.org> on 2019/12/30 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15438) Counter metrics are incorrectly reported as total counts to DataDog - posted by "Jörn Kottmann (Jira)" <ji...@apache.org> on 2019/12/30 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15439) Incorrect SQL Document about DDL support - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2019/12/31 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15440) Enable savepoint support for Table & SQL program - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2019/12/31 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15441) Refactor StreamExecWindowJoin to extends CommonPhysicalJoin - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/31 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15442) Harden the Avro Confluent Schema Registry nightly end-to-end test - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2019/12/31 05:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15443) Use JDBC connector write FLOAT value occur ClassCastException - posted by "yexianxun (Jira)" <ji...@apache.org> on 2019/12/31 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15444) Make the component AbstractInvokable in CheckpointBarrierHandler NonNull - posted by "zhijiang (Jira)" <ji...@apache.org> on 2019/12/31 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15445) JDBC Table Source didn't work for Types with precision (or/and scale) - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2019/12/31 08:54:00 UTC, 0 replies.
- [VOTE] FLIP-90: Support SQL 2016-2017 JSON functions in Flink SQL - posted by Forward Xu <fo...@gmail.com> on 2019/12/31 09:08:40 UTC, 0 replies.
- [jira] [Created] (FLINK-15446) Improve "Connect to External Systems" documentation page - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2019/12/31 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp" - posted by "Victor Wong (Jira)" <ji...@apache.org> on 2019/12/31 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15448) Make "ResourceID#toString" more descriptive - posted by "Victor Wong (Jira)" <ji...@apache.org> on 2019/12/31 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15449) Retain lost task managers on Flink UI - posted by "Victor Wong (Jira)" <ji...@apache.org> on 2019/12/31 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15450) Add kafka topic information to Kafka source - posted by "Victor Wong (Jira)" <ji...@apache.org> on 2019/12/31 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2019/12/31 13:14:00 UTC, 0 replies.
- How to get kafka record's timestamp in job - posted by 刘建刚 <li...@gmail.com> on 2019/12/31 14:37:17 UTC, 0 replies.