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

---

- [jira] [Assigned] (FLINK-8880) Validate configurations for SQL Client - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/01 00:03:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9119) example code error in Concepts & Common API - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/01 03:04:00 UTC, 0 replies.
- [GitHub] flink pull request #5798: [FLINK-7917] The return of taskInformationOrBlobKe... - posted by yanghua <gi...@git.apache.org> on 2018/04/01 09:17:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/01 09:18:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom) - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/01 11:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/04/01 13:10:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7554) Add a testing RuntimeContext to test utilities - posted by "Jiayi (JIRA)" <ji...@apache.org> on 2018/04/01 13:10:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8914) CEP's greedy() modifier doesn't work - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/04/01 13:11:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/04/01 14:39:00 UTC, 17 replies.
- [jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/01 15:12:00 UTC, 9 replies.
- [jira] [Issue Comment Deleted] (FLINK-7554) Add a testing RuntimeContext to test utilities - posted by "Jiayi (JIRA)" <ji...@apache.org> on 2018/04/01 17:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8837) Move DataStreamUtils to package 'experimental'. - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/01 22:11:00 UTC, 0 replies.
- [GitHub] flink pull request #5799: [FLINK-7775] Remove unreferenced method PermanentB... - posted by yanghua <gi...@git.apache.org> on 2018/04/02 03:49:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/02 03:50:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/04/02 06:44:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8837) add ano - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/02 07:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8837) add @Experimental annotation and properly annotate some classes - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/02 08:00:00 UTC, 1 replies.
- [GitHub] flink pull request #5800: [FLINK-8837] add @Experimental annotation and prop... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/02 08:01:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-8837) add @Experimental annotation and properly annotate some classes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/02 08:02:01 UTC, 3 replies.
- [jira] [Created] (FLINK-9121) Remove Flip-6 prefixes from code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/02 09:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "miki haiat (JIRA)" <ji...@apache.org> on 2018/04/02 09:43:00 UTC, 17 replies.
- [jira] [Commented] (FLINK-9104) Re-generate REST API documentation for FLIP-6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/02 12:01:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9122) NFASerialize deserailze failed and cause other exception - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/04/02 12:02:00 UTC, 0 replies.
- [GitHub] flink pull request #5801: [FLINK-9121] [flip6] Remove Flip6 prefixes and oth... - posted by tillrohrmann <gi...@git.apache.org> on 2018/04/02 12:55:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-9121) Remove Flip-6 prefixes from code base - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/02 12:56:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/02 14:01:00 UTC, 13 replies.
- [GitHub] flink issue #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descriptors - posted by StephanEwen <gi...@git.apache.org> on 2018/04/02 14:22:27 UTC, 0 replies.
- [GitHub] flink pull request #5732: [FLINK-9034] [FLINK-9035] [core] Fix state descrip... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/02 14:22:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-9034) State Descriptors drop TypeInformation on serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/02 14:23:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9121) Remove Flip-6 prefixes from code base - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/02 15:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9061) S3 checkpoint data not partitioned well -- causes errors and poor performance - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/04/02 17:51:00 UTC, 11 replies.
- [GitHub] flink issue #5760: [hotfix] [doc] update maven versions in building flink pa... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/02 18:17:49 UTC, 1 replies.
- [GitHub] flink issue #5800: [FLINK-8837] add @Experimental annotation and properly an... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/02 18:18:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments - posted by "Cristian (JIRA)" <ji...@apache.org> on 2018/04/02 19:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9123) Scala version of ProcessFunction doesn't work - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/04/02 19:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9115) Support addition of part suffix in BucketingSink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/04/02 21:03:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/04/02 21:14:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/03 00:39:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9123) Scala version of ProcessFunction doesn't work - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/03 01:26:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/04/03 02:00:00 UTC, 0 replies.
- [GitHub] flink pull request #5802: [FLINK-9087] [runtime] close the BufferConsumer in... - posted by trionesadam <gi...@git.apache.org> on 2018/04/03 03:40:44 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/03 04:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/04/03 04:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/04/03 04:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5803: [FLINK-9124] [kinesis] Allow customization of Kine... - posted by tweise <gi...@git.apache.org> on 2018/04/03 05:20:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 05:21:00 UTC, 6 replies.
- [jira] [Updated] (FLINK-8771) Upgrade scalastyle to 1.0.0 - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/03 05:26:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/04/03 05:48:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-8205) Multi key get - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/03 06:20:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-8205) Multi key get - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/03 06:21:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/03 06:54:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/03 06:55:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/03 06:55:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8771) Upgrade scalastyle to 1.0.0 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/03 07:25:00 UTC, 2 replies.
- [GitHub] flink pull request #5778: [FLINK-8979] (part 1) Make Kafka end-to-end tests ... - posted by asfgit <gi...@git.apache.org> on 2018/04/03 07:41:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-8979) Extend Kafka end-to-end tests to run with different versions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 07:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8804) Bump flink-shaded dependency to 3.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/03 08:04:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9110) Building docs with Ruby 2.5 fails if bundler is not globally installed - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9123) Scala version of ProcessFunction doesn't work - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:15:00 UTC, 0 replies.
- [GitHub] flink pull request #5758: [FLINK-9059][Table API & SQL] add table type attri... - posted by suez1224 <gi...@git.apache.org> on 2018/04/03 08:15:22 UTC, 9 replies.
- [jira] [Commented] (FLINK-9059) Add support for unified table source and sink declaration in environment file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 08:16:00 UTC, 9 replies.
- [jira] [Commented] (FLINK-9122) NFASerialize deserailze failed and cause other exception - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:18:00 UTC, 1 replies.
- [GitHub] flink issue #5769: [FLINK-9069] Add checkstyle rule to detect multiple conse... - posted by zentol <gi...@git.apache.org> on 2018/04/03 08:24:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-9069) Fix some double semicolons to single semicolons, and update checkstyle - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 08:25:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9051) Invert flip6 profile - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/03 08:27:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9051) Invert flip6 profile - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 08:27:01 UTC, 0 replies.
- [GitHub] flink pull request #5743: [FLINK-9051][build] Invert flip6 profile - posted by zentol <gi...@git.apache.org> on 2018/04/03 08:27:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-9105) Table program compiles failed - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/03 08:39:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9105) Table program compiles failed - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/03 08:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9105) Table program compiles failed - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/03 08:39:00 UTC, 0 replies.
- [GitHub] flink pull request #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITC... - posted by zentol <gi...@git.apache.org> on 2018/04/03 08:45:13 UTC, 3 replies.
- [jira] [Commented] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 08:46:00 UTC, 6 replies.
- [GitHub] flink pull request #5695: [FLINK-8704][tests] Port PartialConsumerPipelinedR... - posted by zentol <gi...@git.apache.org> on 2018/04/03 08:46:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 08:47:00 UTC, 9 replies.
- [GitHub] flink issue #5695: [FLINK-8704][tests] Port PartialConsumerPipelinedResultTe... - posted by zentol <gi...@git.apache.org> on 2018/04/03 08:48:11 UTC, 0 replies.
- [GitHub] flink pull request #5790: [FLINK-9107][docs] document timer coalescing for P... - posted by aljoscha <gi...@git.apache.org> on 2018/04/03 08:54:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-9107) Document timer coalescing for ProcessFunctions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 08:55:00 UTC, 3 replies.
- [GitHub] flink pull request #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumers... - posted by zentol <gi...@git.apache.org> on 2018/04/03 08:56:02 UTC, 2 replies.
- [jira] [Updated] (FLINK-8891) RestServerEndpoint can bind on local address only - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:57:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8891) RestServerEndpoint can bind on local address only - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8891) RestServerEndpoint can bind on local address only - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:57:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/03 08:58:00 UTC, 0 replies.
- [GitHub] flink issue #5790: [FLINK-9107][docs] document timer coalescing for ProcessF... - posted by NicoK <gi...@git.apache.org> on 2018/04/03 08:58:32 UTC, 1 replies.
- [GitHub] flink issue #5596: [FLINK-8804][Build] Integrate flink-shaded 3.0 - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:04:44 UTC, 1 replies.
- [GitHub] flink issue #5697: [FLINK-8704][tests] Port ScheduleOrUpdateConsumersTest - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:06:10 UTC, 0 replies.
- [GitHub] flink issue #5694: [FLINK-8704][tests] Port SlotCountExceedingParallelismTes... - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:06:29 UTC, 0 replies.
- [GitHub] flink issue #5772: [FLINK-8963][tests] Port BigUserProgramJobSubmitITCase to... - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:06:34 UTC, 0 replies.
- [GitHub] flink issue #5664: [FLINK-8703][tests] Port CancelingTestBase to MiniCluster... - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:06:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:07:00 UTC, 18 replies.
- [jira] [Commented] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:07:00 UTC, 1 replies.
- [GitHub] flink pull request #5762: [FLINK-9078][E2ETests] Add test that verifies corr... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/04/03 09:11:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:12:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/04/03 09:19:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/04/03 09:19:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-9008) End-to-end test: Quickstarts - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/03 09:24:00 UTC, 0 replies.
- [GitHub] flink issue #5766: [FLINK-8966][tests] Port AvroExternalJarProgramITCase to ... - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:24:59 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/04/03 09:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/04/03 09:36:00 UTC, 1 replies.
- [GitHub] flink issue #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:43:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-9094) AccumulatorLiveITCase unstable on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:44:00 UTC, 3 replies.
- [GitHub] flink issue #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsTest - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:44:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:45:00 UTC, 2 replies.
- [GitHub] flink pull request #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClus... - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:51:36 UTC, 2 replies.
- [GitHub] flink pull request #5676: [FLINK-8910][tests] Automated end-to-end test for ... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/03 09:52:52 UTC, 25 replies.
- [jira] [Commented] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:53:00 UTC, 26 replies.
- [GitHub] flink issue #5669: [FLINK-8703][tests] Port KafkaTestBase to MiniClusterReso... - posted by zentol <gi...@git.apache.org> on 2018/04/03 09:53:13 UTC, 1 replies.
- [GitHub] flink issue #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMachineEx... - posted by twalthr <gi...@git.apache.org> on 2018/04/03 09:54:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 09:55:00 UTC, 2 replies.
- [GitHub] flink pull request #5797: [FLINK-9104][doc]Re-generate REST API documentatio... - posted by zentol <gi...@git.apache.org> on 2018/04/03 10:08:45 UTC, 2 replies.
- [GitHub] flink issue #5795: [hotfix] [docs] fix mistake about Sample code in Concepts... - posted by zentol <gi...@git.apache.org> on 2018/04/03 10:13:53 UTC, 0 replies.
- [GitHub] flink pull request #5730: [FLINK-8961][tests] Port JobRetrievalITCase to fli... - posted by zentol <gi...@git.apache.org> on 2018/04/03 10:25:10 UTC, 3 replies.
- [jira] [Commented] (FLINK-8961) Port JobRetrievalITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 10:26:01 UTC, 5 replies.
- [GitHub] flink pull request #5804: [hotfix] [docs] fix typo in table streaming docs - posted by mayyamus <gi...@git.apache.org> on 2018/04/03 10:33:17 UTC, 1 replies.
- [GitHub] flink pull request #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMa... - posted by asfgit <gi...@git.apache.org> on 2018/04/03 10:38:45 UTC, 0 replies.
- [GitHub] flink pull request #5805: [FLINK-8370][REST] Port AggregatingMetricsHandler ... - posted by zentol <gi...@git.apache.org> on 2018/04/03 10:40:35 UTC, 15 replies.
- [jira] [Commented] (FLINK-8370) Port AbstractAggregatingMetricsHandler to RestServerEndpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 10:41:00 UTC, 16 replies.
- [jira] [Resolved] (FLINK-8973) End-to-end test: Run general purpose job with failures in standalone mode - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/03 10:44:00 UTC, 0 replies.
- [GitHub] flink pull request #5806: [FLINK-8960][tests] Port SavepointITCase to flip6 - posted by zentol <gi...@git.apache.org> on 2018/04/03 10:54:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-8960) Port SavepointITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 10:55:00 UTC, 3 replies.
- [GitHub] flink issue #5799: [FLINK-7775] Remove unreferenced method PermanentBlobCach... - posted by yanghua <gi...@git.apache.org> on 2018/04/03 11:35:21 UTC, 2 replies.
- [GitHub] flink issue #5798: [FLINK-7917] The return of taskInformationOrBlobKey shoul... - posted by yanghua <gi...@git.apache.org> on 2018/04/03 11:35:55 UTC, 2 replies.
- [jira] [Created] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/03 12:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8835) Fix TaskManager config keys - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/03 12:08:00 UTC, 26 replies.
- [jira] [Assigned] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/03 12:20:00 UTC, 0 replies.
- [GitHub] flink pull request #5672: [FLINK-8872][flip6] fix yarn detached mode command... - posted by NicoK <gi...@git.apache.org> on 2018/04/03 12:23:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-8872) Yarn detached mode via -yd does not detach - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 12:24:00 UTC, 3 replies.
- [GitHub] flink issue #5672: [FLINK-8872][flip6] fix yarn detached mode command parsin... - posted by NicoK <gi...@git.apache.org> on 2018/04/03 12:25:24 UTC, 1 replies.
- [GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes - posted by ShashwatRastogi-Reflektion <gi...@git.apache.org> on 2018/04/03 12:33:30 UTC, 5 replies.
- [jira] [Commented] (FLINK-5480) User-provided hashes for operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 12:34:00 UTC, 5 replies.
- [jira] [Updated] (FLINK-8835) Fix TaskManager config keys - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/03 12:39:00 UTC, 0 replies.
- [GitHub] flink pull request #5807: [FLINK-8982][E2E Tests] Add test for known failure... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/04/03 12:51:19 UTC, 10 replies.
- [jira] [Commented] (FLINK-8982) End-to-end test: Queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 12:52:00 UTC, 11 replies.
- [jira] [Updated] (FLINK-8707) Excessive amount of files opened by flink task manager - posted by "Alon Galant (JIRA)" <ji...@apache.org> on 2018/04/03 13:16:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-8707) Excessive amount of files opened by flink task manager - posted by "Alon Galant (JIRA)" <ji...@apache.org> on 2018/04/03 13:23:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8707) Excessive amount of files opened by flink task manager - posted by "Alon Galant (JIRA)" <ji...@apache.org> on 2018/04/03 13:23:00 UTC, 2 replies.
- [GitHub] flink pull request #5808: [FLINK-8835] [taskmanager] Fix TaskManager config ... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/03 13:37:29 UTC, 20 replies.
- [GitHub] flink issue #5807: [FLINK-8982][E2E Tests] Add test for known failure of que... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/04/03 13:54:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-9076) Make credit-based floating buffers optional - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/04/03 14:18:00 UTC, 4 replies.
- [GitHub] flink pull request #5782: [FLINK-6567] [tests] Harden ExecutionGraphMetricsT... - posted by asfgit <gi...@git.apache.org> on 2018/04/03 14:36:48 UTC, 0 replies.
- [GitHub] flink pull request #5771: [FLINK-9094] [tests] Harden AccumulatorLiveITCase - posted by asfgit <gi...@git.apache.org> on 2018/04/03 14:36:53 UTC, 0 replies.
- [jira] [Closed] (FLINK-9094) AccumulatorLiveITCase unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/03 14:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6567) ExecutionGraphMetricsTest fails on Windows CI - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/03 14:38:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9076) Make credit-based floating buffers optional - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/03 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9126) Ability for CassandraInputFormat to output data into a Custom Cassandra Annotated Pojo - posted by "Jeffrey Carter (JIRA)" <ji...@apache.org> on 2018/04/03 15:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9010) NoResourceAvailableException with FLIP-6 - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/04/03 16:29:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/03 20:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5809: [FLINK-8697] [Kinesis Connector] Rename DummyFlink... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/03 20:56:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/03 20:57:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/03 20:57:00 UTC, 2 replies.
- [GitHub] flink issue #5808: [FLINK-8835] [taskmanager] Fix TaskManager config keys - posted by zhangminglei <gi...@git.apache.org> on 2018/04/04 00:49:07 UTC, 3 replies.
- [jira] [Created] (FLINK-9127) Filesystem State Backend logged incorrectly - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2018/04/04 00:59:00 UTC, 0 replies.
- [GitHub] flink pull request #5810: [FLINK-9127] [Core] Filesystem State Backend logge... - posted by skidder <gi...@git.apache.org> on 2018/04/04 01:14:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-9127) Filesystem State Backend logged incorrectly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 01:15:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-8933) Avoid calling Class#newInstance - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/04 01:37:01 UTC, 2 replies.
- [jira] [Updated] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/04 01:38:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8971) Create general purpose testing job - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/04 01:50:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/04 02:19:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions - posted by "Renjie Liu (JIRA)" <ji...@apache.org> on 2018/04/04 02:40:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6924) ADD LOG(X) supported in TableAPI - posted by "Jiayi (JIRA)" <ji...@apache.org> on 2018/04/04 04:51:00 UTC, 0 replies.
- [GitHub] flink issue #5797: [FLINK-9104][doc]Re-generate REST API documentation for F... - posted by zentol <gi...@git.apache.org> on 2018/04/04 07:05:49 UTC, 0 replies.
- [GitHub] flink issue #5809: [FLINK-8697] [Kinesis Connector] Rename DummyFlinkKafkaCo... - posted by zentol <gi...@git.apache.org> on 2018/04/04 07:26:32 UTC, 0 replies.
- [GitHub] flink issue #5785: [FLINK-9108][docs] Fix invalid link - posted by zentol <gi...@git.apache.org> on 2018/04/04 07:27:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-9108) invalid ProcessWindowFunction link in Document - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 07:28:00 UTC, 3 replies.
- [GitHub] flink issue #5702: [FLINK-8771] [Checkstyle/Scalastyle] [Build System] Upgra... - posted by zentol <gi...@git.apache.org> on 2018/04/04 07:28:55 UTC, 0 replies.
- [GitHub] flink pull request #5580: [FLINK-8620] Enable shipping custom files to BlobS... - posted by zentol <gi...@git.apache.org> on 2018/04/04 08:24:44 UTC, 26 replies.
- [jira] [Commented] (FLINK-8620) Enable shipping custom artifacts to BlobStore and accessing them through DistributedCache - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 08:25:01 UTC, 26 replies.
- [GitHub] flink pull request #5811: [FLINK-9113] [connectors] Fix flushing behavior of... - posted by twalthr <gi...@git.apache.org> on 2018/04/04 08:44:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 08:45:00 UTC, 13 replies.
- [jira] [Commented] (FLINK-8971) Create general purpose testing job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/04 08:53:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/04 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/04 09:29:00 UTC, 0 replies.
- [GitHub] flink pull request #5812: [FLINK-9128] [flip6] Add support for scheduleRunAs... - posted by tillrohrmann <gi...@git.apache.org> on 2018/04/04 09:30:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 09:31:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/04/04 09:46:00 UTC, 1 replies.
- [jira] [Reopened] (FLINK-9120) Task Manager Fault Tolerance issue - posted by "dhiraj prajapati (JIRA)" <ji...@apache.org> on 2018/04/04 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9129) Support nested KafkaJsonTableSource - posted by "samar (JIRA)" <ji...@apache.org> on 2018/04/04 09:59:00 UTC, 0 replies.
- [GitHub] flink issue #5795: [hotfix] [docs] fix typos in Table API & SQL - posted by fhueske <gi...@git.apache.org> on 2018/04/04 11:02:24 UTC, 0 replies.
- [jira] [Closed] (FLINK-9129) Support nested KafkaJsonTableSource - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 11:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9119) example code error in Concepts & Common API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 11:21:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 11:46:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9066) Add 'HOTSPOTS' function to Flink SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 11:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9068) Website documentation issue - html tag visible on screen - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 11:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9068) Website documentation issue - html tag visible on screen - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 11:50:00 UTC, 6 replies.
- [GitHub] flink issue #5787: Release 1.5 - posted by twalthr <gi...@git.apache.org> on 2018/04/04 11:51:35 UTC, 0 replies.
- [GitHub] flink pull request #5763: [hotfix][tests] Hide output from config.sh - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:27 UTC, 0 replies.
- [GitHub] flink pull request #5795: [hotfix] [docs] fix typos in Table API & SQL - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:28 UTC, 0 replies.
- [GitHub] flink pull request #5736: [FLINK-9042][tests] Port ResumeCheckpointManuallyI... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:29 UTC, 0 replies.
- [GitHub] flink pull request #5769: [FLINK-9069] Add checkstyle rule to detect multipl... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:29 UTC, 0 replies.
- [GitHub] flink pull request #5772: [FLINK-8963][tests] Port BigUserProgramJobSubmitIT... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:30 UTC, 0 replies.
- [GitHub] flink pull request #5664: [FLINK-8703][tests] Port CancelingTestBase to Mini... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:30 UTC, 0 replies.
- [GitHub] flink pull request #5694: [FLINK-8704][tests] Port SlotCountExceedingParalle... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:30 UTC, 0 replies.
- [GitHub] flink pull request #5596: [FLINK-8804][Build] Integrate flink-shaded 3.0 - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:31 UTC, 0 replies.
- [GitHub] flink pull request #5785: [FLINK-9108][docs] Fix invalid link - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:31 UTC, 0 replies.
- [GitHub] flink pull request #5702: [FLINK-8771] [Checkstyle/Scalastyle] [Build System... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 12:24:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-9042) Port ResumeCheckpointManuallyITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 12:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9055) WebUI shows job as Running although not enough resources are available - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 12:29:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 12:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9031) DataSet Job result changes when adding rebalance after union - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 12:37:00 UTC, 1 replies.
- [GitHub] flink pull request #5813: [FLINK-8980] [e2e] Add a BucketingSink end-to-end ... - posted by twalthr <gi...@git.apache.org> on 2018/04/04 12:49:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-8980) End-to-end test: BucketingSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 12:50:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-9042) Port ResumeCheckpointManuallyITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:32:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8963) Port BigUserProgramJobSubmitITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9069) Fix some double semicolons to single semicolons, and update checkstyle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:33:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9104) Re-generate REST API documentation for FLIP-6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:34:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8966) Port AvroExternalJarProgramITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:34:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8804) Bump flink-shaded-jackson dependency to 3.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:35:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8804) Bump flink-shaded-jackson dependency to 3.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:35:00 UTC, 0 replies.
- [GitHub] flink issue #5811: [FLINK-9113] [connectors] Fix flushing behavior of bucket... - posted by twalthr <gi...@git.apache.org> on 2018/04/04 13:35:36 UTC, 3 replies.
- [jira] [Reopened] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8771) Upgrade scalastyle to 1.0.0 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 13:36:00 UTC, 0 replies.
- [GitHub] flink issue #5812: [FLINK-9128] [flip6] Add support for scheduleRunAsync for... - posted by tillrohrmann <gi...@git.apache.org> on 2018/04/04 13:46:35 UTC, 0 replies.
- [GitHub] flink pull request #5814: [FLINK-9045][REST] Add logging message for web UI ... - posted by zentol <gi...@git.apache.org> on 2018/04/04 13:50:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-9045) LocalEnvironment with web UI does not work with flip-6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 13:51:00 UTC, 4 replies.
- [jira] [Closed] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/04 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 14:06:00 UTC, 0 replies.
- [GitHub] flink issue #5791: [FLINK-8507][Table API & SQL] upgrade calcite dependency ... - posted by twalthr <gi...@git.apache.org> on 2018/04/04 14:10:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-8507) Upgrade Calcite dependency to 1.16 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 14:11:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8254) REST API documentation wonky due to shading - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 14:14:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7726) Move marshalling testbases out of legacy namespace - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 14:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/04 14:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 14:29:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 14:31:00 UTC, 1 replies.
- [GitHub] flink pull request #5791: [FLINK-8507][Table API & SQL] upgrade calcite depe... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 14:35:25 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8507) Upgrade Calcite dependency to 1.16 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 14:37:00 UTC, 0 replies.
- [GitHub] flink issue #5792: [Flink-8563][Table API & SQL] add unittest for consecutiv... - posted by twalthr <gi...@git.apache.org> on 2018/04/04 14:41:54 UTC, 0 replies.
- [jira] [Created] (FLINK-9131) Disable spotbugs on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 14:42:01 UTC, 0 replies.
- [GitHub] flink pull request #5792: [Flink-8563][Table API & SQL] add unittest for con... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 14:47:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-9108) invalid ProcessWindowFunction link in Document - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 14:49:00 UTC, 0 replies.
- [GitHub] flink pull request #5815: [FLINK-9131][travis] Disable spotbugs plugin - posted by zentol <gi...@git.apache.org> on 2018/04/04 14:49:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-9131) Disable spotbugs on travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 14:50:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-8563) Support consecutive DOT operators - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 14:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/04 14:53:00 UTC, 28 replies.
- [jira] [Comment Edited] (FLINK-9008) End-to-end test: Quickstarts - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/04 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9132) Cluster runs out of task slots when a job falls into restart loop - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/04 14:57:00 UTC, 0 replies.
- [GitHub] flink pull request #5794: [Flink-8509][Table API & SQL] Remove SqlGroupedWin... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 15:02:19 UTC, 0 replies.
- [jira] [Created] (FLINK-9133) Improve documentability of REST API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 15:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8509) Remove SqlGroupedWindowFunction from Flink repo - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 15:08:00 UTC, 0 replies.
- [GitHub] flink pull request #5793: [FLINK-8508][Table API & SQL] Remove RexSimplify c... - posted by asfgit <gi...@git.apache.org> on 2018/04/04 15:19:43 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8508) Remove RexSimplify from Flink repo - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 15:20:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8508) Remove RexSimplify from Flink repo - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 15:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9134) Update Calcite dependency to 1.17 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 15:22:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 15:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14 - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 15:29:00 UTC, 0 replies.
- [GitHub] flink issue #5788: [FLINK-9110][docs] fix local bundler installation - posted by twalthr <gi...@git.apache.org> on 2018/04/04 15:51:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-9110) Building docs with Ruby 2.5 fails if bundler is not globally installed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 15:52:00 UTC, 3 replies.
- [jira] [Reopened] (FLINK-9031) DataSet Job result changes when adding rebalance after union - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 16:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9031) DataSet Job result changes when adding rebalance after union - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 16:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9031) DataSet Job result changes when adding rebalance after union - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 16:08:00 UTC, 0 replies.
- [GitHub] flink pull request #5788: [FLINK-9110][docs] fix local bundler installation - posted by asfgit <gi...@git.apache.org> on 2018/04/04 16:16:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9110) Building docs with Ruby 2.5 fails if bundler is not globally installed - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 16:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/04 16:49:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9131) Disable spotbugs on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 17:08:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9107) Document timer coalescing for ProcessFunctions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 17:21:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9110) Building docs with Ruby 2.5 fails if bundler is not globally installed - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/04 17:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9136) Remove StreamingProgramTestBase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 17:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9137) Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/04 17:49:00 UTC, 0 replies.
- [GitHub] flink pull request #5816: [FLINK-9137][tests] Merge TopSpeedWindowingExample... - posted by zentol <gi...@git.apache.org> on 2018/04/04 17:52:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-9137) Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 17:53:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9134) Update Calcite dependency to 1.17 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/04 17:55:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9138) Enhance BucketingSink to also flush data by time interval - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/04 17:55:00 UTC, 0 replies.
- [GitHub] flink pull request #5817: [FLINK-9136][tests] Remove StreamingProgramTestBas... - posted by zentol <gi...@git.apache.org> on 2018/04/04 18:00:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-9136) Remove StreamingProgramTestBase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/04 18:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8554) Upgrade AWS SDK - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/04 23:13:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-7151) FLINK SQL support create temporary function and table - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/04 23:17:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/04 23:19:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-5153) Allow setting custom application tags for Flink on YARN - posted by "Nikhil Simha (JIRA)" <ji...@apache.org> on 2018/04/05 00:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5153) Allow setting custom application tags for Flink on YARN - posted by "Nikhil Simha (JIRA)" <ji...@apache.org> on 2018/04/05 00:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9139) Allow yarn.tags as a job parameter - posted by "Nikhil Simha (JIRA)" <ji...@apache.org> on 2018/04/05 00:23:00 UTC, 0 replies.
- [GitHub] flink pull request #5818: sql() is deprecated. - posted by mayyamus <gi...@git.apache.org> on 2018/04/05 02:03:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-9089) Upgrade Orc dependency to 1.4.3 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/05 02:16:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9134) Update Calcite dependency to 1.17 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/05 03:57:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9134) Update Calcite dependency to 1.17 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/05 04:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9015) Upgrade Calcite dependency to 1.17 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/05 04:05:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9015) Upgrade Calcite dependency to 1.17 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/05 04:05:00 UTC, 0 replies.
- [GitHub] flink issue #5810: [FLINK-9127] [Core] Filesystem State Backend logged incor... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/05 06:40:15 UTC, 0 replies.
- [jira] [Closed] (FLINK-7566) if there's only one checkpointing metadata file in , `flink run -s ` should successfully resume from that metadata file - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/05 06:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8188) Clean up flink-contrib - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/05 07:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8514) move flink-connector-wikiedits to Apache Bahir - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/05 07:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9140) simplify scalastyle configurations - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/05 07:40:00 UTC, 0 replies.
- [GitHub] flink pull request #5819: [FLINK-9140] [Build System] [scalastyle] simplify ... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/05 07:44:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-9140) simplify scalastyle configurations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/05 07:45:00 UTC, 2 replies.
- [GitHub] flink pull request #5820: [hotfix] removed unused scala imports - posted by bowenli86 <gi...@git.apache.org> on 2018/04/05 07:53:43 UTC, 0 replies.
- [jira] [Created] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/05 08:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/05 08:26:00 UTC, 2 replies.
- [GitHub] flink issue #5818: [hotfix][table][docs]sql() is deprecated. - posted by fhueske <gi...@git.apache.org> on 2018/04/05 08:48:32 UTC, 0 replies.
- [GitHub] flink issue #5730: [FLINK-8961][tests] Port JobRetrievalITCase to flip6 - posted by zentol <gi...@git.apache.org> on 2018/04/05 09:09:08 UTC, 1 replies.
- [GitHub] flink pull request #5818: [hotfix][table][docs]sql() is deprecated. - posted by asfgit <gi...@git.apache.org> on 2018/04/05 09:27:04 UTC, 0 replies.
- [GitHub] flink pull request #5821: [FLINK-8742][docs] Move docs generator annotations... - posted by zentol <gi...@git.apache.org> on 2018/04/05 10:46:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-8742) Move ConfigDocsGenerator annotation to flink-annotations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/05 10:47:00 UTC, 2 replies.
- [GitHub] flink pull request #5822: [FLINK-8743][docs] Allow overriding documented def... - posted by zentol <gi...@git.apache.org> on 2018/04/05 10:51:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-8743) Add annotation to override documented default - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/05 10:52:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8742) Move ConfigDocsGenerator annotation to flink-annotations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/05 10:53:00 UTC, 0 replies.
- [GitHub] flink issue #5411: [FLINK-8556] [Kinesis Connector] Add proxy feature to the... - posted by pduveau <gi...@git.apache.org> on 2018/04/05 12:25:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/05 12:26:00 UTC, 1 replies.
- [GitHub] flink issue #5410: [FLINK-8468] [RabbitMQ Connector] Take advantage of AMQP ... - posted by pduveau <gi...@git.apache.org> on 2018/04/05 12:29:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-8468) Make the connector to take advantage of AMQP features (routing key, exchange and message properties) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/05 12:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/05 13:24:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/05 13:33:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/04/05 13:38:00 UTC, 1 replies.
- [GitHub] flink issue #5705: [FLINK-8699][FLINK-8968][state]Fix native resource leak c... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/05 14:24:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/05 14:25:00 UTC, 2 replies.
- [GitHub] flink pull request #5823: [FLINK-9008] [e2e] Implements quickstarts end to e... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/05 14:30:02 UTC, 20 replies.
- [jira] [Commented] (FLINK-9138) Enhance BucketingSink to also flush data by time interval - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/04/05 16:17:00 UTC, 21 replies.
- [jira] [Resolved] (FLINK-9118) Support a time based rollover of part file in Bucketing Sink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/04/05 16:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/05 17:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/05 21:33:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/05 21:34:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/05 22:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/05 22:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8335) Upgrade hbase connector dependency to 1.4.1 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/06 01:24:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/06 01:25:00 UTC, 3 replies.
- [GitHub] flink pull request #5824: [FLINK-9068][docs] Fix for removing extra '

