dev@flink.apache.org, 2017-09

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

- [Discuss] adding a new command line argument -sd/--savepointdirectory - posted by Bowen Li <bo...@offerupnow.com> on 2017/09/01 06:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work - posted by "Peter Ertl (JIRA)" <ji...@apache.org> on 2017/09/01 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/01 10:04:00 UTC, 0 replies.
- Start contributing to Flink - posted by Mikhail Lipkovich <li...@gmail.com> on 2017/09/01 10:51:09 UTC, 3 replies.
- [jira] [Created] (FLINK-7569) '1 record' delay for counted windowed streams - posted by "olivier sohn (JIRA)" <ji...@apache.org> on 2017/09/01 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7570) Fix broken link on faq page - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/01 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7571) Execution of TableSources with Time Indicators fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/01 20:06:00 UTC, 0 replies.
- [Discuss] reading of Snappy files - posted by Mikhail Lipkovich <li...@gmail.com> on 2017/09/01 20:40:28 UTC, 0 replies.
- [jira] [Created] (FLINK-7572) Improve TableSchema ValidationException message. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/09/04 00:29:00 UTC, 0 replies.
- Quick start guide - posted by Michael Fong <mc...@gmail.com> on 2017/09/04 01:56:50 UTC, 2 replies.
- Re: Streaming job gets slower and slower - posted by Till Rohrmann <tr...@apache.org> on 2017/09/04 09:47:12 UTC, 0 replies.
- Re: Sync Flink - posted by Aljoscha Krettek <al...@apache.org> on 2017/09/04 12:36:54 UTC, 0 replies.
- [jira] [Created] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/09/04 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7574) flink-clients - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 13:39:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/04 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7576) Add FutureUtils.retryWithDelay - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/04 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7577) flink-core - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/04 15:14:00 UTC, 0 replies.
- Question about Flink's savepoint - posted by Mu Kong <ko...@gmail.com> on 2017/09/05 01:06:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7578) WindowStream should support rich AggregateFunction - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2017/09/05 04:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7579) Documentation of yarn.application-attempts is not accurate - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2017/09/05 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7580) Let LeaderGatewayRetriever implementations automatically retry failed gateway retrieval operations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/05 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7581) Name netty threads of rest components - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7583) Create singleton isntance for the content type header - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/05 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7584) [Documentation] Add checkstyle version due to breaking change in the plugin - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/05 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7585) SimpleCounter not thread safe - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/05 15:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7586) Report Watermark metrics in all operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/05 16:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7587) Flink doesn't delete checkpoint file's dir from s3 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 18:02:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7588) Document RocksDB tuning for spinning disks - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/05 18:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 21:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/05 22:27:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7591) Support partition by and order by of MATCH_RECOGNIZE - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/06 05:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7592) How to close the output log like "Connected to JobManager at Actor" and "Job execution switched to status RUNNING."? - posted by "brighteast (JIRA)" <ji...@apache.org> on 2017/09/06 07:22:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7593) Generated plan does not create correct groups - posted by "Steffen Dienst (JIRA)" <ji...@apache.org> on 2017/09/06 09:14:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7594) Add a SQL CLI client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/06 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/06 12:44:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7596) Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType) - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/07 01:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 06:30:01 UTC, 2 replies.
- [jira] [Created] (FLINK-7598) ineffective shaded artifacts checks in travis_mvn_watchdog.sh - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/07 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/07 08:58:00 UTC, 0 replies.
- Checkpoints not removing - posted by rnosworthy <ry...@colonynetworks.com> on 2017/09/07 17:25:00 UTC, 1 replies.
- [jira] [Created] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/07 21:35:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7601) Support classifier in MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/08 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7602) Create sub tasks for porting the remaining rest handlers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/08 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7603) Support within clause in MatchRecognize - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/09/08 09:18:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7604) Add OpenTSDB metrics reporter - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/08 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7605) JDBCOutputFormat autoCommit - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/09/08 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7606) Memory leak on NestedMapsStateTable - posted by "Matteo Ferrario (JIRA)" <ji...@apache.org> on 2017/09/08 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks - posted by "Joshua Griffith (JIRA)" <ji...@apache.org> on 2017/09/08 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/08 20:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/08 20:40:00 UTC, 0 replies.
- Problem with basic example - posted by philippe <ph...@cnam.fr> on 2017/09/10 08:01:59 UTC, 9 replies.
- update data from two sources with Flink - posted by ziv <zi...@elbitsystems.com> on 2017/09/10 12:30:35 UTC, 1 replies.
- Using Maven Archetype Plugin 3.0+ to create flink-quickstart-java project - posted by Michael Fong <mc...@gmail.com> on 2017/09/10 13:57:01 UTC, 4 replies.
- [jira] [Created] (FLINK-7610) xerces lib conflict - posted by "Domenico Campagnolo (JIRA)" <ji...@apache.org> on 2017/09/11 05:51:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7611) add metrics to measure the data drop by watermark - posted by "aitozi (JIRA)" <ji...@apache.org> on 2017/09/11 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7612) Implement Event-driven Network IO - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/12 09:13:00 UTC, 0 replies.
- Input records rate at source tasks - posted by Luis Alves <lm...@gmail.com> on 2017/09/12 22:42:33 UTC, 1 replies.
- [jira] [Created] (FLINK-7613) Fix documentation error in QuickStart - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/13 03:21:00 UTC, 0 replies.
- got Warn message - "the expected leader session ID did not equal the received leader session ID " when using LocalFlinkMiniCluster to interpret scala code - posted by XiangWei Huang <xw...@gmail.com> on 2017/09/13 04:21:11 UTC, 0 replies.
- [jira] [Created] (FLINK-7614) Add a code snippet example of a valid POJO to "Data Types" documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/13 09:26:00 UTC, 0 replies.
- Run apache flink from intellij or eclipse - posted by Erdem erdfem <er...@gmail.com> on 2017/09/13 11:52:34 UTC, 1 replies.
- [jira] [Created] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule - posted by "Addison Higham (JIRA)" <ji...@apache.org> on 2017/09/13 21:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7616) Fix missing markups in Execution Configuration - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/14 03:10:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin - posted by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2017/09/14 05:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7618) Add BINARY supported in FlinkTypeFactory - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/09/14 08:43:00 UTC, 0 replies.
- Re: got Warn message - "the expected leader session ID did not equal the received leader session ID " when using LocalFlinkMiniCluster to interpret scala code - posted by Till Rohrmann <tr...@apache.org> on 2017/09/14 08:58:55 UTC, 3 replies.
- [jira] [Created] (FLINK-7619) Improve abstraction in AbstractAsyncIOCallable to better fit - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/14 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7620) Supports custom optimization phase - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/09/14 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7621) Fix inconsistency of CaseSensitive Configuration - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/09/14 12:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/14 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/14 12:44:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/14 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7625) typo in docs metrics sections - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/14 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7626) Add some metric description about checkpoints - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/09/14 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7627) SingleElementIterable should implement with Serializable - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2017/09/15 03:08:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7628) Add cookbooks to the documentation - posted by "James Lafa (JIRA)" <ji...@apache.org> on 2017/09/15 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7629) Scala stream aggregations should support nested field expressions - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/15 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/15 14:41:00 UTC, 0 replies.
- Re: [jira] [Commented] (FLINK-7606) CEP operator leaks state - posted by Kostas Kloudas <k....@data-artisans.com> on 2017/09/15 15:54:22 UTC, 0 replies.
- Elasticsearch connector - posted by "Premkumar, Ramprabhu" <ra...@verizon.com> on 2017/09/15 17:05:59 UTC, 3 replies.
- [jira] [Created] (FLINK-7631) Ineffective check in PageRank#open() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/16 13:22:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7632) Better documentation on C* sink usage for Pojo and Tuples data types - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7633) Better documentation on C* sink on consistency guarantee - posted by "Michael Fong (JIRA)" <ji...@apache.org> on 2017/09/16 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/17 01:01:39 UTC, 0 replies.
- [jira] [Created] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2017/09/18 00:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7636) Introduce Flink RelOptTable, and remove tableSource from all TableSourceScan node constructor - posted by "jingzhang (JIRA)" <ji...@apache.org> on 2017/09/18 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/18 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7638) Port CurrentJobsOverviewHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7639) TaskExecutorITCase is flakey - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/18 21:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7640) Dashboard should display information about JobManager cluster in HA mode - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/19 00:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7641) Loss of JobManager in HA mode should not cause jobs to fail - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/19 01:04:58 UTC, 0 replies.
- [jira] [Created] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/19 03:41:01 UTC, 0 replies.
- [DISCUSS] Dropping Scala 2.10 - posted by Aljoscha Krettek <al...@apache.org> on 2017/09/19 09:56:00 UTC, 1 replies.
- Re: [DISCUSS] Dropping Scala 2.10 - posted by Till Rohrmann <tr...@apache.org> on 2017/09/19 10:00:20 UTC, 12 replies.
- [jira] [Created] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/19 14:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-7644) Line the extra semicolon in the source code - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 01:08:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7645) Modify system-metrics part show in the document - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7646) Restart failed jobs with configurable parallelism range - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/20 04:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7648) Port TaskManagersHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 08:59:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7649) Port JobStoppingHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7651) RetryingRegistration does not wait between failed connection attempts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7650) Port JobCancellationHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/20 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7654) Update RabbitMQ Java client to 4.x - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/20 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7655) Revisit default non-leader id for FencedRpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/20 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7656) Switch to user ClassLoader when invoking initializeOnMaster finalizeOnMaster - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/20 14:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/20 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7658) Support COLLECT Aggregate function in Flink TABLE API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/20 20:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/20 21:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/21 05:24:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7661) Add credit field in PartitionRequest message - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/21 08:26:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7662) Remove unnecessary packaged licenses - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/09/21 14:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7663) Allow AbstractRestHandler to handle bad requests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 15:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7664) Replace FlinkFutureException by CompletionException - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/21 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7665) Use wait/notify in ContinuousFileReaderOperator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/21 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/21 20:00:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-21 - Improve object Copying/Reuse Mode for Streaming Runtime - posted by Aljoscha Krettek <al...@apache.org> on 2017/09/22 08:10:31 UTC, 0 replies.
- [jira] [Created] (FLINK-7667) Add serializable AccessExecutionGraph implementation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/22 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/22 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig - posted by "Raymond Tay (JIRA)" <ji...@apache.org> on 2017/09/22 09:17:00 UTC, 0 replies.
- Question: Flink documentation contribution only to flink-docs-release-1.3 (not flink-docs-release-1.4) - posted by Kewei Shang <ke...@gmail.com> on 2017/09/22 10:15:59 UTC, 2 replies.
- Zookeeper failure handling - posted by Gyula Fóra <gy...@gmail.com> on 2017/09/22 11:54:13 UTC, 14 replies.
- [jira] [Created] (FLINK-7670) typo in docs runtime section - posted by "Kewei SHANG (JIRA)" <ji...@apache.org> on 2017/09/22 13:20:01 UTC, 0 replies.
- LocalStreamEnvironment - configuration doesn't seem to be used in RichFunction operators - posted by Michael Kobit <mk...@gmail.com> on 2017/09/22 16:02:32 UTC, 0 replies.
- [jira] [Created] (FLINK-7671) JobManagerCleanupITCase failed in build - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/22 21:03:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7672) Publish Kinesis connector to Maven Central? - posted by "Radoslaw Gruchalski (JIRA)" <ji...@apache.org> on 2017/09/22 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code - posted by "Radoslaw Gruchalski (JIRA)" <ji...@apache.org> on 2017/09/22 23:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/23 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2017/09/23 10:47:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7676) ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/23 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7677) Add side outputs to ProcessWindowFunction - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/09/23 15:26:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/09/23 20:42:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7679) Upgrade maven enforcer plugin to 3.0.0-M1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/09/23 21:38:00 UTC, 0 replies.
- Re: Support for multiple HDFS - posted by Haohui Mai <ri...@gmail.com> on 2017/09/24 08:02:49 UTC, 0 replies.
- [jira] [Created] (FLINK-7680) Add "Performance Tuning" section to docs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/24 18:06:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7681) Support arbitrary TypeInformation in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/25 10:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7682) Invalid state size formatting - posted by "Andrey (JIRA)" <ji...@apache.org> on 2017/09/25 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 13:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7684) Avoid multiple data copies in MergingWindowSet - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/25 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7685) CompilerException: "Bug: Logic for branching plans (non-tree plans) has an error, and does not track the re-joining of branches correctly" - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/25 14:18:10 UTC, 0 replies.
- [jira] [Created] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website - posted by "Hai Zhou_UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/25 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/25 22:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited - posted by "Bill Liu (JIRA)" <ji...@apache.org> on 2017/09/26 01:13:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7689) Instrument the Flink JDBC connector - posted by "Martin Eden (JIRA)" <ji...@apache.org> on 2017/09/26 06:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7690) Do not call actorSystem.awaitTermination from the main akka message handling thread - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/09/26 07:05:00 UTC, 0 replies.
- RE: is flink' states functionality futile? - posted by ziv <zi...@elbitsystems.com> on 2017/09/26 08:20:06 UTC, 3 replies.
- Regarding flink-cassandra - posted by Jagadish Gangulli <ja...@gmail.com> on 2017/09/26 09:00:46 UTC, 1 replies.
- Question about Flink Metrics - posted by Tony Wei <to...@gmail.com> on 2017/09/26 09:49:26 UTC, 4 replies.
- [jira] [Created] (FLINK-7691) Remove ClassTag in Scala DataSet API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/26 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7692) Support user-defined variables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/26 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7693) Adapt web frontend to use proper DELETE REST call for job termination - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/26 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7694) Port JobMetricsHandler to new REST handler - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/26 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7695) Port JobConfigHandler to new REST endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/26 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7696) Add projection push-down support for TableSources with time attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/26 17:36:00 UTC, 0 replies.
- Re: [E] Re: Elasticsearch connector - posted by "Premkumar, Ramprabhu" <ra...@verizon.com> on 2017/09/26 20:09:46 UTC, 1 replies.
- Re: [DISCUSS] Service Authorization (redux) - posted by Eron Wright <er...@gmail.com> on 2017/09/27 04:46:24 UTC, 0 replies.
- [jira] [Created] (FLINK-7697) Add metrics for Elasticsearch Sink - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/27 06:08:01 UTC, 0 replies.
- Question about job canceling in Flink - posted by wangsan <wa...@163.com> on 2017/09/27 06:55:38 UTC, 1 replies.
- [jira] [Created] (FLINK-7698) Join with null literals leads to NPE - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/09/27 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/09/27 10:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7700) State merging in RocksDB backend leaves old state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/27 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7701) IllegalArgumentException in Netty bootstrap with small memory state segment size - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/27 11:43:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7702) Javadocs link broken - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2017/09/27 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7704) Port JobPlanHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7705) Port JobDetailsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7711) Port JarListHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:00:10 UTC, 0 replies.
- [jira] [Created] (FLINK-7712) Port JarDeleteHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7713) Port JarUploadHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7714) Port JarPlanHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7715) Port JarRunHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:07:00 UTC, 0 replies.
- JIRA contributor rights for FLINK - posted by Malcolm Taylor <ma...@semmle.com> on 2017/09/27 15:07:56 UTC, 1 replies.
- [jira] [Created] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7719) Send checkpoint id to task as part of deployment descriptor when resuming - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/27 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7720) Centralize creation of backends and state related resources - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/09/27 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/27 18:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7722) MiniCluster does not appear to honor Log4j settings - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/09/27 20:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7723) DispatcherTest instable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/09/27 21:50:00 UTC, 0 replies.
- What can Mnemonic do with Flink ? - posted by Gang Wang <ga...@apache.org> on 2017/09/27 21:58:28 UTC, 0 replies.
- [jira] [Created] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/09/27 22:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7725) Add test base for marshalling requests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7726) Move marshalling testbases out of legacy namespace - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7727) Extend logging in file server handlers - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/09/28 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/09/28 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7729) Remove Scala 2.10 support; add Scala 2.12 support - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/09/28 12:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/09/28 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7731) Trigger on GlobalWindow does not clean state completely - posted by "Gerard Garcia (JIRA)" <ji...@apache.org> on 2017/09/28 14:12:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7732) test instability in Kafa end-to-end test (invalid Kafka offset) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7733) test instability in Kafa end-to-end test (RetriableCommitFailedException) - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7734) test instability in ResourceManagerTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/09/28 15:36:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7736) Fix some of the alerts raised by lgtm.com - posted by "Malcolm Taylor (JIRA)" <ji...@apache.org> on 2017/09/28 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7735) Improve date/time handling in publically-facing Expressions - posted by "Kent Murra (JIRA)" <ji...@apache.org> on 2017/09/28 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss - posted by "Ryan Hobbs (JIRA)" <ji...@apache.org> on 2017/09/28 19:11:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7738) Create WebSocket handler (server) - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/09/29 03:15:10 UTC, 0 replies.
- [jira] [Created] (FLINK-7739) Improve Kafka*ITCase tests stability - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/09/29 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7740) Add parameter support in CassandraInputFormat - posted by "Bin Wang (JIRA)" <ji...@apache.org> on 2017/09/29 19:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7741) Fix NPE when throw new SlotNotFoundException - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/30 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7742) Fix array access might be out of bounds - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/09/30 06:44:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7743) Remove the restriction of minimum memory of JM - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/09/30 17:26:03 UTC, 0 replies.