You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-10012) Support setStreamTimeCharacteristic for Python API - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/01 03:56:00 UTC, 0 replies.
- Re: [VOTE] Release 1.5.0, release candidate #2 - posted by shashank734 <sh...@gmail.com> on 2018/08/01 07:44:02 UTC, 0 replies.
- Error while building 1.5.1 from source - posted by shashank734 <sh...@gmail.com> on 2018/08/01 07:46:46 UTC, 2 replies.
- Re: Consuming data from dynamoDB streams to flink - posted by Ying Xu <yx...@lyft.com> on 2018/08/01 08:12:05 UTC, 0 replies.
- [jira] [Created] (FLINK-10013) Fix Kerberos integration for FLIP-6 YarnTaskExecutorRunner - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/08/01 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10014) Fix the decimal literal parameter problem for arithmetic functions in Table - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/08/01 09:11:00 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink 1.5.2 released - posted by Till Rohrmann <tr...@apache.org> on 2018/08/01 09:28:27 UTC, 0 replies.
- [jira] [Created] (FLINK-10015) Use Elasticsearch's ESIntegTestCase to rework 5.x and 6.x's ITCases - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/08/01 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10016) Make YARN/Kerberos end-to-end test stricter - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/08/01 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10017) Support keyed formats for Kafka table source sink factory - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/01 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10018) Want to have stop command with checkpointing - posted by "Keshav Lodhi (JIRA)" <ji...@apache.org> on 2018/08/01 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10019) Fix Composite getResultType of UDF cannot be chained with other operators - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/08/01 18:37:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10020) Kinesis Consumer listShards should support more recoverable exceptions - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/08/01 21:25:00 UTC, 0 replies.
- [HELP] Bisect - posted by 陈梓立 <wa...@gmail.com> on 2018/08/02 07:14:32 UTC, 1 replies.
- [jira] [Created] (FLINK-10021) All-round E2E tests query metric with wrong operator name - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/02 07:47:00 UTC, 0 replies.
- Re: [apache/flink-web] One of your dependencies may have a security vulnerability - posted by Ufuk Celebi <uc...@apache.org> on 2018/08/02 09:10:36 UTC, 1 replies.
- [jira] [Created] (FLINK-10022) Add metrics for input/output buffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/02 11:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10023) Enhance Python API for streaming - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/02 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10024) Test enable_checkpoint python API - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/02 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10025) Add getCheckpointConfig API for PythonStreamExecutionEnvironment - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/02 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10026) Integrate heap based timers in RocksDB backend with incremental checkpoints - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/02 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10027) Add logging to the StreamingFileSink - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/08/02 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10028) Introduce ByteArrayData[Input|Output]View - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/02 12:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10029) Refactor the code for better separation of concerns. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/08/02 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode - posted by "qiang.li (JIRA)" <ji...@apache.org> on 2018/08/02 12:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10031) Support handling late events in Table API & SQL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/02 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10032) Flink SQL DATE_FORMAT Function throw Exception in SQL CLI - posted by "Rann Tao (JIRA)" <ji...@apache.org> on 2018/08/02 13:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10033) Let Task release reference to Invokable on shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/02 19:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10034) Update community page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/02 19:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10035) ConcurrentModificationException with flink-metrics-slf4j - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/02 19:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10036) Flink's CSV output format is not consistent with the standard. - posted by "Caizhi Weng (JIRA)" <ji...@apache.org> on 2018/08/03 02:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10037) Document details event time behavior in a single location - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/08/03 03:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10038) Parallel the creation of InputSplit if necessary - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/08/03 05:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10039) FlinkKafkaProducer - Serializer Error - posted by "Akshay Nagpal (JIRA)" <ji...@apache.org> on 2018/08/03 05:50:00 UTC, 0 replies.
- Permission for contributor status - posted by Sampath Bhat <sa...@gmail.com> on 2018/08/03 07:04:44 UTC, 3 replies.
- [jira] [Created] (FLINK-10040) Decompose RocksDBKeyedStateBackend - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/03 08:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10041) Extract all different iterators (inner or static inner classes) into full classes - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/03 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10042) Extract snapshot algorithms from inner classes into full classes - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/03 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10043) Refactor object construction/inititlization/restore code - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/03 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10044) Check proper RIA style and introduce it where missing - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/03 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10045) .bat script to start/stop Flink daemon - posted by "Pavel Shvetsov (JIRA)" <ji...@apache.org> on 2018/08/03 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10046) .bat script to start a Flink service as a console application - posted by "Pavel Shvetsov (JIRA)" <ji...@apache.org> on 2018/08/03 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10047) Checkpointing takes much longer with credit base flow control. - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/08/03 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10048) Migrate module flink-gelly-examples to flink-examples and rename it - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/03 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10049) Unify the processing logic for NULL arguments in SQL built-in functions - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/08/03 14:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams - posted by "eugen yushin (JIRA)" <ji...@apache.org> on 2018/08/03 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10051) SQL client E2E test is missing dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/03 16:19:00 UTC, 0 replies.
- [VOTE] Release 1.6.0, release candidate #2 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/03 16:23:15 UTC, 15 replies.
- [ANNOUNCE] Weekly community update #31 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/03 16:24:46 UTC, 0 replies.
- [jira] [Created] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/03 17:32:00 UTC, 0 replies.
- Setting an allowable number of checkpoint failures - posted by Lakshmi Gururaja Rao <lr...@lyft.com> on 2018/08/03 20:28:18 UTC, 7 replies.
- [jira] [Created] (FLINK-10053) Add getParallelism API for PythonStreamExecutionEnvironment - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/04 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10054) Add getMaxParallelism/setMaxParallelism API for PythonStreamExecutionEnvironment - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/04 04:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10055) incorrect in-progress file suffix in BucketingSink's doc - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/08/04 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10056) Add testRequestNextInputSplit - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/08/04 10:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10057) optimalize org.apache.flink.yarn.cli.FlinkYarnSessionCli.isYarnPropertiesFileMode - posted by "liuzq (JIRA)" <ji...@apache.org> on 2018/08/04 15:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10058) Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/05 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10059) Add LTRIM supported in Table API and SQL - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/05 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10060) Add RTRIM supported in Table API and SQL - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/05 08:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10061) Fix unsupported configuration in KafkaTableSink - posted by "Jun Zhang (JIRA)" <ji...@apache.org> on 2018/08/05 09:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10062) Docs are not built due to git-commit-id-plugin - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/05 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10063) Jepsen: Automatically restart Mesos Processes - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/08/05 12:49:00 UTC, 0 replies.
- SSL Error on Flink-Kafka - posted by Yaz Sh <ya...@gmail.com> on 2018/08/05 16:43:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10064) Fixed a typo in ExternalCatalogTable - posted by "Jun Zhang (JIRA)" <ji...@apache.org> on 2018/08/05 16:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2018/08/06 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10066) Keep only archived version of previous executions - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/06 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/08/06 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10068) Add documentation for async/RocksDB-based timers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/06 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10069) Add docs for updates SSL model - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/06 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10070) Flink cannot be compiled with maven 3.0.x - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/06 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10071) Document usage of INSERT INTO in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/06 11:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern" documentation - posted by "Rick Hofstede (JIRA)" <ji...@apache.org> on 2018/08/06 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10073) Allow setting a restart strategy in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/06 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10074) Allowable number of checkpoint failures - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/08/06 16:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10075) HTTP connections to a secured REST endpoint flood the log - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/06 17:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10076) Upgrade Calcite dependency to 1.18 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/08/06 22:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10077) Web UI should respond when there is no elected Dispatcher - posted by "Joey Echeverria (JIRA)" <ji...@apache.org> on 2018/08/07 00:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10078) Dispatcher should only block job submission during recovery - posted by "Joey Echeverria (JIRA)" <ji...@apache.org> on 2018/08/07 00:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10079) Automatically resolve and register sink table name from external catalogs - posted by "Jun Zhang (JIRA)" <ji...@apache.org> on 2018/08/07 07:27:00 UTC, 0 replies.
- [VOTE] Release 1.6.0, release candidate #3 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/07 08:01:30 UTC, 3 replies.
- [jira] [Created] (FLINK-10080) Add support for processing time to interval join - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/08/07 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10081) Asynchronous (un)registration of metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10082) Initialize StringBuilder in Slf4jReporter with estimated size - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10083) Kafka08ITCase#testOneSourceMultiplePartitions failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 08:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10084) Migration tests weren't updated for 1.5 & 1.6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10085) Update AbstractOperatorRestoreTestBase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10086) Update CEPMigrationTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10087) Update BucketingSinkMigrationTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10088) error when trying to run flink-sql-client on windows - posted by "anubhav tarar (JIRA)" <ji...@apache.org> on 2018/08/07 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10089) Update FlinkKafkaConsumerBaseMigrationTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 10:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10090) Update ContinuousFileProcessingMigrationTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 11:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10091) Update WindowOperatorMigrationTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 11:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10092) Update StatefulJobSavepointMigrationITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 11:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10093) Update StatefulJobWBroadcastStateMigrationITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10094) Always backup default config for end-to-end tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/07 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10095) Change the serialisation order in TTL value wrapper - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/08/07 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10096) Metrics report incorrect subtask ids - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/08/07 13:20:00 UTC, 0 replies.
- [VOTE] Release 1.6.0, release candidate #4 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/07 15:17:24 UTC, 14 replies.
- [ANNOUNCE] Weekly community update #32 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/07 15:18:37 UTC, 0 replies.
- [jira] [Created] (FLINK-10097) More tests to increase StreamingFileSink test coverage - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/08/07 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10098) Programmatically select timer storage backend - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/08/07 21:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10099) Rework YarnResourceManagerTest - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/08/08 03:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10100) Optimizer pushes partitioning past Null-Filter - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/08/08 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10101) Mesos web ui url is missing. - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/08/08 10:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10102) EXECUTION_FAILOVER_STRATEGY docs are wrong - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/08 11:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10103) Refine built-in-functions docs for SQL - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/08/08 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10104) Job super slow to start - posted by "Florian (JIRA)" <ji...@apache.org> on 2018/08/08 19:48:00 UTC, 0 replies.
- [Discussion] Move cluster creation functions from flink-cli.sh to other scripts - posted by Renjie Liu <li...@gmail.com> on 2018/08/09 02:33:46 UTC, 3 replies.
- [jira] [Created] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/09 03:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10106) Include test name in temp directory of e2e test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/09 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10107) SQL Client end-to-end test fails for releases - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/09 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10108) DATE_FORMAT function in sql test throws a NumberFormatException - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/08/09 09:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10109) Add documentation for StreamingFileSink - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/08/09 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10110) Harden e2e Kafka shutdown - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/09 09:35:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.6.0, release candidate #4 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/09 09:56:25 UTC, 0 replies.
- [jira] [Created] (FLINK-10111) Test failure because of HAQueryableStateFsBackendITCase#testMapState thorws NPE - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/09 11:18:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.6.0 released - posted by Till Rohrmann <tr...@apache.org> on 2018/08/09 11:20:58 UTC, 1 replies.
- [DISCUSS] Improve Tutorials section of documentation - posted by Fabian Hueske <fh...@gmail.com> on 2018/08/09 12:44:51 UTC, 6 replies.
- [jira] [Created] (FLINK-10112) https://ci.apache.org title for release 1.6 shows 1.6-SNAPSHOT - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/08/09 12:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10113) Drop support for pre 1.6 shared buffer state - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/08/09 14:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10114) Support Orc for StreamingFileSink - posted by "zhangminglei (JIRA)" <ji...@apache.org> on 2018/08/09 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10115) Upload Project to WEB UI has issue - posted by "Yazdan Shirvany (JIRA)" <ji...@apache.org> on 2018/08/09 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-keyl - posted by "Will (JIRA)" <ji...@apache.org> on 2018/08/09 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10117) REST API for Queryable State - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/08/09 18:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10118) Queryable state MapState entry query - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/08/09 18:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10119) 存在数据非json格式，使用KafkaJsonTableSource的话，job无法拉起。 - posted by "sean.miao (JIRA)" <ji...@apache.org> on 2018/08/10 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10120) Support string representation for types like array - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/08/10 07:02:00 UTC, 0 replies.
- Request contribution permission - posted by 邓林 <ly...@gmail.com> on 2018/08/10 11:05:31 UTC, 1 replies.
- [jira] [Created] (FLINK-10121) Introduce methods to remove registered operator states - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/10 11:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10122) KafkaConsumer should use partitionable state over union state if partition discovery is not active - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/10 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10123) Use ExecutorThreadFactory instead of DefaultThreadFactory in RestServer/Client - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/10 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10124) Use ByteArrayDataInput/OutputView instead of stream + wrapper - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/10 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/08/10 20:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10126) There should be a Scala DataSource - posted by "Alexis Sarda-Espinosa (JIRA)" <ji...@apache.org> on 2018/08/12 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10127) Add TypeInformation and serializers for JDK7 Instant - posted by "Alexey Trenikhin (JIRA)" <ji...@apache.org> on 2018/08/12 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10128) Timeout on transfering jars on travis-ci - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/08/13 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster - posted by "Keshav Lodhi (JIRA)" <ji...@apache.org> on 2018/08/13 06:49:00 UTC, 0 replies.
- Re: [Discuss] FLIP-26 - SSL Mutual Authentication - posted by Stephan Ewen <se...@apache.org> on 2018/08/13 06:54:36 UTC, 1 replies.
- [jira] [Created] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file - posted by "Keshav Lodhi (JIRA)" <ji...@apache.org> on 2018/08/13 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10131) Improve logging around ResultSubpartition - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/13 10:27:00 UTC, 0 replies.
- [Discuss] Outer join support and timestamp assignment for IntervalJoin - posted by Florian Schmidt <fl...@data-artisans.com> on 2018/08/13 11:18:18 UTC, 2 replies.
- [jira] [Created] (FLINK-10132) Incremental cleanup of local expired state with TTL discovered in full snapshot - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/08/13 14:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters) - posted by "Xiangyu Zhu (JIRA)" <ji...@apache.org> on 2018/08/13 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10134) UTF-16 support for TextInputFormat - posted by "David Dreyfus (JIRA)" <ji...@apache.org> on 2018/08/13 21:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10135) The JobManager doesn't report the cluster-level metrics - posted by "Joey Echeverria (JIRA)" <ji...@apache.org> on 2018/08/13 22:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10136) Add REPEAT supported in Table API and SQL - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/14 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10137) YARN: Log completed Containers - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/08/14 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10138) Queryable state (rocksdb) end-to-end test failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/14 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10139) Update migration tests for 1.6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/14 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10140) Log files are not available via web UI in containerized environment - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/14 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10141) Reduce lock contention introduced with 1.5 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/14 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10142) Reduce synchronization overhead for credit notifications - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/14 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10143) date_format - posted by "sean.miao (JIRA)" <ji...@apache.org> on 2018/08/14 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10144) No unused import "import akka.actor.ActorRef" in class "org.apache.flink.runtime.messages.TaskManagerMessages" - posted by "dalongliu (JIRA)" <ji...@apache.org> on 2018/08/14 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10145) Add replace supported in TableAPI and SQL - posted by "Guibo Pan (JIRA)" <ji...@apache.org> on 2018/08/14 17:09:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #33 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/15 07:20:19 UTC, 0 replies.
- [jira] [Created] (FLINK-10146) numBuffersOut not updated properly - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/15 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10147) numBytesOut metric lagging behind - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/15 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x - posted by "David Haglund (JIRA)" <ji...@apache.org> on 2018/08/15 10:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so. - posted by "Rune Skou Larsen (JIRA)" <ji...@apache.org> on 2018/08/15 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10150) Inconsistent number of "Records received" / "Records sent" - posted by "Helmut Zechmann (JIRA)" <ji...@apache.org> on 2018/08/15 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/08/15 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10152) Add reverse supported in TableAPI and SQL - posted by "Guibo Pan (JIRA)" <ji...@apache.org> on 2018/08/15 16:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10153) Add tutorial section to documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/08/15 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10154) Make sure we always read at least one record in KinesisConnector - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2018/08/15 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10155) JobExecutionException when using evictor followed with map - posted by "Prithvi Raj (JIRA)" <ji...@apache.org> on 2018/08/15 18:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10156) Drop the Table.writeToSink() method - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/08/15 21:22:00 UTC, 0 replies.
- [DISCUSS] Release Flink 1.5.3 - posted by Chesnay Schepler <c....@web.de> on 2018/08/16 06:29:27 UTC, 10 replies.
- [jira] [Created] (FLINK-10157) The TTL state not allow `null` state value - posted by "chengjie.wu (JIRA)" <ji...@apache.org> on 2018/08/16 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10158) The DataOutputSerializer may consume excessive memory - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/08/16 08:35:00 UTC, 0 replies.
- [VOTE] Release 1.5.3, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/08/16 10:59:11 UTC, 4 replies.
- [jira] [Created] (FLINK-10159) TestHarness#initializeState(xyz) calls after TestHarness#open() are being silently ignored - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/08/16 11:38:00 UTC, 0 replies.
- How to handle tests that need docker? - posted by Niels Basjes <Ni...@basjes.nl> on 2018/08/16 12:05:37 UTC, 3 replies.
- [jira] [Created] (FLINK-10160) Index out of bound when serializing operator state - posted by "Zdenek (JIRA)" <ji...@apache.org> on 2018/08/16 12:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10161) Add host in checkpoint detail - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2018/08/16 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10162) Add host in checkpoint detail - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2018/08/16 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10163) Support CREATE VIEW in SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/16 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10164) Add support for resuming from savepoints to StandaloneJobClusterEntrypoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/16 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10165) JarRunHandler/JarRunRequestBody should allow to pass program arguments as escaped json list - posted by "Maciej Prochniak (JIRA)" <ji...@apache.org> on 2018/08/17 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10166) Dependency problems when executing SQL query in sql-client - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/08/17 09:45:00 UTC, 0 replies.
- [Proposal] Utilities for reading, transforming and creating Streaming savepoints - posted by Gyula Fóra <gy...@gmail.com> on 2018/08/17 10:28:40 UTC, 12 replies.
- Re: [Proposal] Utilities for reading, transforming and creatingStreaming savepoints - posted by bupt_ljy <bu...@163.com> on 2018/08/17 18:54:42 UTC, 2 replies.
- [jira] [Created] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala - posted by "Andrew Roberts (JIRA)" <ji...@apache.org> on 2018/08/18 01:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile() - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/08/18 04:30:00 UTC, 0 replies.
- [DISCUSS][TABLE] How to handle empty delete for UpsertSource - posted by Hequn Cheng <ch...@gmail.com> on 2018/08/19 06:21:55 UTC, 10 replies.
- [jira] [Created] (FLINK-10169) RowtimeValidator fails with custom TimestampExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/19 06:41:00 UTC, 0 replies.
- [DISCUSS] Change the Keyed partitioning behavior of the Kafka Producer API - posted by Niels Basjes <Ni...@basjes.nl> on 2018/08/19 08:43:59 UTC, 1 replies.
- [jira] [Created] (FLINK-10170) Support map types in descriptor-based Table API - posted by "Jun Zhang (JIRA)" <ji...@apache.org> on 2018/08/19 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10171) Allow for assemblePartPath override in the BucketingSink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/08/19 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10172) Inconsistentcy in ExpressionParser and ExpressionDsl for order by asc/desc - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/08/19 21:40:00 UTC, 0 replies.
- Fwd: [DISCUSS] Rust add adapter for parquet - posted by Renjie Liu <li...@gmail.com> on 2018/08/20 02:39:57 UTC, 2 replies.
- [jira] [Created] (FLINK-10173) Elasticsearch 6 connector does not package Elasticsearch - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/20 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10174) getbytes with no charsets test error for hex and toBase64 - posted by "xueyu (JIRA)" <ji...@apache.org> on 2018/08/20 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10175) Fix concurrent access to shared buffer in map state / querable state - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/20 09:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10176) Replace ByteArrayData[Input|Output]View with Data[Output|InputDe]Serializer - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/20 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10177) Use transport type AUTO by default - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/20 10:27:00 UTC, 0 replies.
- SQL Client Limitations - posted by Dominik Wosiński <wo...@gmail.com> on 2018/08/20 10:43:35 UTC, 4 replies.
- Support Hadoop 2.6 for StreamingFileSink - posted by Artsem Semianenka <ar...@gmail.com> on 2018/08/20 11:40:32 UTC, 6 replies.
- [jira] [Created] (FLINK-10178) Job cancel REST API not working - posted by "Marc Rooding (JIRA)" <ji...@apache.org> on 2018/08/20 13:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10179) .bat script to start Flink history server - posted by "Pavel Shvetsov (JIRA)" <ji...@apache.org> on 2018/08/20 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10180) .bat script to start Flink standalone job - posted by "Pavel Shvetsov (JIRA)" <ji...@apache.org> on 2018/08/20 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10181) Add anchor link to individual rest requests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/20 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10182) AsynchronousBufferFileWriterTest deadlocks on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/20 15:41:00 UTC, 0 replies.
- Re: Flink checkpointing to Google Cloud Storage - posted by Oleksandr Serdiukov <de...@serdukoff.me> on 2018/08/20 15:53:47 UTC, 0 replies.
- [jira] [Created] (FLINK-10183) Processing-Time based windows aren't emitted when a finite stream ends - posted by "Andrew Roberts (JIRA)" <ji...@apache.org> on 2018/08/20 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2018/08/20 16:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10185) Make ZooKeeperStateHandleStore#releaseAndTryRemove synchronous - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/20 22:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10186) FindBugs warnings: Random object created and used only once - posted by "Hiroaki Yoshida (JIRA)" <ji...@apache.org> on 2018/08/21 01:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10187) Fix LogicalUnnestRule to match Correlate/Uncollect correctly - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/08/21 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10188) Solve nondeterministic functions problem for retraction - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/08/21 06:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10189) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator - posted by "Hiroaki Yoshida (JIRA)" <ji...@apache.org> on 2018/08/21 11:20:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.5.3, release candidate #1 - posted by Chesnay Schepler <ch...@apache.org> on 2018/08/21 11:55:01 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.5.3 released - posted by Chesnay Schepler <ch...@apache.org> on 2018/08/21 12:12:43 UTC, 1 replies.
- Side effect of DataStreamRel#translateToPlan - posted by wangsan <wa...@163.com> on 2018/08/21 13:04:55 UTC, 5 replies.
- [jira] [Created] (FLINK-10190) Unable to use custom endpoint in Kinesis producer - posted by "Sergei Poganshev (JIRA)" <ji...@apache.org> on 2018/08/21 13:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10191) WindowCheckpointingITCase.testAggregatingSlidingProcessingTimeWindow - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/21 14:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10192) SQL Client table visualization mode does not update correctly - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/08/21 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/08/21 17:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10194) Serialization issue with Scala's AggregateDataSet[Row] - posted by "Alexis Sarda-Espinosa (JIRA)" <ji...@apache.org> on 2018/08/21 18:32:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly - posted by "Luka Jurukovski (JIRA)" <ji...@apache.org> on 2018/08/22 01:22:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #34 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/22 07:36:47 UTC, 0 replies.
- [jira] [Created] (FLINK-10196) API to test streaming pipelines with windows - posted by "Nicos Maris (JIRA)" <ji...@apache.org> on 2018/08/22 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10197) flink CEP error when use sql - posted by "sean.miao (JIRA)" <ji...@apache.org> on 2018/08/22 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10198) Set Env object in DBOptions for RocksDB - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/22 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10199) StandaloneSessionClusterEntrypoint does not respect host/ui-port given from jobmanager.sh - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/08/22 15:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10200) Consolidate FileBasedStateOutputStream and FsCheckpointStateOutputStream - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/08/22 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10201) The batchTestUtil was mistakenly used in some stream sql tests - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/08/23 02:55:00 UTC, 0 replies.
- Flink 1.7 Development Priorities - posted by Aljoscha Krettek <al...@apache.org> on 2018/08/23 08:12:09 UTC, 5 replies.
- [jira] [Created] (FLINK-10202) Enable configuration for state.checkpoint.dir with environment - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/08/23 08:21:00 UTC, 0 replies.
- Allowed lateness for coGroup/join operators - posted by Евгений Юшин <ev...@gmail.com> on 2018/08/23 11:44:16 UTC, 0 replies.
- Flink cluster crashing going from 1.4.0 -> 1.5.3 - posted by Jozef Vilcek <jo...@gmail.com> on 2018/08/23 13:25:56 UTC, 9 replies.
- [jira] [Created] (FLINK-10203) HadoopRecoverableWriter does not support Hadoop - posted by "Artsem Semianenka (JIRA)" <ji...@apache.org> on 2018/08/23 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10204) Job is marked as FAILED after serialization exception - posted by "Ben La Monica (JIRA)" <ji...@apache.org> on 2018/08/23 21:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/08/24 02:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10206) Add hbase stream connector - posted by "Igloo (JIRA)" <ji...@apache.org> on 2018/08/24 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10207) Bump checkstyle-plugo to 8.9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/24 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10208) Bump mockito to 2.0+ - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/24 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10209) Exclude jdk.tools dependency from hadoop when running with java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/24 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10210) Time indicators are not always materialised for LogicalCorrelate - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/08/24 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10211) Time indicators are not always materialised for LogicalJoin - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/08/24 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10212) REST API for listing all the available save points - posted by "Marc Rooding (JIRA)" <ji...@apache.org> on 2018/08/24 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10213) Task managers cache a negative DNS lookup of the blob server indefinitely - posted by "Joey Echeverria (JIRA)" <ji...@apache.org> on 2018/08/24 22:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10214) why is job applying as many TMs as default parallelism when starting, each parallelism is 1 - posted by "lzh9 (JIRA)" <ji...@apache.org> on 2018/08/25 03:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10215) Add configuration of java option for historyserver - posted by "liuxianjiao (JIRA)" <ji...@apache.org> on 2018/08/25 08:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10216) Add REGEXP_MATCH in TableAPI and SQL - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/08/25 14:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10217) use Slack for user support and questions - posted by "Nicos Maris (JIRA)" <ji...@apache.org> on 2018/08/25 14:43:00 UTC, 0 replies.
- Flink tableApi/sql calendar - posted by Sergey Nuyanzin <sn...@gmail.com> on 2018/08/25 23:19:12 UTC, 0 replies.
- Added additional logo forms to apache-wide logo collection - posted by Ted Dunning <td...@apache.org> on 2018/08/26 00:27:29 UTC, 1 replies.
- 回复：Flink tableApi/sql calendar - posted by xueyu <27...@qq.com> on 2018/08/26 06:28:08 UTC, 0 replies.
- [jira] [Created] (FLINK-10218) Allow write DataSet without path parameter - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/08/26 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10219) remove the IRC mention from the website - posted by "Nicos Maris (JIRA)" <ji...@apache.org> on 2018/08/26 11:06:00 UTC, 0 replies.
- [DISCUSS] Remove the slides under "Community & Project Info" - posted by Stephan Ewen <se...@apache.org> on 2018/08/26 15:13:27 UTC, 5 replies.
- [jira] [Created] (FLINK-10220) StreamSQL E2E test fails on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/27 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10221) Flink metrics documentation io section table layout error - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/27 08:26:05 UTC, 0 replies.
- Why documentation always say checkpoint does not support Flink specific features like rescaling. - posted by Yun Tang <my...@live.com> on 2018/08/27 08:52:13 UTC, 2 replies.
- [jira] [Created] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/08/27 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10223) TaskManagers should log their `ResourceID` during startup - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/08/27 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10224) Web frontend does not handle scientific notation properly - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/08/27 11:29:00 UTC, 0 replies.
- [DISCUSS] Proposal of external shuffle service - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/08/27 11:57:07 UTC, 1 replies.
- [jira] [Created] (FLINK-10225) Cannot access state from a empty taskmanager - posted by "Pierre Zemb (JIRA)" <ji...@apache.org> on 2018/08/27 12:15:00 UTC, 1 replies.
- [jira] [Created] (FLINK-10226) Latency metrics can choke job-manager - posted by "Jozef Vilcek (JIRA)" <ji...@apache.org> on 2018/08/27 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10227) Remove usage of javax.xml.bind.DatatypeConverter - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/27 13:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10228) Add metrics for netty direct memory consumption - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/08/27 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10229) Support listing of views - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/28 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10230) Support printing the query of a view - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/28 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10231) Support views in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/28 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10232) Add a SQL DDL - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/28 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10233) Undeprevate ConfigOption#withDescription(String) - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/28 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10234) Lambda usage in FutureUtils is ambigouos with Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/28 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10235) KafkaTableSourceSinkFactoryBase#getFlinkKafkaPartitioner does not compile with Java 9 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/28 12:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10236) Reduce histogram percentile/quantile retrieval overhead - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/08/28 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10237) Move listing of slides to the wiki - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/28 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10238) Make nightly builds easier discoverable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/28 17:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10239) Register eventtime timer only once in eventtrigger - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/08/29 04:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10240) Flexible scheduling strategy is needed for batch job - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2018/08/29 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10241) Reduce performance/stability impact of latency metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/29 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10242) Disable latency metrics by default - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/29 07:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10243) Add option to reduce latency metrics granularity - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/29 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10244) Add option to measure latency as absolute value - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/08/29 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10245) Add DataStream HBase Sink - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/08/29 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10246) Harden and separate MetricQueryService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/29 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10247) Run MetricQueryService in separate thread pool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/29 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10248) Add HBase Table Sink - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/08/29 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10249) Document hadoop/presto s3 file system configuration forwarding - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/08/29 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10250) Flink doesn't support functions that extend RichAggregateFunction in a group window - posted by "PengYang (JIRA)" <ji...@apache.org> on 2018/08/29 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10251) Handle oversized response messages in AkkaRpcActor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/29 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10252) Handle oversized metric messges - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/29 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10253) Run MetricQueryService with lower priority - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/29 09:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10254) Fix check in stateBackend - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/08/29 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10255) Standby Dispatcher locks submitted JobGraphs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/08/29 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10256) Rework JobManagerFailsITCase and JobManagerTest into JobMasterITCase and JobMasterHAITCase - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/08/29 15:56:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #35 - posted by Till Rohrmann <tr...@apache.org> on 2018/08/29 15:59:25 UTC, 0 replies.
- 回复：[DISCUSS] Proposal of external shuffle service - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com.INVALID> on 2018/08/29 16:04:23 UTC, 0 replies.
- [jira] [Created] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/08/30 13:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10258) Allow streaming sources to be present for batch executions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/30 13:36:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10259) Key validation for GroupWindowAggregate is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/08/30 13:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10260) Confusing log during TaskManager registration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/30 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10261) INSERT INTO does not work with ORDER BY clause - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/30 15:19:00 UTC, 0 replies.
- Cannot run example on EMR - posted by "Andy M." <aj...@gmail.com> on 2018/08/30 15:34:06 UTC, 1 replies.
- [jira] [Created] (FLINK-10262) Web UI does not show error stack trace any more when program submission fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/30 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10263) User-defined function with LITERAL paramters yields CompileException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/08/30 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10264) Exception is misleading when no default constructor define for events - posted by "Swapan Shaw (JIRA)" <ji...@apache.org> on 2018/08/30 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10265) Configure checkpointing behavior for SQL Client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/30 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10266) Web UI has outdated entry about externalized checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/08/30 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10267) [State] Fix arbitrary iterator access on RocksDBMapIterator - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2018/08/30 17:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10268) Document update deployment/aws HADOOP_CLASSPATH - posted by "Andy M (JIRA)" <ji...@apache.org> on 2018/08/30 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10269) Elasticsearch UpdateRequest fail because of binary incompatibility - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/31 06:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10270) Delete LegacyRestHandlerAdapter - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/08/31 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10271) flink-connector-elasticsearch6_2.11 have exception - posted by "ting (JIRA)" <ji...@apache.org> on 2018/08/31 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10272) using Avro's DateConversion causes ClassNotFoundException on Hadoop bundle - posted by "Roel Van der Paal (JIRA)" <ji...@apache.org> on 2018/08/31 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10273) Access composite type fields after a function - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/08/31 12:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10274) The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running - posted by "YuFeng Shen (JIRA)" <ji...@apache.org> on 2018/08/31 16:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10275) StreamTask support object reuse - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/08/31 17:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10276) Job Manager and Task Manager Metrics Reporter Ports Configuration - posted by "Deirdre Kong (JIRA)" <ji...@apache.org> on 2018/08/31 21:34:00 UTC, 0 replies.