dev@flink.apache.org, 2018-04

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

- [jira] [Created] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/04/02 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9121) Remove Flip-6 prefixes from code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/02 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9122) NFASerialize deserailze failed and cause other exception - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/04/02 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9123) Scala version of ProcessFunction doesn't work - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/04/02 19:42:00 UTC, 0 replies.
- [VOTE] Release 1.5.0, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2018/04/02 19:47:10 UTC, 10 replies.
- Kinesis getRecords read timeout and retry - posted by Thomas Weise <th...@apache.org> on 2018/04/03 01:14:27 UTC, 5 replies.
- Apply for contribution permission - posted by jianhua xiao <em...@gmail.com> on 2018/04/03 01:59:27 UTC, 1 replies.
- [jira] [Created] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/04/03 04:49:00 UTC, 0 replies.
- Re: Adding a part suffix setter to the BucketingSink - posted by Aljoscha Krettek <al...@apache.org> on 2018/04/03 07:57:01 UTC, 1 replies.
- Re: [Proposal] CEP library changes - review request - posted by Shailesh Jain <sh...@stellapps.com> on 2018/04/03 09:01:52 UTC, 2 replies.
- Re: Using Slack for online discussions - posted by Chesnay Schepler <ch...@apache.org> on 2018/04/03 11:50:50 UTC, 8 replies.
- [jira] [Created] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/03 12:05:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #14 - posted by Till Rohrmann <tr...@apache.org> on 2018/04/03 14:03:10 UTC, 0 replies.
- [jira] [Created] (FLINK-9126) Ability for CassandraInputFormat to output data into a Custom Cassandra Annotated Pojo - posted by "Jeffrey Carter (JIRA)" <ji...@apache.org> on 2018/04/03 15:06:00 UTC, 0 replies.
- Trying to restart Flink jobs from savepoint with Avro Schema change - posted by Dhvanan Shah <dh...@reflektion.com> on 2018/04/04 00:36:53 UTC, 1 replies.
- [jira] [Created] (FLINK-9127) Filesystem State Backend logged incorrectly - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2018/04/04 00:59:00 UTC, 0 replies.
- TaskManager deadlock on NetworkBufferPool - posted by Amit Jain <aj...@gmail.com> on 2018/04/04 06:03:10 UTC, 8 replies.
- [jira] [Created] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/04 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9129) Support nested KafkaJsonTableSource - posted by "samar (JIRA)" <ji...@apache.org> on 2018/04/04 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9131) Disable spotbugs on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 14:42:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9132) Cluster runs out of task slots when a job falls into restart loop - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/04 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9133) Improve documentability of REST API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9134) Update Calcite dependency to 1.17 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 16:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9136) Remove StreamingProgramTestBase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 17:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9137) Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9138) Enhance BucketingSink to also flush data by time interval - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/04 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9139) Allow yarn.tags as a job parameter - posted by "Nikhil Simha (JIRA)" <ji...@apache.org> on 2018/04/05 00:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9140) simplify scalastyle configurations - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/05 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/05 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/05 13:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/06 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9144) Spilling batch job hangs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/06 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9145) Website build is broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:38:01 UTC, 0 replies.
- Re: Multi-stream question - posted by TechnoMage <ml...@technomage.com> on 2018/04/07 17:47:12 UTC, 3 replies.
- [jira] [Created] (FLINK-9146) 1.4 more than local cannot start submitting - posted by "abel-sun (JIRA)" <ji...@apache.org> on 2018/04/08 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/08 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution" - posted by "You Chu (JIRA)" <ji...@apache.org> on 2018/04/08 14:58:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9149) The creation of the ExecutionPlan fails when you combine a SideOutput with an SplitStream. - posted by "Fred Teunissen (JIRA)" <ji...@apache.org> on 2018/04/09 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9150) Prepare for Java 10 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/09 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers - posted by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/04/09 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9152) Harmonize BroadcastProcessFunction Context names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/09 23:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9153) TaskManagerRunner should support rpc port range - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/10 09:44:00 UTC, 0 replies.
- Flink 1.3.2 with CEP Pattern, Memory usage increases results in OOM - posted by Abiramalakshmi Natarajan <ab...@gmail.com> on 2018/04/10 11:19:59 UTC, 1 replies.
- [jira] [Created] (FLINK-9154) Include WebSubmissionExtension in REST API docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/10 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9155) Provide message context information in DeserializationSchema - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/10 11:51:00 UTC, 0 replies.
- Access to ProcessingTimeService from the RuntimeContext interface? - posted by Andrew Roberts <ar...@fuze.com> on 2018/04/10 18:32:51 UTC, 1 replies.
- [jira] [Created] (FLINK-9156) CLI does not respect -m,--jobmanager option - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/11 10:02:00 UTC, 0 replies.
- Support for out-of-the-box external catalog for SQL Client - posted by Rong Rong <wa...@gmail.com> on 2018/04/11 17:52:18 UTC, 6 replies.
- [jira] [Created] (FLINK-9157) Create support for commonly used external catalog - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/11 19:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9159) Sanity check default timeout values - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9160) Make subclasses of RuntimeContext internal that should be internal - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/12 02:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9161) Support AS STRUCT syntax to create named STRUCT in SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/12 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9162) Scala REPL hanging when running example - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/04/12 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/12 15:26:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.5.0 - posted by Christophe Jolif <cj...@gmail.com> on 2018/04/12 16:17:21 UTC, 2 replies.
- [jira] [Created] (FLINK-9164) times(#,#) quantifier does not seem to work - posted by "Romain Revol (JIRA)" <ji...@apache.org> on 2018/04/12 20:19:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9165) Improve CassandraSinkBase to send Collections - posted by "Christopher Hughes (JIRA)" <ji...@apache.org> on 2018/04/12 21:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9166) Performance issue with Flink SQL - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/04/13 00:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9167) Approximate KNN with Incremental Insertion - posted by "Alex Klibisz (JIRA)" <ji...@apache.org> on 2018/04/13 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9168) Pulsar Sink Connector - posted by "Xiao Zongyang (JIRA)" <ji...@apache.org> on 2018/04/13 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/13 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9170) HCatolog integration with Table/SQL API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9171) Flink HCatolog integration - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9172) Support external catalog factory that comes default with SQL-Client - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/14 00:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9173) RestClient - Received response is abnormal - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/14 01:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/14 10:20:00 UTC, 0 replies.
- Documentation glitch w/AsyncFunction? - posted by Ken Krugler <kk...@transpac.com> on 2018/04/14 15:34:41 UTC, 3 replies.
- [jira] [Created] (FLINK-9175) Flink CEP with Checkpointing alway failed - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/04/15 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9176) Category annotations are unused - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/15 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Arunan Sugunakumar (JIRA)" <ji...@apache.org> on 2018/04/16 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9178) Add rate control for kafka source - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/16 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9180) Remove REST_ prefix from rest options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9181) Add SQL Client documentation page - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/16 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9182) async checkpoints for timer service - posted by "makeyang (JIRA)" <ji...@apache.org> on 2018/04/16 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9183) Kafka consumer docs to warn about idle partitions - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/04/16 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9184) Remove warning from kafka consumer docs - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/04/16 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/16 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9186) Enable dependency convergence for flink-libraries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 17:19:00 UTC, 0 replies.
- Validating markdown doc files before creating a PR - posted by Ken Krugler <kk...@transpac.com> on 2018/04/16 19:17:20 UTC, 1 replies.
- [jira] [Created] (FLINK-9187) add prometheus pushgateway reporter - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/04/17 02:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/04/17 03:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9189) Add a SBT and Gradle Quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9190) YarnResourceManager sometimes does not request new Containers - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9191) Misleading URLs for website source - posted by "Sebb (JIRA)" <ji...@apache.org> on 2018/04/17 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9192) Undo parameterization of StateMachine Example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9193) Deprecate non-well-defined output methods on DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/17 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9194) Finished jobs are not archived to HistoryServer - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9195) Delete non-well-defined output methods on DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/17 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 15:07:00 UTC, 0 replies.
- CaseClassSerializer and/or TraversableSerializer may still not be threadsafe? - posted by joshlemer <jo...@gmail.com> on 2018/04/17 16:05:51 UTC, 0 replies.
- [jira] [Created] (FLINK-9197) Improve error message for TypyInformation and TypeHint with generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 17:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 18:54:00 UTC, 0 replies.
- [Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization - posted by Eron Wright <er...@gmail.com> on 2018/04/17 22:43:07 UTC, 2 replies.
- [jira] [Created] (FLINK-9199) SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/18 05:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9200) SQL E2E test failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 07:40:00 UTC, 0 replies.
- understanding flink's codes - posted by Mehmet EKICI <me...@NETAS.com.tr> on 2018/04/18 08:11:35 UTC, 1 replies.
- [jira] [Created] (FLINK-9201) same merge window will fire twice if watermark already pass the window for merge windows - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/04/18 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9203) Deprecate non-well-defined SinkFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 11:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9204) Improve visibility of records being skipped by the `DeserializationSchema` in the Kafka / Kinesis connectors - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9205) Delete non-well-defined SinkFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9206) CheckpointCoordinator log messages do not contain the job ID - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/18 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/04/18 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9208) StreamNetworkThroughputBenchmarkTests not run in Maven - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/18 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9209) Several handlers do not properly handle unknown ids - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 15:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9210) Call getValue() only once in gauge serialization - posted by "Jisu You (JIRA)" <ji...@apache.org> on 2018/04/18 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9213) Revert breaking change in checkpoint detail URL - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 17:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/18 19:25:02 UTC, 0 replies.
- [jira] [Created] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/19 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9216) Fix comparator violation - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/04/19 06:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 07:28:05 UTC, 0 replies.
- [jira] [Created] (FLINK-9218) Docs for old versions aren't building successfully - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9219) Add support for OpenGIS features in Table & SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9220) Table program cannot be compiled - posted by "Saurabh Garg (JIRA)" <ji...@apache.org> on 2018/04/19 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/04/19 15:16:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9222) Add a Gradle Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/19 17:04:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9225) Minor code comments fix in RuntimeContext - posted by "binlijin (JIRA)" <ji...@apache.org> on 2018/04/20 06:51:00 UTC, 0 replies.
- [Discussion] Flink Pulsar Connector - posted by Sijie Guo <gu...@gmail.com> on 2018/04/20 07:08:25 UTC, 5 replies.
- [jira] [Created] (FLINK-9226) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9228) log details about task fail/task manager is shutting down - posted by "makeyang (JIRA)" <ji...@apache.org> on 2018/04/20 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9229) Fix literal handling in code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/20 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/21 04:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/21 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9232) Add harness test for AggregationCodeGenerator - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/22 00:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/22 13:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9234) Commons Logging is missing from shaded Flink Table library - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/04/22 17:58:00 UTC, 0 replies.
- Re: [Discuss] Proposing FLIP-25 - Support User State TTL Natively in Flink - posted by Bowen <bo...@gmail.com> on 2018/04/22 19:14:19 UTC, 2 replies.
- [jira] [Created] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/22 23:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9236) Use Apache Parent POM 19 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/23 02:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/23 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9238) There are some questions about BuckeingSink when sinking data to S3. - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/23 10:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9239) Reintroduce example program in quickstarts - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9240) Avoid deprecated akka methods - posted by "Arnout Engelen (JIRA)" <ji...@apache.org> on 2018/04/23 15:52:00 UTC, 0 replies.
- Flink streaming job on yarn-cluster - posted by Qiong Wei <qi...@microsoft.com.INVALID> on 2018/04/23 20:07:22 UTC, 2 replies.
- [jira] [Created] (FLINK-9241) Scala version of Gauge (metric) doesn't work - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/04/23 20:23:00 UTC, 0 replies.
- Re: [jira] [Created] (FLINK-9075) BucketingSink S3 does not work on local cluster - posted by deanding <di...@gmail.com> on 2018/04/23 21:33:20 UTC, 0 replies.
- [jira] [Created] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING - posted by "Miguel E. Coimbra (JIRA)" <ji...@apache.org> on 2018/04/24 00:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 03:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9244) Can't create a BucketingSink with a provided Configuration if no hadoop defaults - posted by "Julien Cuquemelle (JIRA)" <ji...@apache.org> on 2018/04/24 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults - posted by "Julien Cuquemelle (JIRA)" <ji...@apache.org> on 2018/04/24 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9246) HistoryServer job overview broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9247) Allow creating table sources/sinks from an Avro schema - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/24 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9248) Create a SQL Client Avro format fat-jar - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/24 08:46:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9249) Add convenience profile for skipping non-essential plugins - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9251) Move MemoryStateBackend to flink-state-backends - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 16:17:00 UTC, 0 replies.
- Why assignTimestampsAndWatermarks parallelism same as map，it will not fired？ - posted by 潘功森 <pa...@hotmail.com> on 2018/04/25 03:15:50 UTC, 0 replies.
- [jira] [Created] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2018/04/25 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/25 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/04/25 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/04/25 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9256) NPE in SingleInputGate#updateInputChannel() for non-credit based flow control - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/25 14:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/04/25 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/25 18:50:00 UTC, 0 replies.
- CoProcessFunction doesn't support timer on keyed stream - posted by Ken Krugler <kk...@transpac.com> on 2018/04/26 00:37:42 UTC, 2 replies.
- [jira] [Created] (FLINK-9259) The implementation of the SourceFunction is not serializable. - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/26 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9260) Introduce a friendly way to resume the job from externalized checkpoints automatically - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/26 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/04/26 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot - posted by "Chris Schneider (JIRA)" <ji...@apache.org> on 2018/04/26 13:49:00 UTC, 0 replies.
- request for contributor permission - posted by Steven Wu <st...@gmail.com> on 2018/04/26 20:34:10 UTC, 5 replies.
- Introduction - posted by tarush grover <ta...@gmail.com> on 2018/04/27 06:25:49 UTC, 0 replies.
- Assign JIRA issue permission - posted by Sampath Bhat <sa...@gmail.com> on 2018/04/27 08:02:40 UTC, 1 replies.
- [jira] [Created] (FLINK-9263) Kafka010ITCase failed on travis flaky - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 12:00:00 UTC, 0 replies.
- How to start guide for developers - posted by tarush grover <ta...@gmail.com> on 2018/04/27 12:39:40 UTC, 2 replies.
- [jira] [Created] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B] - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/04/27 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9265) Upgrade Prometheus version - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/27 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9266) Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis describe streams calls - posted by "Thomas Moser (JIRA)" <ji...@apache.org> on 2018/04/27 18:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9267) Classloading issues when using RemoteEnvironment ... - posted by "Kedar Mhaswade (JIRA)" <ji...@apache.org> on 2018/04/27 20:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9268) RockDB errors from WindowOperator - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/27 22:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/28 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9270) Upgrade RocksDB to 5.11.3, and resolve concurrent test invocation problem of @RetryOnFailure - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/28 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9271) flink-1.4.2-bin-scala_2.11.tgz is not in gzip format - posted by "Martin Grigorov (JIRA)" <ji...@apache.org> on 2018/04/28 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9272) DataDog API "counter" metric type is deprecated - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/04/28 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9273) Class cast exception - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/29 17:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9274) Add thread name to Kafka Partition Discovery - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/30 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9275) Set more distinctive output flusher thread names - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/30 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9276) Improve error message when TaskManager fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 17:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9277) Reduce noisiness of SlotPool logging - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 17:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed - posted by "Adrian Hains (JIRA)" <ji...@apache.org> on 2018/04/30 18:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9279) PythonPlanBinderTest flakey - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 19:03:00 UTC, 0 replies.