' t... - posted by shankarganesh1234 <gi...@git.apache.org> on 2018/04/06 03:04:25 UTC, 1 replies.
- [GitHub] flink issue #5488: [FLINK-8335] [hbase] Upgrade hbase connector dependency t... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/06 03:59:23 UTC, 4 replies.
- [jira] [Commented] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/06 04:00:00 UTC, 5 replies.
- [jira] [Created] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/06 07:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/06 07:29:00 UTC, 6 replies.
- [jira] [Created] (FLINK-9144) Spilling batch job hangs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/06 09:22:00 UTC, 0 replies.
- [GitHub] flink issue #5824: [FLINK-9068][docs] Fix for removing extra '

' tag - posted by fhueske <gi...@git.apache.org> on 2018/04/06 10:04:18 UTC, 3 replies.
- [GitHub] flink issue #5800: [FLINK-8837] [DataStream API] add @Experimental annotatio... - posted by zentol <gi...@git.apache.org> on 2018/04/06 10:07:05 UTC, 0 replies.
- [GitHub] flink issue #5821: [FLINK-8742][docs] Move docs generator annotations to fli... - posted by zentol <gi...@git.apache.org> on 2018/04/06 10:19:33 UTC, 0 replies.
- [GitHub] flink pull request #5786: [FLINK-9109] [doc] Update documentation for CLI - posted by zentol <gi...@git.apache.org> on 2018/04/06 10:21:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-9109) Add flink modify command to documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/06 10:22:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9068) Website documentation issue - html tag visible on screen - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/06 10:22:00 UTC, 0 replies.
- [GitHub] flink pull request #5705: [FLINK-8699][FLINK-8968][state]Fix native resource... - posted by asfgit <gi...@git.apache.org> on 2018/04/06 10:34:08 UTC, 0 replies.
- [jira] [Closed] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/06 10:36:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8968) Fix native resource leak caused by ReadOptions - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/06 10:37:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9059) Add support for unified table source and sink declaration in environment file - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/06 12:16:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9005) Cluster test: Run general purpose job with failures with Mesos - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/06 12:37:00 UTC, 0 replies.
- [GitHub] flink pull request #5760: [hotfix] [doc] update maven versions in building f... - posted by asfgit <gi...@git.apache.org> on 2018/04/06 13:25:35 UTC, 0 replies.
- [GitHub] flink pull request #5787: Release 1.5 - posted by asfgit <gi...@git.apache.org> on 2018/04/06 13:25:36 UTC, 0 replies.
- [GitHub] flink pull request #5800: [FLINK-8837] [DataStream API] add @Experimental an... - posted by asfgit <gi...@git.apache.org> on 2018/04/06 13:25:37 UTC, 0 replies.
- [jira] [Updated] (FLINK-8967) Port NetworkStackThroughputITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:26:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8837) add @Experimental annotation and properly annotate some classes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8835) Fix TaskManager config keys - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8742) Move ConfigDocsGenerator annotation to flink-annotations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9145) Website build is broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/06 13:38:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/06 15:19:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9145) Website build is broken - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/06 15:24:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/06 15:27:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/06 15:28:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/06 15:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9055) WebUI shows job as Running although not enough resources are available - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/06 15:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9127) Filesystem State Backend logged incorrectly - posted by "Scott Kidder (JIRA)" <ji...@apache.org> on 2018/04/06 15:43:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/04/06 16:00:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9114) Enable user-provided, custom CheckpointRecoveryFactory for non-HA deployments - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/06 16:04:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-7554) Add a testing RuntimeContext to test utilities - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/06 16:30:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9114) Enable user-provided, custom CheckpointRecoveryFactory for non-HA deployments - posted by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/04/06 16:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9144) Spilling batch job hangs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/06 17:56:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/04/06 17:57:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9145) Website build is broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/06 18:05:00 UTC, 11 replies.
- [jira] [Updated] (FLINK-9144) Spilling batch job hangs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/06 18:11:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/07 08:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/07 14:09:00 UTC, 4 replies.
- [GitHub] flink pull request #5825: [FLINK-9040][local runtime] check maxParallelism i... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/07 14:17:13 UTC, 1 replies.
- [GitHub] flink issue #5825: [FLINK-9040][local runtime] check maxParallelism in JobVe... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/07 14:17:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/07 14:18:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/07 14:19:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/08 01:43:00 UTC, 2 replies.
- [GitHub] flink pull request #5826: [FLINK-9089] Upgrade Orc dependency to 1.4.3 - posted by yanghua <gi...@git.apache.org> on 2018/04/08 02:15:41 UTC, 1 replies.
- [GitHub] flink issue #5826: [FLINK-9089] Upgrade Orc dependency to 1.4.3 - posted by yanghua <gi...@git.apache.org> on 2018/04/08 02:15:54 UTC, 2 replies.
- [jira] [Commented] (FLINK-9089) Upgrade Orc dependency to 1.4.3 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/08 02:16:00 UTC, 4 replies.
- [GitHub] flink pull request #5827: [hotfix][docs][minor] fix typo in documentation - posted by pradithya <gi...@git.apache.org> on 2018/04/08 02:42:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1 - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/04/08 02:43:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9143) Restart strategy defined in flink-conf.yaml is ignored - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/08 02:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/08 04:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9146) 1.4 more than local cannot start submitting - posted by "abel-sun (JIRA)" <ji...@apache.org> on 2018/04/08 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/08 06:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/08 06:39:00 UTC, 0 replies.
- [GitHub] flink pull request #5828: [FLINK-9147] [metrics] Include shaded Prometheus d... - posted by tillrohrmann <gi...@git.apache.org> on 2018/04/08 06:42:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/08 06:43:00 UTC, 3 replies.
- [GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test - posted by zhangminglei <gi...@git.apache.org> on 2018/04/08 09:38:10 UTC, 6 replies.
- [GitHub] flink issue #5828: [FLINK-9147] [metrics] Include shaded Prometheus dependen... - posted by zentol <gi...@git.apache.org> on 2018/04/08 09:49:30 UTC, 1 replies.
- [jira] [Created] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution" - posted by "You Chu (JIRA)" <ji...@apache.org> on 2018/04/08 14:58:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution" - posted by "You Chu (JIRA)" <ji...@apache.org> on 2018/04/08 15:02:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/08 21:19:00 UTC, 1 replies.
- [GitHub] flink issue #5394: [FLINK-6571][tests] Catch InterruptedException in StreamS... - posted by zentol <gi...@git.apache.org> on 2018/04/08 21:20:17 UTC, 0 replies.
- [jira] [Updated] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/04/09 06:29:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8747) The tag of waiting for floating buffers in RemoteInputChannel should be updated properly - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/04/09 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9149) The creation of the ExecutionPlan fails when you combine a SideOutput with an SplitStream. - posted by "Fred Teunissen (JIRA)" <ji...@apache.org> on 2018/04/09 09:07:00 UTC, 0 replies.
- [GitHub] flink pull request #5829: [FLINK-9056] [jobmanager] Job submission fails wit... - posted by yuqi1129 <gi...@git.apache.org> on 2018/04/09 13:56:15 UTC, 0 replies.
- [jira] [Created] (FLINK-9150) Prepare for Java 10 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/09 16:11:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/09 16:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers - posted by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/04/09 16:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers - posted by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/04/09 16:33:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9150) Prepare for Java 10 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/09 16:57:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9126) Ability for CassandraInputFormat to output data into a Custom Cassandra Annotated Pojo - posted by "Jeffrey Carter (JIRA)" <ji...@apache.org> on 2018/04/09 19:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9149) The creation of the ExecutionPlan fails when you combine a SideOutput with an SplitStream. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/09 19:45:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/09 19:52:00 UTC, 0 replies.
- [GitHub] flink issue #5777: [FLINK-7897] Consider using nio.Files for file deletion i... - posted by tedyu <gi...@git.apache.org> on 2018/04/09 20:57:57 UTC, 3 replies.
- [jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/09 20:58:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9152) Harmonize BroadcastProcessFunction Context names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/09 23:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9152) Harmonize BroadcastProcessFunction Context names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/09 23:16:00 UTC, 0 replies.
- [GitHub] flink pull request #5830: [FLINK-9152] Harmonize BroadcastProcessFunction Co... - posted by aljoscha <gi...@git.apache.org> on 2018/04/09 23:16:02 UTC, 4 replies.
- [jira] [Commented] (FLINK-9152) Harmonize BroadcastProcessFunction Context names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/09 23:17:00 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/10 00:30:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7525) Add config option to disable Cancel functionality on UI - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/10 00:30:00 UTC, 0 replies.
- [GitHub] flink issue #4482: [FLINK-4534] Fix synchronization issue in BucketingSink - posted by zhangminglei <gi...@git.apache.org> on 2018/04/10 01:27:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/10 01:28:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/10 01:37:00 UTC, 1 replies.
- [GitHub] flink pull request #5831: [FLINK-9151] [Startup Shell Scripts] Export FLINK_... - posted by facboy <gi...@git.apache.org> on 2018/04/10 08:53:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/10 08:54:00 UTC, 5 replies.
- [GitHub] flink pull request #5832: [FLINK-9151] [Startup Shell Scripts] Export FLINK_... - posted by facboy <gi...@git.apache.org> on 2018/04/10 09:03:26 UTC, 1 replies.
- [jira] [Closed] (FLINK-8702) Migrate tests from FlinkMiniCluster to MiniClusterResource - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/10 09:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8961) Port JobRetrievalITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/10 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9153) TaskManagerRunner should support rpc port range - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/10 09:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9137) Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/10 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9154) Include WebSubmissionExtension in REST API docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/10 11:37:00 UTC, 0 replies.
- [GitHub] flink issue #4943: [FLINK-6022] [avro] Use Avro to serialize Avro in flight ... - posted by shashank734 <gi...@git.apache.org> on 2018/04/10 11:41:09 UTC, 3 replies.
- [GitHub] flink pull request #5833: [FLINK-9154][REST][docs] Document WebSubmissionExt... - posted by zentol <gi...@git.apache.org> on 2018/04/10 11:41:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-6022) Don't serialise Schema when serialising Avro GenericRecord - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/10 11:42:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-9154) Include WebSubmissionExtension in REST API docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/10 11:42:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9155) Provide message context information in DeserializationSchema - posted by "Alex Smirnov (JIRA)" <ji...@apache.org> on 2018/04/10 11:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5834: [FLINK-9153] TaskManagerRunner should support rpc ... - posted by yanghua <gi...@git.apache.org> on 2018/04/10 11:56:46 UTC, 9 replies.
- [jira] [Commented] (FLINK-9153) TaskManagerRunner should support rpc port range - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/10 11:57:00 UTC, 14 replies.
- [GitHub] flink issue #5834: [FLINK-9153] TaskManagerRunner should support rpc port ra... - posted by yanghua <gi...@git.apache.org> on 2018/04/10 11:59:30 UTC, 4 replies.
- [GitHub] flink issue #5803: [FLINK-9124] [kinesis] Allow customization of KinesisProx... - posted by tweise <gi...@git.apache.org> on 2018/04/10 13:29:18 UTC, 1 replies.
- [GitHub] flink issue #5802: [FLINK-9087] [runtime] change the method signature of Rec... - posted by trionesadam <gi...@git.apache.org> on 2018/04/10 14:50:02 UTC, 3 replies.
- [jira] [Updated] (FLINK-8205) Multi key get - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/10 16:25:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9070) Improve performance of RocksDBMapState.clear() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/10 16:27:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9070) Improve performance of RocksDBMapState.clear() - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/10 16:27:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-9087) Change the method signature of RecordWriter#broadcastEvent() from BufferConsumer to void - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/10 17:10:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/11 01:07:00 UTC, 0 replies.
- [GitHub] flink pull request #5835: [FLINK-2435] Extending CsvReader capabilities: it ... - posted by DmitryKober <gi...@git.apache.org> on 2018/04/11 07:45:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/11 07:46:00 UTC, 7 replies.
- [GitHub] flink pull request #5836: [FLINK-9141][datastream] Fail early when using bot... - posted by zentol <gi...@git.apache.org> on 2018/04/11 09:19:28 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8426) Error in Generating Timestamp/Watermakr doc - posted by "Dmitrii Kniazev (JIRA)" <ji...@apache.org> on 2018/04/11 09:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5837: [FLINK-8426][docs] Error in Generating Timestamp/W... - posted by mylog00 <gi...@git.apache.org> on 2018/04/11 09:51:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-8426) Error in Generating Timestamp/Watermakr doc - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/11 09:52:00 UTC, 4 replies.
- [GitHub] flink issue #5837: [FLINK-8426][docs] Error in Generating Timestamp/Watermak... - posted by zentol <gi...@git.apache.org> on 2018/04/11 09:59:57 UTC, 2 replies.
- [jira] [Updated] (FLINK-9156) CLI does not respect -m,--jobmanager option - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/11 10:02:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9156) CLI does not respect -m,--jobmanager option - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/11 10:02:00 UTC, 0 replies.
- [GitHub] flink issue #5827: [hotfix][docs][minor] fix typo in documentation - posted by zentol <gi...@git.apache.org> on 2018/04/11 10:04:01 UTC, 0 replies.
- [GitHub] flink issue #5819: [FLINK-9140] [Build System] [scalastyle] simplify scalast... - posted by zentol <gi...@git.apache.org> on 2018/04/11 10:04:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-9156) CLI does not respect -m,--jobmanager option - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/11 10:21:00 UTC, 5 replies.
- [jira] [Assigned] (FLINK-9156) CLI does not respect -m,--jobmanager option - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/11 10:36:00 UTC, 2 replies.
- [GitHub] flink pull request #5838: [FLINK-9156][REST][CLI] Update --jobmanager option... - posted by zentol <gi...@git.apache.org> on 2018/04/11 11:03:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-9087) Change the method signature of RecordWriter#broadcastEvent() from BufferConsumer to void - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/11 11:53:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9157) Create support for commonly used external catalog - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/11 19:09:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9157) Support for commonly used external catalog - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/11 19:10:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-8981) End-to-end test: Kerberos security - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:00:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8978) End-to-end test: Job upgrade - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:01:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:02:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8624) flink-mesos: The flink rest-api sometimes becomes unresponsive - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9159) Sanity check default timeout values - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/12 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9160) Make subclasses of RuntimeContext internal that should be internal - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/12 02:34:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/12 02:50:00 UTC, 7 replies.
- [GitHub] flink pull request #5839: [FLINK-9158][Distributed Coordination] Set default... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/12 03:26:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/12 03:27:00 UTC, 0 replies.
- [GitHub] flink issue #5839: [FLINK-9158][Distributed Coordination] Set default FixedR... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/12 03:27:01 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9159) Sanity check default timeout values - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/12 03:51:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/04/12 07:27:00 UTC, 2 replies.
- [GitHub] flink pull request #5802: [FLINK-9087] [runtime] change the method signature... - posted by asfgit <gi...@git.apache.org> on 2018/04/12 07:37:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 07:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8426) Error in Generating Timestamp/Watermakr doc - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 07:38:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9140) simplify scalastyle configurations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 07:38:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9087) Change the method signature of RecordWriter#broadcastEvent() from BufferConsumer to void - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 07:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9087) Change the method signature of RecordWriter#broadcastEvent() from BufferConsumer to void - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 07:40:00 UTC, 0 replies.
- [GitHub] flink issue #5820: [hotfix] [DataStream API] [Scala] removed unused scala im... - posted by zentol <gi...@git.apache.org> on 2018/04/12 07:43:36 UTC, 1 replies.
- [GitHub] flink issue #5832: [FLINK-9151] [Startup Shell Scripts] Export FLINK_CONF_DI... - posted by facboy <gi...@git.apache.org> on 2018/04/12 08:23:43 UTC, 0 replies.
- [GitHub] flink issue #5831: [FLINK-9151] [Startup Shell Scripts] Export FLINK_CONF_DI... - posted by facboy <gi...@git.apache.org> on 2018/04/12 08:23:59 UTC, 0 replies.
- [jira] [Closed] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers - posted by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/04/12 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9161) Support AS STRUCT syntax to create named STRUCT in SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/12 08:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/12 08:33:00 UTC, 0 replies.
- [GitHub] flink issue #3554: Detached (Remote)StreamEnvironment execution - posted by bachrc <gi...@git.apache.org> on 2018/04/12 08:49:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-9157) Support for commonly used external catalog - posted by "Dmitrii Kober (JIRA)" <ji...@apache.org> on 2018/04/12 09:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8743) Add annotation to override documented default - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 11:41:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8744) Add annotations for documentation common/advanced options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9162) Scala REPL hanging when running example - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/04/12 12:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9162) Scala REPL hanging when running example - posted by "陈梓立 (JIRA)" <ji...@apache.org> on 2018/04/12 12:06:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9162) Scala REPL hanging when running example - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 12:43:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/12 13:51:00 UTC, 0 replies.
- [GitHub] flink pull request #5840: [FLINK-7850] [build system] Give each maven profil... - posted by kai-chi <gi...@git.apache.org> on 2018/04/12 14:36:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-7850) Given each maven profile an activation property - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/12 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/12 15:26:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/12 15:29:00 UTC, 0 replies.
- [GitHub] flink pull request #5841: [FLINK-9163[e2e-tests] harden signal traps and con... - posted by NicoK <gi...@git.apache.org> on 2018/04/12 15:33:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/12 15:34:00 UTC, 2 replies.
- [GitHub] flink issue #5830: [FLINK-9152] Harmonize BroadcastProcessFunction Context n... - posted by aljoscha <gi...@git.apache.org> on 2018/04/12 15:51:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-9160) Make subclasses of RuntimeContext internal that should be internal - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/12 15:52:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8795) Scala shell broken for Flip6 - posted by "Zili Chen (JIRA)" <ji...@apache.org> on 2018/04/12 16:12:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-8707) Excessive amount of files opened by flink task manager - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/04/12 16:19:00 UTC, 0 replies.
- [GitHub] flink pull request #5842: [FLINK-9144][network] fix SpillableSubpartition ca... - posted by NicoK <gi...@git.apache.org> on 2018/04/12 16:28:40 UTC, 1 replies.
- [GitHub] flink pull request #5843: [FLINK-8744][docs] Generate "Common Option" sectio... - posted by zentol <gi...@git.apache.org> on 2018/04/12 17:48:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-8744) Add annotations for documentation common/advanced options - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/12 17:49:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1913) Document how to access data in HCatalog - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/12 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9164) times(#,#) quantifier does not seem to work - posted by "Romain Revol (JIRA)" <ji...@apache.org> on 2018/04/12 20:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9165) Improve CassandraSinkBase to send Collections - posted by "Christopher Hughes (JIRA)" <ji...@apache.org> on 2018/04/12 21:02:00 UTC, 0 replies.
- [GitHub] flink pull request #5844: [FLINK-9165] [DataSink] Upgrading CassandraSinkBas... - posted by Bekreth <gi...@git.apache.org> on 2018/04/12 21:14:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-9165) Improve CassandraSinkBase to send Collections - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/12 21:15:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9103) SSL verification on TaskManager when parallelism > 1 - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/12 22:35:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9160) Make subclasses of RuntimeContext internal that should be internal - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/12 22:40:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9152) Harmonize BroadcastProcessFunction Context names - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/12 22:41:00 UTC, 0 replies.
- [GitHub] flink issue #5844: [FLINK-9165] [DataSink] Upgrading CassandraSinkBase to su... - posted by Bekreth <gi...@git.apache.org> on 2018/04/12 23:15:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-9164) times(#,#) quantifier does not seem to work - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/04/13 00:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9166) Performance issue with Flink SQL - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/04/13 00:13:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9166) Performance issue with Flink SQL - posted by "SUBRAMANYA SURESH (JIRA)" <ji...@apache.org> on 2018/04/13 00:15:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9167) Approximate KNN with Incremental Insertion - posted by "Alex Klibisz (JIRA)" <ji...@apache.org> on 2018/04/13 04:29:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9167) Approximate KNN with Incremental Insertion - posted by "Alex Klibisz (JIRA)" <ji...@apache.org> on 2018/04/13 04:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/13 04:49:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/13 08:23:00 UTC, 0 replies.
- [GitHub] flink pull request #3899: [FLINK-6557] Fix RocksDBKeyedStateBackend on Windo... - posted by zentol <gi...@git.apache.org> on 2018/04/13 08:23:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-6557) RocksDBKeyedStateBackend broken on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/13 08:24:00 UTC, 0 replies.
- [GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-... - posted by juhoautio <gi...@git.apache.org> on 2018/04/13 08:45:07 UTC, 1 replies.
- [jira] [Created] (FLINK-9168) Pulsar Sink Connector - posted by "Xiao Zongyang (JIRA)" <ji...@apache.org> on 2018/04/13 08:54:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9168) Pulsar Sink Connector - posted by "Xiao Zongyang (JIRA)" <ji...@apache.org> on 2018/04/13 08:57:00 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-9168) Pulsar Sink Connector - posted by "Zongyang Xiao (JIRA)" <ji...@apache.org> on 2018/04/13 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/13 16:55:00 UTC, 0 replies.
- [GitHub] flink pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connecto... - posted by XiaoZYang <gi...@git.apache.org> on 2018/04/13 17:14:55 UTC, 0 replies.
- [GitHub] flink issue #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip6 - posted by tillrohrmann <gi...@git.apache.org> on 2018/04/13 17:56:23 UTC, 8 replies.
- [jira] [Commented] (FLINK-8955) Port ClassLoaderITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/13 17:57:00 UTC, 22 replies.
- [GitHub] flink pull request #5780: [FLINK-8955][tests] Port ClassLoaderITCase to flip... - posted by tillrohrmann <gi...@git.apache.org> on 2018/04/13 18:09:53 UTC, 13 replies.
- [jira] [Resolved] (FLINK-8872) Yarn detached mode via -yd does not detach - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/13 19:20:00 UTC, 0 replies.
- [GitHub] flink pull request #5789: [FLINK-9103] Using CanonicalHostName instead of IP... - posted by asfgit <gi...@git.apache.org> on 2018/04/13 20:17:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-9103) SSL verification on TaskManager when parallelism > 1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/13 20:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9103) SSL verification on TaskManager when parallelism > 1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/13 20:18:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9103) SSL verification on TaskManager when parallelism > 1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/04/13 20:19:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/13 22:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9170) HCatolog integration with Table/SQL API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9171) Flink HCatolog integration - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9170) HCatolog integration with Table/SQL API - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1913) Document how to access data in HCatalog - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:53:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-1466) Add InputFormat to read HCatalog tables - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:56:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9157) Support Apache HCatalog in SQL client - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/13 23:57:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9172) Support external catalog factory that comes default with SQL-Client - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/14 00:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9172) Support external catalog factory that comes default with SQL-Client - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/14 00:52:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9157) Support Apache HCatalog in SQL client - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/14 00:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9173) RestClient - Received response is abnormal - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/14 01:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9173) RestClient - Received response is abnormal - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/14 01:24:00 UTC, 6 replies.
- [GitHub] flink pull request #5846: [FLINK-9143] [client] Restart strategy defined in ... - posted by yuqi1129 <gi...@git.apache.org> on 2018/04/14 06:22:29 UTC, 0 replies.
- [jira] [Created] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/14 10:20:00 UTC, 0 replies.
- [GitHub] flink pull request #5847: [FLINK-9174][datastream]Fix the type of state crea... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/14 10:29:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/14 10:30:00 UTC, 3 replies.
- [GitHub] flink issue #5847: [FLINK-9174][datastream]Fix the type of state created in ... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/14 10:36:06 UTC, 1 replies.
- [GitHub] flink pull request #5848: Minor cleanup of Java example code for AsyncFuncti... - posted by kkrugler <gi...@git.apache.org> on 2018/04/14 20:07:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-9173) RestClient - Received response is abnormal - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/14 22:24:00 UTC, 5 replies.
- [jira] [Created] (FLINK-9175) Flink CEP with Checkpointing alway failed - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/04/15 03:53:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8993) Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom) - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/15 11:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9176) Category annotations are unused - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/15 12:15:00 UTC, 0 replies.
- [GitHub] flink issue #5846: [FLINK-9143] [client] Restart strategy defined in flink-c... - posted by yuqi1129 <gi...@git.apache.org> on 2018/04/15 13:45:55 UTC, 0 replies.
- [GitHub] flink issue #5829: [FLINK-9056] [jobmanager] Job submission fails with AskTi... - posted by yuqi1129 <gi...@git.apache.org> on 2018/04/15 13:47:10 UTC, 0 replies.
- [GitHub] flink pull request #5849: [FLINK-8986][e2e-test] Flink end to end test REST ... - posted by walterddr <gi...@git.apache.org> on 2018/04/15 15:13:08 UTC, 18 replies.
- [jira] [Commented] (FLINK-8986) End-to-end test: REST - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/15 15:14:00 UTC, 20 replies.
- [GitHub] flink issue #5849: [FLINK-8986][e2e-test] Flink end to end test REST API - posted by walterddr <gi...@git.apache.org> on 2018/04/15 15:15:43 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9176) Category annotations are unused - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/16 02:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9176) Category annotations are unused - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/16 02:09:00 UTC, 4 replies.
- [GitHub] flink issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector - posted by tzulitai <gi...@git.apache.org> on 2018/04/16 05:24:44 UTC, 3 replies.
- [GitHub] flink issue #5841: [FLINK-9163[e2e-tests] harden signal traps and config res... - posted by tzulitai <gi...@git.apache.org> on 2018/04/16 05:30:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-9175) Flink CEP with Checkpointing alway failed - posted by "godfrey johnson (JIRA)" <ji...@apache.org> on 2018/04/16 05:55:00 UTC, 5 replies.
- [jira] [Resolved] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/16 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Arunan Sugunakumar (JIRA)" <ji...@apache.org> on 2018/04/16 07:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Arunan Sugunakumar (JIRA)" <ji...@apache.org> on 2018/04/16 07:06:00 UTC, 0 replies.
- [GitHub] flink pull request #5850: [FLINK-9177] [Documentation] Update Mesos getting ... - posted by arunans23 <gi...@git.apache.org> on 2018/04/16 07:34:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 07:35:00 UTC, 1 replies.
- [GitHub] flink pull request #5851: [FLINK-9176] [build] Re-introduce category to sure... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/16 08:28:31 UTC, 0 replies.
- [GitHub] flink issue #5838: [FLINK-9156][REST][CLI] Update --jobmanager option logic ... - posted by zentol <gi...@git.apache.org> on 2018/04/16 08:34:44 UTC, 0 replies.
- [jira] [Updated] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/16 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9178) Add rate control for kafka source - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/16 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9180) Remove REST_ prefix from rest options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9181) Add SQL Client documentation page - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/16 10:04:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9181) Add SQL Client documentation page - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/16 10:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9180) Remove REST_ prefix from rest options - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/16 10:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/16 10:28:00 UTC, 0 replies.
- [GitHub] flink issue #5805: [FLINK-8370][REST] Port AggregatingMetricsHandler to flip... - posted by zentol <gi...@git.apache.org> on 2018/04/16 10:38:47 UTC, 0 replies.
- [GitHub] flink pull request #5852: [FLINK-9180] [conf] Remove REST_ prefix from rest ... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/16 10:39:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-9180) Remove REST_ prefix from rest options - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 10:40:00 UTC, 18 replies.
- [GitHub] flink issue #5814: [FLINK-9045][REST] Add logging message for web UI address - posted by zentol <gi...@git.apache.org> on 2018/04/16 10:48:02 UTC, 2 replies.
- [jira] [Created] (FLINK-9182) async checkpoints for timer service - posted by "makeyang (JIRA)" <ji...@apache.org> on 2018/04/16 11:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9174) The type of state created in ProccessWindowFunction.proccess() is inconsistency - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/16 11:19:00 UTC, 1 replies.
- [GitHub] flink pull request #5853: [FLINK-9145] [table] Clean up flink-table dependen... - posted by twalthr <gi...@git.apache.org> on 2018/04/16 11:26:28 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9182) async checkpoints for timer service - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/16 11:31:00 UTC, 0 replies.
- [GitHub] flink issue #5853: [FLINK-9145] [table] Clean up flink-table dependencies - posted by zentol <gi...@git.apache.org> on 2018/04/16 11:33:14 UTC, 3 replies.
- [GitHub] flink pull request #5854: [FLINK-8793][REST] hidden key containing "secret" ... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/16 11:44:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-8793) Hide key containing "secret" in web interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 11:45:00 UTC, 1 replies.
- [GitHub] flink issue #5854: [FLINK-8793][REST] hidden key containing "secret" in web ... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/16 11:45:32 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8793) Hide key containing "secret" in web interface - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/16 11:46:00 UTC, 0 replies.
- [GitHub] flink issue #5835: [FLINK-2435] Extending CsvReader capabilities: it is now ... - posted by fhueske <gi...@git.apache.org> on 2018/04/16 12:10:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/04/16 12:14:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-9166) Performance issue with Flink SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/16 12:25:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9166) Performance issue with Flink SQL - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/16 12:26:00 UTC, 0 replies.
- [GitHub] flink issue #5852: [FLINK-9180] [conf] Remove REST_ prefix from rest options - posted by zhangminglei <gi...@git.apache.org> on 2018/04/16 12:43:23 UTC, 2 replies.
- [jira] [Updated] (FLINK-7866) Weigh list of preferred locations for scheduling - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/16 12:47:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 13:07:00 UTC, 0 replies.
- [GitHub] flink pull request #5855: [FLINK-9179] add prometheus pushgateway reporter - posted by lamber-ken <gi...@git.apache.org> on 2018/04/16 13:22:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 13:23:00 UTC, 10 replies.
- [GitHub] flink pull request #5856: [FLINK-9179] [conf] Fix deduplicate WebOptions.POR... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/16 13:27:14 UTC, 1 replies.
- [jira] [Created] (FLINK-9183) Kafka consumer docs to warn about idle partitions - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/04/16 13:36:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9184) Remove warning from kafka consumer docs - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/04/16 13:37:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9184) Remove warning from kafka consumer docs - posted by "Juho Autio (JIRA)" <ji...@apache.org> on 2018/04/16 13:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9183) Kafka consumer docs to warn about idle partitions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/16 13:47:00 UTC, 0 replies.
- [GitHub] flink pull request #5857: [FLINK-9180][METRICS] add prometheus pushgateway r... - posted by lamber-ken <gi...@git.apache.org> on 2018/04/16 13:52:43 UTC, 1 replies.
- [GitHub] flink issue #5806: [FLINK-8960][tests] Port SavepointITCase to flip6 - posted by aljoscha <gi...@git.apache.org> on 2018/04/16 14:31:26 UTC, 1 replies.
- [GitHub] flink pull request #5665: [FLINK-8703][tests] Port WebFrontendITCase to Mini... - posted by aljoscha <gi...@git.apache.org> on 2018/04/16 14:34:04 UTC, 7 replies.
- [GitHub] flink issue #5813: [FLINK-8980] [e2e] Add a BucketingSink end-to-end test - posted by kl0u <gi...@git.apache.org> on 2018/04/16 14:44:06 UTC, 2 replies.
- [GitHub] flink pull request #5858: [FLINK-9183] [Documentation] Kafka consumer docs t... - posted by juhoautio <gi...@git.apache.org> on 2018/04/16 14:52:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-9183) Kafka consumer docs to warn about idle partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 14:53:00 UTC, 5 replies.
- [GitHub] flink issue #5858: [FLINK-9183] [Documentation] Kafka consumer docs to warn ... - posted by fhueske <gi...@git.apache.org> on 2018/04/16 15:47:49 UTC, 3 replies.
- [jira] [Resolved] (FLINK-9145) Website build is broken - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/16 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/16 16:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Arunan Sugunakumar (JIRA)" <ji...@apache.org> on 2018/04/16 16:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9186) Enable dependency convergence for flink-libraries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 17:19:00 UTC, 0 replies.
- [GitHub] flink pull request #5859: [FLINK-9186][build] Enable dependenvy convergence ... - posted by zentol <gi...@git.apache.org> on 2018/04/16 17:25:57 UTC, 1 replies.
- [jira] [Commented] (FLINK-9186) Enable dependency convergence for flink-libraries - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 17:26:00 UTC, 2 replies.
- [GitHub] flink issue #5848: Minor cleanup of Java example code for AsyncFunctions - posted by kkrugler <gi...@git.apache.org> on 2018/04/16 18:34:42 UTC, 3 replies.
- [jira] [Closed] (FLINK-9156) CLI does not respect -m,--jobmanager option - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 19:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8961) Port JobRetrievalITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 19:23:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 19:24:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9177) Link under Installing Mesos goes to a 404 page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 19:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8370) Port AbstractAggregatingMetricsHandler to RestServerEndpoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 19:24:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9045) LocalEnvironment with web UI does not work with flip-6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/16 19:26:00 UTC, 0 replies.
- [GitHub] flink pull request #1990: [FLINK-3655] Multiple File Paths for InputFileForm... - posted by asfgit <gi...@git.apache.org> on 2018/04/16 19:43:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/16 19:44:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9183) Kafka consumer docs to warn about idle partitions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/16 19:48:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9089) Upgrade Orc dependency to 1.4.3 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/16 19:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7484) CaseClassSerializer.duplicate() does not perform proper deep copy - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/04/16 19:55:00 UTC, 1 replies.
- [GitHub] flink pull request #5860: [FLINK-9138][filesystem-connectors] Implement time... - posted by glaksh100 <gi...@git.apache.org> on 2018/04/16 23:33:39 UTC, 7 replies.
- [GitHub] flink issue #5857: [FLINK-9180][METRICS] add prometheus pushgateway reporter - posted by zhangminglei <gi...@git.apache.org> on 2018/04/17 01:21:11 UTC, 11 replies.
- [jira] [Assigned] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/17 02:06:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9187) add prometheus pushgateway reporter - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/04/17 02:17:00 UTC, 0 replies.
- [GitHub] flink pull request #5857: [FLINK-9187][METRICS] add prometheus pushgateway r... - posted by lamber-ken <gi...@git.apache.org> on 2018/04/17 02:36:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-9187) add prometheus pushgateway reporter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 02:37:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/04/17 03:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9188) Provide a mechanism to configure AmazonKinesisClient in FlinkKinesisConsumer - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/04/17 05:06:00 UTC, 8 replies.
- [jira] [Reopened] (FLINK-9145) Website build is broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/17 11:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/17 11:10:00 UTC, 4 replies.
- [GitHub] flink issue #5665: [FLINK-8703][tests] Port WebFrontendITCase to MiniCluster... - posted by zentol <gi...@git.apache.org> on 2018/04/17 11:39:42 UTC, 2 replies.
- [GitHub] flink issue #5244: [FLINK-8366] [table] Use Row instead of String as key whe... - posted by fhueske <gi...@git.apache.org> on 2018/04/17 12:11:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-8366) Use Row instead of String as key when process upsert results - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 12:12:00 UTC, 2 replies.
- [GitHub] flink issue #4674: [FLINK-7627] [table] SingleElementIterable should impleme... - posted by fhueske <gi...@git.apache.org> on 2018/04/17 12:20:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-7627) SingleElementIterable should implement with Serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 12:21:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9189) Add a SBT and Gradle Quickstarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 12:50:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9190) YarnResourceManager sometimes does not request new Containers - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 13:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9190) YarnResourceManager sometimes does not request new Containers - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 13:15:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/17 13:17:00 UTC, 0 replies.
- [GitHub] flink pull request #5861: [FLINK-9113] [connectors] Use raw local file syste... - posted by twalthr <gi...@git.apache.org> on 2018/04/17 13:21:03 UTC, 2 replies.
- [jira] [Created] (FLINK-9191) Misleading URLs for website source - posted by "Sebb (JIRA)" <ji...@apache.org> on 2018/04/17 13:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9192) Undo parameterization of StateMachine Example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9193) Deprecate non-well-defined output methods on DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/17 13:32:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6 - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 14:37:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6 - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 14:38:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9192) Undo parameterization of StateMachine Example - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/04/17 14:41:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9194) Finished jobs are not archived to HistoryServer - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9195) Delete non-well-defined output methods on DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/17 14:47:00 UTC, 0 replies.
- [GitHub] flink issue #5779: [FLINK-8990] [test] Extend Kafka end-to-end test to verif... - posted by aljoscha <gi...@git.apache.org> on 2018/04/17 14:54:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 14:55:00 UTC, 3 replies.
- [GitHub] flink pull request #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAP... - posted by fhueske <gi...@git.apache.org> on 2018/04/17 14:59:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-6924) ADD LOG(X) supported in TableAPI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 15:00:00 UTC, 2 replies.
- [GitHub] flink issue #5638: [FLINK-6924][table]ADD LOG(X) supported in TableAPI - posted by fhueske <gi...@git.apache.org> on 2018/04/17 15:01:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/17 15:07:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7627) SingleElementIterable should implement with Serializable - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/04/17 15:07:00 UTC, 0 replies.
- [GitHub] flink pull request #4674: [FLINK-7627] [table] SingleElementIterable should ... - posted by hequn8128 <gi...@git.apache.org> on 2018/04/17 15:07:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-9195) Delete non-well-defined output methods on DataStream - posted by "Michael Latta (JIRA)" <ji...@apache.org> on 2018/04/17 15:08:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9193) Deprecate non-well-defined output methods on DataStream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/17 15:31:00 UTC, 15 replies.
- [jira] [Comment Edited] (FLINK-9193) Deprecate non-well-defined output methods on DataStream - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/17 15:31:00 UTC, 2 replies.
- [jira] [Assigned] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/17 15:44:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9194) Finished jobs are not archived to HistoryServer - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/17 16:48:00 UTC, 1 replies.
- [GitHub] flink pull request #5862: [FLINK-2435] User-defined types in CsvReader - posted by DmitryKober <gi...@git.apache.org> on 2018/04/17 16:59:58 UTC, 1 replies.
- [GitHub] flink issue #5861: [FLINK-9113] [connectors] Use raw local file system for b... - posted by twalthr <gi...@git.apache.org> on 2018/04/17 17:01:57 UTC, 0 replies.
- [GitHub] flink pull request #4883: [FLINK-4809] Operators should tolerate checkpoint ... - posted by rmetzger <gi...@git.apache.org> on 2018/04/17 17:01:58 UTC, 0 replies.
- [jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 17:02:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 17:48:00 UTC, 8 replies.
- [jira] [Created] (FLINK-9197) Improve error message for TypyInformation and TypeHint with generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 17:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/17 18:54:00 UTC, 0 replies.
- [GitHub] flink pull request #5244: [FLINK-8366] [table] Use Row instead of String as ... - posted by asfgit <gi...@git.apache.org> on 2018/04/17 19:54:54 UTC, 0 replies.
- [jira] [Closed] (FLINK-8366) Use Row instead of String as key when process upsert results - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/17 19:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6924) ADD LOG(X) supported in TableAPI - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/17 20:00:00 UTC, 0 replies.
- [GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e... - posted by walterddr <gi...@git.apache.org> on 2018/04/17 20:46:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-8985) End-to-end test: CLI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/17 20:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/17 22:14:00 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/17 22:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/17 22:53:00 UTC, 0 replies.
- [GitHub] flink issue #5860: [FLINK-9138][filesystem-connectors] Implement time based ... - posted by glaksh100 <gi...@git.apache.org> on 2018/04/18 00:50:02 UTC, 2 replies.
- [GitHub] flink pull request #5864: [FLINK-8661] Replace Collections.EMPTY_MAP with Co... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/18 01:27:41 UTC, 1 replies.
- [GitHub] flink issue #5857: [FLINK-9187][METRICS] add prometheus pushgateway reporter - posted by lamber-ken <gi...@git.apache.org> on 2018/04/18 01:32:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-9194) Finished jobs are not archived to HistoryServer - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/18 03:37:00 UTC, 21 replies.
- [jira] [Created] (FLINK-9199) SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/18 05:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9199) SubtaskExecutionAttemptAccumulatorsHeaders & SubtaskExecutionAttemptDetailsHeaders has malfunctioning URL - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/18 05:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9199) Malfunctioning URL target in some messageheaders - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/18 05:59:00 UTC, 2 replies.
- [GitHub] flink issue #5864: [FLINK-8661] Replace Collections.EMPTY_MAP with Collectio... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/18 06:03:33 UTC, 4 replies.
- [GitHub] flink pull request #5865: [FLINK-9199][REST][hot-fix] handler and paramter t... - posted by walterddr <gi...@git.apache.org> on 2018/04/18 06:45:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-9199) Malfunctioning URL target in some messageheaders - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 06:46:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9200) SQL E2E test failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 07:40:00 UTC, 0 replies.
- [GitHub] flink pull request #5866: [FLINK-8047] [http connector] Add HTTP Sink to all... - posted by genged <gi...@git.apache.org> on 2018/04/18 07:42:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-8047) Create HTTP Sink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 07:43:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7243) Add ParquetInputFormat - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2018/04/18 08:03:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2018/04/18 08:03:00 UTC, 0 replies.
- [GitHub] flink issue #5859: [FLINK-9186][build] Enable dependenvy convergence for fli... - posted by twalthr <gi...@git.apache.org> on 2018/04/18 08:28:29 UTC, 0 replies.
- [jira] [Closed] (FLINK-9186) Enable dependency convergence for flink-libraries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 08:30:00 UTC, 0 replies.
- [GitHub] flink issue #5712: [FLINK-9011] YarnResourceManager spamming log file at INF... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/18 08:58:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-9011) YarnResourceManager spamming log file at INFO level - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 08:59:00 UTC, 1 replies.
- [GitHub] flink issue #5676: [FLINK-8910][tests] Automated end-to-end test for local r... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/18 09:00:08 UTC, 0 replies.
- [jira] [Created] (FLINK-9201) same merge window will fire twice if watermark already pass the window for merge windows - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/04/18 09:27:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9201) same merge window will be fired twice if watermark already pass the new merged window - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/04/18 09:27:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-5758) Port-range for the web interface via YARN - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/18 09:44:00 UTC, 0 replies.
- [GitHub] flink pull request #5867: [FLINK-8686] [sql-client] Improve basic embedded S... - posted by twalthr <gi...@git.apache.org> on 2018/04/18 09:58:32 UTC, 11 replies.
- [jira] [Commented] (FLINK-8686) Improve basic embedded SQL client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 09:59:00 UTC, 16 replies.
- [GitHub] flink pull request #5508: [FLINK-8672] Support continuous processing in CSV ... - posted by aljoscha <gi...@git.apache.org> on 2018/04/18 10:42:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-8672) Support continuous processing in CSV table source - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 10:43:00 UTC, 0 replies.
- [GitHub] flink pull request #5868: [FLINK-9193] Deprecate non-well-defined output met... - posted by aljoscha <gi...@git.apache.org> on 2018/04/18 10:45:28 UTC, 5 replies.
- [GitHub] flink issue #5867: [FLINK-8686] [sql-client] Improve basic embedded SQL clie... - posted by twalthr <gi...@git.apache.org> on 2018/04/18 10:52:12 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/18 11:01:00 UTC, 0 replies.
- [GitHub] flink pull request #5869: [FLINK-8946] TaskManager stop sending metrics afte... - posted by yanghua <gi...@git.apache.org> on 2018/04/18 11:14:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 11:15:00 UTC, 2 replies.
- [GitHub] flink issue #5869: [FLINK-8946] TaskManager stop sending metrics after JobMa... - posted by yanghua <gi...@git.apache.org> on 2018/04/18 11:15:17 UTC, 1 replies.
- [GitHub] flink pull request #5712: [FLINK-9011] YarnResourceManager spamming log file... - posted by asfgit <gi...@git.apache.org> on 2018/04/18 11:17:23 UTC, 0 replies.
- [jira] [Closed] (FLINK-9011) YarnResourceManager spamming log file at INFO level - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/18 11:18:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9194) Finished jobs are not archived to HistoryServer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 11:19:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9196) YARN: Flink binaries are not deleted from HDFS after cluster shutdown - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 11:24:00 UTC, 3 replies.
- [GitHub] flink pull request #5870: [FLINK-8967][tests] Port NetworkStackThroughputITC... - posted by zentol <gi...@git.apache.org> on 2018/04/18 11:45:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-8967) Port NetworkStackThroughputITCase to flip6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 11:46:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9203) Deprecate non-well-defined SinkFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 11:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5871: [FLINK-9193] Deprecate non-well-defined output met... - posted by aljoscha <gi...@git.apache.org> on 2018/04/18 12:04:05 UTC, 0 replies.
- [GitHub] flink issue #5868: [FLINK-9193] Deprecate non-well-defined output methods on... - posted by aljoscha <gi...@git.apache.org> on 2018/04/18 12:04:19 UTC, 0 replies.
- [GitHub] flink pull request #5779: [FLINK-8990] [test] Extend Kafka end-to-end test t... - posted by asfgit <gi...@git.apache.org> on 2018/04/18 12:12:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 12:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8990) End-to-end test: Dynamic Kafka partition discovery - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 12:15:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9124) Allow customization of KinesisProxy.getRecords read timeout and retry - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 12:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9204) Improve visibility of records being skipped by the `DeserializationSchema` in the Kafka / Kinesis connectors - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/18 12:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9203) Deprecate non-well-defined SinkFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9205) Delete non-well-defined SinkFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 12:36:00 UTC, 0 replies.
- [GitHub] flink issue #5871: [FLINK-9193] Deprecate non-well-defined output methods on... - posted by aljoscha <gi...@git.apache.org> on 2018/04/18 12:36:17 UTC, 0 replies.
- [jira] [Closed] (FLINK-9203) Deprecate non-well-defined SinkFunctions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 12:40:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9206) CheckpointCoordinator log messages do not contain the job ID - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/18 12:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/04/18 12:58:00 UTC, 0 replies.
- [GitHub] flink pull request #5872: [FLINK-9206][checkpoints] add job IDs to Checkpoin... - posted by NicoK <gi...@git.apache.org> on 2018/04/18 13:11:17 UTC, 8 replies.
- [jira] [Commented] (FLINK-9206) CheckpointCoordinator log messages do not contain the job ID - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 13:12:00 UTC, 10 replies.
- [jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job - posted by "Amit Jain (JIRA)" <ji...@apache.org> on 2018/04/18 13:17:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/18 14:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/18 14:30:00 UTC, 14 replies.
- [GitHub] flink issue #5865: [FLINK-9199][REST][hot-fix] handler and paramter typos - posted by zentol <gi...@git.apache.org> on 2018/04/18 14:30:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/18 14:31:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9208) StreamNetworkThroughputBenchmarkTests not run in Maven - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/18 15:05:00 UTC, 0 replies.
- [GitHub] flink pull request #5873: [FLINK-9208][tests] fix naming of StreamNetworkThr... - posted by NicoK <gi...@git.apache.org> on 2018/04/18 15:06:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-9208) StreamNetworkThroughputBenchmarkTests not run in Maven - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 15:07:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 15:12:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9209) Several handlers do not properly handle unknown ids - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 15:22:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9209) Several handlers do not properly handle unknown ids - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 15:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 15:41:00 UTC, 2 replies.
- [GitHub] flink issue #5872: [FLINK-9206][checkpoints] add job IDs to CheckpointCoordi... - posted by NicoK <gi...@git.apache.org> on 2018/04/18 15:51:34 UTC, 1 replies.
- [GitHub] flink pull request #5874: [FLINK-9076][network] reduce minimum number of flo... - posted by NicoK <gi...@git.apache.org> on 2018/04/18 16:02:15 UTC, 1 replies.
- [jira] [Created] (FLINK-9210) Call getValue() only once in gauge serialization - posted by "Jisu You (JIRA)" <ji...@apache.org> on 2018/04/18 16:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8944) Use ListShards for shard discovery in the flink kinesis connector - posted by "Kailash Hassan Dayanand (JIRA)" <ji...@apache.org> on 2018/04/18 16:08:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9210) Call getValue() only once in gauge serialization - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 16:16:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9210) Call getValue() only once in gauge serialization - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 16:16:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9210) Call getValue() only once in gauge serialization - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 16:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/18 16:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 16:32:00 UTC, 0 replies.
- [GitHub] flink pull request #5875: [FLINK-9210] Removed unnecessary getValue calls in... - posted by Silven1117 <gi...@git.apache.org> on 2018/04/18 16:34:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-9210) Call getValue() only once in gauge serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 16:35:00 UTC, 5 replies.
- [GitHub] flink issue #5875: [FLINK-9210] Removed unnecessary getValue calls in serial... - posted by zentol <gi...@git.apache.org> on 2018/04/18 16:42:51 UTC, 3 replies.
- [jira] [Created] (FLINK-9213) Revert breaking change in checkpoint detail URL - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/18 17:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9178) Add rate control for kafka source - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/18 17:36:00 UTC, 7 replies.
- [jira] [Updated] (FLINK-9178) Add rate control for kafka source - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/18 17:37:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6895) Add STR_TO_DATE supported in SQL - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/18 17:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/18 19:25:02 UTC, 0 replies.
- [jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo - posted by "Jeffrey Carter (JIRA)" <ji...@apache.org> on 2018/04/18 19:53:00 UTC, 0 replies.
- [GitHub] flink pull request #5876: [FLINK-9126] New CassandraPojoInputFormat to outpu... - posted by Jicaar <gi...@git.apache.org> on 2018/04/18 20:08:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/18 20:09:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9172) Support external catalog factory that comes default with SQL-Client - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/18 20:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/19 00:03:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/19 00:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7775) Remove unreferenced method PermanentBlobCache#getNumberOfCachedJobs - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/19 00:23:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/19 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/19 03:25:00 UTC, 0 replies.
- [GitHub] flink pull request #5877: [FLINK-8785][Job-Submission]Handle JobSubmissionEx... - posted by buptljy <gi...@git.apache.org> on 2018/04/19 04:30:19 UTC, 0 replies.
- [jira] [Created] (FLINK-9216) Fix comparator violation - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2018/04/19 06:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5878: [FLINK-9216][Streaming] Fix comparator violation - posted by Xpray <gi...@git.apache.org> on 2018/04/19 06:55:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-9216) Fix comparator violation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/19 06:56:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-9190) YarnResourceManager sometimes does not request new Containers - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/19 07:11:00 UTC, 24 replies.
- [GitHub] flink issue #5873: [FLINK-9208][tests] fix naming of StreamNetworkThroughput... - posted by zentol <gi...@git.apache.org> on 2018/04/19 07:26:35 UTC, 0 replies.
- [jira] [Created] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 07:28:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/19 07:32:00 UTC, 8 replies.
- [jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 07:35:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-9145) Website build is broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 07:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9218) Docs for old versions aren't building successfully - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 07:39:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9199) Malfunctioning URL target in some messageheaders - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:03:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:03:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9180) Remove REST_ prefix from rest options - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:03:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8960) Port SavepointITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8955) Port ClassLoaderITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:04:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9208) StreamNetworkThroughputBenchmarkTests not run in Maven - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:05:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9208) StreamNetworkThroughputBenchmarkTests not run in Maven - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 08:05:00 UTC, 0 replies.
- [GitHub] flink issue #5856: [FLINK-9179] [conf] Fix deduplicate WebOptions.PORT and R... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/19 08:09:39 UTC, 4 replies.
- [GitHub] flink issue #5851: [FLINK-9176] [build] Re-introduce category to surefire co... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/19 08:10:29 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/19 08:20:01 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()` - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/19 08:22:00 UTC, 0 replies.
- [GitHub] flink issue #5773: [FLINK-9064] Add Scaladocs link to documentation - posted by yanghua <gi...@git.apache.org> on 2018/04/19 08:24:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-9064) Add Scaladocs link to documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/19 08:25:00 UTC, 0 replies.
- [GitHub] flink pull request #5879: [FLINK-9215][resoucemanager] Only log the exceptio... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/19 08:30:27 UTC, 4 replies.
- [GitHub] flink issue #5870: [FLINK-8967][tests] Port NetworkStackThroughputITCase to ... - posted by zentol <gi...@git.apache.org> on 2018/04/19 08:33:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()` - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/19 08:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/19 08:49:00 UTC, 0 replies.
- [GitHub] flink issue #5842: [FLINK-9144][network] fix SpillableSubpartition causing j... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/19 08:50:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-9144) Spilling batch job hangs - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/19 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9219) Add support for OpenGIS features in Table & SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 09:10:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()` - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/19 09:17:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8646) Move docs directory to flink-docs - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/19 09:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8646) Move docs directory to flink-docs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/19 09:42:00 UTC, 1 replies.
- [GitHub] flink pull request #5327: [FLINK-8428] [table] Implement stream-stream non-w... - posted by twalthr <gi...@git.apache.org> on 2018/04/19 11:18:53 UTC, 32 replies.
- [jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/19 11:19:01 UTC, 34 replies.
- [jira] [Updated] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 11:26:00 UTC, 2 replies.
- [GitHub] flink issue #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT support... - posted by twalthr <gi...@git.apache.org> on 2018/04/19 12:07:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/19 12:08:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 12:14:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 12:14:00 UTC, 1 replies.
- [jira] [Resolved] (FLINK-9113) Data loss in BucketingSink when writing to local filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9220) Table program cannot be compiled - posted by "Saurabh Garg (JIRA)" <ji...@apache.org> on 2018/04/19 12:47:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9220) Table program cannot be compiled - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 12:52:00 UTC, 3 replies.
- [jira] [Assigned] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/19 13:06:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8980) End-to-end test: BucketingSink - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/19 13:15:00 UTC, 0 replies.
- [GitHub] flink pull request #5880: [FLINK-8836] Fix duplicate method in KryoSerialize... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/19 13:16:34 UTC, 5 replies.
- [GitHub] flink issue #5877: [FLINK-8785][Job-Submission]Handle JobSubmissionException... - posted by buptljy <gi...@git.apache.org> on 2018/04/19 13:37:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-9220) Table program cannot be compiled - posted by "Saurabh Garg (JIRA)" <ji...@apache.org> on 2018/04/19 13:49:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9204) Improve visibility of records being skipped by the `DeserializationSchema` in the Kafka / Kinesis connectors - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/19 13:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9155) Provide message context information in DeserializationSchema - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/19 14:00:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-7431) test instability in JobManagerFailsITCase - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 14:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8286) Investigate Flink-Yarn-Kerberos integration for flip-6 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 14:48:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8979) Extend Kafka end-to-end tests to run with different versions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 14:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8977) End-to-end test: Manually resume job after terminal failure - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 14:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8982) End-to-end test: Queryable state - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 14:53:00 UTC, 0 replies.
- [GitHub] flink pull request #5555: [FLINK-8689][table]Add runtime support of distinct... - posted by fhueske <gi...@git.apache.org> on 2018/04/19 15:15:09 UTC, 51 replies.
- [jira] [Commented] (FLINK-8689) Add runtime support of distinct filter using MapView - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/19 15:16:01 UTC, 55 replies.
- [jira] [Created] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/04/19 15:16:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/19 15:22:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/19 15:30:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/04/19 15:31:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9222) Add a Gradle Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:57:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9222) Add a Gradle Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9189) Add a SBT Quickstarts - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:58:01 UTC, 1 replies.
- [jira] [Updated] (FLINK-9222) Add a Gradle Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:58:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-9222) Add a Gradle Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:59:00 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (FLINK-9222) Add a Gradle Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:59:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9189) Add a SBT Quickstarts - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 15:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9189) Add a SBT Quickstart - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/19 16:00:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/19 16:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9206) CheckpointCoordinator log messages do not contain the job ID - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/19 16:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/19 17:04:01 UTC, 0 replies.
- [GitHub] flink issue #5555: [FLINK-8689][table]Add runtime support of distinct filter... - posted by walterddr <gi...@git.apache.org> on 2018/04/19 17:11:22 UTC, 3 replies.
- [GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ... - posted by dubin555 <gi...@git.apache.org> on 2018/04/20 01:31:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/20 01:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9190) YarnResourceManager sometimes does not request new Containers - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/20 05:01:00 UTC, 1 replies.
- [GitHub] flink pull request #5881: [FLINK-9190][yarn] fix YarnResourceManager sometim... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/20 05:09:07 UTC, 10 replies.
- [GitHub] flink issue #5880: [FLINK-8836] Fix duplicate method in KryoSerializer to pe... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/20 05:24:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/20 05:49:00 UTC, 0 replies.
- [GitHub] flink pull request #5882: [FLINK-9223] bufferConsumers should be closed in S... - posted by yanghua <gi...@git.apache.org> on 2018/04/20 06:20:18 UTC, 1 replies.
- [GitHub] flink issue #5882: [FLINK-9223] bufferConsumers should be closed in Spillabl... - posted by yanghua <gi...@git.apache.org> on 2018/04/20 06:20:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/20 06:21:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-5758) Port-range for the web interface via YARN - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/04/20 06:31:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-3089) State API Should Support Data Expiration (State TTL) - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/20 06:45:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 06:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9225) Minor code comments fix in RuntimeContext - posted by "binlijin (JIRA)" <ji...@apache.org> on 2018/04/20 06:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 06:51:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-9225) Minor code comments fix in RuntimeContext - posted by "binlijin (JIRA)" <ji...@apache.org> on 2018/04/20 06:52:02 UTC, 4 replies.
- [jira] [Closed] (FLINK-9224) Add Bucketing e2e test script to run-pre-commit-tests.sh - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/20 06:54:00 UTC, 0 replies.
- [GitHub] flink pull request #5883: [FLINK-9225][core] Minor code comments fix in Runt... - posted by binlijin <gi...@git.apache.org> on 2018/04/20 07:00:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-9225) Minor code comments fix in RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/20 07:01:00 UTC, 3 replies.
- [jira] [Created] (FLINK-9226) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 08:34:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/20 08:35:00 UTC, 1 replies.
- [GitHub] flink pull request #5884: [FLINK-9227] [test] Add Bucketing e2e test script ... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/20 08:46:25 UTC, 1 replies.
- [jira] [Commented] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/20 08:47:00 UTC, 3 replies.
- [GitHub] flink issue #5884: [FLINK-9227] [test] Add Bucketing e2e test script to run-... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/20 09:13:50 UTC, 1 replies.
- [GitHub] flink issue #5324: [FLINK-6926] [table] Add support for SHA-224, SHA-384, SH... - posted by twalthr <gi...@git.apache.org> on 2018/04/20 09:45:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-6926) Add support for MD5, SHA1 and SHA2 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/20 09:46:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9227) Add Bucketing e2e test script to run-nightly-tests.sh - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/20 09:58:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives - posted by "Stephen Jason (JIRA)" <ji...@apache.org> on 2018/04/20 12:08:00 UTC, 6 replies.
- [GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l... - posted by hequn8128 <gi...@git.apache.org> on 2018/04/20 12:18:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct agg on DataStream - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/20 12:58:00 UTC, 4 replies.
- [GitHub] flink pull request #5885: [FLINK-8715] Remove usage of StateDescriptor in st... - posted by tzulitai <gi...@git.apache.org> on 2018/04/20 13:36:23 UTC, 30 replies.
- [jira] [Commented] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/20 13:37:00 UTC, 37 replies.
- [jira] [Created] (FLINK-9228) log details about task fail/task manager is shutting down - posted by "makeyang (JIRA)" <ji...@apache.org> on 2018/04/20 13:50:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:31:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:31:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9037) Test flake Kafka09ITCase#testCancelingEmptyTopic - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9037) Test flake Kafka09ITCase#testCancelingEmptyTopic - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:32:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:45:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:46:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8970) Add more automated end-to-end tests - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:52:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/04/20 14:52:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9217) Kafka010ITCase hanging after timeout in testTimestamps() - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/04/20 14:57:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-8795) Scala shell broken for Flip6 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 14:58:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9100) Shadow/Hide password from configuration that is logged to log file - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/20 15:00:03 UTC, 0 replies.
- [jira] [Created] (FLINK-9229) Fix literal handling in code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/20 15:45:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9229) Fix literal handling in code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/20 15:47:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 17:31:00 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/20 17:32:00 UTC, 0 replies.
- [GitHub] flink issue #5854: [FLINK-9100][FLINK-8793][REST] hidden key containing secr... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/21 04:07:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-9100) Shadow/Hide password from configuration that is logged to log file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/21 04:08:00 UTC, 3 replies.
- [jira] [Updated] (FLINK-9100) Shadow/Hide password from configuration that is logged to log file - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/21 04:15:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8601) Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/21 04:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/21 04:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/21 04:49:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-9219) Add support for OpenGIS features in Table & SQL API - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/04/21 05:07:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/21 05:36:00 UTC, 0 replies.
- [GitHub] flink pull request #5886: [FLINK-9230][test] harden WebFrontendITCase#testSt... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/21 05:36:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/21 05:37:00 UTC, 6 replies.
- [GitHub] flink issue #5886: [FLINK-9230][test] harden WebFrontendITCase#testStopYarn(... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/21 05:42:25 UTC, 2 replies.
- [jira] [Assigned] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/21 06:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/21 06:29:00 UTC, 1 replies.
- [GitHub] flink pull request #5887: [FLINK-6719] Add details about fault-tolerance of ... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/21 06:48:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/21 06:49:00 UTC, 10 replies.
- [GitHub] flink pull request #5888: [FLINK-9194] [histroyserver] Finished jobs are not... - posted by yuqi1129 <gi...@git.apache.org> on 2018/04/21 15:16:27 UTC, 8 replies.
- [jira] [Created] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/21 15:31:00 UTC, 0 replies.
- [GitHub] flink issue #5885: [FLINK-8715] Remove usage of StateDescriptor in state han... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/21 17:29:13 UTC, 5 replies.
- [GitHub] flink issue #5878: [FLINK-9216][Streaming] Fix comparator violation - posted by StephanEwen <gi...@git.apache.org> on 2018/04/21 17:39:43 UTC, 2 replies.
- [jira] [Updated] (FLINK-8739) Optimize runtime support for distinct filter - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/22 00:38:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9232) Add harness test for AggregationCodeGenerator - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/22 00:45:00 UTC, 0 replies.
- [GitHub] flink issue #5887: [FLINK-6719] Add details about fault-tolerance of timers ... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/22 01:41:44 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8999) Ensure the job has an operator with operator state. - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/22 03:30:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/04/22 03:57:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/22 06:01:00 UTC, 0 replies.
- [GitHub] flink pull request #5889: [FLINK-9188] [kinesis] Generic mechanism to set Cl... - posted by tweise <gi...@git.apache.org> on 2018/04/22 06:43:59 UTC, 5 replies.
- [GitHub] flink issue #5889: [FLINK-9188] [kinesis] Generic mechanism to set ClientCon... - posted by tweise <gi...@git.apache.org> on 2018/04/22 06:44:28 UTC, 1 replies.
- [GitHub] flink pull request #5890: [FLINK-8999] [e2e] Ensure the job has an operator ... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/22 07:23:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-8999) Ensure the job has an operator with operator state. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 07:24:00 UTC, 2 replies.
- [GitHub] flink pull request #5891: [FLINK-9088][nifi-connector][build] Bump nifi-site... - posted by yew1eb <gi...@git.apache.org> on 2018/04/22 08:06:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 08:07:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9032) Deprecate ConfigConstants#YARN_CONTAINER_START_COMMAND_TEMPLATE - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/22 08:21:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher) - posted by "Fred Teunissen (JIRA)" <ji...@apache.org> on 2018/04/22 08:29:00 UTC, 3 replies.
- [GitHub] flink pull request #5892: [FLINK-9214] YarnClient should be stopped in YARNS... - posted by yanghua <gi...@git.apache.org> on 2018/04/22 08:46:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 08:47:00 UTC, 8 replies.
- [GitHub] flink issue #5892: [FLINK-9214] YarnClient should be stopped in YARNSessionC... - posted by yanghua <gi...@git.apache.org> on 2018/04/22 08:49:04 UTC, 4 replies.
- [GitHub] flink issue #5731: [FLINK-9033][config] Replace usages of deprecated TASK_MA... - posted by yew1eb <gi...@git.apache.org> on 2018/04/22 08:58:16 UTC, 1 replies.
- [jira] [Commented] (FLINK-9033) Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 08:59:00 UTC, 2 replies.
- [GitHub] flink pull request #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHa... - posted by yew1eb <gi...@git.apache.org> on 2018/04/22 11:04:06 UTC, 10 replies.
- [jira] [Commented] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 11:05:00 UTC, 17 replies.
- [GitHub] flink issue #5748: [FLINK-9053][runtime] only release outputs under the chec... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/22 12:41:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-9053) Exception in RecordWriter during cleanup of StreamTask with the checkpoint trigger running in parallel - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 12:42:00 UTC, 2 replies.
- [GitHub] flink issue #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT cases for... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/22 13:11:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/22 13:12:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/22 13:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9233) Merging state may cause runtime exception when windows trigger onMerge - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/22 13:45:00 UTC, 3 replies.
- [GitHub] flink issue #5874: [FLINK-9076][network] reduce minimum number of floating b... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/22 14:23:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9234) Commons Logging is missing from shaded Flink Table library - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2018/04/22 17:58:00 UTC, 0 replies.
- [GitHub] flink pull request #5748: [FLINK-9053][runtime] only release outputs under t... - posted by asfgit <gi...@git.apache.org> on 2018/04/22 20:43:09 UTC, 0 replies.
- [GitHub] flink pull request #5624: [FLINK-8402][s3][tests] fix hadoop/presto S3 IT ca... - posted by asfgit <gi...@git.apache.org> on 2018/04/22 20:43:09 UTC, 0 replies.
- [GitHub] flink pull request #5488: [FLINK-8335] [hbase] Upgrade hbase connector depen... - posted by asfgit <gi...@git.apache.org> on 2018/04/22 20:43:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/22 23:28:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for flip-6 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/22 23:30:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6 - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/04/22 23:33:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/23 01:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9236) Use Apache Parent POM 19 - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/23 02:27:00 UTC, 0 replies.
- [GitHub] flink issue #5881: [FLINK-9190][yarn] fix YarnResourceManager sometimes does... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/23 02:53:01 UTC, 6 replies.
- [jira] [Assigned] (FLINK-9236) Use Apache Parent POM 19 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/23 03:32:00 UTC, 0 replies.
- [GitHub] flink pull request #5894: [FLINK-9185] [runtime] Fix potential null derefere... - posted by StephenJeson <gi...@git.apache.org> on 2018/04/23 04:01:21 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:55:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8335) Upgrade hbase connector dependency to 1.4.3 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:55:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:56:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9076) Make credit-based floating buffers optional - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:56:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9076) Make credit-based floating buffers optional - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:56:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9158) Set default FixedRestartDelayStrategy delay to 0s - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:56:01 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:57:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8402) HadoopS3FileSystemITCase.testDirectoryListing fails on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:57:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9053) Exception in RecordWriter during cleanup of StreamTask with the checkpoint trigger running in parallel - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:58:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:59:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 04:59:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9197) Improve error message for TypyInformation and TypeHint with generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 05:00:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9197) Improve error message for TypyInformation and TypeHint with generics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/23 05:00:01 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/23 05:22:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/23 05:35:00 UTC, 0 replies.
- [GitHub] flink pull request #5895: Fix kerberos security configuration for YarnTaskEx... - posted by suez1224 <gi...@git.apache.org> on 2018/04/23 06:59:05 UTC, 1 replies.
- [GitHub] flink pull request #5896: [FLINK-8286][Security] Fix kerberos security confi... - posted by suez1224 <gi...@git.apache.org> on 2018/04/23 07:02:48 UTC, 4 replies.
- [jira] [Assigned] (FLINK-9234) Commons Logging is missing from shaded Flink Table library - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 07:16:00 UTC, 0 replies.
- [GitHub] flink issue #5688: [FLINK-6968][Table API & SQL] Add Queryable table sink. - posted by liurenjie1024 <gi...@git.apache.org> on 2018/04/23 08:34:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-6968) Store streaming, updating tables with unique key in queryable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/23 08:35:00 UTC, 0 replies.
- [GitHub] flink pull request #5897: [FLINK-9234] [table] Fix missing dependencies for ... - posted by twalthr <gi...@git.apache.org> on 2018/04/23 09:13:05 UTC, 0 replies.
- [GitHub] flink issue #5897: [FLINK-9234] [table] Fix missing dependencies for externa... - posted by twalthr <gi...@git.apache.org> on 2018/04/23 09:13:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-9234) Commons Logging is missing from shaded Flink Table library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/23 09:14:01 UTC, 3 replies.
- [jira] [Created] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/23 10:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/23 10:10:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/23 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9238) There are some questions about BuckeingSink when sinking data to S3. - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/23 10:25:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/23 10:26:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9239) Reintroduce example program in quickstarts - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 10:51:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9239) Reintroduce example program in quickstarts - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/23 11:35:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9239) Reintroduce example program in quickstarts - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/23 11:36:00 UTC, 4 replies.
- [GitHub] flink pull request #5898: [FLINK-9229] [table] Fix literal handling in code ... - posted by twalthr <gi...@git.apache.org> on 2018/04/23 11:46:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-9229) Fix literal handling in code generation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/23 11:47:00 UTC, 5 replies.
- [GitHub] flink issue #5893: [FLINK-9212][flip6] Port SubtasksAllAccumulatorsHandler t... - posted by yew1eb <gi...@git.apache.org> on 2018/04/23 12:05:12 UTC, 6 replies.
- [GitHub] flink issue #5890: [FLINK-8999] [e2e] Ensure the job has an operator with op... - posted by zhangminglei <gi...@git.apache.org> on 2018/04/23 12:09:10 UTC, 1 replies.
- [GitHub] flink issue #5888: [FLINK-9194] [histroyserver] Finished jobs are not archiv... - posted by zentol <gi...@git.apache.org> on 2018/04/23 12:50:27 UTC, 1 replies.
- [GitHub] flink issue #5879: [FLINK-9215][resoucemanager] Only log the exception when ... - posted by zentol <gi...@git.apache.org> on 2018/04/23 13:38:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-9080) Flink Scheduler goes OOM, suspecting a memory leak - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/23 14:00:00 UTC, 0 replies.
- [GitHub] flink pull request #5899: Klink - posted by bitsilly <gi...@git.apache.org> on 2018/04/23 14:10:55 UTC, 0 replies.
- [GitHub] flink issue #5899: Klink - posted by bitsilly <gi...@git.apache.org> on 2018/04/23 14:11:07 UTC, 2 replies.
- [jira] [Reopened] (FLINK-8600) BucketingSink errors out when used with Presto filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 14:47:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8600) BucketingSink errors out when used with Presto filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 14:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8600) BucketingSink errors out when used with Presto filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 14:48:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8600) BucketingSink errors out when used with Presto filesystem - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/23 14:48:00 UTC, 0 replies.
- [GitHub] flink issue #5610: [FLINK-8537][table]Add a Kafka table source factory with ... - posted by twalthr <gi...@git.apache.org> on 2018/04/23 15:28:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-8537) Add a Kafka table source factory with Avro format support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/23 15:29:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "yuqi (JIRA)" <ji...@apache.org> on 2018/04/23 15:37:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8836) Duplicating a KryoSerializer does not duplicate registered default serializers - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/23 15:39:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/23 15:44:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9240) Avoid deprecated akka methods - posted by "Arnout Engelen (JIRA)" <ji...@apache.org> on 2018/04/23 15:52:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/23 16:17:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9240) Avoid deprecated akka methods - posted by "Konrad Malawski (JIRA)" <ji...@apache.org> on 2018/04/23 16:43:00 UTC, 0 replies.
- [GitHub] flink pull request #5900: [FLINK-9222][docs] add documentation for setting u... - posted by NicoK <gi...@git.apache.org> on 2018/04/23 17:02:57 UTC, 0 replies.
- [GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y... - posted by suez1224 <gi...@git.apache.org> on 2018/04/23 18:21:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/23 18:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9241) Scala version of Gauge (metric) doesn't work - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/04/23 20:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9241) Scala version of Gauge (metric) doesn't work - posted by "Julio Biason (JIRA)" <ji...@apache.org> on 2018/04/23 20:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING - posted by "Miguel E. Coimbra (JIRA)" <ji...@apache.org> on 2018/04/24 00:54:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING - posted by "Miguel E. Coimbra (JIRA)" <ji...@apache.org> on 2018/04/24 00:59:01 UTC, 1 replies.
- [jira] [Closed] (FLINK-7952) Add metrics for counting logging events - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 01:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 03:20:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 03:20:00 UTC, 2 replies.
- [jira] [Closed] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/24 04:22:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9237) Some description about The FsStateBackend in the Docs。 - posted by "liuzhixin (JIRA)" <ji...@apache.org> on 2018/04/24 04:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9244) Can't create a BucketingSink with a provided Configuration if no hadoop defaults - posted by "Julien Cuquemelle (JIRA)" <ji...@apache.org> on 2018/04/24 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults - posted by "Julien Cuquemelle (JIRA)" <ji...@apache.org> on 2018/04/24 07:48:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9245) Can't create a BucketingSink with a provided Configuration if no hadoop defaults - posted by "Julien Cuquemelle (JIRA)" <ji...@apache.org> on 2018/04/24 07:50:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9241) Scala version of Gauge (metric) doesn't work - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 08:07:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9241) Usage docs for ScalaGauge doesn't work - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 08:07:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9241) Usage docs for ScalaGauge doesn't work - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 08:08:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9241) Usage docs for ScalaGauge doesn't work - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9246) HistoryServer job overview broken - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 08:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-8537) Add a Kafka table source factory with Avro format support - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/24 08:29:00 UTC, 0 replies.
- [GitHub] flink pull request #5610: [FLINK-8537][table]Add a Kafka table source factor... - posted by asfgit <gi...@git.apache.org> on 2018/04/24 08:29:33 UTC, 0 replies.
- [jira] [Created] (FLINK-9247) Allow creating table sources/sinks from an Avro schema - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/24 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9248) Create a SQL Client Avro format fat-jar - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/24 08:46:01 UTC, 0 replies.
- [GitHub] flink pull request #5902: [FLINK-9194][history] Add HistoryServer support to... - posted by zentol <gi...@git.apache.org> on 2018/04/24 08:47:37 UTC, 5 replies.
- [jira] [Closed] (FLINK-9244) Can't create a BucketingSink with a provided Configuration if no hadoop defaults - posted by "Julien Cuquemelle (JIRA)" <ji...@apache.org> on 2018/04/24 09:11:00 UTC, 0 replies.
- [GitHub] flink pull request #5903: [FLINK-9211][REST] JarRunHandler submits job to Di... - posted by zentol <gi...@git.apache.org> on 2018/04/24 09:41:41 UTC, 5 replies.
- [jira] [Closed] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/24 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9249) Add convenience profile for skipping non-essential plugins - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 10:37:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9249) Add convenience profile for skipping non-essential plugins - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 11:11:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9242) LocalEnvironment - Operator threads stuck on java.lang.Thread.State: WAITING - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/24 11:14:00 UTC, 0 replies.
- [GitHub] flink pull request #5904: [FLINK-9249][build] Add convenience profile for sk... - posted by zentol <gi...@git.apache.org> on 2018/04/24 11:22:30 UTC, 6 replies.
- [jira] [Commented] (FLINK-9249) Add convenience profile for skipping non-essential plugins - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/24 11:23:00 UTC, 7 replies.
- [jira] [Created] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 11:28:00 UTC, 0 replies.
- [GitHub] flink pull request #5482: [FLINK-8480][DataStream] Add Java API for timeboun... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/04/24 12:07:09 UTC, 6 replies.
- [jira] [Commented] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/24 12:08:00 UTC, 7 replies.
- [GitHub] flink pull request #5905: [FLINK-8202][QS][docs] Update QS configuration pag... - posted by zentol <gi...@git.apache.org> on 2018/04/24 12:26:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-8202) Update queryable section on configuration page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/24 12:27:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9216) Fix comparator violation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 12:32:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 12:32:00 UTC, 0 replies.
- [GitHub] flink pull request #5887: [FLINK-6719] [docs] Add details about fault-tolera... - posted by fhueske <gi...@git.apache.org> on 2018/04/24 12:33:39 UTC, 7 replies.
- [jira] [Commented] (FLINK-8498) GetExecutionPlan fails with IllegalArgumentException in Comparator - posted by "Julian Bauß (JIRA)" <ji...@apache.org> on 2018/04/24 12:34:01 UTC, 0 replies.
- [GitHub] flink issue #5482: [FLINK-8480][DataStream] Add Java API for timebounded str... - posted by florianschmidt1994 <gi...@git.apache.org> on 2018/04/24 12:40:36 UTC, 0 replies.
- [GitHub] flink pull request #5906: [FLINK-9213] [REST] [docs] Revert checkpoint detai... - posted by azagrebin <gi...@git.apache.org> on 2018/04/24 13:03:21 UTC, 0 replies.
- [jira] [Updated] (FLINK-8912) Web UI does not render error messages correctly in FLIP-6 mode - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 13:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9213) Revert breaking change in checkpoint detail URL - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/24 13:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8912) Web UI does not render error messages correctly in FLIP-6 mode - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/24 13:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist - posted by "Aleksei Lesnov (JIRA)" <ji...@apache.org> on 2018/04/24 13:10:00 UTC, 5 replies.
- [GitHub] flink pull request #5907: [FLINK-8912][WebUI] Update error handling for flip... - posted by zentol <gi...@git.apache.org> on 2018/04/24 13:22:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-8912) Web UI does not render error messages correctly in FLIP-6 mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/24 13:23:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9219) Add support for OpenGIS features in Table & SQL API - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/04/24 13:53:00 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "Triones Deng (JIRA)" <ji...@apache.org> on 2018/04/24 13:55:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9231) Enable SO_REUSEADDR on listen sockets - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/24 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9251) Move MemoryStateBackend to flink-state-backends - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 16:17:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9251) Move MemoryStateBackend to flink-state-backends - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 16:20:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-9251) Move MemoryStateBackend to flink-state-backends - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/24 16:20:00 UTC, 0 replies.
- [jira] [Resolved] (FLINK-9115) Support addition of part suffix in BucketingSink - posted by "Lakshmi Rao (JIRA)" <ji...@apache.org> on 2018/04/24 17:03:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9219) Add support for OpenGIS features in Table & SQL API - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2018/04/24 17:44:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/24 19:06:01 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-7588) Document RocksDB tuning for spinning disks - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/25 00:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited - posted by "Roman Khlebnov (JIRA)" <ji...@apache.org> on 2018/04/25 07:18:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist - posted by "Aleksei Lesnov (JIRA)" <ji...@apache.org> on 2018/04/25 07:28:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8497) KafkaConsumer throws NPE if topic doesn't exist - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/25 07:33:00 UTC, 0 replies.
- [GitHub] flink pull request #5731: [FLINK-9033][config] Replace usages of deprecated ... - posted by asfgit <gi...@git.apache.org> on 2018/04/25 07:34:22 UTC, 0 replies.
- [GitHub] flink pull request #5247: [FLINK-8356] Need to add the commit in flush() in ... - posted by asfgit <gi...@git.apache.org> on 2018/04/25 07:34:22 UTC, 0 replies.
- [jira] [Closed] (FLINK-9230) WebFrontendITCase.testStopYarn is unstable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:35:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-8356) JDBCAppendTableSink does not work for Hbase Phoenix Driver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 07:35:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8700) Port tests from FlinkMiniCluster to MiniClusterResource - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8967) Port NetworkStackThroughputITCase to flip6 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:36:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9225) Minor code comments fix in RuntimeContext - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:37:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:37:01 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9225) Minor code comments fix in RuntimeContext - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:37:01 UTC, 0 replies.
- [jira] [Updated] (FLINK-8793) Hide key containing "secret" in web interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:38:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-8793) Hide key containing "secret" in web interface - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:38:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9100) Shadow/Hide password from configuration that is logged to log file - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:38:01 UTC, 0 replies.
- [jira] [Closed] (FLINK-9033) Replace usages of deprecated TASK_MANAGER_NUM_TASK_SLOTS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:39:00 UTC, 0 replies.
- [GitHub] flink pull request #5854: [FLINK-9100][FLINK-8793][REST] hidden key containi... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/25 07:41:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:42:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7551) Add VERSION to the REST urls. - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:42:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8237) BucketingSink throws NPE when Writer.duplicate returns null - posted by "Pavel Shvetsov (JIRA)" <ji...@apache.org> on 2018/04/25 07:42:00 UTC, 4 replies.
- [jira] [Updated] (FLINK-9213) Revert breaking change in checkpoint detail URL - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/25 07:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9029) Getting write permission from HDFS after updating flink-1.40 to flink-1.4.2 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/25 07:50:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9213) Revert breaking change in checkpoint detail URL - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2018/04/25 08:03:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 08:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9252) OperatorChain.pushToOperators NullPointerException when ClassCastException - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2018/04/25 08:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 08:53:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8135) Add description to MessageParameter - posted by "Andrei (JIRA)" <ji...@apache.org> on 2018/04/25 09:00:00 UTC, 5 replies.
- [GitHub] flink issue #5905: [FLINK-8202][QS][docs] Update QS configuration page - posted by zentol <gi...@git.apache.org> on 2018/04/25 09:00:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-8202) Update queryable section on configuration page - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 09:04:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8134) Add description to MessageHeaders - posted by "Maxim Belov (JIRA)" <ji...@apache.org> on 2018/04/25 09:10:00 UTC, 4 replies.
- [GitHub] flink pull request #5908: [FLINK-9182]async checkpoints for timer service - posted by makeyang <gi...@git.apache.org> on 2018/04/25 09:51:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-9182) async checkpoints for timer service - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 09:52:00 UTC, 0 replies.
- [GitHub] flink pull request #5909: [FLINK-8726][docs] Fix and normalize code-highligh... - posted by zentol <gi...@git.apache.org> on 2018/04/25 10:35:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-8726) Code highlighting partially broken - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 10:36:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/25 10:56:00 UTC, 14 replies.
- [GitHub] flink pull request #5910: [FLINK-8841] [state] Remove HashMapSerializer and ... - posted by kl0u <gi...@git.apache.org> on 2018/04/25 11:57:42 UTC, 6 replies.
- [jira] [Commented] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 11:58:00 UTC, 9 replies.
- [GitHub] flink pull request #5911: [FLINK-9243][tests]harden SuccessAfterNetworkBuffe... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/25 12:00:34 UTC, 1 replies.
- [GitHub] flink issue #5911: [FLINK-9243][tests]harden SuccessAfterNetworkBuffersFailu... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/25 12:00:47 UTC, 2 replies.
- [jira] [Commented] (FLINK-8825) Disallow new String() without charset in checkstyle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 12:06:00 UTC, 1 replies.
- [GitHub] flink pull request #5912: [FLINK-9041] Refactor StreamTaskTest to not use sc... - posted by azagrebin <gi...@git.apache.org> on 2018/04/25 12:07:55 UTC, 6 replies.
- [jira] [Commented] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 12:08:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/25 12:10:00 UTC, 0 replies.
- [jira] [Reopened] (FLINK-9101) HAQueryableStateRocksDBBackendITCase failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 12:24:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/25 12:41:00 UTC, 0 replies.
- [GitHub] flink issue #5912: [FLINK-9041] Refactor StreamTaskTest to not use scala and... - posted by zentol <gi...@git.apache.org> on 2018/04/25 12:59:27 UTC, 0 replies.
- [jira] [Created] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/25 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/04/25 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/04/25 13:59:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/04/25 14:00:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9043) Flink recover from checkpoint like Spark Streaming - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/25 14:02:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9157) Support Apache HCatalog in SQL client - posted by "Dmitrii Kober (JIRA)" <ji...@apache.org> on 2018/04/25 14:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9256) NPE in SingleInputGate#updateInputChannel() for non-credit based flow control - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/25 14:14:01 UTC, 0 replies.
- [GitHub] flink pull request #5913: [FLINK-9181] [docs] [sql-client] Add documentation... - posted by twalthr <gi...@git.apache.org> on 2018/04/25 14:18:33 UTC, 25 replies.
- [jira] [Commented] (FLINK-9181) Add SQL Client documentation page - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 14:19:00 UTC, 22 replies.
- [jira] [Resolved] (FLINK-9229) Fix literal handling in code generation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/25 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code - posted by "Florian Schmidt (JIRA)" <ji...@apache.org> on 2018/04/25 14:51:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-8686) Improve basic embedded SQL client - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/04/25 15:50:00 UTC, 1 replies.
- [GitHub] flink pull request #5914: [FLINK-9256][network] fix NPE in SingleInputGate#u... - posted by NicoK <gi...@git.apache.org> on 2018/04/25 16:34:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-9256) NPE in SingleInputGate#updateInputChannel() for non-credit based flow control - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/25 16:35:00 UTC, 2 replies.
- [GitHub] flink pull request #5915: [FLINK-9243][tests] fix flaky SuccessAfterNetworkB... - posted by NicoK <gi...@git.apache.org> on 2018/04/25 18:32:14 UTC, 1 replies.
- [jira] [Created] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/25 18:50:00 UTC, 0 replies.
- [GitHub] flink issue #5904: [FLINK-9249][build] Add convenience profile for skipping ... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/25 21:07:13 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 21:08:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 21:08:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9258) ConcurrentModificationException in ComponentMetricGroup.getAllVariables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 21:11:00 UTC, 0 replies.
- [GitHub] flink issue #5910: [FLINK-8841] [state] Remove HashMapSerializer and use Map... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/25 21:16:10 UTC, 2 replies.
- [GitHub] flink issue #5915: [FLINK-9243][tests] fix flaky SuccessAfterNetworkBuffersF... - posted by zentol <gi...@git.apache.org> on 2018/04/25 21:51:36 UTC, 2 replies.
- [jira] [Closed] (FLINK-9243) SuccessAfterNetworkBuffersFailureITCase#testSuccessfulProgramAfterFailure is unstable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/25 21:54:01 UTC, 0 replies.
- [jira] [Created] (FLINK-9259) The implementation of the SourceFunction is not serializable. - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/26 01:46:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9259) The implementation of the SourceFunction is not serializable. - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/26 02:15:01 UTC, 0 replies.
- [jira] [Commented] (FLINK-9259) The implementation of the SourceFunction is not serializable. - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2018/04/26 02:33:00 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-9259) The implementation of the SourceFunction is not serializable. - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/26 04:40:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9260) Introduce a friendly way to resume the job from externalized checkpoints automatically - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/26 06:03:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator - posted by "Renkai Ge (JIRA)" <ji...@apache.org> on 2018/04/26 07:09:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8135) Add description to MessageParameter - posted by "Andrei (JIRA)" <ji...@apache.org> on 2018/04/26 08:04:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8101) Elasticsearch 6.x support - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/04/26 08:05:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8101) Elasticsearch 6.x support - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/04/26 08:06:00 UTC, 0 replies.
- [GitHub] flink pull request #5916: [hotfix][tests] remove redundant rebalance in Succ... - posted by NicoK <gi...@git.apache.org> on 2018/04/26 08:37:49 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9178) Add rate control for kafka source - posted by "buptljy (JIRA)" <ji...@apache.org> on 2018/04/26 08:47:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9201) same merge window will be fired twice if watermark already passed the merge window - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/04/26 08:57:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9201) same merge window will be fired twice if watermark already passed the new merged window - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/04/26 08:57:00 UTC, 0 replies.
- [GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/26 09:17:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 09:18:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-9259) The implementation of the SourceFunction is not serializable. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/04/26 09:25:00 UTC, 0 replies.
- [GitHub] flink pull request #5917: [FLINK-9201] Fixed the same merge window will be f... - posted by hzyuemeng1 <gi...@git.apache.org> on 2018/04/26 09:30:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-9201) same merge window will be fired twice if watermark already passed the merge window - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 09:31:00 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-9201) same merge window will be fired twice if watermark already passed the merge window - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2018/04/26 09:41:00 UTC, 0 replies.
- [GitHub] flink pull request #5918: [hotfix][ListCheckpointed]modify parallelism in th... - posted by maqingxiang <gi...@git.apache.org> on 2018/04/26 10:17:31 UTC, 0 replies.
- [GitHub] flink pull request #5919: [hotfix][state.md]modify typo in the state.md - posted by maqingxiang <gi...@git.apache.org> on 2018/04/26 10:18:37 UTC, 0 replies.
- [jira] [Created] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/04/26 12:33:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled - posted by "Edward Rojas (JIRA)" <ji...@apache.org> on 2018/04/26 13:03:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-7391) Normalize release entries - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2018/04/26 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot - posted by "Chris Schneider (JIRA)" <ji...@apache.org> on 2018/04/26 13:49:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9262) KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot - posted by "Chris Schneider (JIRA)" <ji...@apache.org> on 2018/04/26 13:50:00 UTC, 0 replies.
- [GitHub] flink pull request #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen s... - posted by trionesadam <gi...@git.apache.org> on 2018/04/26 13:52:42 UTC, 0 replies.
- [GitHub] flink issue #5894: [FLINK-9185] [runtime] Fix potential null dereference in ... - posted by StephenJeson <gi...@git.apache.org> on 2018/04/26 14:16:36 UTC, 2 replies.
- [GitHub] flink pull request #5921: [FLINK-9254] Move NotSoMiniClusterIterations to be... - posted by azagrebin <gi...@git.apache.org> on 2018/04/26 14:24:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 14:25:00 UTC, 1 replies.
- [GitHub] flink issue #5921: [FLINK-9254] Move NotSoMiniClusterIterations to be an end... - posted by azagrebin <gi...@git.apache.org> on 2018/04/26 14:27:35 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8978) End-to-end test: Job upgrade - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/04/26 14:49:00 UTC, 0 replies.
- [GitHub] flink pull request #5922: [FLINK-8780] [docs] Add Broadcast State documentat... - posted by kl0u <gi...@git.apache.org> on 2018/04/26 15:25:25 UTC, 7 replies.
- [jira] [Commented] (FLINK-8780) Add Broadcast State documentation. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 15:26:00 UTC, 7 replies.
- [jira] [Assigned] (FLINK-9232) Add harness test for AggregationCodeGenerator - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/26 16:10:00 UTC, 0 replies.
- [GitHub] flink issue #3783: [FLINK-6388] Add support for DISTINCT into Code Generated... - posted by fhueske <gi...@git.apache.org> on 2018/04/26 16:13:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 16:14:00 UTC, 1 replies.
- [jira] [Closed] (FLINK-8841) Duplicate MapSerializer and HashMapSerializer. - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/04/26 16:34:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8134) Add description to MessageHeaders - posted by "Maxim Belov (JIRA)" <ji...@apache.org> on 2018/04/26 16:43:00 UTC, 0 replies.
- [GitHub] flink pull request #5923: [FLINK-9253][network] make the maximum floating bu... - posted by NicoK <gi...@git.apache.org> on 2018/04/26 16:47:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 16:48:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-9159) Sanity check default timeout values - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/26 16:56:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9159) Sanity check default timeout values - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/26 16:57:00 UTC, 0 replies.
- [GitHub] flink pull request #5427: [FLINK-8533] [checkpointing] Support MasterTrigger... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/26 18:13:31 UTC, 3 replies.
- [jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/26 18:14:01 UTC, 3 replies.
- [jira] [Closed] (FLINK-8689) Add runtime support of distinct filter using MapView - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/26 21:24:00 UTC, 0 replies.
- [GitHub] flink pull request #3783: [FLINK-6388] Add support for DISTINCT into Code Ge... - posted by asfgit <gi...@git.apache.org> on 2018/04/26 21:24:02 UTC, 0 replies.
- [jira] [Closed] (FLINK-6388) Add support for DISTINCT into Code Generated Aggregations - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/26 21:28:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-6249) Distinct Aggregates for OVER window - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/04/26 21:29:00 UTC, 0 replies.
- [GitHub] flink issue #4607: [FLINK-6306][connectors] Sink for eventually consistent f... - posted by narayaruna <gi...@git.apache.org> on 2018/04/27 00:22:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/27 00:23:00 UTC, 1 replies.
- [GitHub] flink pull request #5924: [hotfix][README.md] Update building prerequisites - posted by W4anD0eR96 <gi...@git.apache.org> on 2018/04/27 01:09:17 UTC, 3 replies.
- [GitHub] flink issue #5916: [hotfix][tests] remove redundant rebalance in SuccessAfte... - posted by zhijiangW <gi...@git.apache.org> on 2018/04/27 05:00:26 UTC, 1 replies.
- [GitHub] flink pull request #5925: [FLINK-8992] [e2e-tests] General purpose DataStrea... - posted by tzulitai <gi...@git.apache.org> on 2018/04/27 07:18:35 UTC, 3 replies.
- [jira] [Commented] (FLINK-8992) Implement source and operator that validate exactly-once - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/27 07:19:00 UTC, 5 replies.
- [GitHub] flink issue #5925: [FLINK-8992] [e2e-tests] General purpose DataStream e2e t... - posted by tzulitai <gi...@git.apache.org> on 2018/04/27 07:23:00 UTC, 1 replies.
- [GitHub] flink issue #5923: [FLINK-9253][network] make the maximum floating buffers c... - posted by zhijiangW <gi...@git.apache.org> on 2018/04/27 07:38:28 UTC, 0 replies.
- [GitHub] flink pull request #5926: [FLINK-9073] [tests] Extend savepoint e2e tests fo... - posted by tzulitai <gi...@git.apache.org> on 2018/04/27 07:58:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-9073) Resume from savepoint end-to-end tests should be extended for different state backends - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/27 07:59:00 UTC, 0 replies.
- [GitHub] flink pull request #5927: [FLINK-8237] [BucketingSink] Better error message ... - posted by pavel-shvetsov-git <gi...@git.apache.org> on 2018/04/27 08:04:21 UTC, 0 replies.
- [GitHub] flink issue #5924: [hotfix][README.md] Update building prerequisites - posted by W4anD0eR96 <gi...@git.apache.org> on 2018/04/27 09:33:58 UTC, 3 replies.
- [GitHub] flink pull request #5928: [hotfix][doc] fix doc of externalized checkpoint - posted by sihuazhou <gi...@git.apache.org> on 2018/04/27 09:50:03 UTC, 2 replies.
- [GitHub] flink issue #5928: [hotfix][doc] fix doc of externalized checkpoint - posted by sihuazhou <gi...@git.apache.org> on 2018/04/27 10:23:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9263) Kafka010ITCase failed on travis flaky - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 12:00:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9263) Kafka010ITCase failed on travis flaky - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 12:06:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9263) Kafka010ITCase failed on travis flaky - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 12:06:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9263) Kafka010ITCase failed on travis flaky - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 12:09:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-9263) Kafka010ITCase failed on travis flaky - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 12:09:00 UTC, 0 replies.
- [GitHub] flink pull request #5929: [FLINK-8497] [connectors] KafkaConsumer throws NPE... - posted by alexpf <gi...@git.apache.org> on 2018/04/27 12:46:54 UTC, 0 replies.
- [GitHub] flink pull request #5930: [FLINK-9263][state] Fix concurrency problem in Def... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/27 12:47:23 UTC, 4 replies.
- [GitHub] flink issue #5930: [FLINK-9263][state] Fix concurrency problem in DefaultOpe... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/27 12:51:27 UTC, 4 replies.
- [jira] [Closed] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/27 12:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/27 12:56:00 UTC, 2 replies.
- [jira] [Updated] (FLINK-9263) Kafka010ITCase failed on travis because of the concurrency problem in DefaultOperateStateBackend - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/27 13:01:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8992) Implement source and operator that validate exactly-once - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/04/27 14:16:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9263) Kafka010ITCase failed on travis because of the concurrency problem in DefaultOperateStateBackend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/27 14:42:00 UTC, 7 replies.
- [GitHub] flink pull request #5931: [FLINK-9190][flip6,yarn] Request new container if ... - posted by GJL <gi...@git.apache.org> on 2018/04/27 15:21:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-9260) Introduce a friendly way to resume the job from externalized checkpoints automatically - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/27 15:53:00 UTC, 1 replies.
- [jira] [Created] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B] - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/04/27 15:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9265) Upgrade Prometheus version - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2018/04/27 18:21:00 UTC, 0 replies.
- [GitHub] flink issue #5920: [FLINK-9231] [web] Enable SO_REUSEADDR on listen sockets ... - posted by tedyu <gi...@git.apache.org> on 2018/04/27 18:22:19 UTC, 0 replies.
- [jira] [Created] (FLINK-9266) Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis describe streams calls - posted by "Thomas Moser (JIRA)" <ji...@apache.org> on 2018/04/27 18:42:00 UTC, 0 replies.
- [GitHub] flink pull request #5932: [FLINK-9266][flink-connector-kinesis]Updates Kines... - posted by tmoser2525 <gi...@git.apache.org> on 2018/04/27 18:49:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-9266) Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis describe streams calls - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/27 18:50:00 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (FLINK-9266) Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis describe streams calls - posted by "Thomas Moser (JIRA)" <ji...@apache.org> on 2018/04/27 18:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9267) Classloading issues when using RemoteEnvironment ... - posted by "Kedar Mhaswade (JIRA)" <ji...@apache.org> on 2018/04/27 20:29:00 UTC, 0 replies.
- [GitHub] flink issue #5932: [FLINK-9266][flink-connector-kinesis]Updates Kinesis conn... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/27 21:12:14 UTC, 1 replies.
- [jira] [Created] (FLINK-9268) RockDB errors from WindowOperator - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/27 22:23:00 UTC, 0 replies.
- [GitHub] flink issue #5887: [FLINK-6719] [docs] Add details about fault-tolerance of ... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/27 23:55:53 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9265) Upgrade Prometheus version - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/28 01:35:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/28 01:39:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B] - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/28 01:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/28 02:31:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/28 02:32:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/28 02:34:00 UTC, 1 replies.
- [GitHub] flink pull request #5933: [FLINK-9125] MiniClusterResource should set CoreOp... - posted by yanghua <gi...@git.apache.org> on 2018/04/28 02:47:50 UTC, 2 replies.
- [jira] [Commented] (FLINK-9125) MiniClusterResource should set CoreOptions.TMP_DIRS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/28 02:48:00 UTC, 3 replies.
- [GitHub] flink issue #5933: [FLINK-9125] MiniClusterResource should set CoreOptions.T... - posted by yanghua <gi...@git.apache.org> on 2018/04/28 02:49:15 UTC, 0 replies.
- [GitHub] flink pull request #5934: [FLINK-9269][state] fix concurrency problem when p... - posted by sihuazhou <gi...@git.apache.org> on 2018/04/28 03:03:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/28 03:04:00 UTC, 9 replies.
- [GitHub] flink pull request #5935: [FLINK-9119] example code error in Concepts & Comm... - posted by yanghua <gi...@git.apache.org> on 2018/04/28 03:08:29 UTC, 0 replies.
- [GitHub] flink issue #5935: [FLINK-9119] example code error in Concepts & Common API - posted by yanghua <gi...@git.apache.org> on 2018/04/28 03:09:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-9265) Upgrade Prometheus version - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/04/28 06:40:00 UTC, 1 replies.
- [GitHub] flink pull request #5936: [FLINK-9265] Upgrade Prometheus version - posted by yanghua <gi...@git.apache.org> on 2018/04/28 06:43:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-9268) RockDB errors from WindowOperator - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2018/04/28 08:25:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9270) Upgrade RocksDB to 5.11.3, and resolve concurrent test invocation problem of @RetryOnFailure - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/28 08:28:00 UTC, 0 replies.
- [jira] [Updated] (FLINK-9270) Upgrade RocksDB to 5.11.3, and resolve concurrent test invocation problem of @RetryOnFailure - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/04/28 08:31:00 UTC, 1 replies.
- [GitHub] flink pull request #5937: [FLINK-9270] Upgrade RocksDB to 5.11.3, and resolv... - posted by bowenli86 <gi...@git.apache.org> on 2018/04/28 08:37:51 UTC, 1 replies.
- [jira] [Commented] (FLINK-9270) Upgrade RocksDB to 5.11.3, and resolve concurrent test invocation problem of @RetryOnFailure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/28 08:38:00 UTC, 3 replies.
- [jira] [Resolved] (FLINK-8715) RocksDB does not propagate reconfiguration of serializer to the states - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/28 09:10:00 UTC, 0 replies.
- [GitHub] flink pull request #5938: [FLINK-9196][flip6, yarn] Cleanup application file... - posted by GJL <gi...@git.apache.org> on 2018/04/28 10:04:05 UTC, 5 replies.
- [GitHub] flink issue #5937: [FLINK-9270] Upgrade RocksDB to 5.11.3, and resolve concu... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/28 10:18:57 UTC, 0 replies.
- [GitHub] flink issue #5934: [FLINK-9269][state] fix concurrency problem when performi... - posted by StefanRRichter <gi...@git.apache.org> on 2018/04/28 10:32:44 UTC, 6 replies.
- [jira] [Created] (FLINK-9271) flink-1.4.2-bin-scala_2.11.tgz is not in gzip format - posted by "Martin Grigorov (JIRA)" <ji...@apache.org> on 2018/04/28 11:21:00 UTC, 0 replies.
- [GitHub] flink pull request #5939: [FLINK-8500] [Kafka Connector] Get the timestamp o... - posted by FredTing <gi...@git.apache.org> on 2018/04/28 13:14:38 UTC, 0 replies.
- [jira] [Updated] (FLINK-9268) RockDB errors from WindowOperator - posted by "Narayanan Arunachalam (JIRA)" <ji...@apache.org> on 2018/04/28 14:51:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8255) Key expressions on named row types do not work - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/04/28 15:03:00 UTC, 1 replies.
- [GitHub] flink pull request #5940: [FLINK-8690][table]Support DistinctAgg on DataStre... - posted by walterddr <gi...@git.apache.org> on 2018/04/28 16:07:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-7144) Optimize multiple LogicalAggregate into one - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/28 16:18:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-7144) Optimize multiple LogicalAggregate into one - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/04/28 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9272) DataDog API "counter" metric type is deprecated - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2018/04/28 16:24:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9272) DataDog API "counter" metric type is deprecated - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/28 20:07:00 UTC, 1 replies.
- [jira] [Updated] (FLINK-9266) Upgrade AWS Kinesis Client version to 1.9.0 to reduce Kinesis describe streams calls - posted by "Thomas Moser (JIRA)" <ji...@apache.org> on 2018/04/28 22:04:00 UTC, 3 replies.
- [GitHub] flink pull request #5940: [FLINK-8690][table]Support group window distinct a... - posted by suez1224 <gi...@git.apache.org> on 2018/04/28 22:16:41 UTC, 1 replies.
- [jira] [Created] (FLINK-9273) Class cast exception - posted by "Bob Lau (JIRA)" <ji...@apache.org> on 2018/04/29 17:44:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-8255) Key expressions on named row types do not work - posted by "Sergey Nuyanzin (JIRA)" <ji...@apache.org> on 2018/04/29 20:42:00 UTC, 0 replies.
- [GitHub] flink issue #5931: [FLINK-9190][flip6,yarn] Request new container if contain... - posted by GJL <gi...@git.apache.org> on 2018/04/30 08:02:49 UTC, 2 replies.
- [jira] [Updated] (FLINK-9246) HistoryServer job overview broken - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 08:47:00 UTC, 0 replies.
- [jira] [Closed] (FLINK-8924) Add @Old junit category - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 09:00:00 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-9179) Deduplicate WebOptions.PORT and RestOptions.REST_PORT - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/30 09:28:00 UTC, 0 replies.
- [GitHub] flink issue #5822: [FLINK-8743][docs] Allow overriding documented default - posted by zentol <gi...@git.apache.org> on 2018/04/30 09:45:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for FLIP-6 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 09:58:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8996) Include an operator with broadcast and union state - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/04/30 10:07:00 UTC, 0 replies.
- [GitHub] flink pull request #5941: [FLINK-8971] [e2e] Include broadcast / union state... - posted by tzulitai <gi...@git.apache.org> on 2018/04/30 10:33:38 UTC, 0 replies.
- [GitHub] flink issue #5941: [FLINK-8971] [e2e] Include broadcast / union state in gen... - posted by tzulitai <gi...@git.apache.org> on 2018/04/30 10:40:04 UTC, 0 replies.
- [jira] [Created] (FLINK-9274) Add thread name to Kafka Partition Discovery - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/30 11:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/30 12:10:00 UTC, 1 replies.
- [jira] [Assigned] (FLINK-6188) Some setParallelism() methods can't cope with default parallelism - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 12:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8021) End-to-end tests may not shutdown cluster on failure - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 12:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-8672) Support continuous processing in CSV table source - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 12:21:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2551) Fix Several Bugs in Input/Output Formats - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 12:22:00 UTC, 0 replies.
- [jira] [Assigned] (FLINK-6135) Allowing adding additional inputs to StreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 12:22:00 UTC, 0 replies.
- [GitHub] flink pull request #5942: [FLINK-9274][kafka] add thread name for partition ... - posted by NicoK <gi...@git.apache.org> on 2018/04/30 12:25:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-9274) Add thread name to Kafka Partition Discovery - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/30 12:26:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9275) Set more distinctive output flusher thread names - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/04/30 13:02:00 UTC, 0 replies.
- [GitHub] flink pull request #5943: [FLINK-9275][streaming] add taskName to the output... - posted by NicoK <gi...@git.apache.org> on 2018/04/30 13:05:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-9275) Set more distinctive output flusher thread names - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/30 13:06:00 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/30 13:28:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9273) Class cast exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 15:46:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9271) flink-1.4.2-bin-scala_2.11.tgz is not in gzip format - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 15:55:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 16:27:00 UTC, 0 replies.
- [GitHub] flink pull request #5944: [FLINK-8900] [yarn] Set correct application status... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 16:45:03 UTC, 0 replies.
- [jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/04/30 16:46:00 UTC, 2 replies.
- [jira] [Created] (FLINK-9276) Improve error message when TaskManager fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 17:10:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for FLIP-6 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2018/04/30 17:15:00 UTC, 4 replies.
- [jira] [Created] (FLINK-9277) Reduce noisiness of SlotPool logging - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 17:26:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-9277) Reduce noisiness of SlotPool logging - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/30 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed - posted by "Adrian Hains (JIRA)" <ji...@apache.org> on 2018/04/30 18:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-9279) PythonPlanBinderTest flakey - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/04/30 19:03:00 UTC, 0 replies.
- [GitHub] flink issue #5944: [FLINK-8900] [yarn] Set correct application status when j... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 19:04:40 UTC, 1 replies.
- [GitHub] flink issue #5938: [FLINK-9196][flip6, yarn] Cleanup application files when ... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 19:18:07 UTC, 0 replies.
- [GitHub] flink issue #5943: [FLINK-9275][streaming] add taskName to the output flushe... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 19:23:41 UTC, 0 replies.
- [GitHub] flink issue #5942: [FLINK-9274][kafka] add thread name for partition discove... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 19:29:23 UTC, 0 replies.
- [GitHub] flink issue #5914: [FLINK-9256][network] fix NPE in SingleInputGate#updateIn... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 19:34:41 UTC, 0 replies.
- [GitHub] flink issue #5900: [FLINK-9222][docs] add documentation for setting up Gradl... - posted by StephanEwen <gi...@git.apache.org> on 2018/04/30 19:47:14 UTC, 1 replies.
- [jira] [Closed] (FLINK-9279) PythonPlanBinderTest flakey - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/30 20:47:00 UTC, 0 replies.