You are viewing a plain text version of this content. The canonical link for it is here.
- Re: The contradiction between event time and natural time from EventTimeTrigger - posted by Rong Rong <wa...@gmail.com> on 2019/05/01 04:06:03 UTC, 0 replies.
- [DISCUSS] Features for Apache Flink 1.9.0 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/05/01 05:15:23 UTC, 14 replies.
- Re: [DISCUSS] Releasing Flink-shaded 7.0 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/05/01 05:18:47 UTC, 2 replies.
- [jira] [Created] (FLINK-12380) Add thread name in the log4j.properties - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/05/01 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12381) Without failover (aka "HA") configured, full restarts' checkpointing crashes - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/05/01 08:09:00 UTC, 0 replies.
- Re: HA lock nodes, Checkpoints, and JobGraphs after failure - posted by "dyana.rose" <dy...@salecycle.com> on 2019/05/01 08:17:38 UTC, 1 replies.
- [jira] [Created] (FLINK-12382) HA + ResourceManager exception: Fencing token not set - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/05/01 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12383) "Log file environment variable 'log.file' is not set" despite web.log.path being set - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/05/01 13:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable" - posted by "Henrik (JIRA)" <ji...@apache.org> on 2019/05/01 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12385) RestClusterClient can hang indefinitely during job submission - posted by "Matt Dailey (JIRA)" <ji...@apache.org> on 2019/05/01 15:35:00 UTC, 0 replies.
- Re: [DISCUSS] Update our Roadmap - posted by Bowen Li <bo...@gmail.com> on 2019/05/01 20:41:01 UTC, 3 replies.
- [jira] [Created] (FLINK-12386) Support complete mapping between Flink and Hive data types - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/01 20:44:00 UTC, 0 replies.
- Checkpoint Vs Job Completion - posted by vijikarthi <vi...@yahoo.com> on 2019/05/01 21:54:03 UTC, 2 replies.
- Re: [DISCUSS] FLIP-39: Flink ML pipeline and ML libs - posted by Rong Rong <wa...@gmail.com> on 2019/05/01 22:18:33 UTC, 11 replies.
- Re: Your application for Season of Docs 2019 was unsuccessful - posted by Andrew Chen <ch...@google.com.INVALID> on 2019/05/01 22:21:48 UTC, 1 replies.
- [jira] [Created] (FLINK-12387) Salesforce - posted by "Mukesh Jha (JIRA)" <ji...@apache.org> on 2019/05/02 00:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12388) Update the production readyness checklist - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2019/05/02 02:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12389) flink codegen set String type for ByteBuffer fields - posted by "Yu Yang (JIRA)" <ji...@apache.org> on 2019/05/02 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12390) Fully migrate to asm6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/02 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12391) Add timeout to transfer.sh - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/02 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12392) FlinkRelMetadataQuery does not compile with Scala 2.12 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/02 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12393) Add the user-facing classes of the new type system - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/05/02 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12394) Update FileSystem factory classes to use HadoopConfigLoader - posted by "Piyush Narang (JIRA)" <ji...@apache.org> on 2019/05/02 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12395) Reconcile description and detailed description in CatalogBaseTable - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/02 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12396) KafkaITCase.testOneSourceMultiplePartitions doesn't fail properly - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/03 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12397) Drop flink-shaded-asm-5 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/03 17:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12398) Support partitioned view in catalog API - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/03 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12399) FilterableTableSource does not use filters on job run - posted by "Josh Bradt (JIRA)" <ji...@apache.org> on 2019/05/03 19:44:00 UTC, 0 replies.
- apply for contributor permission - posted by 华超 <hu...@gmail.com> on 2019/05/04 09:21:19 UTC, 1 replies.
- [jira] [Created] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka - posted by "Pierre Zemb (JIRA)" <ji...@apache.org> on 2019/05/04 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12401) Support incremental emit for non-window streaming FlatAggregate on Table API - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/05/05 01:31:00 UTC, 0 replies.
- Re: [DISCUSS] Apache Flink at Season of Docs - posted by jincheng sun <su...@gmail.com> on 2019/05/05 07:19:11 UTC, 0 replies.
- [jira] [Created] (FLINK-12402) Make validation error message for CallExpression more user friendly - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/05/05 07:57:00 UTC, 0 replies.
- Apply for become a Contributor - posted by 郑智国 <zh...@gmail.com> on 2019/05/05 09:06:54 UTC, 2 replies.
- [jira] [Created] (FLINK-12403) Translate "How to use logging" page into Chinese - posted by "Armstrong Nova (JIRA)" <ji...@apache.org> on 2019/05/05 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12404) Translate the "Register a custom serializer for your Flink program" page into Chinese - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/05/05 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12405) Introduce BLOCKING_PERSISTENT result partition type - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/05/05 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12406) Report BLOCKING_PERSISTENT result partition meta back to client - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/05/05 13:00:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-23 Model Serving - posted by Rong Rong <wa...@gmail.com> on 2019/05/06 00:52:35 UTC, 1 replies.
- [jira] [Created] (FLINK-12407) Add all table operators align Java Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/06 01:41:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Becket Qin <be...@gmail.com> on 2019/05/06 02:08:52 UTC, 1 replies.
- Apply for Contributor Permission - posted by 黄兴勃hxb0643 <hx...@gmail.com> on 2019/05/06 02:20:19 UTC, 0 replies.
- [jira] [Created] (FLINK-12408) Support to define all kinds of types in Python API - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2019/05/06 03:36:00 UTC, 0 replies.
- Apply for Contributor Permission - posted by Xingbo Huang <hx...@gmail.com> on 2019/05/06 03:40:13 UTC, 1 replies.
- [jira] [Created] (FLINK-12409) Adds from_elements in TableEnvironment - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2019/05/06 03:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields - posted by "Chethan U (JIRA)" <ji...@apache.org> on 2019/05/06 03:56:00 UTC, 0 replies.
- IllegalArgumentException when using state with TTL enable and kryoSerializer as field Serializer - posted by Shi Quan <qu...@outlook.com> on 2019/05/06 06:44:06 UTC, 2 replies.
- [jira] [Created] (FLINK-12411) Fix failling e2e test test_streaming_sql.sh - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/05/06 07:06:00 UTC, 0 replies.
- Re: Flink Forward Europe 2019 - Call for Presentations open until 17th May - posted by Robert Metzger <rm...@apache.org> on 2019/05/06 07:44:20 UTC, 4 replies.
- How to convert protobuf to Row - posted by 刘建刚 <li...@gmail.com> on 2019/05/06 09:26:37 UTC, 0 replies.
- [jira] [Created] (FLINK-12412) Allow ListTypeInfo used for java.util.List and MapTypeInfo used for java.util.Map - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/05/06 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12413) Implement ExecutionFailureHandler - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/05/06 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12414) Implement ExecutionGraph to SchedulingTopology Adapter - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/05/06 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12415) Translate "History Server" doc into Chinese - posted by "Armstrong Nova (JIRA)" <ji...@apache.org> on 2019/05/06 12:30:00 UTC, 0 replies.
- What's the meaning of "namespace" in KeyedStateBackend - posted by Shi Quan <qu...@outlook.com> on 2019/05/06 13:35:45 UTC, 1 replies.
- [jira] [Created] (FLINK-12416) Docker build script fails on symlink creation ln -s - posted by "Slava D (JIRA)" <ji...@apache.org> on 2019/05/06 15:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12417) Merge ReadableCatalog and ReadableWritableCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/06 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12418) Add input/output format and SerDeLib information for Hive tables in HiveCatalogUtil#createHiveTable - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/06 23:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12419) Add support for consuming BLOCKING_PERSISTENT ResultPartition - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/05/07 01:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12420) Add support of cache/invalidateCache for TableAPI - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2019/05/07 01:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12421) Synchronize the latest documentation changes into Chinese documents - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/05/07 02:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12422) Remove IN_TESTS for make test code and production code consistent - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/05/07 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12423) Add Timer metric type for flink-metrics module - posted by "Armstrong Nova (JIRA)" <ji...@apache.org> on 2019/05/07 02:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12424) Supports dag (multiple-sinks query) optimization - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/07 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12425) Implement RPCs to allow clients release result partitions in a Flink cluster. - posted by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2019/05/07 05:43:00 UTC, 0 replies.
- Unsubscribe me - posted by tarush grover <ta...@gmail.com> on 2019/05/07 05:44:25 UTC, 0 replies.
- Unsubscr​ibe me - posted by Fei5 Yang 杨飞 <ya...@xiaomi.com> on 2019/05/07 06:35:06 UTC, 0 replies.
- [jira] [Created] (FLINK-12426) TM occasionally hang in deploying state - posted by "Qi (JIRA)" <ji...@apache.org> on 2019/05/07 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12427) Translate the "Flink DataStream API Programming Guide" page into Chinese - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/05/07 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12428) Translate the "Event Time" page into Chinese - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/05/07 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12429) Translate the "Generating Timestamps / Watermarks" page into Chinese - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/05/07 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12430) Translate the "Pre-defined Timestamp Extractors / Watermark Emitters" page into Chinese - posted by "YangFei (JIRA)" <ji...@apache.org> on 2019/05/07 09:27:00 UTC, 0 replies.
- apply for the flink contributor permission - posted by clay clay <cl...@gmail.com> on 2019/05/07 10:12:39 UTC, 5 replies.
- [jira] [Created] (FLINK-12431) Port utility methods for extracting fields information from TypeInformation - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/05/07 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12432) Add SchedulerNG Stub Implementation - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/05/07 13:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12433) Finalize SchedulerNG Stub Implementation - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/05/07 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12434) Replace listeners with CompletableFuture in InputGates - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/07 14:40:00 UTC, 0 replies.
- [DISCUSS] Change threading-model in StreamTask to a mailbox-based approach - posted by Stefan Richter <s....@ververica.com> on 2019/05/07 15:39:18 UTC, 1 replies.
- [jira] [Created] (FLINK-12435) UT Failure: GroupWindowTest.testExpressionOnWindowHavingFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/07 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12436) Differentiate Flink database properties from Hive database properties - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/07 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12437) Taskmanager doesn't initiate registration after jobmanager marks it terminated - posted by "Abdul Qadeer (JIRA)" <ji...@apache.org> on 2019/05/07 23:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12438) Translate "Task Lifecycle" page into Chinese - posted by "Armstrong Nova (JIRA)" <ji...@apache.org> on 2019/05/08 02:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12439) Add FileSystem Connector with CSV format support in Python Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/08 02:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12440) Add all connector support align Java Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/08 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12441) Add column stats for decimal type - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/05/08 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12442) Add some more (negative) test cases for FLINK-12365 - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/05/08 04:42:00 UTC, 0 replies.
- Apply for contributor permission - posted by Rui Li <li...@gmail.com> on 2019/05/08 08:03:00 UTC, 6 replies.
- [jira] [Created] (FLINK-12443) Replace InternalType with LogicalType in blink runner - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/05/08 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12444) Large number of broken links in chinese docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/08 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12445) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots does not stop application on failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/08 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12446) Add documentation how to enable openSSL - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/08 11:21:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 7.0, release candidate 1 - posted by jincheng sun <su...@gmail.com> on 2019/05/08 13:39:08 UTC, 6 replies.
- [jira] [Created] (FLINK-12447) Bump required Maven version to 3.1.1 (from 3.0.3) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/05/08 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12448) FlinkKafkaProducer late closure after class loader - posted by "Chris Slotterback (JIRA)" <ji...@apache.org> on 2019/05/08 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12449) [Bitwise Functions] Add BIT_AND, BIT_OR functions supported in Table API and SQL - posted by "Zhanchun Zhang (JIRA)" <ji...@apache.org> on 2019/05/08 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12450) [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table API and SQL - posted by "Zhanchun Zhang (JIRA)" <ji...@apache.org> on 2019/05/08 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12451) [Bitwise Functions] Add BIT_XOR function supported in Table API and SQL - posted by "Zhanchun Zhang (JIRA)" <ji...@apache.org> on 2019/05/08 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12452) alterTable() should ensure existing base table and the new one are of the same type - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/08 21:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12453) StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/05/09 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12454) Add custom check options for lint-python.sh - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/09 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12455) Move the package of pyflink to flink-dist - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2019/05/09 04:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12456) Wrong CharType convertion in type_utils.py - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/05/09 05:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12457) Remove char support in blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/05/09 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12458) Throw PartitionNotFoundException if consumer can not establish a connection to remote TM - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/09 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jar - posted by "Victor Wong (JIRA)" <ji...@apache.org> on 2019/05/09 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12460) Change taskmanager.tmp.dirs to io.tmp.dirs in configuration docs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2019/05/09 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12461) 1.8 not working with Scala 2.12.8 - posted by "Gaël Renoux (JIRA)" <ji...@apache.org> on 2019/05/09 07:52:00 UTC, 0 replies.
- Re: [Discuss] Add JobListener (hook) in flink job lifecycle - posted by Flavio Pompermaier <po...@okkam.it> on 2019/05/09 08:13:28 UTC, 1 replies.
- [jira] [Created] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first - posted by "Gaël Renoux (JIRA)" <ji...@apache.org> on 2019/05/09 08:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12463) Deduplicate empty .out log file checks - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/09 09:56:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12464) Kinesis e2e test fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/09 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12465) MetricsAvailabilityITCase fails on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/09 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12466) Containerized e2e tests fail on Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/09 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12467) DataStreamAllroundTestProgram should define pause between checkpoints - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/09 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12468) Unregister application from the YARN Resource Manager with a valid appTrackingUrl - posted by "Victor Wong (JIRA)" <ji...@apache.org> on 2019/05/09 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12469) Clean up catalog API on default/current DB - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/05/09 16:57:00 UTC, 0 replies.
- Re: [Season of Docs - Support] Re: Your application for Season of Docs 2019 was unsuccessful - posted by jincheng sun <su...@gmail.com> on 2019/05/09 23:34:49 UTC, 1 replies.
- [jira] [Created] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2019/05/10 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12471) Fix broken links in documentation to make CRON travis job work - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/05/10 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12472) Support setting attemptFailuresValidityInterval of jobs on Yarn - posted by "Victor Wong (JIRA)" <ji...@apache.org> on 2019/05/10 02:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12473) Add ML pipeline and ML lib Core API - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2019/05/10 04:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12474) UnionInputGate should be notified when closing SingleInputGate by canceler thread - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/10 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12475) CommonTestUtils#printLog4jDebugConfig() should include timestamp - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/10 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12476) [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/10 07:36:00 UTC, 0 replies.
- want to contribute to Apache Flink - posted by "lyy900111@163.com" <ly...@163.com> on 2019/05/10 07:48:26 UTC, 4 replies.
- [VOTE] FLIP-36 Interactive Programming for the Table API - posted by Stephan Ewen <se...@apache.org> on 2019/05/10 09:17:18 UTC, 0 replies.
- [jira] [Created] (FLINK-12477) Change threading-model in StreamTask to a mailbox-based approach - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12478) Decompose monolithic run-loops in StreamTask implementations into step-wise calls - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12479) Make InputProcessors and StreamIterationHead non-blocking - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12480) Introduce mailbox to StreamTask main-loop - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12481) Make processing time timer trigger run via the mailbox - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12483) Support (legacy) SourceFunctions with mailbox - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12484) Drop unnecessary locking for code-paths that now use the mailbox - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/10 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12485) Add a tool to check the user interface of Python Table API aligns with Java Table API. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/10 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12486) RocksDB State Backend docs don't explain that operator state is kept on heap - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2019/05/10 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12487) Introduce planner rules to rewrite expression and merge calc - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/10 12:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12488) Scope of MemorySegment metrics has changed - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/10 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12489) Flink on Mesos - Parameterize network resources. - posted by "Oleksandr Nitavskyi (JIRA)" <ji...@apache.org> on 2019/05/10 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12490) Introduce NetworkInput class - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/10 13:29:00 UTC, 0 replies.
- Re: [DISCUSS] Bump required Maven version to 3.1.1 (from 3.0.3) - posted by Robert Metzger <rm...@apache.org> on 2019/05/10 13:39:50 UTC, 0 replies.
- [DISCUSS] Proposal for Flink job execution/availability metrics impovement - posted by "Kim, Hwanju" <hw...@amazon.com.INVALID> on 2019/05/11 04:50:22 UTC, 7 replies.
- [jira] [Created] (FLINK-12491) Incorrect documentation for directory path separators of CoreOptions.TMP_DIRS - posted by "Kezhu Wang (JIRA)" <ji...@apache.org> on 2019/05/11 06:33:00 UTC, 0 replies.
- Applying for Contributor Permission - posted by Zhinan Cheng <ch...@gmail.com> on 2019/05/12 07:44:02 UTC, 1 replies.
- [jira] [Created] (FLINK-12492) Minor optimize the cep operator by avoiding unnecessary copy - posted by "aitozi (JIRA)" <ji...@apache.org> on 2019/05/12 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12493) AWS EMR instructions lead to ClassNotFoundException - posted by "Alberto Romero (JIRA)" <ji...@apache.org> on 2019/05/12 18:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12494) JDBCOutputFormat support reconnect when link failure and flush by timeInterval - posted by "zhaoshijie (JIRA)" <ji...@apache.org> on 2019/05/13 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12495) Move PythonGatewayServer into flink-clients - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/13 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12496) Support translation from StreamExecGroupWindowAggregate to StreamTransformation. - posted by "Jing Zhang (JIRA)" <ji...@apache.org> on 2019/05/13 08:09:00 UTC, 0 replies.
- Flink contributor permission application - posted by Tong Sun <st...@gmail.com> on 2019/05/13 08:27:30 UTC, 1 replies.
- [jira] [Created] (FLINK-12497) Refactor the start method of ConnectionManager - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/13 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12498) java.io.IOException: Failed to fetch BLOB - posted by "周瑞平 (JIRA)" <ji...@apache.org> on 2019/05/13 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12499) JDBCAppendTableSink support retry - posted by "FaxianZhao (JIRA)" <ji...@apache.org> on 2019/05/13 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12500) Flink flink-taskmanager restarts and running job also get killed - posted by "Chethan U (JIRA)" <ji...@apache.org> on 2019/05/13 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12501) AvroTypeSerializer does not work with types generated by avrohugger - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/05/13 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12502) Harden JobMasterTest#testRequestNextInputSplitWithDataSourceFailover - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/05/13 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12503) Improve the exceptions [Proper Error] - posted by "Chethan U (JIRA)" <ji...@apache.org> on 2019/05/13 17:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12504) NullPoint here NullPointException there.. It's every where - posted by "Chethan U (JIRA)" <ji...@apache.org> on 2019/05/13 18:03:00 UTC, 0 replies.
- Adding Metrics to StreamingFileSink - posted by Kailash Dayanand <ka...@gmail.com> on 2019/05/13 18:46:23 UTC, 0 replies.
- [jira] [Created] (FLINK-12505) Unify database operations to HiveCatalogBase from its subclasses - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/13 22:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12506) Add more over window unit tests - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2019/05/14 02:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12507) Fix AsyncLookupJoin doesn't close all generated ResultFutures - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/05/14 05:26:00 UTC, 0 replies.
- Applying for permission as a contributor - posted by Wei Sun <an...@gmail.com> on 2019/05/14 06:16:32 UTC, 1 replies.
- [jira] [Created] (FLINK-12508) Expand Documentation on Testing DataStream API programs - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/14 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12509) Introduce planner rules about non semi/anti join - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/14 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12510) Deadlock when reading from InputGates - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/14 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12511) make variable "comment" in all catalog metadata classes final - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/14 20:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12512) TableSourceTest#testNestedProject test failed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/15 01:38:00 UTC, 0 replies.
- [Discuss]: Adding Metrics to StreamingFileSink - posted by Kailash Dayanand <ka...@gmail.com> on 2019/05/15 07:43:39 UTC, 4 replies.
- Re: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component - posted by Aljoscha Krettek <al...@apache.org> on 2019/05/15 08:27:39 UTC, 1 replies.
- [jira] [Created] (FLINK-12513) Improve end-to-end (bash based) tests - posted by "Alex (JIRA)" <ji...@apache.org> on 2019/05/15 08:32:00 UTC, 0 replies.
- Flink solution to active - active Multi site cloud data ingestion - posted by "Melekh, Gregory" <gr...@intl.att.com> on 2019/05/15 08:36:39 UTC, 3 replies.
- [jira] [Created] (FLINK-12514) Refactor the failure checkpoint counting mechanism with ordered checkpoint id - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/15 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12515) Sync flink-shaded-hadoop with dependency management entries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/15 09:41:00 UTC, 0 replies.
- Re: [DISCUSS] Clean up and reorganize the JIRA components - posted by Piotr Nowojski <pi...@ververica.com> on 2019/05/15 10:13:25 UTC, 5 replies.
- [jira] [Created] (FLINK-12516) Update Travis base image from trusty to xenial - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/15 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12517) Run network tests with dynamically-linked openSSL - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/15 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12518) Run e2e tests with openSSL - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/15 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12519) Introduce planner rules about semi/anti join - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/15 12:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12520) Support to provide fully-qualified domain host name in TaskManagerMetricGroup - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2019/05/15 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12521) Use minio as AWS S3 alternative in end-to-end tests - posted by "Alex (JIRA)" <ji...@apache.org> on 2019/05/15 13:23:00 UTC, 0 replies.
- Re: User Interface not showing the actual count received and produced - posted by "PoolakkalMukkath, Shakir" <Sh...@comcast.com> on 2019/05/15 15:01:09 UTC, 2 replies.
- [jira] [Created] (FLINK-12522) Error While Initializing S3A FileSystem - posted by "Manish Bellani (JIRA)" <ji...@apache.org> on 2019/05/15 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12523) "Kafka 0.11 end-to-end test" failed because it cannot find test-scripts - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/15 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12524) Introduce planner rules about rank - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/16 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12525) Impose invariant StreamExecutionEnvironment.setBufferTimeout > 0 - posted by "Robert Stoll (JIRA)" <ji...@apache.org> on 2019/05/16 05:21:00 UTC, 0 replies.
- Apply for a Contributor permission - posted by "Zhou, Brian" <B....@dell.com> on 2019/05/16 05:38:36 UTC, 2 replies.
- grant jira permission - posted by Charoes <ch...@gmail.com> on 2019/05/16 06:15:38 UTC, 1 replies.
- [jira] [Created] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/16 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12527) Remove GLOBAL_VERSION_UPDATER in ExecutionGraph - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/16 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12528) Remove progressLock in ExecutionGraph - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/16 07:57:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12529) Release buffers of the record deserializer timely to improve the efficiency of heap memory usage on taskmanager - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/05/16 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12530) Move Task.inputGatesById to NetworkEnvironment - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/16 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12531) flink sql-client throw NoMatchingTableFactoryException - posted by "leishuiyu (JIRA)" <ji...@apache.org> on 2019/05/16 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12532) Upgrade Avro to version 1.9.0 - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2019/05/16 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/05/16 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12534) Reduce the test cost for Python API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/16 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12535) Make CheckpointBarrierHandler non-blocking - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/16 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12536) Make BufferOrEventSequence#getNext() non-blocking - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/16 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12537) Improve Documentation Build Time - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2019/05/16 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12538) Network notifyDataAvailable() only called after getting a new buffer - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/16 14:50:00 UTC, 0 replies.
- Job recovery with task manager restart - posted by Thomas Weise <th...@apache.org> on 2019/05/16 15:01:06 UTC, 3 replies.
- [jira] [Created] (FLINK-12539) StreamingFileSink: Make the class extendable to customize for different usecases - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2019/05/16 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12540) Kafka011ProducerExactlyOnceITCase#testExactlyOnceCustomOperator - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/17 01:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/17 02:36:00 UTC, 0 replies.
- contributor permission - posted by 王红斌 <ch...@gmail.com> on 2019/05/17 03:42:36 UTC, 0 replies.
- [jira] [Created] (FLINK-12542) Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka test failed - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/17 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12543) Consider naming convention for config options of shuffle services - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/17 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12544) Deadlock during releasing memory in SpillableSubpartition - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/17 10:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12545) TableSourceTest.testNestedProject failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/05/17 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12546) Base Docker images on `library/flink` - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/17 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12547) Deadlock when the task thread downloads jars using BlobClient - posted by "Haibo Sun (JIRA)" <ji...@apache.org> on 2019/05/17 14:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12548) FlinkKafkaConsumer issues configuring underlying KafkaConsumer - posted by "Leonid Ilyevsky (JIRA)" <ji...@apache.org> on 2019/05/17 20:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12549) include exceptions thrown by HMS client in CatalogException in HiveCatalogBase - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/17 23:36:00 UTC, 0 replies.
- How to make executable jar file of Monitoring the Wikipedia Edit Stream in intellij idea - posted by Mar_zieh <m....@gmail.com> on 2019/05/18 03:41:02 UTC, 0 replies.
- [jira] [Created] (FLINK-12550) hostnames with a dot never receive local input splits - posted by "Felix seibert (JIRA)" <ji...@apache.org> on 2019/05/18 15:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12551) elasticsearch6 connector print log error - posted by "xiongkun (JIRA)" <ji...@apache.org> on 2019/05/19 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12552) Combine HiveCatalog and GenericHiveMetastoreCatalog - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2019/05/19 15:26:01 UTC, 0 replies.
- [VOTE] Release flink-shaded 7.0, release candidate 2 - posted by jincheng sun <su...@gmail.com> on 2019/05/20 01:19:21 UTC, 10 replies.
- [jira] [Created] (FLINK-12553) Fix a bug in SqlDateTimeUtils#parseToTimeMillis - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/05/20 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12554) Create TableFactory for Hive connector - posted by "Rui Li (JIRA)" <ji...@apache.org> on 2019/05/20 08:22:00 UTC, 0 replies.
- questions about yarn container(taskmanager)memory allocation - posted by XiangWei Huang <xw...@gmail.com> on 2019/05/20 08:46:40 UTC, 1 replies.
- [jira] [Created] (FLINK-12555) Introduce an incapsulated metric group layout for shuffle API and deprecate old one - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/20 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12556) Extend some end-to-end tests to run with custom (input) File System implementation - posted by "Alex (JIRA)" <ji...@apache.org> on 2019/05/20 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12557) Unify create table DDL with clause and connector descriptor keys - posted by "Danny Chan (JIRA)" <ji...@apache.org> on 2019/05/20 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12558) Yarn application can't stop when flink job finished - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2019/05/20 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12559) Introduce metadata handlers on window aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/20 11:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12560) Documentation language build flags - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2019/05/20 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12561) Unable to insert into cassandra table using FileWordCount example using Remote Cassandra Host with credentials - posted by "Ramesh Srinivasalu (JIRA)" <ji...@apache.org> on 2019/05/20 14:39:00 UTC, 0 replies.
- [ANNOUNCE] Seattle Flink Meetup at AWS on May 30 - posted by Bowen Li <bo...@gmail.com> on 2019/05/20 16:46:32 UTC, 0 replies.
- [DISCUSS] FLIP to Restructure, Update & Rework Apache Flink's Documentation - posted by Konstantin Knauf <ko...@ververica.com> on 2019/05/20 17:13:44 UTC, 4 replies.
- [jira] [Created] (FLINK-12562) Improve code in ExpandColumnFunctionsRule - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2019/05/21 01:04:00 UTC, 0 replies.
- Re: Fwd: [DISCUSS] Flink SQL DDL Design - posted by Yuzhao Chen <yu...@gmail.com> on 2019/05/21 01:30:34 UTC, 0 replies.
- Contributor - posted by 何泽雄 <to...@gmail.com> on 2019/05/21 01:55:09 UTC, 0 replies.
- [jira] [Created] (FLINK-12563) Introduce vector data format in blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/05/21 03:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12564) Remove getBufferProvider method from ResultPartitionWriter interface - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/21 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12565) PythonStreamBinderTest#testProgram test failer - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/21 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12566) Remove row interval type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2019/05/21 06:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12567) Rework DescriptorProperties to adapt unified DDL with clause and Descriptor key value pairs - posted by "Danny Chan (JIRA)" <ji...@apache.org> on 2019/05/21 06:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12568) Implement TableSink and OutputFormat to write Hive tables - posted by "Rui Li (JIRA)" <ji...@apache.org> on 2019/05/21 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12569) Broken/Outdated docker/build.sh for flink 1.8.0 - posted by "Ankit Chaudhary (JIRA)" <ji...@apache.org> on 2019/05/21 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12570) Switch Task from ResultPartition to ResultPartitionWriter interface - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/21 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12571) Make NetworkEnvironment#start() return the binded data port - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/21 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12572) Implement TableSource and InputFormat to read Hive tables - posted by "zjuwangg (JIRA)" <ji...@apache.org> on 2019/05/21 09:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12573) ability to add suffix to part file created in Bucket (StreamingFileSink) - posted by "yitzchak lieberman (JIRA)" <ji...@apache.org> on 2019/05/21 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12574) using sink StreamingFileSink files are overwritten when resuming application causing data loss - posted by "yitzchak lieberman (JIRA)" <ji...@apache.org> on 2019/05/21 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12575) Introduce planner rules to remove redundant shuffle and collation - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/21 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/21 13:20:00 UTC, 0 replies.
- contribute to Apache Flink - posted by "lujisen@126.com" <lu...@126.com> on 2019/05/21 13:41:48 UTC, 2 replies.
- [jira] [Created] (FLINK-12577) Flink uses Kryo serializer if given a SpecificRecord type - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/21 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12578) Use secure URLs for Maven repositories - posted by "Jungtaek Lim (JIRA)" <ji...@apache.org> on 2019/05/21 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12579) Influx Metric exporter throws a lot of negative infinity errors - posted by "Theo Diefenthal (JIRA)" <ji...@apache.org> on 2019/05/21 19:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12580) Rename GenericHiveMetastoreCatalogTest to HiveCatalogFlinkMetadataTest, and HiveCatalogTest to HiveCatalogHiveMetadataTest - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/21 21:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12581) HiveCatalog.alterTable() and alterDatabase() should check the existing object and new object are of same type - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/21 21:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12582) Alterations in GenericInMemoryCatalog should check existing object and new object are of the same class - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/21 22:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12583) Add all format support align with the Java Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/22 00:05:00 UTC, 0 replies.
- Checkpoint / Two Phase Commit - posted by vijikarthi <vi...@yahoo.com> on 2019/05/22 00:30:37 UTC, 1 replies.
- [jira] [Created] (FLINK-12584) Add Bucket File Syetem Table Sink - posted by "zhangjun (JIRA)" <ji...@apache.org> on 2019/05/22 01:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12585) Align Stream/BatchTableEnvironment with JAVA Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/22 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12586) Stderr and stdout are reversed in OptimizerPlanEnvironment - posted by "Kazunori Shinhira (JIRA)" <ji...@apache.org> on 2019/05/22 05:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12587) Add pure-API Watermark class - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/05/22 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12588) Add TableSchema for Python Table API - posted by "Wei Zhong (JIRA)" <ji...@apache.org> on 2019/05/22 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12589) SQL end-to-end test fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/22 08:40:00 UTC, 0 replies.
- rmetzger@apache.org - posted by to...@gmail.com, to...@gmail.com on 2019/05/22 08:53:26 UTC, 1 replies.
- [jira] [Created] (FLINK-12590) Replace http links in documentation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/22 10:03:00 UTC, 0 replies.
- [SURVEY] Usage of flink-ml and [DISCUSS] Delete flink-ml - posted by Shaoxuan Wang <ws...@gmail.com> on 2019/05/22 10:08:29 UTC, 7 replies.
- [jira] [Created] (FLINK-12591) StatsDReporterTest is unstable - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/22 11:24:00 UTC, 0 replies.
- [DISCUSS] Correct the flink pom `artifactId` config before flink 1.9 release - posted by jincheng sun <su...@gmail.com> on 2019/05/22 11:31:25 UTC, 5 replies.
- [jira] [Created] (FLINK-12592) StreamTableEnvironment object has no attribute connect - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/05/22 14:40:01 UTC, 0 replies.
- Kinesis Connector RuntimeException - posted by "PoolakkalMukkath, Shakir" <Sh...@comcast.com> on 2019/05/22 15:35:59 UTC, 1 replies.
- [jira] [Created] (FLINK-12593) Revise the document for CEP - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/05/23 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12594) Make Job ID Configurable for a Job Cluster - posted by "Chaoran Yu (JIRA)" <ji...@apache.org> on 2019/05/23 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12595) KinesisDataFetcherTest.testOriginalExceptionIsPreservedWhenInterruptedDuringShutdown deadlocks - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/05/23 06:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12596) Unify all kinds of cluster into ClusterClient in FlinkShell - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/05/23 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12597) Remove the legacy flink-libraries/flink-ml - posted by "Shaoxuan Wang (JIRA)" <ji...@apache.org> on 2019/05/23 07:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12598) Flink-shaded's shade-sources profile does not work anymore - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/23 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12599) Add Jobgraph zooming with mouse wheel - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2019/05/23 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12600) Introduce planner rules to do deterministic rewriting on RelNode - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/23 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12601) Register DataStream/DataSet as DataStream/SetTableOperations in Catalog - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/05/23 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12602) Correct the flink pom `artifactId` config and scala-free check logic - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2019/05/23 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12603) Remove getOwningTaskName method from InputGate - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/23 11:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12604) Register TableSource/Sink as CatalogTable - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/05/23 12:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12605) Describe new contribution process - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/05/23 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12606) Move SourceFunction to flink-core - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/05/23 14:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job - posted by "Akshay Kanfade (JIRA)" <ji...@apache.org> on 2019/05/23 21:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12608) Add getVertexOrThrow(ExecutionVertexID) to SchedulingTopology - posted by "BoWang (JIRA)" <ji...@apache.org> on 2019/05/24 01:50:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12609) Align the data types of Python with Java - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2019/05/24 03:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12610) Introduce planner rules about aggregate - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/24 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12611) Make time indicator nullable in blink - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2019/05/24 06:50:00 UTC, 0 replies.
- Re: [DISCUSS] A more restrictive JIRA workflow - posted by Robert Metzger <rm...@apache.org> on 2019/05/24 07:18:36 UTC, 0 replies.
- [jira] [Created] (FLINK-12612) Track stored paritions on the TM - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/24 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12613) Move SinkFunction to flink-core - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/05/24 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12614) Refactor YARN tests to not do assertion in @After methods - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/24 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12615) Track allocated partitions on the JM - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/24 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12616) Maintain connection between JM<->TM until all partitions have been released - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/24 10:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12617) StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/24 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12618) jdk.tools exclusion interfering with swift-fs-hadoop build - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/24 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint - posted by "Congxian Qiu(klion26) (JIRA)" <ji...@apache.org> on 2019/05/24 12:44:00 UTC, 0 replies.
- [DISCUSS] Proposal to support disk spilling in HeapKeyedStateBackend - posted by Yu Li <ca...@gmail.com> on 2019/05/24 12:50:53 UTC, 4 replies.
- [jira] [Created] (FLINK-12620) Deadlock in task deserialization - posted by "Mike Kaplinskiy (JIRA)" <ji...@apache.org> on 2019/05/24 19:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12621) Use MiniCluster instead of JobExecutor - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/05/25 00:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12622) The process function compiles error in MyProcessWindowFunction in windows.md - posted by "chaiyongqiang (JIRA)" <ji...@apache.org> on 2019/05/25 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12623) Flink on yarn encountered AMRMClientImpl does not update AMRM token properly - posted by "dalongliu (JIRA)" <ji...@apache.org> on 2019/05/25 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12624) Make Flink case-insensitive to meta object names - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/26 04:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12625) Improve SQL Client to work with Catalog APIs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/26 04:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12626) Client should not register table-source-sink twice in TableEnvironment - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/26 04:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12627) Document how to configure and use catalogs in SQL CLI - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/26 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12628) Check test failure if partition has no consumers in Execution.getPartitionMaxParallelism - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/26 18:49:00 UTC, 0 replies.
- [VOTE] Release flink-shaded 7.0, release candidate 3 - posted by jincheng sun <su...@gmail.com> on 2019/05/27 01:23:48 UTC, 11 replies.
- [jira] [Created] (FLINK-12629) Add integration test for scala shell in yarn mode - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2019/05/27 01:49:00 UTC, 0 replies.
- Application Related Configurations - posted by Ramya Ramamurthy <ha...@gmail.com> on 2019/05/27 06:39:43 UTC, 1 replies.
- [jira] [Created] (FLINK-12630) Refactor abstract InputGate to general interface - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2019/05/27 07:15:00 UTC, 0 replies.
- [DISCUSS] Ground Source and Sink Concepts in Flink SQL - posted by Jark Wu <im...@gmail.com> on 2019/05/27 07:34:54 UTC, 1 replies.
- [jira] [Created] (FLINK-12631) Check if proper JAR file in JobWithJars - posted by "Ji Liu (JIRA)" <ji...@apache.org> on 2019/05/27 08:36:01 UTC, 0 replies.
- [jira] [Created] (FLINK-12632) Flink WebUI doesn't show the full error response when a job deployment fails - posted by "Harshith Bolar (JIRA)" <ji...@apache.org> on 2019/05/27 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12633) flink sql-client throw No context matches - posted by "xiezhiqiang (JIRA)" <ji...@apache.org> on 2019/05/27 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12634) Store shading prefix in property - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/27 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12635) REST API stability test does not cover jar upload - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/27 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12636) REST API stability test does not fail on compatible modifications - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/27 12:46:00 UTC, 0 replies.
- Distributed cache fault - posted by Vasyl Bervetskyi <vb...@softserveinc.com> on 2019/05/27 15:54:04 UTC, 1 replies.
- [jira] [Created] (FLINK-12637) Add floatingBufferUsage and exclusiveBufferUsage for credit based mode - posted by "aitozi (JIRA)" <ji...@apache.org> on 2019/05/27 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12638) Expose max parallelism via the REST API and via the Web UI - posted by "Sean Bollin (JIRA)" <ji...@apache.org> on 2019/05/28 03:00:04 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.8.1 - posted by jincheng sun <su...@gmail.com> on 2019/05/28 06:30:11 UTC, 10 replies.
- [jira] [Created] (FLINK-12639) FLIP-42: Rework Documentation - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/28 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12640) mvn install flink-shaded-hadoop2-uber: Error creating shaded jar: null - posted by "xiezhiqiang (JIRA)" <ji...@apache.org> on 2019/05/28 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12641) Add partition release logic from JM -> TM - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/28 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12642) OutputBufferPoolUsageGauge can fail with NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/28 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12644) Setup Java 9 cron jobs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/28 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12643) Implement ExecutionGraph to FailoverTopology Adapter - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2019/05/28 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12645) high parallelism e2e test fails due to missing disk space - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/28 08:29:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-33: Standardize connector metrics - posted by Piotr Nowojski <pi...@ververica.com> on 2019/05/28 09:28:32 UTC, 3 replies.
- [jira] [Created] (FLINK-12646) Fix broken tests of RestClientTest - posted by "Victor Wong (JIRA)" <ji...@apache.org> on 2019/05/28 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12647) Add feature flag to revert to previous behavior - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/28 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12648) Load Hadoop file system via FileSystem.get() - posted by "Victor Wong (JIRA)" <ji...@apache.org> on 2019/05/28 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12649) Add a shim layer to support multiple versions of HMS - posted by "Rui Li (JIRA)" <ji...@apache.org> on 2019/05/28 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/28 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12651) Add "Style Guide" to Documentation Contribution Guide - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/28 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12652) Add Glossary to Concepts Section of Documentation - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/28 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12653) Keyed state backend fails to restore during rescaling - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2019/05/28 14:34:00 UTC, 0 replies.
- KeyGroup management, data locality - posted by Smirnov Sergey Vladimirovich <s....@tinkoff.ru.INVALID> on 2019/05/28 14:57:57 UTC, 0 replies.
- [jira] [Created] (FLINK-12654) Enable Azure FS E2E tests on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/05/28 15:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12655) SlotCountExceedingParallelismTest failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/28 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12656) Integrate Flink with Hive user defined functions - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/28 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12657) Integrate Flink with Hive UDF - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/28 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12658) Integrate Flink with Hive GenericUDF - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/28 16:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12659) Integrate Flink with Hive GenericUDTF - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/28 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12660) Integrate Flink with Hive GenericUDAFResolver and GenericUDAFResolver2 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/28 16:21:00 UTC, 0 replies.
- Application for contributor permission - posted by 杨钊 <yz...@gmail.com> on 2019/05/28 16:45:13 UTC, 0 replies.
- job specific configs - posted by "Moorhead,Richard" <Ri...@cerner.com.INVALID> on 2019/05/28 17:49:06 UTC, 0 replies.
- [DISCUSS] FLIP-41: Unify Keyed State Snapshot Binary Format for Savepoints - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/05/28 21:02:20 UTC, 2 replies.
- [jira] [Created] (FLINK-12661) test failure: RestAPIStabilityTest.testDispatcherRestAPIStability - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/28 21:44:00 UTC, 0 replies.
- NPE in DataStream - posted by Abderrazak TAZARNI <ta...@gmail.com> on 2019/05/28 22:33:42 UTC, 0 replies.
- [jira] [Created] (FLINK-12662) Flink how jobs for failover in history server as well - posted by "Su Ralph (JIRA)" <ji...@apache.org> on 2019/05/29 01:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12663) Implement HiveTableSource to read Hive tables - posted by "zjuwangg (JIRA)" <ji...@apache.org> on 2019/05/29 02:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12664) Implement TableSink to write Hive tables - posted by "Rui Li (JIRA)" <ji...@apache.org> on 2019/05/29 05:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12665) Introduce MiniBatchIntervalInferRule and watermark assigner operators - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/29 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12666) Update RM idleness check for TMs to take partitions into account - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/29 07:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-12667) Add JobID argument to TaskExecutorGateway#releasePartitions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/05/29 07:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12668) Introduce fromParallelElements for generating DataStreamSource - posted by "bupt_ljy (JIRA)" <ji...@apache.org> on 2019/05/29 07:29:00 UTC, 0 replies.
- Re: [DISCUSS] Flink client api enhancement for downstream project - posted by Jeff Zhang <zj...@gmail.com> on 2019/05/29 08:17:49 UTC, 0 replies.
- [jira] [Created] (FLINK-12669) Implement FixedDelayRestartBackoffTimeStrategy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/05/29 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12670) Implement FailureRateRestartBackoffTimeStrategy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2019/05/29 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12671) Summarizer: summary statistics for Table - posted by "Xu Yang (JIRA)" <ji...@apache.org> on 2019/05/29 09:32:00 UTC, 0 replies.
- Key state does not support migration - posted by Richard Deurwaarder <ri...@xeli.eu> on 2019/05/29 11:35:19 UTC, 0 replies.
- [jira] [Created] (FLINK-12672) Use SingleInputGate.closeFuture in triggerPartitionStateCheck instead of consumer state in RemoteChannelStateChecker - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/29 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12673) Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2019/05/29 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12674) BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers is not implemented - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2019/05/29 13:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12675) Event time synchronization in Kafka consumer - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2019/05/29 13:42:00 UTC, 0 replies.
- [DISCUSS] FLIP-42: Savepoint Connector - posted by Seth Wiesman <se...@ververica.com> on 2019/05/29 15:27:01 UTC, 0 replies.
- [Discuss] FLIP-43: Savepoint Connector - posted by Seth Wiesman <sj...@gmail.com> on 2019/05/29 15:51:04 UTC, 1 replies.
- [jira] [Created] (FLINK-12676) add descriptor, validator, and factory for GenericInMemoryCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/29 18:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12677) Add descriptor, validator, and factory for HiveCatalog - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/29 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12678) Add AbstractCatalog to manage the common catalog name and default database name for catalogs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/29 19:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12679) Support 'default-database' config for catalog entries in SQL CLI yaml file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2019/05/29 19:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12680) Add timer type to metric system - posted by "Piyush Goyal (JIRA)" <ji...@apache.org> on 2019/05/30 01:47:00 UTC, 0 replies.
- Re: [Discuss] FLIP-43: Savepoint Connector - posted by vino yang <ya...@gmail.com> on 2019/05/30 01:55:19 UTC, 21 replies.
- [jira] [Created] (FLINK-12681) Make SimpleCounter thread-safe. - posted by "Piyush Goyal (JIRA)" <ji...@apache.org> on 2019/05/30 01:59:00 UTC, 0 replies.
- [RESULT] [VOTE] Release flink-shaded 7.0, release candidate #3 - posted by jincheng sun <su...@gmail.com> on 2019/05/30 06:43:41 UTC, 0 replies.
- [jira] [Created] (FLINK-12682) StringWriter support custom row delimiter - posted by "Xiaowei Wang (JIRA)" <ji...@apache.org> on 2019/05/30 08:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12683) Provide task manager's location information for checkpoint acknowledge message to improve the checkpoint log message - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2019/05/30 08:57:00 UTC, 0 replies.
- Flink internals - posted by John Tipper <jo...@hotmail.com> on 2019/05/30 10:29:34 UTC, 2 replies.
- [jira] [Created] (FLINK-12684) User defined configuration for per job clusters - posted by "Richard Moorhead (JIRA)" <ji...@apache.org> on 2019/05/30 19:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12685) Supports UNNEST query in blink planner - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2019/05/31 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12686) StreamGraph Supports Blink Batch Mode - posted by "Biao Liu (JIRA)" <ji...@apache.org> on 2019/05/31 04:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12687) ByteHashSet is always in dense mode - posted by "Liya Fan (JIRA)" <ji...@apache.org> on 2019/05/31 04:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12688) Make serializer lazy initialization thread safe in StateDescriptor - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 04:48:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink-shaded 7.0 released - posted by jincheng sun <su...@gmail.com> on 2019/05/31 05:53:20 UTC, 3 replies.
- Apply contribute to Apache Flink - posted by 何建宁 <he...@gmail.com> on 2019/05/31 06:07:15 UTC, 0 replies.
- [jira] [Created] (FLINK-12689) Building flink-dist fails because flink-azure-fs-hadoop jar cannot be added to /opt - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2019/05/31 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12690) Introduce Planner interface - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/05/31 10:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12691) Make Queue Capacity and Timeout of AsyncWaitOperator changeable during runtime - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2019/05/31 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 12:47:00 UTC, 0 replies.
- Join in Apache Flink community - posted by Pengfei Li <lp...@gmail.com> on 2019/05/31 13:07:12 UTC, 0 replies.
- [jira] [Created] (FLINK-12693) Store state per key-group in CopyOnWriteStateTable - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12694) Implement a HeapAccountingManager - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12695) Implement a HeapStatusMonitor - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12696) Implement a MmapManager - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12697) Support on-disk state storage for HeapKeyedStateBackend - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12698) Implement a SpillLoadManager - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12699) Reduce CPU consumption when snapshot/restore the spilled key-group - posted by "Yu Li (JIRA)" <ji...@apache.org> on 2019/05/31 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12700) Nodejs installation suggestions - posted by "xiezhiqiang (JIRA)" <ji...@apache.org> on 2019/05/31 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-12701) Column name alias causes exception when used with where and group-by - posted by "Josh Bradt (JIRA)" <ji...@apache.org> on 2019/05/31 15:26:00 UTC, 0 replies.