dev@flink.apache.org, 2017-10

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

- partial upgrade - posted by Chen Qin <qi...@gmail.com> on 2017/10/01 01:03:07 UTC, 2 replies.
- Metrics to data connectors - posted by Michael Fong <mc...@gmail.com> on 2017/10/01 14:45:22 UTC, 1 replies.
- [jira] [Created] (FLINK-7744) Add missing top links to documentation - posted by "Sirko B (JIRA)" <ji...@apache.org> on 2017/10/01 17:41:00 UTC, 0 replies.
- Logistic Regression in Flink ML - posted by Bowen Li <bo...@offerupnow.com> on 2017/10/02 00:39:09 UTC, 1 replies.
- [jira] [Created] (FLINK-7745) add tests for ensuring NetworkBufferPool overprovisioning behaviour - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/02 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7746) move ResultPartitionWriter#writeBufferToAllChannels up into ResultPartition - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/02 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7747) remove RecordWriter wrapper - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/02 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7748) remove event listener behaviour from ResultPartitionWriter - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/02 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7749) remove ResultPartitionWriter - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/02 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7750) Strange behaviour in savepoints - posted by "Razvan (JIRA)" <ji...@apache.org> on 2017/10/02 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7751) Documentation for Homebrew installation is unclear - posted by "Chris Ward (JIRA)" <ji...@apache.org> on 2017/10/02 12:14:00 UTC, 0 replies.
- Unable to write snapshots to S3 on EMR - posted by "Andy M." <aj...@gmail.com> on 2017/10/02 13:52:02 UTC, 17 replies.
- [jira] [Created] (FLINK-7752) RedirectHandler should execute on the IO thread - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/10/02 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7753) HandlerUtils should close the channel on error responses - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/10/02 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7754) Complete termination future after actor has been stopped. - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/02 18:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/02 19:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/10/03 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/10/03 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7758) Fix bug Kafka09Fetcher add offset metrics - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/04 07:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7759) Fix Bug that fieldName/functionName with prefix equals "true" or "false" can't be parsed by ExpressionParser. - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/10/04 10:00:05 UTC, 0 replies.
- Fwd: Re: Flink Watermark and timing - posted by Timo Walther <tw...@apache.org> on 2017/10/04 11:44:28 UTC, 0 replies.
- [jira] [Created] (FLINK-7760) Restore failing from external checkpointing metadata. - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/10/04 11:45:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7761) Twitter example is not self-contained - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/04 13:20:00 UTC, 0 replies.
- System resource logger - posted by Piotr Nowojski <pi...@data-artisans.com> on 2017/10/04 14:13:00 UTC, 5 replies.
- Dependency convergence - posted by Piotr Nowojski <pi...@data-artisans.com> on 2017/10/04 16:39:50 UTC, 4 replies.
- [jira] [Created] (FLINK-7762) Make WikipediaEditsSourceTest a proper test - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/05 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7763) TableSinkITCase fails with "object reuse" enabled - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/05 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/05 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7765) Enable dependency convergence - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/05 13:13:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7766) Remove obsolete reflection for hflush on HDFS - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/05 17:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7767) Avoid loading Hadoop conf dynamically at runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/05 17:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7768) Load File Systems via Java Service abstraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/05 17:49:00 UTC, 0 replies.
- Issue of Twitter streaming with CustomEndpoint - posted by Devendra Vishwakarma <vv...@gmail.com> on 2017/10/06 06:14:44 UTC, 1 replies.
- [jira] [Created] (FLINK-7769) Move Queryable State outside the runtime. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/06 08:01:23 UTC, 0 replies.
- [jira] [Created] (FLINK-7770) Hide Queryable State behind a proxy. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/06 08:01:23 UTC, 0 replies.
- [jira] [Created] (FLINK-7771) Make the operator state queryable - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/06 08:31:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7772) Test instability in BlobCacheDeleteTest - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/06 10:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7773) Test instability in UtilsTest#testYarnFlinkResourceManagerJobManagerLostLeadership - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/06 12:32:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7774) Deserializers are not cleaned up when closing input streams - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/06 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/06 18:18:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7776) remove duplicate records in group aggregation - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/10/08 11:37:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7777) Upgrade maven plugin japicmp version to 0.10.0 - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/09 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7778) Relocate ZooKeeper - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/09 09:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7779) Relocate Curator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/09 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7780) Integrate savepoint command into REST client - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/09 11:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7781) Support sime on-demand metrics aggregation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/09 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7782) Flink CEP not recognizing pattern - posted by "Ajay (JIRA)" <ji...@apache.org> on 2017/10/09 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7783) Don't always remove checkpoints ZooKeeperCompletedCheckpointStore#recover() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/09 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7784) Don't fail TwoPhaseCommitSinkFunction when failing to commit - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/09 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7785) DispatcherTest failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/09 16:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments - posted by "Brice Bingman (JIRA)" <ji...@apache.org> on 2017/10/09 16:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7787) Remove guava dependency in the cassandra connector - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/10/09 19:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7788) Allow port range for queryable state client proxy. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/09 19:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7789) Add handler for Async IO operator timeouts - posted by "Karthik Deivasigamani (JIRA)" <ji...@apache.org> on 2017/10/10 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7790) Unresolved query parameters are not omitted - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/10 10:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7791) Integrate LIST command into REST client - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/10 12:42:00 UTC, 0 replies.
- Get pattern events - posted by Erdem erdfem <er...@gmail.com> on 2017/10/10 14:22:16 UTC, 6 replies.
- [jira] [Created] (FLINK-7792) CliFrontend tests suppress logging - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/10 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7793) SlotManager releases idle TaskManager in standalone mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/10 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7794) Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html - posted by "Paul Wu (JIRA)" <ji...@apache.org> on 2017/10/10 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7795) Utilize error-prone to discover common coding mistakes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/10 19:28:00 UTC, 0 replies.
- Not being able to log from Flink to Kafka - posted by Jose Gonzalez Torres <jl...@gmail.com> on 2017/10/10 20:36:22 UTC, 1 replies.
- [jira] [Created] (FLINK-7796) RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/10 20:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7797) Add support for windowed outer joins for streaming tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/10 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7798) Add support for windowed joins to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/10 21:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7799) Improve performance of windowed joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/10 21:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7800) Enable window joins without equi-join predicates - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/10 21:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7801) Integrate list command into REST client - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/10 22:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7802) Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/10/11 03:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7803) Update savepoint Documentation - posted by "Razvan (JIRA)" <ji...@apache.org> on 2017/10/11 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7804) YarnResourceManager does not execute AMRMClientAsync callbacks in main thread - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/11 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7805) Add HA capabilities to YarnResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/11 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7806) Move CurrentJobsOverviewHandler to jobs/overview - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/11 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7807) HandlerUtils methods should log errors - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/11 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7808) JobDetails constructor should check length of tasksPerState array - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/11 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7809) Drop support for Scala 2.10 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/11 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7810) Switch from custom Flakka to Akka 2.4.x - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/11 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7811) Add support for Scala 2.12 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/11 12:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7812) Log system resources as metrics - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/11 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7813) Replace MetricRegistryThreadFactory - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/11 13:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7814) Add BETWEEN expression to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/11 14:17: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 Aljoscha Krettek <al...@apache.org> on 2017/10/11 15:34:25 UTC, 0 replies.
- [jira] [Created] (FLINK-7815) Remove grouping from MultipleJobsDetails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/11 15:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7816) Support Scala 2.12 closures and Java 8 lambdas in ClosureCleaner - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/11 16:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7817) Add TaskManagerDetailsHandler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/11 16:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7818) Synchronize MetricStore access in the TaskManagersHandler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/11 22:45:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7819) Check object to clean is closure - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/12 05:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7820) remove text related to FoldingState and FoldingStateDescriptor from doc - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/10/12 06:28:02 UTC, 0 replies.
- the Table API `limit` is confused - posted by John Fang <hu...@gmail.com> on 2017/10/12 06:30:43 UTC, 3 replies.
- [jira] [Created] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/12 08:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7822) Add documentation for the new queryable state client. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/12 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7823) Adjust queryable state configuration parameters - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/12 09:28:13 UTC, 0 replies.
- [jira] [Created] (FLINK-7824) Put the queryable state jars in the opt folder. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/12 09:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7825) Change the `QueryableStateClient` to use a builder pattern. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/12 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7826) Add support for all types of state to the QueryableStateClient. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/12 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7827) creating and starting a NetCat in test cases programmatically - posted by "bluejoe (JIRA)" <ji...@apache.org> on 2017/10/12 10:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7828) Improve object copying/reuse mode for streaming runtime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/12 12:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/12 13:01:00 UTC, 0 replies.
- running flink 1.4 in eclipse - posted by Radu Tudoran <ra...@huawei.com> on 2017/10/12 15:17:53 UTC, 0 replies.
- [jira] [Created] (FLINK-7830) Problematic interaction of CEP and asynchronous snapshots - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/12 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7831) Retrieve last received heartbeat from HeartbeatManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/12 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7832) SlotManager should return number of registered slots - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/12 16:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-7833) Flink's Literal(value, SqlTimeTypeInfo) fails to convert Calctie's RexNode - posted by "John Fang (JIRA)" <ji...@apache.org> on 2017/10/13 05:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7834) cost model supports network cost and memory cost - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/10/13 07:22:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7835) Fix duplicate() method in NFASerializer - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/13 09:41:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.4 - posted by Till Rohrmann <tr...@apache.org> on 2017/10/13 09:49:11 UTC, 14 replies.
- [jira] [Created] (FLINK-7836) specifying node label for flink job to run on yarn - posted by "zhaibaba (JIRA)" <ji...@apache.org> on 2017/10/13 09:54:00 UTC, 0 replies.
- 回复：[DISCUSS] Releasing Flink 1.4 - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/10/13 15:02:45 UTC, 4 replies.
- [jira] [Created] (FLINK-7837) AggregatingFunction does not work with immutable types - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/13 15:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7838) Kafka 0.11 producer exactly-once test failure - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/13 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/10/13 16:19:00 UTC, 0 replies.
- creating and starting a NetCat in test cases programmatically - posted by bluejoe <bl...@foxmail.com> on 2017/10/14 03:59:48 UTC, 0 replies.
- [jira] [Created] (FLINK-7840) Shade Akka's Netty Dependency - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/14 17:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7841) Add docs for Flink's S3 support - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/14 17:12:04 UTC, 0 replies.
- [jira] [Created] (FLINK-7842) Shade jackson (org.codehouse.jackson) in flink-shaded-hadoop2 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/14 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7843) Improve and enhance documentation for system metrics - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/15 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2017/10/15 23:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7845) Netty Exception when submitting batch job repeatedly - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/10/16 08:44:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7846) Remove guava shading from ES2 connector - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/16 11:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7847) Fix typo in flink-avro shading pattern - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/16 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7848) Allow time attributes for atomic types - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/10/16 12:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7849) Remove guava shading from hcatalog connector - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/16 12:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7850) Given each maven profile an activation property - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/16 13:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/16 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7852) An input of GenericTypeInfo cannot be converted to Table - posted by "hanningning (JIRA)" <ji...@apache.org> on 2017/10/16 16:31:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7853) Reject table function outer joins with predicates in Table API - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/10/17 00:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7854) Reject lateral table outer joins with predicates in SQL - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/10/17 00:31:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/10/17 05:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/10/17 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7857) Port JobVertexDetails to REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/10/17 05:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/10/17 05:47:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7859) Allow field annotations to define TypeInformation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/10/17 07:55:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7860) Support YARN proxy user in Flink (impersonation) - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2017/10/17 09:02:00 UTC, 0 replies.
- Minimal HA Setup for Apache Flink - posted by Srinath Perera <he...@gmail.com> on 2017/10/17 09:53:20 UTC, 1 replies.
- [jira] [Created] (FLINK-7861) Suppress ActorKilledExceptions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/17 11:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7862) Add TaskManagerDetailsHandler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/17 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7863) Make MetricFetcher work with RestfulGateway - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/17 15:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7864) Support side-outputs in CoProcessFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/18 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/10/18 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7866) Weigh list of preferred locations for scheduling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/18 09:13:00 UTC, 0 replies.
- Pattern change on runtime - posted by Erdem erdfem <er...@gmail.com> on 2017/10/18 13:53:50 UTC, 2 replies.
- [jira] [Created] (FLINK-7867) Start MetricQueryService on TaskManagerRunner - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/18 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7868) Don't run checkstyle again for tests in Misc profile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/18 19:42:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7869) Don't use PipelineErrorHandler on the client - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/10/19 04:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7870) SlotPool should cancel the slot request to RM if not need any more. - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/10/19 05:21:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7871) SlotPool should release its unused slot to RM - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/10/19 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7872) Set ACCESS_CONTROL_ALLOW_ORIGIN header in HandlerUtils#sendResponse - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/19 09:07:00 UTC, 0 replies.
- [ANNOUNCE] Flink 1.4 feature-freeze date and release burn-down - posted by Aljoscha Krettek <al...@apache.org> on 2017/10/19 09:17:28 UTC, 0 replies.
- [jira] [Created] (FLINK-7873) Introduce HybridStreamStateHandle for quick recovery from checkpoint. - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2017/10/19 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7874) Add environment logging to cluster entrypoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/19 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7875) StaticFileServer should not reuse the tmp dir - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/19 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7876) Register TaskManagerMetricGroup under ResourceID instead of InstanceID - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/19 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7877) Fix compilation against the Hadoop 3 beta1 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/19 17:05:00 UTC, 0 replies.
- Improving Javadocs - posted by Kent Murra <ke...@remitly.com> on 2017/10/19 17:58:29 UTC, 2 replies.
- [jira] [Created] (FLINK-7878) Extend the resource type user can define in ResourceSpec - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/10/20 02:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7879) only execute apache-rat in one build profile - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/20 06:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7880) flink-queryable-state-java fails with core-dump - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/20 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7881) flink can't deployed on yarn with ha - posted by "deng (JIRA)" <ji...@apache.org> on 2017/10/20 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7882) Writing to S3 from EMR fails with exception - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2017/10/20 09:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7883) Stop fetching source before a cancel with savepoint - posted by "Antoine Philippot (JIRA)" <ji...@apache.org> on 2017/10/20 10:23:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7884) Port ClusterOverviewHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/20 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7885) Port ClusterConfigHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/20 14:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7886) Enable dependency convergence for flink-core - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/20 14:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7888) Enable dependency convergence for flink-runtime - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/20 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7887) Enable dependency convergence for flink-shaded-hadoop - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/20 14:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7889) Enable dependency convergence for flink-streaming-java - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/20 14:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7890) Enable dependency convergence for flink-connector-kafka-base - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/20 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7891) Enable dependency convergence for other modules (please split this subtask up if necessary) - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/10/20 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7892) Port CheckpointStatsHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/20 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7893) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/20 14:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7894) Improve metrics around fine-grained recovery and associated checkpointing behaviors - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2017/10/20 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7895) Error in the example in SideOutput usage example that show how to get late message of window - posted by "aitozi (JIRA)" <ji...@apache.org> on 2017/10/20 19:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7896) Kafka011ProducerExactlyOnceITCase.testExactlyOnceRegularSink does not finish on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/21 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/21 14:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7898) TaskExecutorTest.testTriggerRegistrationOnLeaderChange fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/22 11:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7899) SlotManagerTest.testTaskManagerTimeoutDoesNotRemoveSlots flaky on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/23 06:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7900) Add a Rich KeySelector - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/23 08:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7901) Detecting whether an operator is restored doesn't work with chained state (Flink 1.3) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/23 09:01:16 UTC, 0 replies.
- [jira] [Created] (FLINK-7902) TwoPhaseCommitSinkFunctions should use custom TypeSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/23 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7903) Add Flip6 build profile - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/23 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7904) Enable Flip6 build profile on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/23 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7905) HadoopS3FileSystemITCase failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/23 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7906) HadoopS3FileSystemITCase flaky on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/23 14:37:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7907) Flink Metrics documentation missing Scala examples - posted by "Colin Williams (JIRA)" <ji...@apache.org> on 2017/10/24 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7908) Restructure the QS module to reduce client deps. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/24 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7909) Unify cluster creation for test bases - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/24 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7910) Generalize TestEnvironment/TestStreamEnvironment to be used with Flip-6 MiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/24 16:57:00 UTC, 0 replies.
- [VOTE] Release Apache Flink-shaded 2.0 (RC1) - posted by Chesnay Schepler <ch...@apache.org> on 2017/10/25 07:15:29 UTC, 4 replies.
- [jira] [Created] (FLINK-7911) Flaky QS ClientTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/25 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7912) Document metrics REST API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/25 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7913) Add support for Kafka default partitioner - posted by "Konstantin Lalafaryan (JIRA)" <ji...@apache.org> on 2017/10/25 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7914) Expose Akka gated interval as user option - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/25 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7915) Verify functionality of RollingSinkSecuredITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/25 13:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7916) Remove NetworkStackThroughputITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/25 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/25 13:38:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7918) Run AbstractTestBase tests on Flip-6 MiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/25 15:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7919) Join with Solution Set fails with NPE if Solution Set has no entry - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/25 16:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7920) Make MiniClusterConfiguration immutable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/25 16:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7921) Flink downloads link redirect to spark downloads page - posted by "Anil Kumar (JIRA)" <ji...@apache.org> on 2017/10/25 17:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7922) leastRestrictive in FlinkTypeFactory does not resolve composite type correctly - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/10/25 18:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/10/25 18:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7924) Fix incorrect names of checkpoint options - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/25 18:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7925) Add CheckpointingOptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/10/25 18:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7926) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "David Dreyfus (JIRA)" <ji...@apache.org> on 2017/10/25 19:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7927) Different Netty Versions in dependencies of flink-runtime make it impossible to use 3rd party libraries using netty - posted by "Claudius Eisele (JIRA)" <ji...@apache.org> on 2017/10/25 20:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7928) Extend the filed in ResourceProfile for precisely calculating the resource of a task manager - posted by "shuai.xu (JIRA)" <ji...@apache.org> on 2017/10/26 03:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7929) Add unit/integration tests for states backed by RocksDB - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/10/26 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7930) Support periodic jobs with state that gets restored and persisted in a savepoint - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2017/10/26 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7931) FlinkKinesisProducer violates at-least-once guarantees (1.3 branch) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/26 10:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7932) Best Practices docs recommend passing parameters through open(Configuration c) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/26 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7933) Test instability PrometheusReporterTest - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2017/10/26 16:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7934) Upgrade Calcite dependency to 1.15 - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/10/26 17:52:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7935) Metrics with user supplied scope variables - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/10/27 00:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7936) Lack of synchronization w.r.t. taskManagers in MetricStore#add() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/27 05:18:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7937) Add pagination to Flink History view - posted by "Andrew Roberts (JIRA)" <ji...@apache.org> on 2017/10/27 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7938) support addAll() in ListState - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/10/27 21:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7939) DataStream of atomic type cannot be converted to Table with time attributes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/10/28 19:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7940) Add timeout for futures - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/29 15:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/10/30 05:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7942) NPE when apply FilterJoinRule - posted by "lincoln.lee (JIRA)" <ji...@apache.org> on 2017/10/30 06:48:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7943) OptionalDataException when launching Flink jobs concurrently - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/30 08:02:00 UTC, 0 replies.
- [RESULT][VOTE] Release Apache Flink-shaded 2.0 (RC1) - posted by Chesnay Schepler <ch...@apache.org> on 2017/10/30 09:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-7944) Allow configuring Hadoop Classpath - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/10/30 09:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7945) kafka-connector10 use kafkaConsumer0.9 caused it lost the important metric in kafka clients10 - posted by "aitozi (JIRA)" <ji...@apache.org> on 2017/10/30 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7946) Add an option to truncate IDs to 8 characters - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/10/30 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7947) Let ParameterTool return a dedicated GlobalJobParameters object - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/30 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7948) YarnApplicationMaster should also load the hdfs-site.xml - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/30 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full - posted by "Bartłomiej Tartanus (JIRA)" <ji...@apache.org> on 2017/10/30 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7950) flink-queryable-state-runtime not a dependency in flink-dist - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/10/30 17:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7951) YarnApplicationMaster does not load HDFSConfiguration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/10/30 22:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7952) Add metrics for counting logging events - posted by "Hai Zhou UTC+8 (JIRA)" <ji...@apache.org> on 2017/10/31 12:28:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7953) Kafka consumer printing error - java.lang.IllegalArgumentException: Invalid offset: -915623761772 - posted by "Shashank Agarwal (JIRA)" <ji...@apache.org> on 2017/10/31 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7954) sideoutput in async function - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2017/10/31 17:00:01 UTC, 0 replies.