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

---

- [flink] branch master updated (a7abe7d -> ea43832) - posted by di...@apache.org on 2020/11/02 02:36:26 UTC, 3 replies.
- [flink] branch release-1.11 updated (0656151 -> 6b1f7e0) - posted by di...@apache.org on 2020/11/02 02:38:47 UTC, 3 replies.
- [flink-statefun] branch master updated: [FLINK-19840] Do not allow rocksdb timerservice that uses the heap - posted by tz...@apache.org on 2020/11/02 04:36:43 UTC, 0 replies.
- [flink-statefun] branch release-2.2 updated: [FLINK-19840] Do not allow rocksdb timerservice that uses the heap - posted by tz...@apache.org on 2020/11/02 04:39:48 UTC, 0 replies.
- [flink] branch master updated (ea43832 -> 4467277d) - posted by go...@apache.org on 2020/11/02 06:43:00 UTC, 1 replies.
- [flink] branch master updated (4467277d -> 1e4b380) - posted by ar...@apache.org on 2020/11/02 08:37:11 UTC, 4 replies.
- [flink] branch master updated (1e4b380 -> 6b5d4c0) - posted by ar...@apache.org on 2020/11/02 08:42:46 UTC, 2 replies.
- [flink] branch master updated (6b5d4c0 -> 46b0f8b) - posted by dw...@apache.org on 2020/11/02 08:47:42 UTC, 1 replies.
- [flink] branch master updated (46b0f8b -> bfc8a9e) - posted by ja...@apache.org on 2020/11/02 09:06:21 UTC, 1 replies.
- [flink] branch master updated (bfc8a9e -> f84acf6) - posted by dw...@apache.org on 2020/11/02 09:18:00 UTC, 3 replies.
- [flink] branch master updated (f84acf6 -> 3ab31a0) - posted by ar...@apache.org on 2020/11/02 09:29:02 UTC, 3 replies.
- [flink] branch master updated (3ab31a0 -> c6043a5) - posted by ch...@apache.org on 2020/11/02 10:53:40 UTC, 3 replies.
- [flink] branch master updated (c6043a5 -> 34d143f) - posted by al...@apache.org on 2020/11/02 12:09:42 UTC, 2 replies.
- [flink] branch master updated (34d143f -> ad1c4f0) - posted by di...@apache.org on 2020/11/02 12:52:46 UTC, 1 replies.
- [flink] branch master updated (ad1c4f0 -> ed33697) - posted by zh...@apache.org on 2020/11/02 13:57:10 UTC, 3 replies.
- [flink] branch master updated (ed33697 -> 133593a) - posted by rm...@apache.org on 2020/11/02 16:01:45 UTC, 2 replies.
- [flink] branch master updated (133593a -> 0c7659e) - posted by lz...@apache.org on 2020/11/03 02:13:42 UTC, 2 replies.
- [flink] branch master updated (0c7659e -> eee0d8e) - posted by lz...@apache.org on 2020/11/03 02:16:19 UTC, 2 replies.
- [flink] branch master updated (eee0d8e -> dc0c5b5) - posted by di...@apache.org on 2020/11/03 05:02:33 UTC, 1 replies.
- [flink] branch master updated (dc0c5b5 -> 59d2a2d) - posted by ja...@apache.org on 2020/11/03 05:28:30 UTC, 4 replies.
- [flink] branch master updated (59d2a2d -> 0d7d8c8) - posted by ja...@apache.org on 2020/11/03 06:33:37 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-16268][table-planner-blink] Failed to run rank over window with Hive built-in functions - posted by lz...@apache.org on 2020/11/03 07:07:43 UTC, 0 replies.
- [flink] branch master updated (0d7d8c8 -> d3fdc17) - posted by kk...@apache.org on 2020/11/03 07:55:18 UTC, 3 replies.
- [flink] branch master updated (d3fdc17 -> 9e4bf5e) - posted by al...@apache.org on 2020/11/03 08:29:09 UTC, 1 replies.
- [flink] branch master updated: [FLINK-15408][table-planner-blink] Interval join supports non-equal condition - posted by go...@apache.org on 2020/11/03 08:32:46 UTC, 0 replies.
- [flink-benchmarks] branch master updated (333eb8e -> 2df8178) - posted by pn...@apache.org on 2020/11/03 08:38:51 UTC, 0 replies.
- [flink-benchmarks] 01/02: [hotfix] Fix metadata in pom.xml - posted by pn...@apache.org on 2020/11/03 08:38:52 UTC, 0 replies.
- [flink-benchmarks] 02/02: [FLINK-19884] Add benchmarks for batch-style execution for bounded keyed streams - posted by pn...@apache.org on 2020/11/03 08:38:53 UTC, 0 replies.
- [flink] branch master updated (091c7fa -> b45ee1f) - posted by ch...@apache.org on 2020/11/03 10:50:44 UTC, 4 replies.
- [flink] branch master updated (b45ee1f -> c715421) - posted by di...@apache.org on 2020/11/03 11:21:19 UTC, 1 replies.
- [flink] branch release-1.11 updated: [FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner (#13899) - posted by di...@apache.org on 2020/11/03 11:23:04 UTC, 3 replies.
- [flink] branch master updated (c715421 -> 4d7c89fd) - posted by di...@apache.org on 2020/11/03 11:26:14 UTC, 4 replies.
- [flink] branch master updated (4d7c89fd -> d0458aa) - posted by go...@apache.org on 2020/11/03 11:37:54 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-19907][network] Recover channel state before initializing operators chain - posted by ar...@apache.org on 2020/11/03 12:13:52 UTC, 1 replies.
- [flink] branch master updated (d0458aa -> 1f40502) - posted by ar...@apache.org on 2020/11/03 12:26:47 UTC, 3 replies.
- [flink] branch master updated (1f40502 -> a4d70ae) - posted by az...@apache.org on 2020/11/03 13:05:00 UTC, 1 replies.
- [flink] branch master updated (a4d70ae -> 6ed81d9) - posted by se...@apache.org on 2020/11/03 15:34:34 UTC, 0 replies.
- [flink] 01/10: [hotfix] Minor JavaDocs fixes for File Source classes. - posted by se...@apache.org on 2020/11/03 15:34:35 UTC, 0 replies.
- [flink] 02/10: [FLINK-19800][connector file] Make FileSourceSplit / FileSourceSplitState interaction extensible - posted by se...@apache.org on 2020/11/03 15:34:36 UTC, 0 replies.
- [flink] 03/10: [FLINK-19802][connector files] Let BulkFormat createReader and restoreReader methods accept Splits directly - posted by se...@apache.org on 2020/11/03 15:34:37 UTC, 0 replies.
- [flink] 04/10: [FLINK-19803][connector files] Make PendingSplitCheckpoint and its Serializer generic to support sub-classes of FileSourceSplit - posted by se...@apache.org on 2020/11/03 15:34:38 UTC, 0 replies.
- [flink] 05/10: [FLINK-19804][connector files] Make FileSource class generic with respect to split types - posted by se...@apache.org on 2020/11/03 15:34:39 UTC, 0 replies.
- [flink] 06/10: [FLINK-19597][network] Introduce SortBuffer and PartitionSortedBuffer for sort-merge based blocking shuffle - posted by se...@apache.org on 2020/11/03 15:34:40 UTC, 0 replies.
- [flink] 07/10: [FLINK-19600][network] Introduce PartitionedFile and the corresponding writer/reader for sort-merge based blocking shuffle - posted by se...@apache.org on 2020/11/03 15:34:41 UTC, 0 replies.
- [flink] 08/10: [FLINK-19601][network] Introduce sort-merge based blocking result partition SortMergeResultPartition and the corresponding subpartition reader - posted by se...@apache.org on 2020/11/03 15:34:42 UTC, 0 replies.
- [flink] 09/10: [FLINK-19602][network] Introduce new config options to enable sort-merge based blocking shuffle - posted by se...@apache.org on 2020/11/03 15:34:43 UTC, 0 replies.
- [flink] 10/10: [FLINK-19603][network] Introduce shuffle data compression to sort-merge based blocking shuffle - posted by se...@apache.org on 2020/11/03 15:34:44 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19901][metrics] Fix caching offset for variables - posted by ch...@apache.org on 2020/11/03 17:59:34 UTC, 0 replies.
- [flink] branch master updated (6ed81d9 -> 477d37d) - posted by ch...@apache.org on 2020/11/03 18:01:07 UTC, 1 replies.
- [flink] branch release-1.11 updated: [FLINK-19901][metrics] Fix caching offset for variables - posted by ch...@apache.org on 2020/11/03 18:03:55 UTC, 1 replies.
- [flink] branch master updated (477d37d -> 5b4a370) - posted by dw...@apache.org on 2020/11/03 18:13:53 UTC, 4 replies.
- [flink] branch release-1.11 updated (8addf89 -> cdd537c) - posted by ch...@apache.org on 2020/11/03 18:18:27 UTC, 2 replies.
- [flink] branch release-1.10 updated: [FLINK-19901][metrics] Fix caching offset for variables - posted by ch...@apache.org on 2020/11/03 18:26:54 UTC, 4 replies.
- [flink] branch master updated (5b4a370 -> 3c613dd) - posted by ar...@apache.org on 2020/11/03 19:56:45 UTC, 4 replies.
- [flink] branch master updated: [FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs - posted by di...@apache.org on 2020/11/04 01:03:26 UTC, 1 replies.
- [flink] branch master updated (b868639 -> a5bb18a) - posted by di...@apache.org on 2020/11/04 01:14:59 UTC, 2 replies.
- [flink] branch release-1.11 updated: [FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW - posted by di...@apache.org on 2020/11/04 01:26:31 UTC, 1 replies.
- [flink] branch master updated (a5bb18a -> 6c1b3b6) - posted by ja...@apache.org on 2020/11/04 02:13:54 UTC, 4 replies.
- [flink] branch master updated (6c1b3b6 -> 25701e1) - posted by ja...@apache.org on 2020/11/04 02:16:06 UTC, 4 replies.
- [flink] branch master updated (25701e1 -> 9652b6d) - posted by ja...@apache.org on 2020/11/04 02:22:25 UTC, 4 replies.
- [flink] branch master updated (9652b6d -> a2eb2c1) - posted by lz...@apache.org on 2020/11/04 03:41:22 UTC, 4 replies.
- [flink-statefun] branch release-2.2 updated: [FLINK-19866] Move intialization logic to open() instead initializeState - posted by tz...@apache.org on 2020/11/04 06:14:42 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-19866] Move intialization logic to open() instead initializeState - posted by tz...@apache.org on 2020/11/04 06:14:58 UTC, 0 replies.
- [flink] branch release-1.11 updated (4bf1f02 -> 0a38f73) - posted by ja...@apache.org on 2020/11/04 07:02:14 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-19258][docs] Fix the wrong example for "csv.line-delimiter" option - posted by ja...@apache.org on 2020/11/04 07:34:43 UTC, 0 replies.
- [flink] branch master updated (a2eb2c1 -> 2145610) - posted by go...@apache.org on 2020/11/04 07:37:05 UTC, 0 replies.
- [flink] branch master updated (2145610 -> 375c96c) - posted by az...@apache.org on 2020/11/04 08:04:32 UTC, 1 replies.
- [flink-statefun] annotated tag release-2.2.1-rc1 updated (3d53612 -> 94463e7) - posted by tz...@apache.org on 2020/11/04 09:10:10 UTC, 0 replies.
- svn commit: r42300 - /dev/flink/flink-statefun-2.2.1-rc1/ - posted by tz...@apache.org on 2020/11/04 09:12:29 UTC, 0 replies.
- [flink] branch master updated (375c96c -> 9447179) - posted by kk...@apache.org on 2020/11/04 09:26:44 UTC, 3 replies.
- [flink] branch master updated (9447179 -> a268465) - posted by ch...@apache.org on 2020/11/04 09:31:04 UTC, 4 replies.
- [flink] branch master updated (a268465 -> fc2148c) - posted by ch...@apache.org on 2020/11/04 09:36:03 UTC, 4 replies.
- [flink] branch master updated (fc2148c -> c9f29a7) - posted by lz...@apache.org on 2020/11/04 10:08:40 UTC, 1 replies.
- [flink] branch master updated (c9f29a7 -> 4435fe2) - posted by lz...@apache.org on 2020/11/04 10:11:47 UTC, 0 replies.
- [flink] branch master updated (4435fe2 -> c4a74be) - posted by ch...@apache.org on 2020/11/04 10:35:08 UTC, 3 replies.
- [flink] branch master updated (c4a74be -> 325fb24) - posted by tz...@apache.org on 2020/11/04 10:47:01 UTC, 4 replies.
- [flink-benchmarks] branch master updated: [FLINK-19680] Explicitly set alignment timeout to 0 in the existing Unaligned Checkpoints benchmarks - posted by pn...@apache.org on 2020/11/04 11:07:07 UTC, 0 replies.
- [flink] branch master updated (325fb24 -> cddb821) - posted by di...@apache.org on 2020/11/04 12:40:32 UTC, 4 replies.
- [flink] branch master updated: [FLINK-19790][json] Clear reused ObjectNode's content for map converter in RowDataToJsonConverters - posted by li...@apache.org on 2020/11/04 12:47:26 UTC, 0 replies.
- [flink] branch master updated (cddb821 -> b7487bd) - posted by li...@apache.org on 2020/11/04 12:48:32 UTC, 3 replies.
- [flink] branch master updated (b7487bd -> 36c3326) - posted by tw...@apache.org on 2020/11/04 13:44:03 UTC, 1 replies.
- [flink] branch release-1.11 updated: [FLINK-19867][table-common] Validation fails for UDF that accepts var-args - posted by tw...@apache.org on 2020/11/04 13:54:44 UTC, 0 replies.
- [flink] branch release-1.11 updated (be1aea7 -> f488e70) - posted by tw...@apache.org on 2020/11/04 13:55:49 UTC, 2 replies.
- [flink] branch master updated (36c3326 -> 7f5dd53) - posted by dw...@apache.org on 2020/11/04 15:16:09 UTC, 4 replies.
- [flink] branch master updated (7f5dd53 -> 0862478) - posted by az...@apache.org on 2020/11/04 15:21:55 UTC, 0 replies.
- [flink] branch master updated (0862478 -> 2eaee83) - posted by tr...@apache.org on 2020/11/04 17:23:45 UTC, 4 replies.
- [flink] branch master updated (2eaee83 -> 7a2d76d) - posted by kk...@apache.org on 2020/11/04 18:11:19 UTC, 3 replies.
- [flink] branch master updated (7a2d76d -> 77e9e65) - posted by rm...@apache.org on 2020/11/04 19:32:09 UTC, 4 replies.
- [flink] 01/01: [FLINK-19849] Fix NOTICE files for 1.12 release - posted by rm...@apache.org on 2020/11/04 19:32:10 UTC, 0 replies.
- [flink] branch release-1.11 updated (f488e70 -> b50fc62) - posted by li...@apache.org on 2020/11/05 02:31:08 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-19790][json] Clear reused ObjectNode's content for map converter in RowDataToJsonConverters - posted by li...@apache.org on 2020/11/05 02:32:08 UTC, 0 replies.
- [flink] branch master updated (77e9e65 -> b88859f) - posted by xt...@apache.org on 2020/11/05 02:39:33 UTC, 4 replies.
- [flink] branch master updated (b88859f -> c55420b) - posted by ja...@apache.org on 2020/11/05 04:36:23 UTC, 3 replies.
- [flink] branch master updated (c55420b -> 854f523) - posted by go...@apache.org on 2020/11/05 06:42:01 UTC, 3 replies.
- [flink] branch master updated (854f523 -> 869f0bc) - posted by az...@apache.org on 2020/11/05 07:30:14 UTC, 4 replies.
- [flink] branch master updated (869f0bc -> 56207e8) - posted by lz...@apache.org on 2020/11/05 08:08:43 UTC, 4 replies.
- [flink] branch master updated (56207e8 -> 358713b) - posted by rm...@apache.org on 2020/11/05 08:38:42 UTC, 4 replies.
- [flink] branch master updated (358713b -> f3964a9) - posted by ar...@apache.org on 2020/11/05 09:04:09 UTC, 3 replies.
- [flink] branch master updated (f3964a9 -> 513c806) - posted by rm...@apache.org on 2020/11/05 09:30:08 UTC, 4 replies.
- [flink] branch master updated (513c806 -> 97af79e) - posted by al...@apache.org on 2020/11/05 10:04:40 UTC, 4 replies.
- [flink] branch master updated (97af79e -> 0198805) - posted by tr...@apache.org on 2020/11/05 10:22:28 UTC, 4 replies.
- [flink] branch master updated (0198805 -> 473d2c5) - posted by di...@apache.org on 2020/11/05 11:15:27 UTC, 2 replies.
- [flink] branch master updated (473d2c5 -> 4044a75) - posted by rm...@apache.org on 2020/11/05 11:57:23 UTC, 1 replies.
- [flink] branch master updated (4044a75 -> 61b1106) - posted by di...@apache.org on 2020/11/05 12:00:26 UTC, 2 replies.
- [flink] branch release-1.11 updated (b50fc62 -> 9948c07) - posted by di...@apache.org on 2020/11/05 12:06:07 UTC, 1 replies.
- [flink] 01/02: [FLINK-18916][python][docs] Add "Operations" under the "Python API" -> "User Guide" -> "Table API" section - posted by di...@apache.org on 2020/11/05 12:06:08 UTC, 1 replies.
- [flink] 02/02: [FLINK-18922][python][docs] Add "Catalogs" under the "Python API" -> "User Guide" -> "Table API" section - posted by di...@apache.org on 2020/11/05 12:06:09 UTC, 1 replies.
- [flink] branch master updated (61b1106 -> f504bf5) - posted by ja...@apache.org on 2020/11/05 13:13:21 UTC, 2 replies.
- [flink] branch master updated (f504bf5 -> ad18d13) - posted by ja...@apache.org on 2020/11/05 13:18:11 UTC, 0 replies.
- [flink] branch master updated (ad18d13 -> 92d5033) - posted by se...@apache.org on 2020/11/05 14:51:46 UTC, 0 replies.
- [flink] 01/03: [FLINK-15981][refactor] Refactor NettyMessage#write() to allow writing multiple message parts. - posted by se...@apache.org on 2020/11/05 14:51:47 UTC, 0 replies.
- [flink] 02/03: [FLINK-15981][network] Implement zero-copy file transfer in network based on FileRegion for bounded blocking partitions - posted by se...@apache.org on 2020/11/05 14:51:48 UTC, 0 replies.
- [flink] 03/03: [hotfix] Move FileBufferReaderITCase from 'flink-tests' to 'flink-runtime' - posted by se...@apache.org on 2020/11/05 14:51:49 UTC, 0 replies.
- [flink] branch master updated (92d5033 -> 7ea3a60) - posted by jq...@apache.org on 2020/11/05 15:32:46 UTC, 4 replies.
- [flink] branch master updated (7ea3a60 -> 1193530) - posted by rm...@apache.org on 2020/11/05 15:48:38 UTC, 1 replies.
- [flink] branch master updated (1193530 -> 28110ed) - posted by tr...@apache.org on 2020/11/05 17:00:32 UTC, 4 replies.
- [flink] branch master updated (28110ed -> eb05e50) - posted by kk...@apache.org on 2020/11/05 19:12:08 UTC, 2 replies.
- [flink] branch master updated (eb05e50 -> 747566d) - posted by kk...@apache.org on 2020/11/05 22:50:35 UTC, 1 replies.
- [flink] branch master updated (747566d -> dc49dc7) - posted by go...@apache.org on 2020/11/06 02:22:57 UTC, 4 replies.
- [flink] branch master updated (dc49dc7 -> 2d12d32) - posted by ja...@apache.org on 2020/11/06 03:31:46 UTC, 3 replies.
- [flink] branch master updated (2d12d32 -> b23c310) - posted by di...@apache.org on 2020/11/06 04:36:34 UTC, 1 replies.
- [flink] branch master updated (b23c310 -> 51cd11e) - posted by di...@apache.org on 2020/11/06 06:02:03 UTC, 4 replies.
- [flink] branch master updated (51cd11e -> e0a0aa6) - posted by di...@apache.org on 2020/11/06 06:34:17 UTC, 4 replies.
- [flink] branch master updated: [FLINK-18004][docs] Update checkpoint UI related pictures in documentation - posted by ta...@apache.org on 2020/11/06 07:01:53 UTC, 0 replies.
- [flink] branch master updated (dbf240c -> a2267fa) - posted by ar...@apache.org on 2020/11/06 07:05:30 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-18926][python][docs] Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section - posted by di...@apache.org on 2020/11/06 07:35:54 UTC, 4 replies.
- [flink] branch master updated (a2267fa -> a6c064e) - posted by dw...@apache.org on 2020/11/06 08:30:45 UTC, 4 replies.
- [flink] branch master updated (a6c064e -> ad44485) - posted by kk...@apache.org on 2020/11/06 08:52:30 UTC, 4 replies.
- [flink] branch release-1.11 updated (4203965 -> 92dc1c2) - posted by kk...@apache.org on 2020/11/06 08:58:04 UTC, 3 replies.
- [flink] branch master updated (ad44485 -> 9eb295f) - posted by ch...@apache.org on 2020/11/06 09:10:15 UTC, 4 replies.
- [flink] branch master updated (9eb295f -> 4dfcc8e) - posted by ch...@apache.org on 2020/11/06 09:18:06 UTC, 3 replies.
- [flink] branch release-1.11 updated: [fix] error in EmbeddedJobClient - posted by kk...@apache.org on 2020/11/06 09:33:50 UTC, 2 replies.
- [flink] branch release-1.11 updated (92dc1c2 -> b0b2625) - posted by kk...@apache.org on 2020/11/06 09:38:49 UTC, 0 replies.
- [flink] branch master updated (4dfcc8e -> 1fa0447) - posted by al...@apache.org on 2020/11/06 10:03:16 UTC, 1 replies.
- [flink] branch master updated (1fa0447 -> 2ad11e5) - posted by ch...@apache.org on 2020/11/06 10:13:38 UTC, 1 replies.
- [flink] branch master updated (2ad11e5 -> 798dfbf) - posted by ja...@apache.org on 2020/11/06 11:31:05 UTC, 2 replies.
- [flink] branch master updated (798dfbf -> 6cad089) - posted by go...@apache.org on 2020/11/06 11:36:29 UTC, 2 replies.
- [flink] branch master updated (6cad089 -> 4370139) - posted by ch...@apache.org on 2020/11/06 12:01:21 UTC, 1 replies.
- [flink] branch master updated (4370139 -> 15fa170) - posted by dw...@apache.org on 2020/11/06 12:34:42 UTC, 3 replies.
- [flink] branch master updated (15fa170 -> c2093a5) - posted by ch...@apache.org on 2020/11/06 12:36:54 UTC, 4 replies.
- [flink] branch master updated (c2093a5 -> b07f68a) - posted by ch...@apache.org on 2020/11/06 12:44:29 UTC, 1 replies.
- [flink] branch master updated (b07f68a -> dfd2a55) - posted by al...@apache.org on 2020/11/06 13:25:14 UTC, 1 replies.
- [flink] branch master updated (dfd2a55 -> 19eb503) - posted by al...@apache.org on 2020/11/06 13:52:49 UTC, 4 replies.
- [flink] branch master updated (19eb503 -> f6be70b) - posted by lz...@apache.org on 2020/11/06 14:33:20 UTC, 4 replies.
- [flink] branch master updated (f6be70b -> 79ded59) - posted by se...@apache.org on 2020/11/06 16:41:23 UTC, 0 replies.
- [flink] 01/02: [FLINK-19384][core] Add common permissive exception signatures to all methods of Source. - posted by se...@apache.org on 2020/11/06 16:41:24 UTC, 0 replies.
- [flink] 02/02: [hotfix] Improve JavaDocs of SourceReader. - posted by se...@apache.org on 2020/11/06 16:41:25 UTC, 0 replies.
- [flink] branch master updated: Revert "[FLINK-19850] Add e2e tests for the new FileSink in streaming mode" - posted by rm...@apache.org on 2020/11/06 17:39:54 UTC, 1 replies.
- [flink] branch master updated: [FLINK-19992][hive] Integrate new orc to Hive source - posted by lz...@apache.org on 2020/11/07 02:27:33 UTC, 0 replies.
- [flink] branch master updated (3e89818 -> c33e1ad) - posted by lz...@apache.org on 2020/11/07 02:28:31 UTC, 2 replies.
- [flink] branch master updated (c33e1ad -> 3367c23) - posted by tz...@apache.org on 2020/11/07 02:30:35 UTC, 2 replies.
- [flink] branch release-1.11 updated (b0b2625 -> 12a2ade) - posted by tz...@apache.org on 2020/11/07 02:33:18 UTC, 4 replies.
- [flink] 01/03: [FLINK-19741] Let timer service skip reading raw keyed state if it isn't the writer - posted by tz...@apache.org on 2020/11/07 02:33:19 UTC, 3 replies.
- [flink] 02/03: [FLINK-19748] Skip key groups that don't have a defined stream offset - posted by tz...@apache.org on 2020/11/07 02:33:20 UTC, 3 replies.
- [flink] 03/03: [FLINK-19748] [test] Adjust raw keyed state test to only write some key groups - posted by tz...@apache.org on 2020/11/07 02:33:21 UTC, 3 replies.
- [flink] branch master updated (3367c23 -> 2c1e24b) - posted by go...@apache.org on 2020/11/07 03:01:39 UTC, 2 replies.
- [flink] branch master updated (2c1e24b -> f1f25e0) - posted by lz...@apache.org on 2020/11/07 03:51:38 UTC, 4 replies.
- [flink] branch master updated (f1f25e0 -> d230058) - posted by ja...@apache.org on 2020/11/07 04:03:44 UTC, 4 replies.
- [flink] branch master updated (d230058 -> 09386f2) - posted by lz...@apache.org on 2020/11/07 06:25:08 UTC, 4 replies.
- [flink] branch master updated (09386f2 -> 64b9665) - posted by tw...@apache.org on 2020/11/07 09:42:05 UTC, 4 replies.
- [flink] branch master updated (64b9665 -> f850f55) - posted by lz...@apache.org on 2020/11/07 11:22:20 UTC, 3 replies.
- [flink] branch master updated (f850f55 -> 0ccea43) - posted by kk...@apache.org on 2020/11/07 12:29:32 UTC, 1 replies.
- [flink] branch master updated (0ccea43 -> efa4d18) - posted by di...@apache.org on 2020/11/07 13:45:18 UTC, 3 replies.
- [flink] branch master updated (efa4d18 -> c619a18) - posted by kk...@apache.org on 2020/11/07 14:53:48 UTC, 4 replies.
- [flink] branch master updated (c619a18 -> 9d435f4) - posted by tr...@apache.org on 2020/11/07 15:23:40 UTC, 4 replies.
- [flink] branch master updated: [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions - posted by go...@apache.org on 2020/11/07 16:05:54 UTC, 0 replies.
- [flink] branch master updated (9d435f4 -> 23349b6) - posted by go...@apache.org on 2020/11/07 16:06:54 UTC, 1 replies.
- [flink] branch master updated (23349b6 -> 5f7e0dc) - posted by tr...@apache.org on 2020/11/07 17:04:12 UTC, 4 replies.
- [flink] branch master updated (5f7e0dc -> dc56273) - posted by tr...@apache.org on 2020/11/07 17:11:01 UTC, 4 replies.
- [flink] branch master updated (dc56273 -> c037dcb) - posted by dw...@apache.org on 2020/11/07 18:06:36 UTC, 1 replies.
- [flink] branch master updated (c037dcb -> 05b56bd) - posted by tw...@apache.org on 2020/11/07 18:21:55 UTC, 2 replies.
- [flink] branch master updated: [minor] Rework Javadoc in Sink interface - posted by al...@apache.org on 2020/11/07 21:11:13 UTC, 1 replies.
- [flink] branch master updated (97eb584 -> 8efa521) - posted by tw...@apache.org on 2020/11/07 22:13:31 UTC, 4 replies.
- [flink] branch master updated (8efa521 -> 24d612b) - posted by ja...@apache.org on 2020/11/08 03:40:08 UTC, 3 replies.
- [flink] branch master updated (24d612b -> eeb69fc) - posted by ja...@apache.org on 2020/11/08 04:14:41 UTC, 2 replies.
- [flink] branch master updated (eeb69fc -> 8317426) - posted by lz...@apache.org on 2020/11/08 07:09:35 UTC, 3 replies.
- [flink] branch master updated (8317426 -> bff7da1) - posted by ja...@apache.org on 2020/11/08 10:00:10 UTC, 4 replies.
- [flink] branch master updated (bff7da1 -> 89bed42) - posted by al...@apache.org on 2020/11/08 10:52:53 UTC, 3 replies.
- [flink] branch master updated: [hotfix][python][docs] Fix the mistakes of connector options in the examples - posted by di...@apache.org on 2020/11/08 12:25:07 UTC, 0 replies.
- [flink] branch master updated (89bed42 -> 39ffff0) - posted by di...@apache.org on 2020/11/08 12:26:04 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix][python][docs] Fix the mistakes of connector options in the examples - posted by di...@apache.org on 2020/11/08 12:27:21 UTC, 1 replies.
- [flink] branch release-1.11 updated (12a2ade -> 1b75ae8) - posted by di...@apache.org on 2020/11/08 12:32:14 UTC, 2 replies.
- [flink] branch master updated: [FLINK-19888][hive] Migrate Hive source to FLIP-27 source interface for streaming - posted by lz...@apache.org on 2020/11/08 13:15:18 UTC, 0 replies.
- [flink] branch master updated (39ffff0 -> fc581da) - posted by lz...@apache.org on 2020/11/08 13:16:32 UTC, 3 replies.
- [flink] branch master updated: [FLINK-19934][Connector] Add SplitEnumeratorContext.runInCoordinatorThread(Runnable) - posted by se...@apache.org on 2020/11/08 14:59:31 UTC, 0 replies.
- [flink] branch master updated (f25ca1b -> 80c040f) - posted by jq...@apache.org on 2020/11/08 15:11:41 UTC, 4 replies.
- [flink] 01/07: [hotfix][connector/common] Move SourceReaderTestBase to a separate module of flink-connector-test-utils in flink-test-utils-parent. - posted by jq...@apache.org on 2020/11/08 15:11:42 UTC, 3 replies.
- [flink] 02/07: [hotfix][util] Add a util class to help closing components with timeout. - posted by jq...@apache.org on 2020/11/08 15:11:43 UTC, 3 replies.
- [flink] 03/07: [hotfix][runtime/operator] Make RecreateOnResetOperatorCoordinator fully asynchronous. - posted by jq...@apache.org on 2020/11/08 15:11:44 UTC, 3 replies.
- [flink] 04/07: [FLINK-18323][connector/kafka] Make a few methods in KafkaTestBase public so that it can run as a standalone Kafka service. - posted by jq...@apache.org on 2020/11/08 15:11:45 UTC, 3 replies.
- [flink] 05/07: [hotfix][connector/common] Add a new util class to help with serde in the Source. - posted by jq...@apache.org on 2020/11/08 15:11:46 UTC, 3 replies.
- [flink] 06/07: [hotfix][connector/common] Allow adding external tasks to the SplitFetcher. It helps avoid synchronizations between fetcher thread and main thread. - posted by jq...@apache.org on 2020/11/08 15:11:47 UTC, 3 replies.
- [flink] 07/07: [FLINK-18323][connector/kafka] Add Kafka Source based on FLIP-27. - posted by jq...@apache.org on 2020/11/08 15:11:48 UTC, 3 replies.
- [flink] branch master updated (80c040f -> 0b3f15e) - posted by tr...@apache.org on 2020/11/08 17:21:50 UTC, 4 replies.
- [flink] 01/04: [hotfix] Add MockSplitEnumeratorContext.runInCoordinatorThread implementation - posted by tr...@apache.org on 2020/11/08 17:21:51 UTC, 0 replies.
- [flink] 02/04: [FLINK-19693][runtime] Downstream Failover for Approximate Local Recovery - posted by tr...@apache.org on 2020/11/08 17:21:52 UTC, 0 replies.
- [flink] 03/04: [FLINK-19693] Introduce a flag to enable approximate failover - posted by tr...@apache.org on 2020/11/08 17:21:53 UTC, 0 replies.
- [flink] 04/04: [FLINK-19693] ITCases for Approximate Local Recovery - posted by tr...@apache.org on 2020/11/08 17:21:54 UTC, 0 replies.
- [flink] branch master updated (0b3f15e -> 2cce1ac) - posted by jq...@apache.org on 2020/11/09 02:54:29 UTC, 3 replies.
- [flink] branch master updated (2cce1ac -> 93c6256) - posted by li...@apache.org on 2020/11/09 02:55:41 UTC, 4 replies.
- [flink] branch master updated: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API. - posted by di...@apache.org on 2020/11/09 05:06:23 UTC, 1 replies.
- [flink] annotated tag release-1.12.0-rc1 updated (df623e0 -> f6cb994) - posted by di...@apache.org on 2020/11/09 06:57:15 UTC, 4 replies.
- [flink] branch master updated (f24cb3f -> eaaa174) - posted by tr...@apache.org on 2020/11/09 09:07:37 UTC, 4 replies.
- [flink] branch release-1.11 updated (1b75ae8 -> 32e2305) - posted by tr...@apache.org on 2020/11/09 09:11:07 UTC, 4 replies.
- [flink] 01/03: [FLINK-19237] Fix rejected slot offer bug in JobMaster - posted by tr...@apache.org on 2020/11/09 09:11:08 UTC, 4 replies.
- [flink] 02/03: [FLINK-20033] Make JobManagerJobStatusListener call back run directly - posted by tr...@apache.org on 2020/11/09 09:11:09 UTC, 4 replies.
- [flink] 03/03: [FLINK-20033] Ensure that stopping a JobMaster will suspend the running job - posted by tr...@apache.org on 2020/11/09 09:11:10 UTC, 4 replies.
- [flink] branch release-1.10 updated (85fc5c1 -> 10bfd29) - posted by tr...@apache.org on 2020/11/09 09:14:18 UTC, 4 replies.
- [flink] 01/01: [FLINK-20033] Ensure that stopping a JobMaster will suspend the running job - posted by tr...@apache.org on 2020/11/09 09:14:19 UTC, 2 replies.
- [flink] branch master updated (eaaa174 -> 4f9881a) - posted by tr...@apache.org on 2020/11/09 09:31:18 UTC, 4 replies.
- [flink] branch master updated (4f9881a -> 7b4c97b) - posted by di...@apache.org on 2020/11/09 09:48:19 UTC, 4 replies.
- [flink] branch master updated (7b4c97b -> 8bc6a7b) - posted by tr...@apache.org on 2020/11/09 09:59:51 UTC, 4 replies.
- [flink] branch master updated (8bc6a7b -> 20aa5f9) - posted by al...@apache.org on 2020/11/09 13:09:28 UTC, 1 replies.
- [flink] branch master updated (20aa5f9 -> cba124a) - posted by sj...@apache.org on 2020/11/09 14:15:24 UTC, 3 replies.
- [flink-statefun] branch master updated (315718c -> 60ee9bf) - posted by sj...@apache.org on 2020/11/09 14:17:37 UTC, 2 replies.
- [flink-statefun] 01/01: [FLINK-20009][docs] Add documentation link check to travis - posted by sj...@apache.org on 2020/11/09 14:17:38 UTC, 2 replies.
- [flink-statefun] branch release-2.2 updated: [hotfix] Fix broken doc links - posted by sj...@apache.org on 2020/11/09 14:17:41 UTC, 2 replies.
- svn commit: r44433 - in /dev/flink/flink-1.12.0-rc1: ./ python/ - posted by di...@apache.org on 2020/11/09 14:23:35 UTC, 0 replies.
- [flink-statefun] branch master updated: [hotfix] fix travis configuration - posted by sj...@apache.org on 2020/11/09 14:37:47 UTC, 0 replies.
- [flink-statefun] branch master updated: [hotfix] Disable travis documentation check - posted by sj...@apache.org on 2020/11/09 21:59:45 UTC, 0 replies.
- [flink] branch master updated (cba124a -> a475f57) - posted by se...@apache.org on 2020/11/09 23:34:09 UTC, 0 replies.
- [flink] 01/05: [FLINK-19265][core] Add to source coordinator built-in methods to signal "no more splits". - posted by se...@apache.org on 2020/11/09 23:34:10 UTC, 0 replies.
- [flink] 02/05: [FLINK-20049][core] Add built-in method to request split in source API. - posted by se...@apache.org on 2020/11/09 23:34:11 UTC, 0 replies.
- [flink] 03/05: [hotfix][connector files] Remove empty default method override in FileSourceReader - posted by se...@apache.org on 2020/11/09 23:34:12 UTC, 0 replies.
- [flink] 04/05: [hotfix] Close File FormatReaders also when the source reader is closed before end of split. - posted by se...@apache.org on 2020/11/09 23:34:13 UTC, 0 replies.
- [flink] 05/05: [FLINK-20051][connector kafka] Ensure KafkaPartitionSplitRecords returned on consumer wakeup is properly initializes - posted by se...@apache.org on 2020/11/09 23:34:14 UTC, 0 replies.
- [flink] branch master updated (a475f57 -> b93f13d) - posted by sj...@apache.org on 2020/11/10 01:15:19 UTC, 4 replies.
- [flink] branch master updated (b93f13d -> a9a0032) - posted by go...@apache.org on 2020/11/10 02:44:27 UTC, 4 replies.
- [flink] branch master updated (a9a0032 -> d6f53f1) - posted by go...@apache.org on 2020/11/10 03:02:28 UTC, 4 replies.
- [flink] branch master updated (d6f53f1 -> ea88795) - posted by ja...@apache.org on 2020/11/10 03:23:22 UTC, 4 replies.
- [flink] branch master updated (ea88795 -> ae09f9b) - posted by jq...@apache.org on 2020/11/10 05:05:24 UTC, 1 replies.
- [flink] branch master updated (ae09f9b -> 044d9ee) - posted by kl...@apache.org on 2020/11/10 06:52:55 UTC, 1 replies.
- [flink] branch master updated: [FLINK-18070][table-planner-blink] Don't materialize time attribute for middle nodes in StreamCommonSubGraphBasedOptimizer - posted by go...@apache.org on 2020/11/10 07:25:14 UTC, 0 replies.
- [flink] branch master updated (044d9ee -> e9c83a1) - posted by go...@apache.org on 2020/11/10 07:26:18 UTC, 1 replies.
- [flink] branch master updated (e9c83a1 -> 8a63e64) - posted by tr...@apache.org on 2020/11/10 10:34:03 UTC, 4 replies.
- svn commit: r44456 - /dev/flink/flink-statefun-2.2.1-rc1/ /release/flink/flink-statefun-2.2.1/ - posted by tz...@apache.org on 2020/11/10 10:55:39 UTC, 0 replies.
- svn commit: r44457 - /release/flink/flink-statefun-2.2.0/ - posted by tz...@apache.org on 2020/11/10 10:56:59 UTC, 0 replies.
- [flink-statefun] annotated tag release-2.2.1 updated (3d53612 -> 7b2de48) - posted by tz...@apache.org on 2020/11/10 11:08:37 UTC, 2 replies.
- [flink] branch master updated (8a63e64 -> 700a92d) - posted by nk...@apache.org on 2020/11/10 11:37:01 UTC, 4 replies.
- [flink] branch master updated (700a92d -> 3c4cb04) - posted by kl...@apache.org on 2020/11/10 11:42:43 UTC, 4 replies.
- [flink] branch master updated (3c4cb04 -> 3fed93d) - posted by di...@apache.org on 2020/11/10 12:15:43 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20064][docs] Fix the broken links - posted by di...@apache.org on 2020/11/10 12:41:15 UTC, 0 replies.
- [flink] branch release-1.11 updated (32e2305 -> e55dd45) - posted by di...@apache.org on 2020/11/10 12:47:20 UTC, 3 replies.
- [flink] branch master updated (3fed93d -> 9b12c15) - posted by rm...@apache.org on 2020/11/10 13:45:35 UTC, 4 replies.
- [flink] branch master updated (9b12c15 -> d00941c) - posted by se...@apache.org on 2020/11/10 14:04:52 UTC, 0 replies.
- [flink] 01/02: [refactor] Move Source Reader Test Utils classes from 'flink-core' test jar to 'flink-connector-test-utils' - posted by se...@apache.org on 2020/11/10 14:04:53 UTC, 0 replies.
- [flink] 02/02: [FLINK-20063][connector files] FileSourceReader request only a split if it doesn't have one already - posted by se...@apache.org on 2020/11/10 14:04:54 UTC, 0 replies.
- [flink] branch master updated (d00941c -> 6a2e5fc) - posted by rm...@apache.org on 2020/11/10 15:11:04 UTC, 4 replies.
- [flink] branch master updated (6a2e5fc -> 697ac49) - posted by rm...@apache.org on 2020/11/10 15:25:49 UTC, 4 replies.
- [flink] branch master updated (697ac49 -> 3add52d) - posted by rm...@apache.org on 2020/11/10 16:21:46 UTC, 4 replies.
- [flink] branch release-1.11 updated (e55dd45 -> 75ef124) - posted by rm...@apache.org on 2020/11/10 16:22:42 UTC, 4 replies.
- [flink] branch master updated: [FLINK-19448][connector/common] Fix handling of finished splits and closing split fetchers in SourceReaderBase - posted by se...@apache.org on 2020/11/10 19:01:05 UTC, 0 replies.
- [flink] branch master updated (aa84aa7 -> a9d859b) - posted by zh...@apache.org on 2020/11/10 19:09:46 UTC, 4 replies.
- [flink] branch master updated: [FLINK-20013][network] Release network buffer in BoundedBlockingSubpartition if task is failed or canceled (#14008) - posted by ar...@apache.org on 2020/11/10 19:17:21 UTC, 0 replies.
- [flink] branch master updated (a9d859b -> c46ae27) - posted by ar...@apache.org on 2020/11/10 19:18:32 UTC, 3 replies.
- [flink] branch master updated (c46ae27 -> 79c54ad) - posted by di...@apache.org on 2020/11/11 01:20:37 UTC, 4 replies.
- [flink] branch release-1.11 updated (75ef124 -> 5e93fed) - posted by di...@apache.org on 2020/11/11 01:27:16 UTC, 4 replies.
- [flink] branch master updated (79c54ad -> cb01e19) - posted by di...@apache.org on 2020/11/11 01:32:05 UTC, 4 replies.
- [flink] branch master updated (cb01e19 -> 0ab2389) - posted by di...@apache.org on 2020/11/11 02:06:36 UTC, 4 replies.
- [flink] branch master updated (0ab2389 -> ba7c232) - posted by ja...@apache.org on 2020/11/11 03:00:35 UTC, 4 replies.
- [flink] branch master updated (ba7c232 -> 592c2e7) - posted by ja...@apache.org on 2020/11/11 03:04:37 UTC, 4 replies.
- [flink] branch master updated (592c2e7 -> 83d8137) - posted by lz...@apache.org on 2020/11/11 04:00:43 UTC, 4 replies.
- [flink] branch master updated (83d8137 -> cb2d137) - posted by jq...@apache.org on 2020/11/11 06:05:07 UTC, 4 replies.
- [flink] branch release-1.11 updated (5e93fed -> 477482a) - posted by jq...@apache.org on 2020/11/11 06:08:22 UTC, 4 replies.
- [flink] branch master updated (cb2d137 -> cacb4c1) - posted by jq...@apache.org on 2020/11/11 06:25:12 UTC, 4 replies.
- [flink] branch master updated (cacb4c1 -> 18ffebb) - posted by ar...@apache.org on 2020/11/11 06:44:08 UTC, 4 replies.
- [flink-statefun] branch github-actions-test created (now c0fd8ad) - posted by tz...@apache.org on 2020/11/11 07:28:37 UTC, 2 replies.
- [flink-statefun] 01/02: Trying out GHA - posted by tz...@apache.org on 2020/11/11 07:28:38 UTC, 2 replies.
- [flink-statefun] 02/02: Remove Travis - posted by tz...@apache.org on 2020/11/11 07:28:39 UTC, 2 replies.
- [flink] branch release-1.11 updated (477482a -> 18e4c1b) - posted by jq...@apache.org on 2020/11/11 07:31:42 UTC, 4 replies.
- [flink] branch master updated (18ffebb -> 0c36c84) - posted by rm...@apache.org on 2020/11/11 07:48:08 UTC, 3 replies.
- [flink] branch master updated (0c36c84 -> 5af1d00) - posted by dw...@apache.org on 2020/11/11 08:30:24 UTC, 4 replies.
- [flink-web] branch asf-site updated (0f16e95 -> 14a105e) - posted by tz...@apache.org on 2020/11/11 08:48:29 UTC, 0 replies.
- [flink-web] 01/03: Add release announcement for StateFun 2.2.1 - posted by tz...@apache.org on 2020/11/11 08:48:30 UTC, 0 replies.
- [flink-web] 02/03: Update Downloads page config for StateFun 2.2.1 - posted by tz...@apache.org on 2020/11/11 08:48:31 UTC, 0 replies.
- [flink-web] 03/03: Rebuild website - posted by tz...@apache.org on 2020/11/11 08:48:32 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20018] Allow escaping in 'pipeline.cached-files' and 'pipeline.default-kryo-serializers' - posted by dw...@apache.org on 2020/11/11 08:52:45 UTC, 3 replies.
- [flink] branch release-1.11 updated (18e4c1b -> 0ec1c4d) - posted by dw...@apache.org on 2020/11/11 08:59:34 UTC, 0 replies.
- [flink-statefun-docker] branch master updated (01facf0 -> 12b2592) - posted by tz...@apache.org on 2020/11/11 09:00:22 UTC, 0 replies.
- [flink] branch release-1.10 updated: [FLINK-20018] Allow escaping in 'pipeline.cached-files' and 'pipeline.default-kryo-serializers' - posted by dw...@apache.org on 2020/11/11 09:10:34 UTC, 2 replies.
- [flink] branch master updated (5af1d00 -> 91404f4) - posted by tr...@apache.org on 2020/11/11 09:47:15 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20076][runtime][test] Fixed DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles. - posted by tr...@apache.org on 2020/11/11 09:49:23 UTC, 0 replies.
- [flink] branch release-1.10 updated: [FLINK-20076][runtime][test] Fixed DispatcherTest.testOnRemovedJobGraphDoesNotCleanUpHAFiles. - posted by tr...@apache.org on 2020/11/11 09:50:19 UTC, 0 replies.
- [flink] branch release-1.11 updated (0ec1c4d -> 5f1e665) - posted by tr...@apache.org on 2020/11/11 09:58:43 UTC, 3 replies.
- [flink] branch release-1.10 updated (e3beef3 -> fd624ce) - posted by tr...@apache.org on 2020/11/11 09:59:59 UTC, 3 replies.
- [flink] branch master updated (91404f4 -> 1d3f8c3) - posted by kl...@apache.org on 2020/11/11 11:34:48 UTC, 1 replies.
- [flink] branch master updated (1d3f8c3 -> 0609918) - posted by sj...@apache.org on 2020/11/11 15:24:11 UTC, 4 replies.
- [flink] branch master updated: [FLINK-20079][task] Initialize operator chain before upstream partition request - posted by ar...@apache.org on 2020/11/11 16:49:10 UTC, 0 replies.
- [flink] branch master updated (0609918 -> bf16a7d) - posted by ar...@apache.org on 2020/11/11 16:50:41 UTC, 3 replies.
- [flink] branch release-1.11 updated: [FLINK-20079][task] Initialize operator chain before upstream partition request - posted by ar...@apache.org on 2020/11/11 16:53:04 UTC, 0 replies.
- [flink] branch release-1.11 updated (5f1e665 -> 57845ce) - posted by ar...@apache.org on 2020/11/11 17:04:24 UTC, 3 replies.
- [flink] branch master updated (bf16a7d -> e86b409) - posted by ja...@apache.org on 2020/11/12 07:52:30 UTC, 4 replies.
- [flink] branch master updated (e86b409 -> 0e6e9de) - posted by kn...@apache.org on 2020/11/12 09:13:09 UTC, 2 replies.
- [flink] branch client-exception created (now 498033a) - posted by kk...@apache.org on 2020/11/12 09:27:16 UTC, 4 replies.
- [flink] 01/01: comments - posted by kk...@apache.org on 2020/11/12 09:27:17 UTC, 4 replies.
- [flink] branch master updated (0e6e9de -> fb0ee3a) - posted by ja...@apache.org on 2020/11/12 10:27:02 UTC, 4 replies.
- [flink] branch master updated (fb0ee3a -> 8d7e9e6) - posted by jq...@apache.org on 2020/11/12 10:45:10 UTC, 2 replies.
- [flink] branch master updated (8d7e9e6 -> 9c9d62b) - posted by jq...@apache.org on 2020/11/12 10:49:00 UTC, 1 replies.
- [flink] branch master updated (9c9d62b -> b48104f) - posted by tw...@apache.org on 2020/11/12 11:11:32 UTC, 3 replies.
- [flink] branch master updated (b48104f -> b9b9ff3) - posted by di...@apache.org on 2020/11/12 12:00:33 UTC, 1 replies.
- [flink] branch master updated (b9b9ff3 -> 530c1f0) - posted by dw...@apache.org on 2020/11/12 12:58:23 UTC, 4 replies.
- [flink] branch release-1.11 updated (57845ce -> 4c91f8a) - posted by dw...@apache.org on 2020/11/12 13:03:11 UTC, 4 replies.
- [flink] branch master updated: [FLINK-20075]When the JobMaster is initialized, the JobID of the JobGraph is retrieved again in the createlotpool method - posted by tr...@apache.org on 2020/11/12 13:25:49 UTC, 1 replies.
- [flink] branch master updated (c118520 -> 5256c21) - posted by ar...@apache.org on 2020/11/12 13:50:34 UTC, 4 replies.
- [flink] branch master updated (5256c21 -> 8926201) - posted by tr...@apache.org on 2020/11/12 13:56:33 UTC, 4 replies.
- [flink] branch release-1.11 updated (4c91f8a -> 68d16f0) - posted by tr...@apache.org on 2020/11/12 14:01:16 UTC, 4 replies.
- [flink] branch release-1.10 updated (fd624ce -> fef13fd) - posted by tr...@apache.org on 2020/11/12 14:02:26 UTC, 4 replies.
- [flink] branch master updated (8926201 -> 10ff4c6) - posted by tw...@apache.org on 2020/11/12 15:21:12 UTC, 4 replies.
- [flink] branch master updated (10ff4c6 -> ae1fda5) - posted by ja...@apache.org on 2020/11/12 15:27:36 UTC, 4 replies.
- [flink] branch master updated (ae1fda5 -> 1c89ab3) - posted by ja...@apache.org on 2020/11/12 15:28:45 UTC, 4 replies.
- [flink-statefun] branch master updated: [hotfix][docs] Fix some typos in Java code in documentation - posted by sj...@apache.org on 2020/11/12 17:24:33 UTC, 0 replies.
- [flink] branch master updated (1c89ab3 -> 92df49e) - posted by sj...@apache.org on 2020/11/12 18:14:31 UTC, 4 replies.
- [flink] branch release-1.11 updated: [BP-1.11][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed or canceled - posted by ar...@apache.org on 2020/11/12 20:12:07 UTC, 3 replies.
- [flink] branch release-1.10 updated: [BP-1.10][FLINK-20013][network] BoundedBlockingSubpartition may leak network buffer if task is failed or canceled - posted by ar...@apache.org on 2020/11/12 20:14:24 UTC, 3 replies.
- [flink] branch master updated (92df49e -> d20a9d5) - posted by sj...@apache.org on 2020/11/13 02:47:52 UTC, 4 replies.
- [flink-web] branch asf-site updated: [FLINK-20093] Link to SQL components download page (#391) - posted by dw...@apache.org on 2020/11/13 09:11:53 UTC, 0 replies.
- [flink] branch master updated (d20a9d5 -> 3bd1a81) - posted by al...@apache.org on 2020/11/13 09:33:46 UTC, 4 replies.
- [flink] branch release-1.11 updated (6626d39 -> 10ad46b) - posted by ja...@apache.org on 2020/11/13 14:16:36 UTC, 3 replies.
- [flink] branch master updated: [FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down - posted by ti...@apache.org on 2020/11/14 00:08:37 UTC, 1 replies.
- [flink] branch master updated (3dc43e6 -> d332ff4) - posted by tz...@apache.org on 2020/11/14 01:19:31 UTC, 4 replies.
- [flink-statefun] branch master updated (1366c29 -> 9a93f74) - posted by tz...@apache.org on 2020/11/14 01:37:11 UTC, 0 replies.
- [flink-statefun] 01/02: [FLINK-20085] [core] Remove RemoteFunctionStateMigrator migration code paths - posted by tz...@apache.org on 2020/11/14 01:37:12 UTC, 0 replies.
- [flink-statefun] 02/02: [FLINK-20085] [core] Remove statefun.remote.migrate-legacy-state config - posted by tz...@apache.org on 2020/11/14 01:37:13 UTC, 0 replies.
- [flink] branch release-1.11 updated (10ad46b -> c24185d) - posted by se...@apache.org on 2020/11/15 22:01:28 UTC, 0 replies.
- [flink] 01/22: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for FutureCompletingBlockingQueue - posted by se...@apache.org on 2020/11/15 22:01:29 UTC, 0 replies.
- [flink] 02/22: [refactor][connectors] Backport of the connector-base exception handling from the Kafka Connector Pull Request - posted by se...@apache.org on 2020/11/15 22:01:30 UTC, 0 replies.
- [flink] 03/22: [hotfix][core] Add to Source Enumerator convenience methods to assign single split - posted by se...@apache.org on 2020/11/15 22:01:31 UTC, 0 replies.
- [flink] 04/22: [FLINK-19205][core] Add access to configuration and hostname in the SourceReaderContext - posted by se...@apache.org on 2020/11/15 22:01:32 UTC, 0 replies.
- [flink] 05/22: [hotfix][connectors] Add RequestSplitEvent to 'flink-connector-base' - posted by se...@apache.org on 2020/11/15 22:01:33 UTC, 0 replies.
- [flink] 06/22: [hotfix][testing] Add a set of parameterizable testing mocks for the Split Reader API - posted by se...@apache.org on 2020/11/15 22:01:34 UTC, 0 replies.
- [flink] 07/22: [FLINK-19162][connectors] Add 'recycle()' to the RecordsWithSplitIds to support reuse of heavy objects. - posted by se...@apache.org on 2020/11/15 22:01:35 UTC, 0 replies.
- [flink] 08/22: [FLINK-18680][connectors] Make connector base RecordsWithSplitIds more lightweight. - posted by se...@apache.org on 2020/11/15 22:01:36 UTC, 0 replies.
- [flink] 09/22: [FLINK-17393][connectors] Wakeup the SplitFetchers more elegantly. - posted by se...@apache.org on 2020/11/15 22:01:37 UTC, 0 replies.
- [flink] 10/22: [FLINK-19225][connectors] Various small improvements to SourceReaderBase - posted by se...@apache.org on 2020/11/15 22:01:38 UTC, 0 replies.
- [flink] 11/22: [hotfix][tests] Move constants in SplitFetcherTest relevant to only one test into test method - posted by se...@apache.org on 2020/11/15 22:01:39 UTC, 0 replies.
- [flink] 12/22: [refactor][core] Eagerly initialize the FetchTask to support proper unit testing - posted by se...@apache.org on 2020/11/15 22:01:40 UTC, 0 replies.
- [flink] 13/22: [FLINK-18128][connectors] Ensure idle split fetchers lead to availability notifications. - posted by se...@apache.org on 2020/11/15 22:01:41 UTC, 0 replies.
- [flink] 14/22: [FLINK-19223][connectors] Simplify Availability Future Model in Base Connector - posted by se...@apache.org on 2020/11/15 22:01:42 UTC, 0 replies.
- [flink] 15/22: [FLINK-19245][connectors] Set default capacity for FutureCompletingBlockingQueue. - posted by se...@apache.org on 2020/11/15 22:01:43 UTC, 0 replies.
- [flink] 16/22: [hotfix][tests] Extend test coverage for FutureCompletingBlockingQueue. - posted by se...@apache.org on 2020/11/15 22:01:44 UTC, 0 replies.
- [flink] 17/22: [FLINK-17393][connectors] (follow-up) Wakeup the SplitFetchers more elegantly. - posted by se...@apache.org on 2020/11/15 22:01:45 UTC, 0 replies.
- [flink] 18/22: [FLINK-19225][connectors] Various small improvements to SourceReaderBase (part 2) - posted by se...@apache.org on 2020/11/15 22:01:46 UTC, 0 replies.
- [flink] 19/22: [hotfix][connectors] Improve JavaDocs for SingleThreadFetcherManager - posted by se...@apache.org on 2020/11/15 22:01:47 UTC, 0 replies.
- [flink] 20/22: [FLINK-19250][connectors] Fix error propagation in connector base (SplitFetcherManager). - posted by se...@apache.org on 2020/11/15 22:01:48 UTC, 0 replies.
- [flink] 21/22: [FLINK-19251][connectors] Avoid confusing queue handling in "SplitReader.handleSplitsChanges()" - posted by se...@apache.org on 2020/11/15 22:01:49 UTC, 0 replies.
- [flink] 22/22: [hotfix] Adjust japicmp exclusion to permit adding methods to SourceReaderContext and SplitEnumeratorContext interfaces - posted by se...@apache.org on 2020/11/15 22:01:50 UTC, 0 replies.
- [flink] branch master updated (d332ff4 -> 9482802) - posted by ar...@apache.org on 2020/11/16 07:33:26 UTC, 2 replies.
- [flink] branch master updated (9482802 -> f3f5e31) - posted by rm...@apache.org on 2020/11/16 07:34:27 UTC, 4 replies.
- [flink] branch release-1.11 updated (c24185d -> 1a8ff89) - posted by se...@apache.org on 2020/11/16 09:22:05 UTC, 0 replies.
- [flink] 01/21: [backport] Backport some core changes that were part of the FLIP-27 File Source commit - posted by se...@apache.org on 2020/11/16 09:22:06 UTC, 1 replies.
- [flink] 02/21: [backport] Relevant test mock changes from "[FLINK-18907][test] Refactor MockSourceReader" - posted by se...@apache.org on 2020/11/16 09:22:07 UTC, 1 replies.
- [flink] 03/21: [backport] Relevant test mock changes from "[FLINK-18907][task] Add test coverage for watermarks with chained sources" - posted by se...@apache.org on 2020/11/16 09:22:08 UTC, 1 replies.
- [flink] 04/21: [backport] Relevant test mock changes from "[FLINK-18907][task] Fix and add test coverage for watermarks gauges with chained sources" - posted by se...@apache.org on 2020/11/16 09:22:09 UTC, 1 replies.
- [flink] 05/21: [backport] Relevant test mock changes from "[FLINK-18907][test] Add stream status forwarding test for chained sources" - posted by se...@apache.org on 2020/11/16 09:22:10 UTC, 1 replies.
- [flink] 06/21: [refactor][tests] Move some source test utils from flink-connector-base to flink-core - posted by se...@apache.org on 2020/11/16 09:22:11 UTC, 1 replies.
- [flink] 07/21: [FLINK-19457][core] Add a number sequence generating source for the FLIP-27 source API. - posted by se...@apache.org on 2020/11/16 09:22:12 UTC, 1 replies.
- [flink] 08/21: [FLINK-19492][core] Consolidate Source Events between Source API and Split Reader API - posted by se...@apache.org on 2020/11/16 09:22:13 UTC, 1 replies.
- [flink] 09/21: [FLINK-19448][connector base] Explicitly check for un-expected condition that would leave an inconsistent state - posted by se...@apache.org on 2020/11/16 09:22:14 UTC, 1 replies.
- [flink] 10/21: [FLINK-19427][FLINK-19489][tests] Fix test conditions for 'SplitFetcherTest.testNotifiesWhenGoingIdleConcurrent()' - posted by se...@apache.org on 2020/11/16 09:22:15 UTC, 1 replies.
- [flink] 11/21: [FLINK-18044][Connectors/Common] Add the subtask index information to the SourceReaderContext. (#12647) - posted by se...@apache.org on 2020/11/16 09:22:16 UTC, 1 replies.
- [flink] 12/21: [hotfix][runtime] Remove commented-out annotation in SourceOperator - posted by se...@apache.org on 2020/11/16 09:22:17 UTC, 1 replies.
- [flink] 13/21: [FLINK-18820] Emit MAX_WATERMARK at the end in SourceOperator - posted by se...@apache.org on 2020/11/16 09:22:18 UTC, 1 replies.
- [flink] 14/21: [hotfix] Replace finally block with JUnit After method in SourceOperatorTest. - posted by se...@apache.org on 2020/11/16 09:22:19 UTC, 1 replies.
- [flink] 15/21: [hotfix] Only close the SourceReader and EventTimeLogic in the SourceOperator if they are not null. - posted by se...@apache.org on 2020/11/16 09:22:20 UTC, 1 replies.
- [flink] 16/21: [hotfix] Add a waitUntil() method to the CommonTestUtils. - posted by se...@apache.org on 2020/11/16 09:22:21 UTC, 1 replies.
- [flink] 17/21: Backport of "[FLINK-19698][connector/common] Let SplitEnumerator/SourceReader/SourceCoordinator implement CheckpointListener." - posted by se...@apache.org on 2020/11/16 09:22:22 UTC, 1 replies.
- [flink] 18/21: [FLINK-19698][connector/common] Add a close() method to the SplitReader. - posted by se...@apache.org on 2020/11/16 09:22:23 UTC, 1 replies.
- [flink] 19/21: [FLINK-19384][core] Add common permissive exception signatures to all methods of Source. - posted by se...@apache.org on 2020/11/16 09:22:24 UTC, 1 replies.
- [flink] 20/21: [build] Add exclusions for added default methods in SourceReader and SplitEnumerator interfaces. - posted by se...@apache.org on 2020/11/16 09:22:25 UTC, 1 replies.
- [flink] 21/21: [refactor][DataStream API] Make DataStreamUtils.collect() methods more flexible. - posted by se...@apache.org on 2020/11/16 09:22:26 UTC, 1 replies.
- [flink] branch release-1.11 updated: [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRunnable (#14072) - posted by nk...@apache.org on 2020/11/16 09:30:44 UTC, 1 replies.
- [flink] branch release-1.11 updated (bc9f0fc -> ae23ab6) - posted by se...@apache.org on 2020/11/16 09:40:50 UTC, 0 replies.
- [flink] branch release-1.10 updated (10f155e -> a14665d) - posted by nk...@apache.org on 2020/11/16 09:42:20 UTC, 4 replies.
- [flink] branch release-1.11 updated (c24185d -> bc9f0fc) - posted by nk...@apache.org on 2020/11/16 09:48:26 UTC, 2 replies.
- [flink] branch master updated (f3f5e31 -> 432de2b) - posted by tr...@apache.org on 2020/11/16 10:32:44 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20156] Correct JavaDoc example code in WatermarkStrategy.withTimestampAssigner - posted by tr...@apache.org on 2020/11/16 10:35:06 UTC, 4 replies.
- [flink] branch master updated (432de2b -> 4a6ce27) - posted by tr...@apache.org on 2020/11/16 10:46:24 UTC, 4 replies.
- [flink] branch master updated (4a6ce27 -> 4e74e08) - posted by kk...@apache.org on 2020/11/16 11:45:06 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20152] Document supported execution.target values - posted by kk...@apache.org on 2020/11/16 11:47:24 UTC, 4 replies.
- [flink] branch master updated (4e74e08 -> 30ae028) - posted by rm...@apache.org on 2020/11/16 13:24:45 UTC, 4 replies.
- [flink] branch master updated (30ae028 -> d72866b) - posted by tr...@apache.org on 2020/11/16 14:14:16 UTC, 4 replies.
- [flink] branch master updated (d72866b -> e4f525e) - posted by ar...@apache.org on 2020/11/16 14:24:25 UTC, 4 replies.
- [flink] branch master updated (e4f525e -> 13e0648) - posted by sj...@apache.org on 2020/11/16 14:45:29 UTC, 4 replies.
- [flink] branch master updated (13e0648 -> 5f2942a) - posted by tr...@apache.org on 2020/11/16 15:02:51 UTC, 4 replies.
- [flink] branch master updated (5f2942a -> 958fc80) - posted by kk...@apache.org on 2020/11/16 15:09:26 UTC, 4 replies.
- [flink] branch master updated (958fc80 -> b878f54) - posted by dw...@apache.org on 2020/11/16 16:32:24 UTC, 4 replies.
- [flink] branch master updated (b878f54 -> 89f9dcd) - posted by tw...@apache.org on 2020/11/16 16:33:38 UTC, 4 replies.
- [flink] branch master updated (89f9dcd -> caa5104) - posted by sj...@apache.org on 2020/11/16 17:04:25 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-18673][table] Improve support for ROW constructor - posted by tw...@apache.org on 2020/11/16 17:22:50 UTC, 4 replies.
- [flink] branch master updated (caa5104 -> 05b6124) - posted by tw...@apache.org on 2020/11/16 19:20:39 UTC, 4 replies.
- [flink] branch master updated (05b6124 -> 4cc0e72) - posted by rm...@apache.org on 2020/11/16 20:10:56 UTC, 4 replies.
- [flink] branch master updated (4cc0e72 -> 6e30032) - posted by ja...@apache.org on 2020/11/17 02:07:15 UTC, 4 replies.
- [flink] branch master updated (6e30032 -> 92c4faf) - posted by ja...@apache.org on 2020/11/17 02:09:23 UTC, 4 replies.
- [flink] branch master updated (92c4faf -> 6caee2b) - posted by di...@apache.org on 2020/11/17 02:36:43 UTC, 4 replies.
- [flink] branch master updated: [FLINK-19859][docs] Add document for the upsert-kafka connector - posted by ja...@apache.org on 2020/11/17 03:54:24 UTC, 0 replies.
- [flink] branch master updated (6caee2b -> 7ce0f39) - posted by ja...@apache.org on 2020/11/17 03:55:40 UTC, 3 replies.
- [flink] branch master updated: [FLINK-20163][docs-zh] Translate page "raw format" into Chinese - posted by ja...@apache.org on 2020/11/17 04:18:33 UTC, 0 replies.
- [flink] branch master updated (7ce0f39 -> 80bea7a) - posted by ja...@apache.org on 2020/11/17 04:19:50 UTC, 3 replies.
- [flink-statefun] branch master updated (9a93f74 -> 0720790) - posted by tz...@apache.org on 2020/11/17 04:48:22 UTC, 0 replies.
- [flink-statefun] 01/01: [FLINK-20161] [README] Update build status badge to point to Github Actions - posted by tz...@apache.org on 2020/11/17 04:48:23 UTC, 0 replies.
- [flink-statefun] branch release-2.2 updated (c6c0f66 -> 7ee09a5) - posted by tz...@apache.org on 2020/11/17 04:49:32 UTC, 0 replies.
- [flink-statefun] 01/03: [FLINK-20161] [ci] Add Github Actions workflow for JDK 8 build - posted by tz...@apache.org on 2020/11/17 04:49:33 UTC, 0 replies.
- [flink-statefun] 02/03: [FLINK-20161] [ci] Remove Travis CI workflow - posted by tz...@apache.org on 2020/11/17 04:49:34 UTC, 0 replies.
- [flink-statefun] 03/03: [FLINK-20161] [README] Update build status badge to point to Github Actions - posted by tz...@apache.org on 2020/11/17 04:49:35 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19300] Fix input stream read to prevent heap based timer loss - posted by tz...@apache.org on 2020/11/17 04:57:56 UTC, 0 replies.
- [flink] branch master updated (80bea7a -> 4bd0ad1) - posted by tz...@apache.org on 2020/11/17 04:59:12 UTC, 3 replies.
- [flink] branch release-1.11 updated: [FLINK-19300] Fix input stream read to prevent heap based timer loss - posted by tz...@apache.org on 2020/11/17 05:00:59 UTC, 4 replies.
- [flink] branch master updated (4bd0ad1 -> 1538e56) - posted by zh...@apache.org on 2020/11/17 06:24:56 UTC, 4 replies.
- [flink] branch master updated (1538e56 -> 0fa50a3) - posted by rm...@apache.org on 2020/11/17 07:17:35 UTC, 4 replies.
- [flink] branch master updated (0fa50a3 -> 1909e933) - posted by go...@apache.org on 2020/11/17 07:41:09 UTC, 4 replies.
- [flink] branch master updated (1909e933 -> e33fa27) - posted by go...@apache.org on 2020/11/17 08:17:10 UTC, 4 replies.
- [flink] branch master updated (e33fa27 -> 23863e2) - posted by dw...@apache.org on 2020/11/17 08:47:44 UTC, 4 replies.
- [flink] branch master updated (23863e2 -> 1ba35fb) - posted by xt...@apache.org on 2020/11/17 08:52:28 UTC, 4 replies.
- [flink] branch release-1.11 updated (f33c30f -> ef42b84) - posted by dw...@apache.org on 2020/11/17 08:57:48 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-19806][runtime] Harden DefaultScheduler for concurrent suspending and failing - posted by zh...@apache.org on 2020/11/17 10:07:05 UTC, 2 replies.
- [flink] branch release-1.11 updated (ef42b84 -> 4054aa0) - posted by zh...@apache.org on 2020/11/17 10:10:48 UTC, 1 replies.
- [flink] branch master updated (1ba35fb -> 488bc0a) - posted by tw...@apache.org on 2020/11/17 12:08:00 UTC, 4 replies.
- [flink] branch master updated (488bc0a -> 2ad9216) - posted by az...@apache.org on 2020/11/17 12:32:47 UTC, 4 replies.
- [flink] branch release-1.11 updated (4054aa0 -> 5a8cc80) - posted by az...@apache.org on 2020/11/17 12:40:48 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-19906][table-planner-blink] Fix incorrect result when compare two binary fields - posted by ja...@apache.org on 2020/11/17 14:42:13 UTC, 3 replies.
- [flink] branch release-1.11 updated (5a8cc80 -> 98ae790) - posted by ja...@apache.org on 2020/11/17 14:59:27 UTC, 0 replies.
- [flink] branch master updated (2ad9216 -> 70fffca) - posted by go...@apache.org on 2020/11/18 01:57:54 UTC, 4 replies.
- [flink] branch master updated (70fffca -> 3f67e06) - posted by di...@apache.org on 2020/11/18 02:08:37 UTC, 4 replies.
- [flink] branch release-1.11 updated (98ae790 -> 8aa2e7b) - posted by go...@apache.org on 2020/11/18 02:14:31 UTC, 4 replies.
- [flink] branch code_cleanup created (now 3f67e06) - posted by di...@apache.org on 2020/11/18 06:17:45 UTC, 4 replies.
- [flink] branch release-1.11 updated (8aa2e7b -> 275cc3b) - posted by rm...@apache.org on 2020/11/18 06:25:01 UTC, 4 replies.
- [flink] 01/03: [hotfix][runtime] Fixed wrong HTTP error code used in exception handling of MultipartUploadResource. - posted by rm...@apache.org on 2020/11/18 06:25:02 UTC, 0 replies.
- [flink] 02/03: [hotfix][runtime] It was possible to traverse the directory of the host through /jobmanager/logs/. - posted by rm...@apache.org on 2020/11/18 06:25:03 UTC, 0 replies.
- [flink] 03/03: [hotfix][runtime] A customized filename can be specified through Content-Disposition that also allows passing of path information which was not properly handled. This is fixed now. - posted by rm...@apache.org on 2020/11/18 06:25:04 UTC, 0 replies.
- [flink] branch release-1.10 updated (a14665d -> e8760736) - posted by rm...@apache.org on 2020/11/18 06:35:42 UTC, 4 replies.
- [flink] branch master updated (3f67e06 -> a5264a6) - posted by rm...@apache.org on 2020/11/18 06:45:28 UTC, 4 replies.
- [flink] branch master updated (a5264a6 -> c7b2e12) - posted by ar...@apache.org on 2020/11/18 07:33:06 UTC, 4 replies.
- [flink] branch master updated (c7b2e12 -> 823a14c) - posted by ja...@apache.org on 2020/11/18 07:47:59 UTC, 4 replies.
- [flink] branch master updated (823a14c -> b4b1abf) - posted by al...@apache.org on 2020/11/18 07:57:02 UTC, 4 replies.
- [flink] branch master updated (b4b1abf -> cb850fd) - posted by tr...@apache.org on 2020/11/18 07:59:55 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-19816] Make job state cleanup dependent on final job result - posted by tr...@apache.org on 2020/11/18 08:04:25 UTC, 4 replies.
- [flink] branch master updated (cb850fd -> 2465b71) - posted by lz...@apache.org on 2020/11/18 08:20:21 UTC, 4 replies.
- [flink] branch master updated (2465b71 -> e7caf34) - posted by di...@apache.org on 2020/11/18 08:23:17 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20183][python] Fix the default PYTHONPATH is overwritten in client side - posted by di...@apache.org on 2020/11/18 08:27:18 UTC, 0 replies.
- [flink] branch release-1.11 updated (a2925a0 -> 61f4148) - posted by di...@apache.org on 2020/11/18 08:31:20 UTC, 3 replies.
- [flink] branch master updated (e7caf34 -> 60906fa) - posted by ja...@apache.org on 2020/11/18 08:40:20 UTC, 4 replies.
- [flink] branch release-1.10 updated: [FLINK-20183][python] Fix the default PYTHONPATH is overwritten in client side - posted by di...@apache.org on 2020/11/18 08:41:22 UTC, 2 replies.
- [flink] branch release-1.10 updated (e8760736 -> 2eaba74) - posted by di...@apache.org on 2020/11/18 08:55:33 UTC, 1 replies.
- [flink] branch master updated (60906fa -> 7ae2be5) - posted by ja...@apache.org on 2020/11/18 08:57:05 UTC, 4 replies.
- [flink] branch master updated (7ae2be5 -> 3907a4a) - posted by ja...@apache.org on 2020/11/18 09:16:04 UTC, 4 replies.
- [flink] branch master updated (3907a4a -> 424d41d) - posted by kk...@apache.org on 2020/11/18 09:27:10 UTC, 4 replies.
- [flink-web] branch asf-site updated: [FLINK-20129] Link to zh SQL components download page (#393) - posted by ja...@apache.org on 2020/11/18 09:28:46 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20143][yarn] Support non-qualified path for Yarn shared lib - posted by kk...@apache.org on 2020/11/18 10:09:16 UTC, 1 replies.
- [flink] branch master updated (424d41d -> 6221e3b) - posted by ja...@apache.org on 2020/11/18 10:28:53 UTC, 4 replies.
- [flink] branch master updated (6221e3b -> dc081da) - posted by di...@apache.org on 2020/11/18 11:35:30 UTC, 4 replies.
- [flink] branch master updated (dc081da -> 92ce495) - posted by di...@apache.org on 2020/11/18 11:41:47 UTC, 4 replies.
- [flink] branch master updated (92ce495 -> ac94bef) - posted by kk...@apache.org on 2020/11/18 11:49:19 UTC, 4 replies.
- [flink] branch master updated (ac94bef -> 63aec82) - posted by di...@apache.org on 2020/11/18 11:54:53 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20207][python] Improve the error message printed when submitting the pyflink jobs via 'flink run' - posted by di...@apache.org on 2020/11/18 12:00:44 UTC, 1 replies.
- [flink] branch release-1.11 updated (f6f6271 -> ca702af) - posted by di...@apache.org on 2020/11/18 12:11:00 UTC, 2 replies.
- [flink] branch master updated (63aec82 -> a5a6ab4) - posted by al...@apache.org on 2020/11/18 12:44:33 UTC, 4 replies.
- [flink] branch master updated (a5a6ab4 -> 17a59f0) - posted by tw...@apache.org on 2020/11/18 13:57:40 UTC, 4 replies.
- [flink] 01/02: [FLINK-17424][e2e] Adopt download strategy of Kafka tests in Elasticsearch tests - posted by tw...@apache.org on 2020/11/18 13:57:41 UTC, 4 replies.
- [flink] 02/02: [hotfix][e2e] Simplify SQL client e2e testing matrix - posted by tw...@apache.org on 2020/11/18 13:57:42 UTC, 4 replies.
- [flink] branch master updated (17a59f0 -> a0398ff) - posted by ja...@apache.org on 2020/11/18 14:45:57 UTC, 4 replies.
- [flink] branch master updated (a0398ff -> 6aa3055) - posted by ja...@apache.org on 2020/11/18 14:58:00 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-20200][table-planner] Fix SQL Hints is not allowed in CREATE VIEW syntax - posted by ja...@apache.org on 2020/11/18 15:12:43 UTC, 0 replies.
- [flink] branch release-1.11 updated (ca702af -> 2cd5439) - posted by ja...@apache.org on 2020/11/18 15:24:44 UTC, 3 replies.
- [flink] branch master updated (6aa3055 -> fe01302) - posted by tw...@apache.org on 2020/11/18 17:13:33 UTC, 4 replies.
- [flink] branch master updated (fe01302 -> 8b2d0ac) - posted by ja...@apache.org on 2020/11/19 02:17:47 UTC, 4 replies.
- [flink] branch master updated (8b2d0ac -> cd833c2) - posted by lz...@apache.org on 2020/11/19 02:22:19 UTC, 4 replies.
- [flink] branch release-1.10 updated: [FLINK-20218][python] Import urllib.parse before importing apache-beam (#14125) - posted by di...@apache.org on 2020/11/19 03:44:04 UTC, 1 replies.
- [flink] branch master updated (cd833c2 -> b4d885d) - posted by ja...@apache.org on 2020/11/19 03:47:15 UTC, 4 replies.
- [flink] branch release-1.10 updated (2eaba74 -> 2fbef47) - posted by di...@apache.org on 2020/11/19 03:53:49 UTC, 1 replies.
- [flink] branch master updated (b4d885d -> 492965c) - posted by di...@apache.org on 2020/11/19 05:53:54 UTC, 4 replies.
- [flink] branch master updated (492965c -> 02eb6dc) - posted by al...@apache.org on 2020/11/19 11:31:43 UTC, 4 replies.
- [flink] branch master updated (02eb6dc -> bd28f52) - posted by di...@apache.org on 2020/11/19 12:15:34 UTC, 4 replies.
- [flink] branch master updated (bd28f52 -> f62094d) - posted by tr...@apache.org on 2020/11/19 13:32:42 UTC, 4 replies.
- [flink] branch release-1.11 updated: [FLINK-15170][test] Replace System.currentTimeMillis with System.nanoTime in WebFrontendITCase - posted by tr...@apache.org on 2020/11/19 13:49:08 UTC, 0 replies.
- [flink] branch release-1.11 updated (2cd5439 -> 01c5c14) - posted by tr...@apache.org on 2020/11/19 14:07:21 UTC, 0 replies.
- [flink] branch release-1.10 updated (2fbef47 -> d2409c1) - posted by tr...@apache.org on 2020/11/19 14:08:24 UTC, 0 replies.
- [flink] branch master updated: [hotfx][runtime] Add explainations about managed memory fraction contracts in StreamingJobGraphGenerator. - posted by xt...@apache.org on 2020/11/20 02:18:13 UTC, 0 replies.
- svn commit: r44586 - /release/flink/KEYS - posted by tz...@apache.org on 2020/11/20 02:32:18 UTC, 0 replies.
- [flink] branch master updated (08b9a12 -> 851300d) - posted by lz...@apache.org on 2020/11/20 02:59:20 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20204][docs-zh][kafka] Translate page 'upsert-kafka connector' into Chinese - posted by ja...@apache.org on 2020/11/20 04:14:47 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20243][docs] Remove useless words in CLI page - posted by ja...@apache.org on 2020/11/20 04:16:50 UTC, 0 replies.
- [flink] branch master updated (5b9625e -> 5c7ed8e) - posted by ja...@apache.org on 2020/11/20 04:26:11 UTC, 0 replies.
- [flink-web] branch asf-site updated (0ce9ceb -> 7fc4a01) - posted by kl...@apache.org on 2020/11/20 05:43:20 UTC, 0 replies.
- [flink-web] 01/02: [FLINK-17491][docs-zh] Translate Training page on project website - posted by kl...@apache.org on 2020/11/20 05:43:21 UTC, 0 replies.
- [flink-web] 02/02: Rebuild website - posted by kl...@apache.org on 2020/11/20 05:43:22 UTC, 1 replies.
- [flink] branch master updated (5c7ed8e -> a97fe1f) - posted by ar...@apache.org on 2020/11/20 07:17:22 UTC, 0 replies.
- [flink] branch master updated (a97fe1f -> df8de4a) - posted by ja...@apache.org on 2020/11/20 07:31:42 UTC, 0 replies.
- [flink] 01/02: [FLINK-17096][table-blink] Mini-batch group aggregation doesn't expire state even if state ttl is enabled - posted by ja...@apache.org on 2020/11/20 07:31:43 UTC, 0 replies.
- [flink] 02/02: [hotfix][table-blink] Improve state cleanup harness tests for group aggregation - posted by ja...@apache.org on 2020/11/20 07:31:44 UTC, 0 replies.
- [flink] branch master updated (df8de4a -> 4bef0f0) - posted by ar...@apache.org on 2020/11/20 09:09:50 UTC, 0 replies.
- [flink] branch master updated (4bef0f0 -> 8baa71b) - posted by ja...@apache.org on 2020/11/20 09:19:11 UTC, 0 replies.
- [flink] branch master updated (8baa71b -> 3a066d6) - posted by ja...@apache.org on 2020/11/20 09:21:07 UTC, 0 replies.
- [flink-web] branch asf-site updated (7fc4a01 -> 84e1252) - posted by kl...@apache.org on 2020/11/20 09:48:53 UTC, 0 replies.
- [flink-web] 01/02: Add congxian qiu to community page - posted by kl...@apache.org on 2020/11/20 09:48:54 UTC, 0 replies.
- [flink] branch master updated (3a066d6 -> 7e05b33) - posted by rm...@apache.org on 2020/11/20 12:07:45 UTC, 0 replies.
- [flink] branch master updated (7e05b33 -> c8b7863) - posted by kk...@apache.org on 2020/11/20 13:52:09 UTC, 0 replies.
- [flink] 01/02: [FLINK-20240] Add execution.runtime-mode setter in StreamExecutionEnvironment - posted by kk...@apache.org on 2020/11/20 13:52:10 UTC, 0 replies.
- [flink] 02/02: [fix] Make copies of the Configuration in the Environments. - posted by kk...@apache.org on 2020/11/20 13:52:11 UTC, 0 replies.
- [flink-docker] branch dev-master updated: [FLINK-19125] Adopt Jemalloc as default memory allocator to avoid memory leak - posted by tr...@apache.org on 2020/11/20 15:42:38 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Reduce logging verbosity from the checkpoint-related REST handlers - posted by rm...@apache.org on 2020/11/20 19:02:14 UTC, 0 replies.
- [flink] branch release-1.11 updated (13940b6 -> ffb14e4) - posted by rm...@apache.org on 2020/11/20 19:03:19 UTC, 0 replies.
- [flink] 01/02: [FLINK-20165][CI] Update test docker image - posted by rm...@apache.org on 2020/11/20 19:03:20 UTC, 0 replies.
- [flink] 02/02: [hotfix][yarn] Provide .out files in debug logs as well - posted by rm...@apache.org on 2020/11/20 19:03:21 UTC, 0 replies.
- [flink] branch master updated (8dca9fa -> 6e38705) - posted by rm...@apache.org on 2020/11/20 19:04:39 UTC, 0 replies.
- [flink] branch master updated (6e38705 -> 5659c8f) - posted by sj...@apache.org on 2020/11/20 19:18:51 UTC, 0 replies.
- [flink] 01/02: [FLINK-20239][docs] Confusing pages: Hive Read & Write and Hive Streaming - posted by sj...@apache.org on 2020/11/20 19:18:52 UTC, 0 replies.
- [flink] 02/02: [hotfix][docs] Clean up hive doc headers - posted by sj...@apache.org on 2020/11/20 19:18:53 UTC, 0 replies.
- [flink] branch master updated (5659c8f -> 7940afd) - posted by se...@apache.org on 2020/11/22 19:06:23 UTC, 0 replies.
- [flink] 01/04: [FLINK-20276][connector file] Stream formats should apply decompressors - posted by se...@apache.org on 2020/11/22 19:06:24 UTC, 0 replies.
- [flink] 02/04: [hotfix][tests] Decouple atomic file writing from temp file filters. - posted by se...@apache.org on 2020/11/22 19:06:25 UTC, 0 replies.
- [flink] 03/04: [FLINK-20081][connector/common][source] The SourceCoordinator should fail the job instead of killing JM when it catches an unhandled exception. - posted by se...@apache.org on 2020/11/22 19:06:26 UTC, 0 replies.
- [flink] 04/04: [FLINK-20081][connector/common][source] Fix the executor notifier to let the handler run in main thread when handling exception from the callable. - posted by se...@apache.org on 2020/11/22 19:06:27 UTC, 0 replies.
- [flink] branch master updated (7940afd -> 75599bc) - posted by se...@apache.org on 2020/11/22 22:56:16 UTC, 0 replies.
- [flink] 01/03: [refactor] Add ManuallyTriggeredScheduledExecutorService from 'flink-runtime' to 'flink-test-utils-junit'. - posted by se...@apache.org on 2020/11/22 22:56:17 UTC, 0 replies.
- [flink] 02/03: [refactor] Consolidate code for 'ManuallyTriggeredScheduledExecutor' between test-utils and runtime tests. - posted by se...@apache.org on 2020/11/22 22:56:18 UTC, 0 replies.
- [flink] 03/03: [FLINK-20261][connector source] Enumerators do not assign splits to unregistered (failed) readers. - posted by se...@apache.org on 2020/11/22 22:56:19 UTC, 0 replies.
- [flink] branch master updated (75599bc -> 8ac6af2) - posted by se...@apache.org on 2020/11/23 00:16:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20275][python] Fix the delimiter of the dependencies of Python DataStream API - posted by di...@apache.org on 2020/11/23 01:41:54 UTC, 0 replies.
- [flink-statefun] branch master updated (0720790 -> 2235b79) - posted by tz...@apache.org on 2020/11/23 02:08:04 UTC, 0 replies.
- [flink-statefun] 01/03: [FLINK-20189] [core] Backport IOUtils.tryReadFully - posted by tz...@apache.org on 2020/11/23 02:08:05 UTC, 1 replies.
- [flink-statefun] 02/03: [FLINK-20189] [core] Use tryReadFully in Header.skipHeaderSilently - posted by tz...@apache.org on 2020/11/23 02:08:06 UTC, 1 replies.
- [flink-statefun] 03/03: [FLINK-20189] [test] Extend UnboundedFeedbackLoggerTests to use RandomReadLengthByteArrayInputStream - posted by tz...@apache.org on 2020/11/23 02:08:07 UTC, 1 replies.
- [flink-statefun] branch release-2.2 updated (7ee09a5 -> ad0bc25) - posted by tz...@apache.org on 2020/11/23 02:09:09 UTC, 0 replies.
- [flink] branch master updated (e245eb1 -> 3b0ad56) - posted by xt...@apache.org on 2020/11/23 03:03:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20150][debezium-avro] Add documentation for the debezium-avro-confluent format - posted by ja...@apache.org on 2020/11/23 03:22:52 UTC, 0 replies.
- [flink] branch master updated (0c962c3 -> 49029a0) - posted by ja...@apache.org on 2020/11/23 03:33:52 UTC, 0 replies.
- [flink] branch master updated (49029a0 -> d6a1fd0) - posted by ja...@apache.org on 2020/11/23 03:39:53 UTC, 0 replies.
- [flink] branch master updated (d6a1fd0 -> 89bc29e) - posted by ja...@apache.org on 2020/11/23 07:39:08 UTC, 0 replies.
- [flink] branch master updated (89bc29e -> ea6d42b) - posted by rm...@apache.org on 2020/11/23 09:23:38 UTC, 0 replies.
- [flink] branch master updated (ea6d42b -> 8abaaec) - posted by kk...@apache.org on 2020/11/23 09:42:10 UTC, 0 replies.
- [flink] branch release-1.11 updated (ffb14e4 -> 001f952) - posted by ar...@apache.org on 2020/11/23 10:25:45 UTC, 0 replies.
- [flink] 01/02: [hotfix][checkpoint] Adding testlogger to all checkpoint tests. - posted by ar...@apache.org on 2020/11/23 10:25:46 UTC, 0 replies.
- [flink] 02/02: [FLINK-19585][tests] Waiting for all tasks to run before savepointing in UnalignedCheckpointCompatibilityITCase. - posted by ar...@apache.org on 2020/11/23 10:25:47 UTC, 0 replies.
- [flink] branch master updated (8abaaec -> 625db70) - posted by di...@apache.org on 2020/11/23 11:15:47 UTC, 0 replies.
- [flink] branch master updated (625db70 -> 40bbc17) - posted by se...@apache.org on 2020/11/23 11:39:45 UTC, 0 replies.
- [flink] branch master updated (40bbc17 -> eb500b8) - posted by ar...@apache.org on 2020/11/23 12:15:17 UTC, 0 replies.
- [flink] branch master updated (eb500b8 -> 75a584cb) - posted by ja...@apache.org on 2020/11/23 12:51:04 UTC, 0 replies.
- [flink] branch master updated (75a584cb -> d878cac) - posted by ar...@apache.org on 2020/11/23 13:00:24 UTC, 0 replies.
- [flink] 01/04: [FLINK-20145][checkpointing] Fix FileBasedBufferIterator#read. - posted by ar...@apache.org on 2020/11/23 13:00:25 UTC, 0 replies.
- [flink] 02/04: [FLINK-20145][network] Double-check if gate still has priority buffer when enqueuing in UnionInputGate. - posted by ar...@apache.org on 2020/11/23 13:00:26 UTC, 0 replies.
- [flink] 03/04: [FLINK-20145][task] Ignore double notification in StreamTwoInputProcessor. - posted by ar...@apache.org on 2020/11/23 13:00:27 UTC, 0 replies.
- [flink] 04/04: [FLINK-20145][tests] Add ITCases for UC with union gates and multiple input operators. - posted by ar...@apache.org on 2020/11/23 13:00:28 UTC, 0 replies.
- [flink] branch master updated (d878cac -> a4cc8c2) - posted by dw...@apache.org on 2020/11/23 14:03:50 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20262] Building flink-dist docker image does not work without python2 - posted by dw...@apache.org on 2020/11/23 14:05:37 UTC, 0 replies.
- [flink] branch master updated (a4cc8c2 -> c9782be) - posted by go...@apache.org on 2020/11/23 15:13:08 UTC, 0 replies.
- [flink] branch master updated: [FLINK-18279][docs] Simplify Table Overview - posted by sj...@apache.org on 2020/11/23 15:30:59 UTC, 0 replies.
- [flink] branch master updated (0fd9dc6 -> fd663e4) - posted by tw...@apache.org on 2020/11/23 17:07:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20296][training-docs] remove obsolete content about keyBy(string) - posted by da...@apache.org on 2020/11/23 19:18:29 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20296][training-docs] remove obsolete content about keyBy(string) - posted by da...@apache.org on 2020/11/23 19:19:52 UTC, 0 replies.
- [flink] branch master updated (1b8385d -> def24b0) - posted by se...@apache.org on 2020/11/23 20:51:17 UTC, 0 replies.
- [flink] 01/04: [FLINK-20193][runtime] Catch all uncaught Throwables from the SplitEnumerator in the SourceCoordinator. - posted by se...@apache.org on 2020/11/23 20:51:18 UTC, 0 replies.
- [flink] 02/04: [hotfix][runtime] Replace manual byte[] reading with DataInput.readFully() - posted by se...@apache.org on 2020/11/23 20:51:19 UTC, 0 replies.
- [flink] 03/04: [hotfix][runtime] Minor style warning cleanups in SourceCoordinatorContext - posted by se...@apache.org on 2020/11/23 20:51:20 UTC, 0 replies.
- [flink] 04/04: [hotfix][core] Fix JavaDocs for TemporaryClassLoaderContext - posted by se...@apache.org on 2020/11/23 20:51:21 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19325][checkpointing] Avoid flushing while writing metadata. - posted by ar...@apache.org on 2020/11/23 21:19:54 UTC, 0 replies.
- [flink] branch master updated (640d722 -> 2817502) - posted by di...@apache.org on 2020/11/24 01:20:50 UTC, 0 replies.
- [flink] branch master updated (2817502 -> 00ee23b4) - posted by xt...@apache.org on 2020/11/24 02:03:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19630][hive][doc] Make bundled hive jar the recommended way to add dependencies - posted by lz...@apache.org on 2020/11/24 02:39:24 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20277] Fix that ContinuousFileMonitoringFunction cannot restore from failure - posted by go...@apache.org on 2020/11/24 02:41:52 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19653][hive] Reduce our dependency on hive runner for tests - posted by lz...@apache.org on 2020/11/24 02:56:37 UTC, 0 replies.
- [flink] branch master updated (e9b05e7 -> a8d24b8) - posted by go...@apache.org on 2020/11/24 06:36:52 UTC, 0 replies.
- [flink] branch master updated (a8d24b8 -> 3295879) - posted by rm...@apache.org on 2020/11/24 06:47:42 UTC, 0 replies.
- [flink] branch master updated (3295879 -> d4a5467) - posted by zh...@apache.org on 2020/11/24 06:59:53 UTC, 0 replies.
- [flink] branch release-1.11 updated (39aea57 -> 3854c30) - posted by zh...@apache.org on 2020/11/24 07:10:32 UTC, 0 replies.
- [flink] branch master updated (d4a5467 -> 4bde1c9) - posted by jq...@apache.org on 2020/11/24 07:13:16 UTC, 0 replies.
- [flink] branch master updated (4bde1c9 -> 5576194a) - posted by ja...@apache.org on 2020/11/24 07:27:31 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix] Fix the SingleThreadFetcherManager to get the running fetchers correctly. - posted by jq...@apache.org on 2020/11/24 07:31:10 UTC, 0 replies.
- [flink] branch master updated (5576194a -> 0c78dfd) - posted by ja...@apache.org on 2020/11/24 07:37:03 UTC, 0 replies.
- [flink] branch master updated (0c78dfd -> 542b9fd) - posted by al...@apache.org on 2020/11/24 08:41:17 UTC, 0 replies.
- [flink] branch master updated (542b9fd -> e31320d) - posted by tw...@apache.org on 2020/11/24 08:56:55 UTC, 0 replies.
- [flink] branch master updated (e31320d -> 8e40283) - posted by al...@apache.org on 2020/11/24 09:00:37 UTC, 0 replies.
- [flink-statefun] branch master updated (2235b79 -> df792ac) - posted by tz...@apache.org on 2020/11/24 09:22:29 UTC, 0 replies.
- [flink-statefun] 01/07: [FLINK-20265] [core] Add IncompleteInvocationContext to FromFunction - posted by tz...@apache.org on 2020/11/24 09:22:30 UTC, 0 replies.
- [flink-statefun] 02/07: [FLINK-20265] [core] Allow PersistedRemoteFunctionValues to register states based on protocol PersistedValueSpecs - posted by tz...@apache.org on 2020/11/24 09:22:31 UTC, 0 replies.
- [flink-statefun] 03/07: [FLINK-20265] [core] Deprecate PersistedRemoteFunctionValues constructor which supports eager state specs - posted by tz...@apache.org on 2020/11/24 09:22:32 UTC, 0 replies.
- [flink-statefun] 04/07: [hotfix] [core] Refactor state utility methods into PersistedRemoteFunctionValues - posted by tz...@apache.org on 2020/11/24 09:22:33 UTC, 0 replies.
- [flink-statefun] 05/07: [FLINK-20265] [core, test] Add UT to cover user contracts of PersistedRemoteFunctionValues - posted by tz...@apache.org on 2020/11/24 09:22:34 UTC, 0 replies.
- [flink-statefun] 06/07: [hotfix] [core] Remove redundant conditioning in HttpRequestReplyClient.parseResponse - posted by tz...@apache.org on 2020/11/24 09:22:35 UTC, 0 replies.
- [flink-statefun] 07/07: [FLINK-20265] [core] Implement new extended protocol in RequestReplyFunction - posted by tz...@apache.org on 2020/11/24 09:22:36 UTC, 0 replies.
- [flink] branch FLINK-19743 created (now 4cb7775) - posted by jq...@apache.org on 2020/11/24 09:36:54 UTC, 0 replies.
- [flink] 01/02: [FLINK-19743][connectors/common] Add metric definitions of Source. (FLIP-33) - Expose the Source metrics via SourceMetricGroup and SourceReaderContext. - Let SourceOperator report the WatermarkLag. - posted by jq...@apache.org on 2020/11/24 09:36:55 UTC, 0 replies.
- [flink] 02/02: [FLINK-19743][connectors/common] Report numRecordsIn and numRecordsInPerSecond in SourceReaderBase. - posted by jq...@apache.org on 2020/11/24 09:36:56 UTC, 0 replies.
- [flink] branch master updated (8e40283 -> 7e7dbc2) - posted by lz...@apache.org on 2020/11/24 09:40:05 UTC, 0 replies.
- [flink] branch master updated (7e7dbc2 -> 7161b18) - posted by se...@apache.org on 2020/11/24 10:13:17 UTC, 0 replies.
- [flink] branch master updated (7161b18 -> 8cf28ee) - posted by tw...@apache.org on 2020/11/24 10:40:35 UTC, 0 replies.
- [flink] branch master updated (8cf28ee -> 33a2a40) - posted by dw...@apache.org on 2020/11/24 10:54:36 UTC, 0 replies.
- [flink] branch master updated (33a2a40 -> 3a2572a) - posted by lz...@apache.org on 2020/11/24 11:17:08 UTC, 0 replies.
- [flink] branch master updated (3a2572a -> 2fd73c1) - posted by ja...@apache.org on 2020/11/24 11:37:42 UTC, 0 replies.
- [flink] branch master updated (2fd73c1 -> dee76cd) - posted by xt...@apache.org on 2020/11/24 12:11:56 UTC, 0 replies.
- [flink] branch master updated (dee76cd -> c3973d6) - posted by se...@apache.org on 2020/11/24 12:22:01 UTC, 0 replies.
- [flink] branch master updated (c3973d6 -> 7a04197) - posted by se...@apache.org on 2020/11/24 13:16:42 UTC, 0 replies.
- [flink] branch master updated (7a04197 -> a3320d1) - posted by tw...@apache.org on 2020/11/24 14:07:34 UTC, 0 replies.
- [flink] branch master updated (a3320d1 -> cdcc57c) - posted by tr...@apache.org on 2020/11/24 15:06:28 UTC, 0 replies.
- [flink] branch master updated (cdcc57c -> e4286e7) - posted by tw...@apache.org on 2020/11/24 15:13:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20256][table-common] Allow errors when extracting the data type a DataView - posted by tw...@apache.org on 2020/11/24 16:05:52 UTC, 0 replies.
- [flink] branch master updated: [FLINK-19398][connectors/hive] Fix the failure when creating hive connector from userclassloader - posted by lz...@apache.org on 2020/11/25 02:14:28 UTC, 0 replies.
- [flink] branch master updated (cb79fd8 -> 68a7324) - posted by ja...@apache.org on 2020/11/25 03:35:39 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20291][table][filesystem] Optimize the exception message of FileSystemTableSink when missing format dependencies - posted by ja...@apache.org on 2020/11/25 04:01:33 UTC, 0 replies.
- [flink] branch master updated (264f2e9 -> c41051f) - posted by ja...@apache.org on 2020/11/25 06:40:22 UTC, 0 replies.
- [flink] branch master updated (c41051f -> 07a449e) - posted by lz...@apache.org on 2020/11/25 06:41:51 UTC, 0 replies.
- [flink] branch master updated (07a449e -> c852167) - posted by tr...@apache.org on 2020/11/25 09:32:32 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-19775][tests] Fix SystemProcessingTimeServiceTest.testImmediateShutdown - posted by tr...@apache.org on 2020/11/25 09:34:00 UTC, 0 replies.
- [flink] branch master updated (c852167 -> ef9c3ca) - posted by lz...@apache.org on 2020/11/25 09:43:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20191][docs] Add documentation for FLIP-95 ability interfaces - posted by tw...@apache.org on 2020/11/25 09:57:59 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20333][python] Fix the issue that metaspace OOM will be thrown after submitting PyFlink UDF jobs multiple times to the standalone cluster - posted by di...@apache.org on 2020/11/25 11:23:47 UTC, 0 replies.
- [flink] branch release-1.11 updated (306bc8d -> 1839211) - posted by di...@apache.org on 2020/11/25 11:25:43 UTC, 0 replies.
- [flink] branch master updated (c354f7b -> 9902c4f) - posted by ar...@apache.org on 2020/11/25 12:17:04 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20213][fs-connector] Partition commit is delayed when records keep coming - posted by lz...@apache.org on 2020/11/25 12:40:10 UTC, 0 replies.
- [flink] branch master updated (9902c4f -> e46ee85) - posted by ar...@apache.org on 2020/11/25 13:18:32 UTC, 0 replies.
- [flink] branch master updated (e46ee85 -> 6e1b842) - posted by ja...@apache.org on 2020/11/25 13:53:45 UTC, 0 replies.
- [flink] branch master updated (6e1b842 -> 0fbdda1) - posted by ja...@apache.org on 2020/11/25 13:55:16 UTC, 0 replies.
- [flink] branch master updated (0fbdda1 -> 425d699) - posted by az...@apache.org on 2020/11/25 14:17:43 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix][docs] The default value column of sink.partition-commit.success-file.name should be _SUCCESS - posted by az...@apache.org on 2020/11/25 14:19:03 UTC, 0 replies.
- [flink] branch master updated (425d699 -> 01d8f99) - posted by al...@apache.org on 2020/11/25 14:20:39 UTC, 0 replies.
- [flink] branch master updated (01d8f99 -> 40e6e16) - posted by dw...@apache.org on 2020/11/25 18:07:13 UTC, 0 replies.
- [flink] branch master updated (40e6e16 -> af46ae2) - posted by ar...@apache.org on 2020/11/25 20:04:54 UTC, 0 replies.
- [flink] branch master updated (af46ae2 -> bf2c13d) - posted by di...@apache.org on 2020/11/26 01:06:40 UTC, 0 replies.
- [flink] 01/02: [FLINK-20284][python] Port Grpc SharedResourceHolder class to flink-python module - posted by di...@apache.org on 2020/11/26 01:06:41 UTC, 0 replies.
- [flink] 02/02: [FLINK-20284][python] Change default DESTROY_DELAY_SECONDS to 0 - posted by di...@apache.org on 2020/11/26 01:06:42 UTC, 0 replies.
- [flink] branch release-1.11 updated (95f0261 -> 6229c7b) - posted by di...@apache.org on 2020/11/26 01:08:33 UTC, 0 replies.
- [flink] branch master updated (bf2c13d -> 74fd8b7) - posted by go...@apache.org on 2020/11/26 01:56:38 UTC, 0 replies.
- [flink] branch master updated (74fd8b7 -> 4cc1da9) - posted by go...@apache.org on 2020/11/26 01:58:48 UTC, 0 replies.
- [flink] branch master updated (4cc1da9 -> c008907) - posted by ta...@apache.org on 2020/11/26 02:42:26 UTC, 0 replies.
- [flink] branch release-1.12 created (now c008907) - posted by ta...@apache.org on 2020/11/26 02:43:48 UTC, 0 replies.
- [flink] branch master updated (c008907 -> 1820a2e) - posted by ja...@apache.org on 2020/11/26 05:58:32 UTC, 0 replies.
- [flink] branch master updated (1820a2e -> b2231ee) - posted by di...@apache.org on 2020/11/26 06:26:22 UTC, 0 replies.
- [flink] branch release-1.12 updated: Update for 1.12.0 - posted by di...@apache.org on 2020/11/26 06:30:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20184][doc] update hive streaming read and temporal table document - posted by lz...@apache.org on 2020/11/26 06:31:51 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20184][doc] update hive streaming read and temporal table document - posted by lz...@apache.org on 2020/11/26 06:33:00 UTC, 0 replies.
- [flink] branch master updated (47ae334 -> 54ac81a) - posted by ja...@apache.org on 2020/11/26 06:37:16 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20316][docs][table] Update the "Deduplication" section of "Query" page - posted by ja...@apache.org on 2020/11/26 06:52:21 UTC, 0 replies.
- [flink] branch master updated (54ac81a -> 50af0b1) - posted by ar...@apache.org on 2020/11/26 07:08:10 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20331][checkpointing][task] Don't fail the task if unaligned checkpoint was subsumed - posted by ar...@apache.org on 2020/11/26 07:19:02 UTC, 0 replies.
- [flink] branch master updated (50af0b1 -> b337383) - posted by di...@apache.org on 2020/11/26 07:29:31 UTC, 0 replies.
- [flink] branch release-1.12 updated (2c77c38 -> f872b2f) - posted by di...@apache.org on 2020/11/26 07:31:30 UTC, 0 replies.
- [flink] 01/02: [FLINK-20362][docs] Fix broken link in sourceSinks.zh.md - posted by di...@apache.org on 2020/11/26 07:31:31 UTC, 0 replies.
- [flink] 02/02: [hotfix][docs] Add the missing datastream_execution_mode.zh.md - posted by di...@apache.org on 2020/11/26 07:31:32 UTC, 0 replies.
- [flink] branch master updated (b337383 -> ff85aa5) - posted by tw...@apache.org on 2020/11/26 08:12:10 UTC, 0 replies.
- [flink] branch master updated (ff85aa5 -> e2b34eb) - posted by ja...@apache.org on 2020/11/26 09:51:56 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-19982][streaming] Change log level when CollectSinkFunction receives invalid requests for future investigation - posted by ja...@apache.org on 2020/11/26 09:53:20 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][python] Update the version of PyFlink to 1.12.dev0 - posted by di...@apache.org on 2020/11/26 09:55:01 UTC, 0 replies.
- [flink] branch master updated (e2b34eb -> af1b2cf) - posted by di...@apache.org on 2020/11/26 13:05:48 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20365][python] The native k8s cluster could not be unregistered when executing Python DataStream jobs in attach mode - posted by di...@apache.org on 2020/11/26 13:07:37 UTC, 0 replies.
- [flink] branch master updated (af1b2cf -> cf9bbfd) - posted by dw...@apache.org on 2020/11/26 13:15:58 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-17424][e2e] Further stabilize Elasticsearch downloads - posted by tw...@apache.org on 2020/11/26 13:34:44 UTC, 0 replies.
- [flink] branch master updated (cf9bbfd -> 8983bb0) - posted by az...@apache.org on 2020/11/26 13:35:59 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix][kafka] Fix val declaration in scala code doc example - posted by az...@apache.org on 2020/11/26 13:37:46 UTC, 0 replies.
- [flink] branch master updated (8983bb0 -> 5071452) - posted by az...@apache.org on 2020/11/26 13:44:25 UTC, 0 replies.
- [flink] branch release-1.10 updated (d2409c1 -> 46680ce) - posted by az...@apache.org on 2020/11/26 13:47:23 UTC, 0 replies.
- [flink] branch master updated (5071452 -> 51d9642) - posted by az...@apache.org on 2020/11/26 13:56:30 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix][table][docs] Fix table systemFunction lag description. - posted by az...@apache.org on 2020/11/26 13:59:25 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix][docs] Fix typo in event_timestamps_watermarks.md - posted by az...@apache.org on 2020/11/26 14:00:40 UTC, 0 replies.
- [flink] branch master updated (51d9642 -> b0cddac) - posted by az...@apache.org on 2020/11/26 14:02:41 UTC, 0 replies.
- [flink] branch release-1.11 updated: [hotfix][table][docs] Fix typo in System (Built-in) Functions page - posted by az...@apache.org on 2020/11/26 14:04:14 UTC, 0 replies.
- [flink] branch release-1.10 updated: [hotfix][table][docs] Fix typo in System (Built-in) Functions page - posted by az...@apache.org on 2020/11/26 14:06:13 UTC, 0 replies.
- [flink] branch master updated (b0cddac -> 22679aa) - posted by az...@apache.org on 2020/11/26 14:10:46 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][connectors] Fixed typo in Source.java docs - posted by az...@apache.org on 2020/11/26 14:12:24 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][kafka] Fix val declaration in scala code doc example - posted by az...@apache.org on 2020/11/26 14:14:16 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][table][docs] Fix table systemFunction lag description. - posted by az...@apache.org on 2020/11/26 14:15:45 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][docs] Fix typo in event_timestamps_watermarks.md - posted by az...@apache.org on 2020/11/26 14:18:21 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][table][docs] Fix typo in System (Built-in) Functions page - posted by az...@apache.org on 2020/11/26 14:20:02 UTC, 0 replies.
- [flink] branch master updated: [minor, docs] Clarify *final results* in DataStream execution mode docs - posted by al...@apache.org on 2020/11/26 15:37:00 UTC, 0 replies.
- [flink] branch release-1.12 updated: [minor, docs] Clarify *final results* in DataStream execution mode docs - posted by al...@apache.org on 2020/11/26 15:38:45 UTC, 0 replies.
- [flink] branch release-1.12 updated (b900b0c -> 7c4192e) - posted by tr...@apache.org on 2020/11/26 15:56:15 UTC, 0 replies.
- [flink] 01/29: [FLINK-20342][docs] Move ops/deployment/Overview to ops/Overview - posted by tr...@apache.org on 2020/11/26 15:56:16 UTC, 0 replies.
- [flink] 02/29: [FLINK-20342][docs] Change Cluster & Deployment into Resource Providers - posted by tr...@apache.org on 2020/11/26 15:56:17 UTC, 0 replies.
- [flink] 03/29: [FLINK-20342][docs] Renamed ops/deployment into ops/resource-providers - posted by tr...@apache.org on 2020/11/26 15:56:18 UTC, 0 replies.
- [flink] 04/29: [FLINK-20342][docs] Reordered items in nav bar & fixed broken links from renaming ops/deployment into ops/resource-providers - posted by tr...@apache.org on 2020/11/26 15:56:19 UTC, 0 replies.
- [flink] 05/29: [FLINK-20342][docs] Group ssl and kerberos documentation page under security - posted by tr...@apache.org on 2020/11/26 15:56:20 UTC, 0 replies.
- [flink] 06/29: [FLINK-20342][docs] Move Plugins above File Systems - posted by tr...@apache.org on 2020/11/26 15:56:21 UTC, 0 replies.
- [flink] 07/29: [FLINK-20342][docs] Split Deployment & Operations into Deployment and Operations - posted by tr...@apache.org on 2020/11/26 15:56:22 UTC, 0 replies.
- [flink] 08/29: [FLINK-20342][docs] Move memory configuration from ops to deployment - posted by tr...@apache.org on 2020/11/26 15:56:23 UTC, 0 replies.
- [flink] 09/29: [FLINK-20342][docs] Move plugins under filesystems - posted by tr...@apache.org on 2020/11/26 15:56:24 UTC, 0 replies.
- [flink] 10/29: [FLINK-20342][docs] Move cli from ops to deployment - posted by tr...@apache.org on 2020/11/26 15:56:25 UTC, 0 replies.
- [flink] 11/29: [FLINK-20342][docs] Move repls from ops to deployment - posted by tr...@apache.org on 2020/11/26 15:56:26 UTC, 0 replies.
- [flink] 12/29: [FLINK-20342][docs] Remove config.md from ops - posted by tr...@apache.org on 2020/11/26 15:56:27 UTC, 0 replies.
- [flink] 13/29: [FLINK-20342][docs] Group debugging topics under monitoring/debugging - posted by tr...@apache.org on 2020/11/26 15:56:28 UTC, 0 replies.
- [flink] 14/29: [FLINK-20342][docs] Group monitoring guides under monitoring/monitoring - posted by tr...@apache.org on 2020/11/26 15:56:29 UTC, 0 replies.
- [flink] 15/29: [FLINK-20342][docs] Move ops below deployment in navigation bar - posted by tr...@apache.org on 2020/11/26 15:56:30 UTC, 0 replies.
- [flink] 16/29: [FLINK-20342][docs] Move monitoring/monitoring and monitoring/debugging to ops/monitoring and ops/debugging respectively - posted by tr...@apache.org on 2020/11/26 15:56:31 UTC, 0 replies.
- [flink] 17/29: [FLINK-20342][docs] Change order in ops - posted by tr...@apache.org on 2020/11/26 15:56:32 UTC, 0 replies.
- [flink] 18/29: [FLINK-20342][docs] Split monitoring/metrics.md into monitoring/metrics.md and deployment/metric_reporters.md - posted by tr...@apache.org on 2020/11/26 15:56:33 UTC, 0 replies.
- [flink] 19/29: [FLINK-20342][docs] Move monitoring/metrics.md to ops/metrics.md - posted by tr...@apache.org on 2020/11/26 15:56:34 UTC, 0 replies.
- [flink] 20/29: [FLINK-20342][docs] Move monitoring/historyserver.md and monitoring/logging.md to deployment/* - posted by tr...@apache.org on 2020/11/26 15:56:35 UTC, 0 replies.
- [flink] 21/29: [FLINK-20342][docs] Move deployment/logging, historyserver and external_resources under advanced - posted by tr...@apache.org on 2020/11/26 15:56:36 UTC, 0 replies.
- [flink] 22/29: [FLINK-20342][docs] Group standalone resource providers under resource-providers/standalone - posted by tr...@apache.org on 2020/11/26 15:56:37 UTC, 0 replies.
- [flink] 23/29: [FLINK-20342][docs] Use fa-cogs as icon for Operations - posted by tr...@apache.org on 2020/11/26 15:56:38 UTC, 0 replies.
- [flink] 24/29: [FLINK-20342][docs] Moce production readiness checklist and upgrading applications to back of Operations section - posted by tr...@apache.org on 2020/11/26 15:56:39 UTC, 0 replies.
- [flink] 25/29: [FLINK-20342][docs] Move ops/monitoring/rest_api.md to ops/rest_api.md - posted by tr...@apache.org on 2020/11/26 15:56:40 UTC, 0 replies.
- [flink] 26/29: [FLINK-20342][docs] Rearrange the order of resource providers - posted by tr...@apache.org on 2020/11/26 15:56:41 UTC, 0 replies.
- [flink] 27/29: [FLIN-20342][docs] Split up jobmanager_high_availability.md into ha/index.md, ha/kubernets_ha.md and ha/zookeeper_ha.md - posted by tr...@apache.org on 2020/11/26 15:56:42 UTC, 0 replies.
- [flink] 28/29: [FLINK-20342][docs] Move deployment/config.md and deployment/memory/index.md to position 3 and 4 - posted by tr...@apache.org on 2020/11/26 15:56:43 UTC, 0 replies.
- [flink] 29/29: [FLINK-20342][docs] Add redirects for moved pages - posted by tr...@apache.org on 2020/11/26 15:56:44 UTC, 0 replies.
- [flink] branch master updated (c149de8 -> a576d49) - posted by tr...@apache.org on 2020/11/26 15:59:29 UTC, 0 replies.
- [flink] branch master updated (a576d49 -> 144a9b2) - posted by tr...@apache.org on 2020/11/26 16:03:03 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20351] Correct the logging of the location of a task failure on the JM - posted by tr...@apache.org on 2020/11/26 16:18:16 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20351] Correct the logging of the location of a task failure on the JM - posted by tr...@apache.org on 2020/11/26 16:22:48 UTC, 0 replies.
- [flink] branch master updated (144a9b2 -> 88d0ee0) - posted by go...@apache.org on 2020/11/27 01:54:47 UTC, 0 replies.
- [flink] branch release-1.12 updated (84b6631 -> 1aa1b8c) - posted by go...@apache.org on 2020/11/27 01:59:02 UTC, 0 replies.
- [flink] 01/04: [FLINK-18545][configuration] Introduce `pipeline.name` to allow users to specify job name by configuration - posted by go...@apache.org on 2020/11/27 01:59:03 UTC, 0 replies.
- [flink] 02/04: [FLINK-18545][configuration] Allow users to specify job name by configuration in ExecutionEnvironment - posted by go...@apache.org on 2020/11/27 01:59:04 UTC, 0 replies.
- [flink] 03/04: [FLINK-18545][python] Specify job name by `pipeline.name` for flink-python - posted by go...@apache.org on 2020/11/27 01:59:05 UTC, 0 replies.
- [flink] 04/04: [FLINK-18545][table] Specify job name by `pipeline.name` for sql job - posted by go...@apache.org on 2020/11/27 01:59:06 UTC, 0 replies.
- [flink] branch master updated (88d0ee0 -> fad84798) - posted by lz...@apache.org on 2020/11/27 02:46:12 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20241][hive] Improve exception message when hive deps are missing on JM/TM - posted by lz...@apache.org on 2020/11/27 02:48:08 UTC, 0 replies.
- [flink] branch master updated (fad84798 -> 562e5a4) - posted by lz...@apache.org on 2020/11/27 02:49:33 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20327][doc] The Hive's read/write page should redirect to SQL Fileystem connector - posted by lz...@apache.org on 2020/11/27 02:51:03 UTC, 0 replies.
- [flink] branch release-1.11 updated (65a6b0f -> 7ae1a5b) - posted by go...@apache.org on 2020/11/27 06:54:53 UTC, 0 replies.
- [flink] 01/03: [FLINK-18545][configuration] Introduce `pipeline.name` to allow users to specify job name by configuration - posted by go...@apache.org on 2020/11/27 06:54:54 UTC, 0 replies.
- [flink] 02/03: [FLINK-18545][configuration] Allow users to specify job name by configuration in ExecutionEnvironment - posted by go...@apache.org on 2020/11/27 06:54:55 UTC, 0 replies.
- [flink] 03/03: [FLINK-18545][table] Specify job name by `pipeline.name` for sql job - posted by go...@apache.org on 2020/11/27 06:54:56 UTC, 0 replies.
- [flink] branch master updated (562e5a4 -> fd23b35) - posted by ar...@apache.org on 2020/11/27 08:34:29 UTC, 0 replies.
- [flink] branch release-1.12 updated (3c432d8 -> 33c19e1) - posted by ar...@apache.org on 2020/11/27 08:36:10 UTC, 0 replies.
- [flink] branch master updated (fd23b35 -> f7fad2c) - posted by kk...@apache.org on 2020/11/27 09:30:04 UTC, 0 replies.
- [flink] branch release-1.12 updated (33c19e1 -> 03398f8) - posted by kk...@apache.org on 2020/11/27 09:32:41 UTC, 0 replies.
- [flink] branch master updated (f7fad2c -> 7bf76c0) - posted by go...@apache.org on 2020/11/27 09:34:06 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20366][table-planner-blink] ColumnIntervalUtil#getColumnIntervalWithFilter should consider constant predicate - posted by go...@apache.org on 2020/11/27 09:36:18 UTC, 0 replies.
- [flink-statefun] branch master updated (df792ac -> e82c2a0) - posted by tz...@apache.org on 2020/11/27 10:43:14 UTC, 0 replies.
- [flink-statefun] 01/08: [FLINK-20268] [python] Add StateSpec registration to Python SDK - posted by tz...@apache.org on 2020/11/27 10:43:15 UTC, 0 replies.
- [flink-statefun] 02/08: [hotfix] [python, test] Simplify function binding in request_reply_test - posted by tz...@apache.org on 2020/11/27 10:43:16 UTC, 0 replies.
- [flink-statefun] 03/08: [FLINK-20268] [python] Detect missing states and respond IncompleteInvocationContext - posted by tz...@apache.org on 2020/11/27 10:43:17 UTC, 0 replies.
- [flink-statefun] 04/08: [hotfix] [python, test] Remove useless print in tests - posted by tz...@apache.org on 2020/11/27 10:43:18 UTC, 0 replies.
- [flink-statefun] 05/08: [FLINK-20268] Update statefun-python-walkthrough-example to cover new protocol - posted by tz...@apache.org on 2020/11/27 10:43:19 UTC, 0 replies.
- [flink-statefun] 06/08: [FLINK-20268] [python] Update all Python examples to declare state with SDK - posted by tz...@apache.org on 2020/11/27 10:43:20 UTC, 0 replies.
- [flink-statefun] 07/08: [FLINK-20268] [core] Declare states with Python SDK in E2E tests - posted by tz...@apache.org on 2020/11/27 10:43:21 UTC, 0 replies.
- [flink-statefun] 08/08: [FLINK-20268] [python, docs] Update Python SDK README.md - posted by tz...@apache.org on 2020/11/27 10:43:22 UTC, 0 replies.
- [flink] branch master updated (7bf76c0 -> d219466) - posted by rm...@apache.org on 2020/11/27 11:13:01 UTC, 0 replies.
- [flink] branch release-1.12 updated (52d1adc -> 042df1f) - posted by rm...@apache.org on 2020/11/27 11:14:23 UTC, 0 replies.
- [flink] 01/02: [hotfix][docs] Document classloader shutdown hooks - posted by rm...@apache.org on 2020/11/27 11:14:24 UTC, 0 replies.
- [flink] 02/02: [FLINK-20343] Add new Deployment overview page - posted by rm...@apache.org on 2020/11/27 11:14:25 UTC, 0 replies.
- [flink] branch master updated (d219466 -> 6709a5a) - posted by go...@apache.org on 2020/11/27 13:39:19 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20349][table-planner-blink] Fix checking for deadlock caused by exchange - posted by go...@apache.org on 2020/11/27 13:42:19 UTC, 0 replies.
- [flink] branch release-1.11 updated (7ae1a5b -> 05a7875) - posted by ar...@apache.org on 2020/11/27 15:07:05 UTC, 0 replies.
- [flink] 01/02: [hotfix][task] Fix checkstyle/IDE warnings in BatchTask and TempBarrier - posted by ar...@apache.org on 2020/11/27 15:07:06 UTC, 0 replies.
- [flink] 02/02: [FLINK-19852][task] Reuse TempBarrier memory between iterations - posted by ar...@apache.org on 2020/11/27 15:07:07 UTC, 0 replies.
- [flink] branch master updated (6709a5a -> f5889bd) - posted by ar...@apache.org on 2020/11/27 19:31:12 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20389][tests] Fix UnalignedCheckpointITCase to work with unassigned splits. - posted by ar...@apache.org on 2020/11/27 19:32:51 UTC, 0 replies.
- [flink] branch master updated (f5889bd -> d5b1565) - posted by kl...@apache.org on 2020/11/28 06:31:38 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20384][doc] Fix Wrong Links in Some Chinese Docs - posted by kl...@apache.org on 2020/11/28 06:32:54 UTC, 0 replies.
- [flink] branch master updated (d5b1565 -> 0e639714) - posted by se...@apache.org on 2020/11/28 20:51:30 UTC, 0 replies.
- [flink] branch master updated (0e639714 -> 89f1754) - posted by se...@apache.org on 2020/11/29 12:59:41 UTC, 0 replies.
- [flink] branch release-1.12 updated (2e8d9b9 -> 64ea9d6) - posted by se...@apache.org on 2020/11/29 13:15:22 UTC, 0 replies.
- [flink] 01/04: [hotfix][runtime] Expand JavaDocs (and reorder methods) in OperatorCoordinator. - posted by se...@apache.org on 2020/11/29 13:15:23 UTC, 0 replies.
- [flink] 02/04: [hotfix][tests] Pull nested test suites out of CheckpointIDCounterTest and follow standard test-base pattern. - posted by se...@apache.org on 2020/11/29 13:15:24 UTC, 0 replies.
- [flink] 03/04: [FLINK-20396][checkpointing] Checkpoint Coordinator exposes the checkpoint ID of the restored checkpoint for partial state restores. - posted by se...@apache.org on 2020/11/29 13:15:25 UTC, 0 replies.
- [flink] 04/04: [FLINK-20344][dist] Change example value for default savepoint path flink-conf template. - posted by se...@apache.org on 2020/11/29 13:15:26 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-20175] Avro Confluent Registry SQL format does not support adding nullable columns - posted by dw...@apache.org on 2020/11/29 19:47:12 UTC, 0 replies.
- [flink] branch master updated (89f1754 -> ffb538b) - posted by dw...@apache.org on 2020/11/30 08:23:38 UTC, 0 replies.
- [flink] branch master updated (ffb538b -> 7aa0fb9) - posted by tr...@apache.org on 2020/11/30 09:26:58 UTC, 0 replies.
- [flink] branch release-1.12 updated (64ea9d6 -> 27ee325) - posted by tr...@apache.org on 2020/11/30 09:34:07 UTC, 0 replies.
- [flink] 01/03: [hotfix][tests] Introduce TestingSchedulerNG implementation - posted by tr...@apache.org on 2020/11/30 09:34:08 UTC, 0 replies.
- [flink] 02/03: [FLINK-20382][runtime] Fail hard when JobMaster cannot start scheduling of a job - posted by tr...@apache.org on 2020/11/30 09:34:09 UTC, 0 replies.
- [flink] 03/03: [hotfix] Expose FatalExitExceptionHandler's exit code via EXIT_CODE - posted by tr...@apache.org on 2020/11/30 09:34:10 UTC, 0 replies.
- [flink] branch release-1.11 updated (d2f24e8 -> 17197d7) - posted by tr...@apache.org on 2020/11/30 09:36:04 UTC, 0 replies.
- [flink] branch master updated (7aa0fb9 -> 586d3d0) - posted by rm...@apache.org on 2020/11/30 11:30:04 UTC, 0 replies.
- [flink] branch release-1.12 updated (27ee325 -> 42c1514) - posted by rm...@apache.org on 2020/11/30 11:31:55 UTC, 0 replies.
- [flink] branch master updated (586d3d0 -> 0ea11b8) - posted by se...@apache.org on 2020/11/30 11:33:31 UTC, 0 replies.
- [flink] branch release-1.12 updated (42c1514 -> bc870f6) - posted by se...@apache.org on 2020/11/30 11:35:50 UTC, 0 replies.
- [flink] 01/02: [FLINK-20397][checkpointing] Pass checkpointId to OperatorCoordinator.resetToCheckpoint() - posted by se...@apache.org on 2020/11/30 11:35:51 UTC, 0 replies.
- [flink] 02/02: [FLINK-20396][checkpointing] Add a 'subtaskReset()' method to the OperatorCoordinator. - posted by se...@apache.org on 2020/11/30 11:35:52 UTC, 0 replies.
- [flink] branch master updated (0ea11b8 -> e5a2c3c) - posted by ch...@apache.org on 2020/11/30 12:19:03 UTC, 0 replies.
- [flink] branch release-1.12 updated (bc870f6 -> be972ef) - posted by dw...@apache.org on 2020/11/30 12:29:01 UTC, 0 replies.
- [flink] 01/02: [FLINK-20245][hive][docs] Document how to create a Hive catalog from DDL - posted by dw...@apache.org on 2020/11/30 12:29:02 UTC, 0 replies.
- [flink] 02/02: [FLINK-20391] Set FORWARD_EDGES_PIPELINED for BATCH ExecutionMode - posted by dw...@apache.org on 2020/11/30 12:29:03 UTC, 0 replies.
- [flink] branch master updated (e5a2c3c -> 828faab) - posted by ch...@apache.org on 2020/11/30 14:13:13 UTC, 0 replies.
- [flink] branch master updated (828faab -> 36d2945) - posted by al...@apache.org on 2020/11/30 14:47:48 UTC, 0 replies.
- [flink] branch release-1.12 updated (be972ef -> 56bfa33) - posted by al...@apache.org on 2020/11/30 15:15:47 UTC, 0 replies.
- [flink] 01/10: [hotfix][fs-connector] Remove unused state serializer from FileWriter - posted by al...@apache.org on 2020/11/30 15:15:48 UTC, 0 replies.
- [flink] 02/10: [hotfix][fs-connector] Fix the typo in the FileSinkITCase - posted by al...@apache.org on 2020/11/30 15:15:49 UTC, 0 replies.
- [flink] 03/10: [FLINK-20337] Let StatefulSinkWriterOperator load StreamingFileSink's state - posted by al...@apache.org on 2020/11/30 15:15:50 UTC, 0 replies.
- [flink] 04/10: [FLINK-20337] Extend StatefulSinkWriterOperator Javadoc - posted by al...@apache.org on 2020/11/30 15:15:51 UTC, 0 replies.
- [flink] 05/10: [FLINK-20337] Let FileSink restore state from StreamingFileSink - posted by al...@apache.org on 2020/11/30 15:15:52 UTC, 0 replies.
- [flink] 06/10: [refactor] Factor test data generator/resolver out of BucketStateSerializerTest - posted by al...@apache.org on 2020/11/30 15:15:53 UTC, 0 replies.
- [flink] 07/10: [FLINK-20337] Add migration test for deserializing existing StreamingFileSink state with FileSink serializer - posted by al...@apache.org on 2020/11/30 15:15:54 UTC, 0 replies.
- [flink] 08/10: [refactor] Factor common testing code out of FileSinkITBase - posted by al...@apache.org on 2020/11/30 15:15:55 UTC, 0 replies.
- [flink] 09/10: [FLINK-20337] Add ITCase for migrating from StreamingFileSink to FileSink - posted by al...@apache.org on 2020/11/30 15:15:56 UTC, 0 replies.
- [flink] 10/10: [refactor] Move FileSink migration tests to flink-connector-files - posted by al...@apache.org on 2020/11/30 15:15:57 UTC, 0 replies.
- [flink] branch master updated (36d2945 -> 6d88eff) - posted by ch...@apache.org on 2020/11/30 15:25:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-20410] Retry querying for schema in the schema registry e2e test. - posted by dw...@apache.org on 2020/11/30 15:39:56 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20410] Retry querying for schema in the schema registry e2e test. - posted by dw...@apache.org on 2020/11/30 15:41:07 UTC, 0 replies.
- [flink] branch master updated (6f46458 -> b457225) - posted by li...@apache.org on 2020/11/30 16:59:22 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-20287][docs] Add documentation of how to switch memory allocator in Flink docker image - posted by li...@apache.org on 2020/11/30 17:01:12 UTC, 0 replies.
- [flink] branch master updated (b457225 -> 2049639) - posted by se...@apache.org on 2020/11/30 17:46:21 UTC, 0 replies.
- [flink] 01/04: [FLINK-20413][runtime] Sources return splits in "resetSubtask()", rather than in "subtaskFailed()" - posted by se...@apache.org on 2020/11/30 17:46:22 UTC, 1 replies.
- [flink] 02/04: [hotfix][connector files] Add some debug logging to file split enumerator. - posted by se...@apache.org on 2020/11/30 17:46:23 UTC, 1 replies.
- [flink] 03/04: [hotfix][build] Remove outdated CI logger config entries - posted by se...@apache.org on 2020/11/30 17:46:24 UTC, 1 replies.
- [flink] 04/04: [FLINK-20118][file connector] Introduce TaskManager and JobManager failures in FileSourceTextLinesITCase - posted by se...@apache.org on 2020/11/30 17:46:25 UTC, 1 replies.
- [flink] branch release-1.12 updated (e1c0220 -> 8160349) - posted by se...@apache.org on 2020/11/30 17:47:53 UTC, 0 replies.
- [flink] branch master updated (2049639 -> 01b4dbe) - posted by sj...@apache.org on 2020/11/30 23:01:34 UTC, 0 replies.
- [flink] 01/02: [FLINK-19082][doc] Add docs for temporal table and temporal table join - posted by sj...@apache.org on 2020/11/30 23:01:35 UTC, 1 replies.
- [flink] 02/02: [FLINK-20326][doc] fix broken links to define LookupableTableSource in temporal table page - posted by sj...@apache.org on 2020/11/30 23:01:36 UTC, 1 replies.
- [flink] branch release-1.12 updated (8160349 -> 1882625) - posted by sj...@apache.org on 2020/11/30 23:03:49 UTC, 0 replies.