You are viewing a plain text version of this content. The canonical link for it is here.
- [flink] branch master updated: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support TIMESTAMP_LTZ rowtime (#17074) - posted by ja...@apache.org on 2021/09/01 02:13:43 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support TIMESTAMP_LTZ rowtime (#17083) - posted by ja...@apache.org on 2021/09/01 02:17:44 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-23924][python][examples] Add PyFlink examples - posted by di...@apache.org on 2021/09/01 03:38:29 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially - posted by di...@apache.org on 2021/09/01 03:45:45 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially - posted by di...@apache.org on 2021/09/01 03:46:17 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes - posted by ar...@apache.org on 2021/09/01 05:56:45 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23468][test] Do not hide original exception if SSL is not available - posted by pn...@apache.org on 2021/09/01 06:17:30 UTC, 0 replies.
- [flink] branch master updated (e050a48 -> e396f4a) - posted by ar...@apache.org on 2021/09/01 06:28:46 UTC, 0 replies.
- [flink] branch release-1.14 updated (e66b92b -> ba675e1) - posted by ar...@apache.org on 2021/09/01 06:29:22 UTC, 0 replies.
- [flink] 01/11: [FLINK-23854][datastream] Expose the restored checkpoint id in ManagedInitializationContext. - posted by ar...@apache.org on 2021/09/01 06:29:23 UTC, 0 replies.
- [flink] 02/11: [FLINK-23854][datastream] Pass checkpoint id to SinkWriter#snapshotState and restoredCheckpointId to Sink#InitContext. - posted by ar...@apache.org on 2021/09/01 06:29:24 UTC, 0 replies.
- [flink] 03/11: [FLINK-23896][streaming] Implement retrying for failed committables for Sinks. - posted by ar...@apache.org on 2021/09/01 06:29:25 UTC, 0 replies.
- [flink] 04/11: [hotfix][connectors/kafka] Add TestLogger to Kafka tests. - posted by ar...@apache.org on 2021/09/01 06:29:26 UTC, 0 replies.
- [flink] 05/11: [FLINK-23678][tests] Re-enable KafkaSinkITCase and optimize it. - posted by ar...@apache.org on 2021/09/01 06:29:27 UTC, 0 replies.
- [flink] 06/11: [FLINK-23854][connectors/kafka] Abort transactions on close in KafkaWriter. - posted by ar...@apache.org on 2021/09/01 06:29:28 UTC, 0 replies.
- [flink] 07/11: [FLINK-23854][connectors/kafka] Transfer KafkaProducer from writer to committer. - posted by ar...@apache.org on 2021/09/01 06:29:29 UTC, 0 replies.
- [flink] 08/11: [FLINK-23896][connectors/kafka] Retry committing KafkaCommittables on transient failures. - posted by ar...@apache.org on 2021/09/01 06:29:30 UTC, 0 replies.
- [flink] 09/11: [FLINK-23854][connectors/kafka] Add FlinkKafkaInternalProducer#setTransactionalId. - posted by ar...@apache.org on 2021/09/01 06:29:31 UTC, 0 replies.
- [flink] 10/11: [FLINK-23854][connectors/kafka] Reliably abort lingering transactions in Kafka. - posted by ar...@apache.org on 2021/09/01 06:29:32 UTC, 0 replies.
- [flink] 11/11: [FLINK-23854][kafka/connectors] Adding pooling - posted by ar...@apache.org on 2021/09/01 06:29:33 UTC, 0 replies.
- [flink] branch master updated (e396f4a -> a3489f5) - posted by ja...@apache.org on 2021/09/01 06:37:51 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24085][docs] Add page title for "Versioned Tables" and "Time Zone" pages - posted by ja...@apache.org on 2021/09/01 06:38:53 UTC, 0 replies.
- [flink] branch master updated (a3489f5 -> 5af151f) - posted by ar...@apache.org on 2021/09/01 06:40:18 UTC, 0 replies.
- [flink] 01/03: [hotfix][docs] Soft-deprecating Streaming File Sink - posted by ar...@apache.org on 2021/09/01 06:40:19 UTC, 1 replies.
- [flink] 02/03: [FLINK-23817][docs] Add metric description to Kafka source. - posted by ar...@apache.org on 2021/09/01 06:40:20 UTC, 1 replies.
- [flink] 03/03: [hotfix][docs] Remove general operator task/operator metrics in Kafka Sink docs. - posted by ar...@apache.org on 2021/09/01 06:40:21 UTC, 1 replies.
- [flink] branch master updated (5af151f -> f946614) - posted by ja...@apache.org on 2021/09/01 06:42:03 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF (#16983) - posted by ja...@apache.org on 2021/09/01 06:42:33 UTC, 0 replies.
- [flink] branch master updated (f946614 -> d2de244) - posted by ja...@apache.org on 2021/09/01 06:46:18 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-24051][connectors/kafka] Make groupId optional when constructing a KafkaSource - posted by ar...@apache.org on 2021/09/01 06:46:39 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24029][docs] Fix "dept_id" typo in SQL "Getting Started" page - posted by ja...@apache.org on 2021/09/01 06:46:56 UTC, 0 replies.
- [flink] branch release-1.13 updated (4da1633 -> a072584) - posted by ar...@apache.org on 2021/09/01 06:47:50 UTC, 0 replies.
- [flink] branch release-1.13 updated (a072584 -> 3f619dd) - posted by ja...@apache.org on 2021/09/01 06:48:46 UTC, 0 replies.
- [flink] branch release-1.14 updated (ad44b55 -> ff8f33a) - posted by ar...@apache.org on 2021/09/01 07:14:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24099][docs] Refer to nightlies.apache.org - posted by ch...@apache.org on 2021/09/01 08:12:06 UTC, 0 replies.
- [flink-training] branch master updated (bbb051a -> 177cadf) - posted by nk...@apache.org on 2021/09/01 08:23:41 UTC, 0 replies.
- [flink-training] branch master updated (177cadf -> a66d5f1) - posted by nk...@apache.org on 2021/09/01 08:27:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits - posted by jq...@apache.org on 2021/09/01 09:42:43 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23971][tests] fix connector testing framework error when compare records in different splits - posted by jq...@apache.org on 2021/09/01 09:54:54 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-22895][docs] Fix example typo in "Table Concepts & Common API" page - posted by ch...@apache.org on 2021/09/01 11:06:48 UTC, 0 replies.
- [flink-training] branch master updated (a66d5f1 -> f5630be) - posted by nk...@apache.org on 2021/09/01 11:08:27 UTC, 0 replies.
- [flink-training] 01/02: [hotfix] test imports wrong solution class - posted by nk...@apache.org on 2021/09/01 11:08:28 UTC, 0 replies.
- [flink-training] 02/02: [hotfix][CI] also verify tests with Scala disabled (default) - posted by nk...@apache.org on 2021/09/01 11:08:29 UTC, 0 replies.
- [flink] branch master updated (ad052cc -> 61b5b0a) - posted by tw...@apache.org on 2021/09/01 11:10:24 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24087][connector-kafka] Avoid importing Table API classes for DataStream API programs - posted by tw...@apache.org on 2021/09/01 11:10:58 UTC, 0 replies.
- [flink] branch master updated (61b5b0a -> 6628237) - posted by ch...@apache.org on 2021/09/01 11:40:19 UTC, 0 replies.
- [flink] branch master updated (6628237 -> 582941b) - posted by ch...@apache.org on 2021/09/01 11:54:04 UTC, 0 replies.
- [flink] branch master updated (582941b -> 1b764ce) - posted by ja...@apache.org on 2021/09/01 12:00:38 UTC, 0 replies.
- [flink-statefun] branch master updated: [hotfix] link to golang sdk from homepage - posted by sj...@apache.org on 2021/09/01 14:04:05 UTC, 0 replies.
- [flink-statefun] branch release-3.1 updated: [hotfix] link to golang sdk from homepage - posted by sj...@apache.org on 2021/09/01 14:04:09 UTC, 0 replies.
- [flink] branch master updated (1b764ce -> c7bf8b3) - posted by pn...@apache.org on 2021/09/01 14:24:04 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23797][tests] Wait for all task running before savepoint for all tests in SavepointITCase - posted by pn...@apache.org on 2021/09/01 14:25:46 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Fix spotless violations - posted by dw...@apache.org on 2021/09/01 15:17:22 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to SingleInputGate#setupChannels() - posted by pn...@apache.org on 2021/09/01 16:08:42 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to SingleInputGate#setupChannels() - posted by pn...@apache.org on 2021/09/01 16:09:02 UTC, 0 replies.
- [flink-statefun-playground] branch release-3.1 updated: [hotfix] Remove trailing YAML document delimiters in module.yamls - posted by tz...@apache.org on 2021/09/01 17:36:20 UTC, 0 replies.
- [flink-statefun-playground] branch dev updated: [hotfix] Remove trailing YAML document delimiters in module.yamls - posted by tz...@apache.org on 2021/09/01 17:37:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-17495][metrics] Add support for configuring additional variables - posted by ch...@apache.org on 2021/09/01 17:38:48 UTC, 0 replies.
- [flink] branch master updated (869b486 -> 94d7952) - posted by ti...@apache.org on 2021/09/02 01:56:32 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment - posted by di...@apache.org on 2021/09/02 01:56:53 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment - posted by di...@apache.org on 2021/09/02 01:57:22 UTC, 0 replies.
- [flink] branch master updated (f2982ca -> da1912d) - posted by di...@apache.org on 2021/09/02 02:00:40 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str - posted by di...@apache.org on 2021/09/02 02:03:18 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL - posted by ta...@apache.org on 2021/09/02 05:53:15 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL - posted by ta...@apache.org on 2021/09/02 05:56:06 UTC, 0 replies.
- [flink-training] branch master updated: [hotfix] trim whitespace before checking enable_scala - posted by nk...@apache.org on 2021/09/02 06:12:21 UTC, 0 replies.
- [flink] branch master updated (aa2dddc -> 0ff68d0) - posted by ch...@apache.org on 2021/09/02 07:14:28 UTC, 0 replies.
- [flink] branch release-1.13 updated (b7f71ca -> ca9f9b2) - posted by ja...@apache.org on 2021/09/02 07:18:03 UTC, 0 replies.
- [flink] branch master updated (0ff68d0 -> cc58c6c) - posted by ch...@apache.org on 2021/09/02 07:18:54 UTC, 0 replies.
- [flink] branch master updated (cc58c6c -> 9aa70fe) - posted by ch...@apache.org on 2021/09/02 07:19:51 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24047][tests] Retry if leader election is in progress - posted by ch...@apache.org on 2021/09/02 07:20:16 UTC, 0 replies.
- [flink] branch master updated (9aa70fe -> 35f6375) - posted by tw...@apache.org on 2021/09/02 07:29:58 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible - posted by tw...@apache.org on 2021/09/02 07:30:16 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24099][docs] Refer to nightlies.apache.org - posted by ch...@apache.org on 2021/09/02 07:36:43 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24099][docs] Refer to nightlies.apache.org - posted by ch...@apache.org on 2021/09/02 07:44:22 UTC, 0 replies.
- [flink] branch master updated (35f6375 -> 4759f32) - posted by ja...@apache.org on 2021/09/02 08:08:41 UTC, 0 replies.
- [flink] branch master updated (4759f32 -> 71836bf) - posted by tw...@apache.org on 2021/09/02 08:41:49 UTC, 0 replies.
- [flink] 01/05: [hotfix][docs] Use language-specific comment syntax - posted by tw...@apache.org on 2021/09/02 08:41:50 UTC, 0 replies.
- [flink] 02/05: [hotfix][table-api] Expose NOT for Table API - posted by tw...@apache.org on 2021/09/02 08:41:51 UTC, 0 replies.
- [flink] 03/05: [hotfix][table-planner] add test cases for AND and OR - posted by tw...@apache.org on 2021/09/02 08:41:52 UTC, 0 replies.
- [flink] 04/05: [hotfix][table-planner] Ensure that IS JSON never returns NULL - posted by tw...@apache.org on 2021/09/02 08:41:53 UTC, 0 replies.
- [flink] 05/05: [FLINK-16501][table] Support IS JSON predicate in Table API - posted by tw...@apache.org on 2021/09/02 08:41:54 UTC, 0 replies.
- [flink-web] branch asf-site updated: [hotfix] Ipdate README - posted by ch...@apache.org on 2021/09/02 09:13:18 UTC, 0 replies.
- [flink] branch release-1.13 updated (30465e0 -> 62f3c9c) - posted by di...@apache.org on 2021/09/02 11:10:36 UTC, 0 replies.
- [flink] branch master updated: [hotfix][test] Clearly mark old TestHarness classes as deprecated - posted by pn...@apache.org on 2021/09/02 12:51:29 UTC, 0 replies.
- [flink-statefun] branch master updated (a2423ac -> 1aa2313) - posted by ig...@apache.org on 2021/09/02 13:15:17 UTC, 0 replies.
- [flink] branch master updated (557dab1 -> 67a16b0) - posted by tr...@apache.org on 2021/09/02 13:36:37 UTC, 0 replies.
- [flink] branch release-1.14 updated (5c13464 -> ae4dfab) - posted by tr...@apache.org on 2021/09/02 13:42:45 UTC, 0 replies.
- [flink] branch release-1.13 updated (62f3c9c -> 8b04f32) - posted by tr...@apache.org on 2021/09/02 13:44:52 UTC, 0 replies.
- [flink] branch master updated (67a16b0 -> 87c0543) - posted by ch...@apache.org on 2021/09/02 14:14:31 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-22227][clients] Log submitted job name, id and receiving jobmanager - posted by ch...@apache.org on 2021/09/02 14:15:19 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24005][coordination] Only return fulfilled requirements for reserved slots - posted by ch...@apache.org on 2021/09/02 14:17:23 UTC, 0 replies.
- [flink] branch master updated (87c0543 -> e5b88a3) - posted by tw...@apache.org on 2021/09/02 14:55:34 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24130][python] Fix RowDataSerializerTest after FLINK-24054 - posted by tw...@apache.org on 2021/09/02 14:56:08 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24005][coordination] Only return fulfilled requirements for reserved slots - posted by ch...@apache.org on 2021/09/02 15:25:12 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Let PartitionRequestClientFactoryTest extend TestLogger - posted by tr...@apache.org on 2021/09/02 15:27:00 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix] Let PartitionRequestClientFactoryTest extend TestLogger - posted by tr...@apache.org on 2021/09/02 15:31:56 UTC, 0 replies.
- [flink-statefun] branch master updated (1aa2313 -> 6ae7648) - posted by ig...@apache.org on 2021/09/02 15:32:06 UTC, 0 replies.
- [flink] branch release-1.13 updated: [hotfix] Let PartitionRequestClientFactoryTest extend TestLogger - posted by tr...@apache.org on 2021/09/02 15:33:49 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24121][flink-python] There are spelling mistakes in the notes. - posted by sj...@apache.org on 2021/09/02 16:09:11 UTC, 0 replies.
- [flink] branch master updated (78108fb -> c40505c) - posted by sj...@apache.org on 2021/09/02 16:09:34 UTC, 0 replies.
- [flink] branch release-1.14 updated (e086f80 -> a3e0f94) - posted by sj...@apache.org on 2021/09/02 16:11:21 UTC, 0 replies.
- [flink] 01/02: [FLINK-24121][flink-python] There are spelling mistakes in the notes. - posted by sj...@apache.org on 2021/09/02 16:11:22 UTC, 0 replies.
- [flink] 02/02: [hotfix][python] Add missing space to error message - posted by sj...@apache.org on 2021/09/02 16:11:23 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-24110] Filter null ComponentJsonObjects - posted by sj...@apache.org on 2021/09/02 16:51:05 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-24109] Correct egress string serialization - posted by sj...@apache.org on 2021/09/02 19:18:44 UTC, 0 replies.
- [flink] branch master updated (c40505c -> 989d234) - posted by tr...@apache.org on 2021/09/02 19:44:12 UTC, 0 replies.
- [flink] branch master updated (989d234 -> 3feae4c) - posted by hx...@apache.org on 2021/09/03 01:55:49 UTC, 0 replies.
- [flink] branch release-1.14 updated (a3e0f94 -> 2fa2d96) - posted by hx...@apache.org on 2021/09/03 01:56:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese (#16949) - posted by ja...@apache.org on 2021/09/03 02:40:40 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese (#16949) - posted by ja...@apache.org on 2021/09/03 02:41:36 UTC, 0 replies.
- [flink] branch master updated (22f7feb -> 0ee049d) - posted by ch...@apache.org on 2021/09/03 06:20:04 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24023][runtime-web] The names of metrics are incomplete (#17117) - posted by ja...@apache.org on 2021/09/03 07:11:51 UTC, 0 replies.
- [flink] branch master updated (6d673ae -> 68a29f3) - posted by go...@apache.org on 2021/09/03 07:24:27 UTC, 0 replies.
- [flink] branch release-1.14 updated: Revert "[FLINK-23544][table-planner] Window TVF Supports session window in plan" - posted by go...@apache.org on 2021/09/03 08:03:35 UTC, 0 replies.
- [flink] branch master updated (68a29f3 -> e03c84a) - posted by tw...@apache.org on 2021/09/03 08:26:37 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23111][runtime-web] Fix monaco editor async setup - posted by tw...@apache.org on 2021/09/03 08:28:08 UTC, 0 replies.
- [flink-training] branch master updated (90da3df -> 1b67207) - posted by nk...@apache.org on 2021/09/03 08:50:54 UTC, 0 replies.
- [flink-training] 01/02: [FLINK-23926] replace startTime and endTime with a single eventTime field - posted by nk...@apache.org on 2021/09/03 08:50:55 UTC, 0 replies.
- [flink-training] 02/02: [hotfix] collect rather than collectWithTimestamp - posted by nk...@apache.org on 2021/09/03 08:50:56 UTC, 0 replies.
- [flink] branch master updated (e03c84a -> 12f9982) - posted by tr...@apache.org on 2021/09/03 09:09:23 UTC, 0 replies.
- [flink] branch release-1.14 updated (1c06ee7 -> b496718) - posted by tr...@apache.org on 2021/09/03 09:12:15 UTC, 0 replies.
- [flink] branch master updated (12f9982 -> 1625955) - posted by tr...@apache.org on 2021/09/03 09:36:48 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24120] Add docs for using environment variable MALLOC_ARENA_MAX to avoid unlimited memory increasing - posted by tr...@apache.org on 2021/09/03 09:38:08 UTC, 0 replies.
- [flink] branch release-1.13 updated (40e0b12 -> 5619992) - posted by tr...@apache.org on 2021/09/03 09:39:36 UTC, 0 replies.
- [flink] branch master updated (1625955 -> 338ae25) - posted by tr...@apache.org on 2021/09/03 09:49:09 UTC, 0 replies.
- [flink] branch release-1.14 updated (2a873eb -> c1aa875) - posted by tr...@apache.org on 2021/09/03 09:56:02 UTC, 0 replies.
- [flink] branch master updated (338ae25 -> 0a2607c) - posted by tr...@apache.org on 2021/09/03 10:18:48 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23654][runtime] Splitting IO and future threadpools and adding advanced configurations - posted by tr...@apache.org on 2021/09/03 10:22:44 UTC, 0 replies.
- [flink] branch master updated (0a2607c -> 36f607c) - posted by dw...@apache.org on 2021/09/03 10:27:19 UTC, 0 replies.
- [flink] 01/02: [FLINK-21090] Add tests for stop-with-savepoint and FLIP-147 - posted by dw...@apache.org on 2021/09/03 10:27:20 UTC, 1 replies.
- [flink] 02/02: [FLINK-21090] Minor code improvements - posted by dw...@apache.org on 2021/09/03 10:27:21 UTC, 1 replies.
- [flink] branch release-1.14 updated (d3d9afd -> 7b1c5a6) - posted by dw...@apache.org on 2021/09/03 10:41:31 UTC, 0 replies.
- [flink] branch master updated (36f607c -> 6b4f8a4) - posted by tr...@apache.org on 2021/09/03 13:09:13 UTC, 0 replies.
- [flink] branch release-1.14 updated (7b1c5a6 -> 94387a4) - posted by tr...@apache.org on 2021/09/03 13:12:51 UTC, 0 replies.
- [flink] branch master updated (6b4f8a4 -> cd01d4c) - posted by pn...@apache.org on 2021/09/03 13:51:19 UTC, 0 replies.
- [flink] branch release-1.14 updated (94387a4 -> 2e76974) - posted by pn...@apache.org on 2021/09/03 13:53:36 UTC, 0 replies.
- [flink] 01/02: [FLINK-23916][python] Add python API to set tolerable checkpoint failure number - posted by pn...@apache.org on 2021/09/03 13:53:37 UTC, 0 replies.
- [flink] 02/02: [FLINK-23916][docs] Update the documentation how to set tolerable checkpoint failure number - posted by pn...@apache.org on 2021/09/03 13:53:38 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-23916][docs] Update the documentation how to set tolerable checkpoint failure number - posted by pn...@apache.org on 2021/09/03 13:57:23 UTC, 0 replies.
- [flink] branch release-1.13 updated (e1a7121 -> 9f60a51) - posted by dw...@apache.org on 2021/09/03 14:33:58 UTC, 0 replies.
- [flink-training] branch master updated: [FLINK-24118] Allow TaxiFareGenerator to produce bounded streams (#40) - posted by nk...@apache.org on 2021/09/03 14:36:47 UTC, 0 replies.
- [flink] branch release-1.13 updated (9f60a51 -> c6863d1) - posted by tw...@apache.org on 2021/09/03 14:47:54 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-22367][streaming] Reset syncSavepointId only if it is equal to checkpoint id from event - posted by dw...@apache.org on 2021/09/03 14:59:56 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24064][connector/common] HybridSource restore from savepoint - posted by th...@apache.org on 2021/09/03 23:24:08 UTC, 0 replies.
- [flink] branch master updated (2984d87 -> b800fb2) - posted by ar...@apache.org on 2021/09/04 11:51:51 UTC, 0 replies.
- [flink] 01/02: [hotfix][docs] Fix sentence - posted by ar...@apache.org on 2021/09/04 11:51:52 UTC, 0 replies.
- [flink] 02/02: [hotfix][docs] Move 'Running in an IDE' section to prerequisites When going through the tutorial step-by-step you will encounter the error right at the beginning but might not notice this section at the bottom. As most developers are probably using an IDE this also becomes a prerequisite to actually get the tutorial to run. - posted by ar...@apache.org on 2021/09/04 11:51:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24158][runtime] Remove useless collector in LimitOperator - posted by ti...@apache.org on 2021/09/04 13:50:32 UTC, 0 replies.
- [flink] branch master updated (c0c33d3 -> 888b365) - posted by ga...@apache.org on 2021/09/06 02:48:30 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker - posted by di...@apache.org on 2021/09/06 05:27:38 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker - posted by di...@apache.org on 2021/09/06 05:29:33 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker - posted by di...@apache.org on 2021/09/06 05:29:59 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker - posted by di...@apache.org on 2021/09/06 05:52:19 UTC, 0 replies.
- [flink] branch release-1.14 updated (f6460e9 -> 9c8d21f) - posted by ga...@apache.org on 2021/09/06 06:51:08 UTC, 0 replies.
- [flink] 01/02: Revert "[FLINK-23759][runtime][checkpoint] Ignore the restored checkpoints when reporting latest completed id with abortion message" - posted by ga...@apache.org on 2021/09/06 06:51:09 UTC, 0 replies.
- [flink] 02/02: [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup - posted by ga...@apache.org on 2021/09/06 06:51:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24090][docs] Added Troubleshooting section with ignoring in-flight data explanation into unaligned checkpoints page - posted by pn...@apache.org on 2021/09/06 07:36:43 UTC, 0 replies.
- [flink] branch master updated (5b47a81 -> fe17ca6) - posted by jq...@apache.org on 2021/09/06 07:45:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data - posted by gy...@apache.org on 2021/09/06 07:46:56 UTC, 0 replies.
- [flink] branch master updated (6af5c9a -> 25b985d) - posted by pn...@apache.org on 2021/09/06 07:52:54 UTC, 0 replies.
- [flink] 01/03: [refactor][streaming] Improved description of the calculation of the processing time delay - posted by pn...@apache.org on 2021/09/06 07:52:55 UTC, 0 replies.
- [flink] 02/03: [refactor][streaming] Busy waiting in checkScheduledTimestamps replaced by CompletableFuture - posted by pn...@apache.org on 2021/09/06 07:52:56 UTC, 0 replies.
- [flink] 03/03: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay - posted by pn...@apache.org on 2021/09/06 07:52:57 UTC, 0 replies.
- [flink] branch release-1.14 updated (9c8d21f -> 5a68bb8) - posted by pn...@apache.org on 2021/09/06 07:54:10 UTC, 0 replies.
- [flink] 01/04: [FLINK-24090][docs] Added Troubleshooting section with ignoring in-flight data explanation into unaligned checkpoints page - posted by pn...@apache.org on 2021/09/06 07:54:11 UTC, 0 replies.
- [flink] 02/04: [refactor][streaming] Improved description of the calculation of the processing time delay - posted by pn...@apache.org on 2021/09/06 07:54:12 UTC, 0 replies.
- [flink] 03/04: [refactor][streaming] Busy waiting in checkScheduledTimestamps replaced by CompletableFuture - posted by pn...@apache.org on 2021/09/06 07:54:13 UTC, 0 replies.
- [flink] 04/04: [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay - posted by pn...@apache.org on 2021/09/06 07:54:14 UTC, 0 replies.
- [flink-web] branch asf-site updated (0486128 -> eaabd93) - posted by ch...@apache.org on 2021/09/06 09:10:29 UTC, 0 replies.
- [flink-web] 01/04: [hotfix] Remove Makefile - posted by ch...@apache.org on 2021/09/06 09:10:30 UTC, 0 replies.
- [flink-web] 02/04: [FLINK-24164] Point website to nightlies.apache.org - posted by ch...@apache.org on 2021/09/06 09:10:31 UTC, 0 replies.
- [flink-web] 03/04: [FLINK-24164] Use site.DOCS_BASE_URL where possible - posted by ch...@apache.org on 2021/09/06 09:10:32 UTC, 0 replies.
- [flink-web] 04/04: Rebuild website - posted by ch...@apache.org on 2021/09/06 09:10:33 UTC, 1 replies.
- [flink] branch master updated (25b985d -> 73bb9d3) - posted by ch...@apache.org on 2021/09/06 10:46:51 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23839][kafka] Improve warnings on InvalidTxnState-/ProducerFencedException - posted by ch...@apache.org on 2021/09/06 10:47:10 UTC, 0 replies.
- [flink] branch master updated (73bb9d3 -> 327a98f) - posted by lz...@apache.org on 2021/09/06 11:27:35 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data - posted by gy...@apache.org on 2021/09/06 12:50:34 UTC, 0 replies.
- [flink] branch master updated (327a98f -> f0a0648) - posted by tw...@apache.org on 2021/09/06 13:52:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23912][coordination] Ignore repeated empty requirements declarations - posted by ch...@apache.org on 2021/09/06 15:33:51 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23912][coordination] Ignore repeated empty requirements declarations - posted by ch...@apache.org on 2021/09/06 15:34:15 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24064][connector/common] HybridSource restore from savepoint - posted by th...@apache.org on 2021/09/06 16:37:26 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24064][connector/common] HybridSource restore from savepoint - posted by th...@apache.org on 2021/09/06 16:40:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23983][tests] Ensure to close and dispose created keyed-statebackend in StateBackendTestBase - posted by ta...@apache.org on 2021/09/07 02:28:03 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23983][tests] Ensure to close and dispose created keyed-statebackend in StateBackendTestBase - posted by ta...@apache.org on 2021/09/07 02:29:28 UTC, 0 replies.
- [flink] branch master updated (4f5978f -> c13b749) - posted by ja...@apache.org on 2021/09/07 04:00:57 UTC, 0 replies.
- [flink] branch master updated (c13b749 -> 311eaaa) - posted by dw...@apache.org on 2021/09/07 06:13:36 UTC, 0 replies.
- [flink] branch release-1.14 updated (7bf4240 -> c1b6acd) - posted by dw...@apache.org on 2021/09/07 06:13:58 UTC, 0 replies.
- [flink] 01/02: [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one - posted by dw...@apache.org on 2021/09/07 06:13:59 UTC, 0 replies.
- [flink] 02/02: [FLINK-24069][tests] Added exponentially increasing checkpoint interval for every next attempt of testIgnoreInFlightDataDuringRecovery - posted by dw...@apache.org on 2021/09/07 06:14:00 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23832][docs] Update DataStream API Integration page - posted by tw...@apache.org on 2021/09/07 06:21:16 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23832][docs] Update DataStream API Integration page - posted by tw...@apache.org on 2021/09/07 06:26:00 UTC, 0 replies.
- [flink-statefun] branch test_please_ignore created (now 486dd1f) - posted by ch...@apache.org on 2021/09/07 06:47:40 UTC, 0 replies.
- [flink-statefun] 01/01: testing123 - posted by ch...@apache.org on 2021/09/07 06:47:41 UTC, 0 replies.
- [flink-statefun] branch test_please_ignore updated: on push because dispatch on branch is tricky - posted by ch...@apache.org on 2021/09/07 06:51:44 UTC, 0 replies.
- [flink-statefun] branch test_please_ignore updated: use html file for clarity - posted by ch...@apache.org on 2021/09/07 06:54:52 UTC, 0 replies.
- [flink-statefun] branch test_please_ignore updated: fix name - posted by ch...@apache.org on 2021/09/07 06:55:33 UTC, 0 replies.
- [flink-statefun] branch test_please_ignore updated (d4869dc -> a38c308) - posted by ch...@apache.org on 2021/09/07 07:03:36 UTC, 0 replies.
- [flink-statefun] 01/02: disable other actions for now - posted by ch...@apache.org on 2021/09/07 07:03:37 UTC, 0 replies.
- [flink-statefun] 02/02: lets try rsync - posted by ch...@apache.org on 2021/09/07 07:03:38 UTC, 0 replies.
- [flink-statefun] branch test_please_ignore updated: v2 - posted by ch...@apache.org on 2021/09/07 07:06:52 UTC, 0 replies.
- [flink] branch master updated (6563270 -> 10eecac) - posted by ro...@apache.org on 2021/09/07 07:58:24 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23457][network] Select a desirable buffer size - posted by pn...@apache.org on 2021/09/07 08:25:26 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23612][table-runtime] Fix compile exception for ROUND function with some numeric input arguments - posted by lz...@apache.org on 2021/09/07 09:12:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23614][table-planner] The resulting scale of TRUNCATE(DECIMAL) is not correct - posted by lz...@apache.org on 2021/09/07 09:13:27 UTC, 0 replies.
- [flink] branch master updated (e55e664 -> 85684e4) - posted by ar...@apache.org on 2021/09/07 10:18:23 UTC, 0 replies.
- [flink] 01/11: [FLINK-24131][tests] Harden leak check in KafkaSinkITCase. - posted by ar...@apache.org on 2021/09/07 10:18:24 UTC, 1 replies.
- [flink] 02/11: [FLINK-24131][datastream] Ensure that SinkWriter#prepareCommit is not called twice for final commit. - posted by ar...@apache.org on 2021/09/07 10:18:25 UTC, 1 replies.
- [flink] 03/11: [FLINK-24131][datastream] Recommit recovered transactions as quickly as possible. - posted by ar...@apache.org on 2021/09/07 10:18:26 UTC, 1 replies.
- [flink] 04/11: [FLINK-24131][datastream] Ensure writer and committer are closed correctly even with Interruptions. - posted by ar...@apache.org on 2021/09/07 10:18:27 UTC, 1 replies.
- [flink] 05/11: [FLINK-24131][connectors/kafka] Ensure kafka writer and producer closed correctly even with Interruptions. - posted by ar...@apache.org on 2021/09/07 10:18:28 UTC, 1 replies.
- [flink] 06/11: [FLINK-24131][runtime] Introduce CheckpointIDCounter#INITIAL_CHECKPOINT_ID. - posted by ar...@apache.org on 2021/09/07 10:18:29 UTC, 1 replies.
- [flink] 07/11: [FLINK-24131][connectors/kafka] Improve debuggability of KafkaWriter. - posted by ar...@apache.org on 2021/09/07 10:18:30 UTC, 1 replies.
- [flink] 08/11: [FLINK-24131][connectors/kafka] Improve handling of committer errors in KafkaCommitter. - posted by ar...@apache.org on 2021/09/07 10:18:31 UTC, 1 replies.
- [flink] 09/11: [FLINK-24131][connectors/kafka] Improve threading model of KafkaWriter. - posted by ar...@apache.org on 2021/09/07 10:18:32 UTC, 1 replies.
- [flink] 10/11: [FLINK-24131][connectors/kafka] Fix KafkaWriter currentSendTime metric. - posted by ar...@apache.org on 2021/09/07 10:18:33 UTC, 1 replies.
- [flink] 11/11: [FLINK-24151][connectors/kafka] Add concurrent checkpoint test to KafkaSinkITCase. - posted by ar...@apache.org on 2021/09/07 10:18:34 UTC, 1 replies.
- [flink] branch release-1.12 updated: [FLINK-22198][connector/kafka] Disable log deletion on Kafka broker in Kafka table connector tests (#17158) - posted by ja...@apache.org on 2021/09/07 10:24:13 UTC, 0 replies.
- [flink] branch master updated (85684e4 -> 05e0149) - posted by ch...@apache.org on 2021/09/07 10:24:32 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-22971][tests] Bump testcontainers to 1.16.0 - posted by ch...@apache.org on 2021/09/07 10:24:53 UTC, 0 replies.
- [flink] branch master updated (05e0149 -> 76aab58) - posted by tw...@apache.org on 2021/09/07 10:34:50 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Update Window TopN SQL example - posted by tw...@apache.org on 2021/09/07 10:41:04 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] Update Window TopN SQL example - posted by tw...@apache.org on 2021/09/07 10:42:45 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24165][datastream] Fix typo in javadoc of KeyContext class - posted by ja...@apache.org on 2021/09/07 11:17:37 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24181][build][docs] Bump JSoup to 1.14.2 - posted by ch...@apache.org on 2021/09/07 11:24:18 UTC, 0 replies.
- [flink] branch release-1.14 updated (bf96ba3 -> 510c2fc) - posted by ar...@apache.org on 2021/09/07 12:07:52 UTC, 0 replies.
- [flink] branch master updated (535bb23 -> ef082c9) - posted by ar...@apache.org on 2021/09/07 13:17:05 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector - posted by ar...@apache.org on 2021/09/07 13:19:30 UTC, 0 replies.
- [flink] branch release-1.14 updated (510c2fc -> 3c20439) - posted by ro...@apache.org on 2021/09/07 13:46:59 UTC, 0 replies.
- [flink] 01/02: [hotfix][tests] Parameterize PartiallyFinishedSourcesITCase with failover strategy - posted by ro...@apache.org on 2021/09/07 13:47:00 UTC, 0 replies.
- [flink] 02/02: [FLINK-24162][tests] Check MAX_WATERMARK per attempt in FLIP-147 tests - posted by ro...@apache.org on 2021/09/07 13:47:01 UTC, 0 replies.
- [flink] branch master updated (0dc46ca -> 74cdcd7) - posted by ch...@apache.org on 2021/09/07 14:04:21 UTC, 0 replies.
- [flink] branch release-1.14 updated (3c20439 -> 6472d5b) - posted by ch...@apache.org on 2021/09/07 14:07:19 UTC, 0 replies.
- [flink] 01/03: [hotfix][yarn-tests] Fixes path definition for local YARN-test working directory artifact collection - posted by ch...@apache.org on 2021/09/07 14:07:20 UTC, 2 replies.
- [flink] 02/03: [hotfix][yarn-tests] Replaces runtime by timestamp - posted by ch...@apache.org on 2021/09/07 14:07:21 UTC, 2 replies.
- [flink] 03/03: [FLINK-23611][yarn-tests] Disables INFO log messages coming from YARN's ResourceLocalizationService - posted by ch...@apache.org on 2021/09/07 14:07:22 UTC, 2 replies.
- [flink] branch release-1.13 updated (c7ccd24 -> 30fca11) - posted by ch...@apache.org on 2021/09/07 14:07:44 UTC, 0 replies.
- [flink] branch release-1.12 updated (b9dc04e -> c1844b1) - posted by ch...@apache.org on 2021/09/07 14:09:57 UTC, 0 replies.
- [flink] branch master updated (74cdcd7 -> 9136c40) - posted by se...@apache.org on 2021/09/07 14:32:08 UTC, 0 replies.
- [flink-web] branch asf-site updated: Blog post "Implement custom source connector for Table API and SQL" - posted by ch...@apache.org on 2021/09/07 14:54:23 UTC, 0 replies.
- [flink-web] branch asf-site updated: Rebuild website - posted by ch...@apache.org on 2021/09/07 14:55:18 UTC, 1 replies.
- [flink] branch release-1.13 updated (30fca11 -> 57efc69) - posted by se...@apache.org on 2021/09/07 15:12:34 UTC, 0 replies.
- [flink] 01/04: [hotfix] Remove outdated JavaDocs in SourceFunction about deprecated TimeCharacteristic - posted by se...@apache.org on 2021/09/07 15:12:35 UTC, 0 replies.
- [flink] 02/04: [hotfix] Deduplicate JavaDocs in SourceFunction - posted by se...@apache.org on 2021/09/07 15:12:36 UTC, 0 replies.
- [flink] 03/04: [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange. - posted by se...@apache.org on 2021/09/07 15:12:37 UTC, 0 replies.
- [flink] 04/04: [FLINK-23527][core] Clarify semantics of SourceFunction.cancel() with respect to thread interruptions. - posted by se...@apache.org on 2021/09/07 15:12:38 UTC, 0 replies.
- [flink-web] branch asf-site updated (06b799e -> 899a72f) - posted by tw...@apache.org on 2021/09/07 15:44:13 UTC, 0 replies.
- [flink-web] 01/04: Revert "Blog post "Implement custom source connector for Table API and SQL"" - posted by tw...@apache.org on 2021/09/07 15:44:14 UTC, 0 replies.
- [flink-web] 02/04: Revert "Rebuild website" - posted by tw...@apache.org on 2021/09/07 15:44:15 UTC, 0 replies.
- [flink-web] 03/04: Add blog post "Implementing a Custom Source Connector for Table API and SQL" - posted by tw...@apache.org on 2021/09/07 15:44:16 UTC, 0 replies.
- [flink] branch master updated (9136c40 -> 5565590) - posted by di...@apache.org on 2021/09/08 01:42:25 UTC, 0 replies.
- [flink] 01/02: [FLINK-24137][python] Add more logs during starting up Python worker - posted by di...@apache.org on 2021/09/08 01:42:26 UTC, 1 replies.
- [flink] 02/02: [FLINK-24137][python][tests] Upload logs for PyFlink tests - posted by di...@apache.org on 2021/09/08 01:42:27 UTC, 1 replies.
- [flink] branch release-1.14 updated (6472d5b -> 6b4abd5) - posted by di...@apache.org on 2021/09/08 01:43:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24115][docs] Fix outdated SQL Temporal Join example (#17121) - posted by ja...@apache.org on 2021/09/08 02:42:48 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24115][docs] Fix outdated SQL Temporal Join example (#17124) - posted by ja...@apache.org on 2021/09/08 02:43:23 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24115][docs] Fix outdated SQL Temporal Join example (#17122) - posted by ja...@apache.org on 2021/09/08 02:43:42 UTC, 0 replies.
- [flink] branch master updated (9dfb1af -> 6eff01b) - posted by ga...@apache.org on 2021/09/08 03:10:53 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase - posted by ga...@apache.org on 2021/09/08 03:12:54 UTC, 0 replies.
- [flink] branch master updated (6eff01b -> 371f247) - posted by ta...@apache.org on 2021/09/08 03:47:23 UTC, 0 replies.
- [flink] branch master updated (371f247 -> d2007b7) - posted by ta...@apache.org on 2021/09/08 07:18:33 UTC, 0 replies.
- [flink] branch release-1.14 updated (3a8a6b0 -> 602a177) - posted by ta...@apache.org on 2021/09/08 07:19:43 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-23949][checkpoint] Fix first incremental checkpoint after a savepoint degenerate into a full checkpoint - posted by ta...@apache.org on 2021/09/08 07:20:06 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-23949][checkpoint] Fix first incremental checkpoint after a savepoint degenerate into a full checkpoint - posted by ta...@apache.org on 2021/09/08 07:21:04 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24183][legal] Add aws-java-sdk-s3 to source NOTICE - posted by ch...@apache.org on 2021/09/08 08:16:33 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24183][legal] Add aws-java-sdk-s3 to source NOTICE - posted by ch...@apache.org on 2021/09/08 08:17:24 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24183][legal] Add aws-java-sdk-s3 to source NOTICE - posted by ch...@apache.org on 2021/09/08 08:18:07 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-24183][legal] Add aws-java-sdk-s3 to source NOTICE - posted by ch...@apache.org on 2021/09/08 08:18:30 UTC, 0 replies.
- [flink] branch release-1.12 updated: Revert "[FLINK-23949][checkpoint] Fix first incremental checkpoint after a savepoint degenerate into a full checkpoint" - posted by ta...@apache.org on 2021/09/08 08:24:01 UTC, 0 replies.
- [flink] branch master updated (92812c0 -> 37a0e91) - posted by ch...@apache.org on 2021/09/08 08:31:40 UTC, 0 replies.
- [flink] branch release-1.14 updated (a4cd43b -> adb9009) - posted by ch...@apache.org on 2021/09/08 08:32:00 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24170][build] Use maven-directory-plugin:directory-of goal - posted by ch...@apache.org on 2021/09/08 08:32:22 UTC, 0 replies.
- [flink] branch master updated (37a0e91 -> 7e91e82) - posted by ch...@apache.org on 2021/09/08 08:41:38 UTC, 0 replies.
- [flink] branch release-1.14 updated (adb9009 -> 7818495) - posted by ch...@apache.org on 2021/09/08 08:42:14 UTC, 0 replies.
- [flink] branch master updated (7e91e82 -> 7c65adb) - posted by ch...@apache.org on 2021/09/08 11:12:30 UTC, 0 replies.
- [flink] branch master updated (7c65adb -> 73db546) - posted by ch...@apache.org on 2021/09/08 11:23:34 UTC, 0 replies.
- [flink] branch master updated (73db546 -> 5f1a991) - posted by ar...@apache.org on 2021/09/08 12:31:16 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector - posted by ar...@apache.org on 2021/09/08 13:51:38 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23807][connector/testing-framework] Use RestClient to detect TaskManager failure in test environments - posted by ar...@apache.org on 2021/09/08 13:52:07 UTC, 0 replies.
- [flink] branch master updated (5f1a991 -> ab9b85b) - posted by ar...@apache.org on 2021/09/08 14:00:47 UTC, 0 replies.
- [flink] branch release-1.14 updated (21fd895 -> f907ef2) - posted by ch...@apache.org on 2021/09/08 14:25:07 UTC, 0 replies.
- [flink] branch release-1.13 updated (d8166f2 -> 9ac8121) - posted by ch...@apache.org on 2021/09/08 14:25:32 UTC, 0 replies.
- [flink] branch master updated: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest - posted by ro...@apache.org on 2021/09/08 15:34:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels - posted by ga...@apache.org on 2021/09/08 15:49:58 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels - posted by ga...@apache.org on 2021/09/08 15:51:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase - posted by ga...@apache.org on 2021/09/08 16:03:34 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase - posted by ga...@apache.org on 2021/09/08 16:07:33 UTC, 0 replies.
- [flink] branch master updated (c740f92 -> 271a346) - posted by da...@apache.org on 2021/09/08 20:35:11 UTC, 0 replies.
- [flink] 01/02: [FLINK-24041][connectors] First draft of API, Add DynamoDB sink to verify API, Add Firehose sink, Refactor to use FLIP-143: Unified Sink API, Increase robustness for flush, Add license header, Update JavaDoc comments - posted by da...@apache.org on 2021/09/08 20:35:12 UTC, 0 replies.
- [flink] 02/02: [FLINK-24041][connectors] Added unit and integration tests for the generic sink implementation. Corrected an inconsistency that led to prepareCommit() not fully flushing the entire contents of the buffer at checkpoint time, removed catching of RuntimeExceptions in concrete implementations, added @PublicEvolving to classes, rearranged cosmetics of classes, corrected spelling errors, changed tests to reflect removal of RuntimeException, added checks on the parameters passed to AsyncSinkWrite [...] - posted by da...@apache.org on 2021/09/08 20:35:13 UTC, 0 replies.
- [flink] branch master updated (271a346 -> 7b43677) - posted by ja...@apache.org on 2021/09/09 02:42:03 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24196][docs-zh] Translate "EXPLAIN Statements" page of "SQL" into Chinese (#17195) - posted by ja...@apache.org on 2021/09/09 02:48:31 UTC, 0 replies.
- [flink] branch master updated (125cb70 -> d4c483f) - posted by jq...@apache.org on 2021/09/09 03:34:58 UTC, 0 replies.
- [flink] branch master updated (d4c483f -> 1702c9e) - posted by pn...@apache.org on 2021/09/09 03:53:24 UTC, 0 replies.
- [flink] branch master updated (1702c9e -> 16ab8b4) - posted by pn...@apache.org on 2021/09/09 04:17:55 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24209][jdbc][build] Add test scope - posted by ch...@apache.org on 2021/09/09 05:24:34 UTC, 0 replies.
- [flink] branch master updated (16ab8b4 -> 69fefdd) - posted by ch...@apache.org on 2021/09/09 05:25:22 UTC, 0 replies.
- [flink] 01/03: [FLINK-24193][tests] Add ClassLoaderExtension - posted by ch...@apache.org on 2021/09/09 05:25:23 UTC, 0 replies.
- [flink] 02/03: [FLINK-24193][rest][tests] Migrate tests to ClassLoaderExtension - posted by ch...@apache.org on 2021/09/09 05:25:24 UTC, 0 replies.
- [flink] 03/03: [hotfix][rest][tests] Cleanup - posted by ch...@apache.org on 2021/09/09 05:25:25 UTC, 0 replies.
- [flink] branch master updated (69fefdd -> a1a645a) - posted by yu...@apache.org on 2021/09/09 07:00:22 UTC, 0 replies.
- [flink] branch master updated (a1a645a -> c69193b) - posted by ch...@apache.org on 2021/09/09 07:45:48 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24031] Extend vcs.xml - posted by ch...@apache.org on 2021/09/09 07:46:10 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix] Add .eslintcache to .gitignore - posted by ch...@apache.org on 2021/09/09 07:49:15 UTC, 0 replies.
- [flink] branch release-1.13 updated: [hotfix] Add .eslintcache to .gitignore - posted by ch...@apache.org on 2021/09/09 07:50:27 UTC, 0 replies.
- [flink] branch master updated (c69193b -> 1980481) - posted by ar...@apache.org on 2021/09/09 07:59:59 UTC, 0 replies.
- [flink] branch release-1.14 updated (adc9d43 -> 8e982b7) - posted by ar...@apache.org on 2021/09/09 08:09:15 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest - posted by ro...@apache.org on 2021/09/09 08:48:16 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API - posted by di...@apache.org on 2021/09/09 09:34:24 UTC, 0 replies.
- [flink] branch master updated (60046b1 -> 0b4855f) - posted by di...@apache.org on 2021/09/09 12:25:24 UTC, 0 replies.
- [flink] branch release-1.14 updated (e859af6 -> 2db50d6) - posted by di...@apache.org on 2021/09/09 12:25:47 UTC, 0 replies.
- [flink] 01/02: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode - posted by di...@apache.org on 2021/09/09 12:25:48 UTC, 0 replies.
- [flink] 02/02: [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loopback mode - posted by di...@apache.org on 2021/09/09 12:25:49 UTC, 0 replies.
- [flink] branch master updated (0b4855f -> 2e721ab) - posted by ch...@apache.org on 2021/09/09 12:37:06 UTC, 0 replies.
- [flink] branch release-1.14 updated (2db50d6 -> 2459a3c) - posted by ch...@apache.org on 2021/09/09 12:38:04 UTC, 0 replies.
- [flink] 01/02: [FLINK-24213][qs] Introduce factory for established connection - posted by ch...@apache.org on 2021/09/09 12:38:05 UTC, 2 replies.
- [flink] 02/02: [FLINK-24213][qs] Use single lock in ServerConnection - posted by ch...@apache.org on 2021/09/09 12:38:06 UTC, 2 replies.
- [flink] branch master updated: [FLINK-23836][doc-zh] Translate "Execution Configuration" page into Chinese (#16865) - posted by ja...@apache.org on 2021/09/09 14:38:51 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified Sink API, Increase robustness for flush, Add license header, Update JavaDoc comments, added unit and integration tests for the generic sink implementation. Corrected an inconsistency that led to prepareCommit() not fully flushing the entire contents of the buffer at checkpoint time, removed catching of RuntimeExceptions in concrete implementations, added @PublicEvolving to classes, rearranged cosmetics of classes, correct [...] - posted by da...@apache.org on 2021/09/09 14:42:13 UTC, 0 replies.
- [flink] branch master updated (76ee66f -> 713f066) - posted by se...@apache.org on 2021/09/09 15:12:04 UTC, 0 replies.
- [flink] branch release-1.14 updated (2459a3c -> c56ecf3) - posted by se...@apache.org on 2021/09/09 15:43:45 UTC, 0 replies.
- [flink] 01/08: [FLINK-22357][core] Upgrades API stability of unified source API to @Public (= stable). - posted by se...@apache.org on 2021/09/09 15:43:46 UTC, 0 replies.
- [flink] 02/08: [hotfix][core] Improve/fix JavaDocs in SplitEnumeratorContext class. - posted by se...@apache.org on 2021/09/09 15:43:47 UTC, 0 replies.
- [flink] 03/08: [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources. - posted by se...@apache.org on 2021/09/09 15:43:48 UTC, 0 replies.
- [flink] 04/08: [hotfix][connectors] Deduplicate config default in FutureCompletingBlockingQueue. - posted by se...@apache.org on 2021/09/09 15:43:49 UTC, 0 replies.
- [flink] 05/08: [hotfix] Remove outdated JavaDocs in SourceFunction about deprecated TimeCharacteristic - posted by se...@apache.org on 2021/09/09 15:43:50 UTC, 0 replies.
- [flink] 06/08: [hotfix] Deduplicate JavaDocs in SourceFunction - posted by se...@apache.org on 2021/09/09 15:43:51 UTC, 0 replies.
- [flink] 07/08: [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange. - posted by se...@apache.org on 2021/09/09 15:43:52 UTC, 0 replies.
- [flink] 08/08: [FLINK-23527][core] Clarify semantics of SourceFunction.cancel() with respect to thread interruptions. - posted by se...@apache.org on 2021/09/09 15:43:53 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-22901][table-planner-blink] Introduce getUpsertKeys in FlinkRelMetadataQuery - posted by lz...@apache.org on 2021/09/10 01:46:20 UTC, 0 replies.
- [flink] branch master updated (713f066 -> 0cecdca) - posted by di...@apache.org on 2021/09/10 02:07:23 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23345][python] Limits the version requests to 2.26.0 or above - posted by di...@apache.org on 2021/09/10 02:07:41 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-23345][python] Limits the version requests to 2.26.0 or above - posted by di...@apache.org on 2021/09/10 02:07:57 UTC, 0 replies.
- [flink] branch release-1.12 updated (afcba03 -> 07a3f66) - posted by di...@apache.org on 2021/09/10 02:31:34 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode - posted by di...@apache.org on 2021/09/10 02:31:54 UTC, 0 replies.
- [flink] branch release-1.10 updated: [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode - posted by di...@apache.org on 2021/09/10 02:32:12 UTC, 0 replies.
- [flink] branch master updated (0cecdca -> 412c45f) - posted by xt...@apache.org on 2021/09/10 02:58:17 UTC, 0 replies.
- [flink] branch release-1.14 updated (3621b00 -> 4e732ad) - posted by xt...@apache.org on 2021/09/10 02:59:33 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure after test framework was fixed. - posted by xt...@apache.org on 2021/09/10 03:01:08 UTC, 0 replies.
- [flink] branch master updated (412c45f -> d93682c) - posted by go...@apache.org on 2021/09/10 03:22:31 UTC, 0 replies.
- [flink] branch release-1.13 updated (53f79ea -> 4db7f4c) - posted by ch...@apache.org on 2021/09/10 05:29:17 UTC, 0 replies.
- [flink] branch release-1.12 updated (07a3f66 -> de69c3e) - posted by ch...@apache.org on 2021/09/10 05:29:54 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jvm - posted by hx...@apache.org on 2021/09/10 06:04:32 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jvm - posted by hx...@apache.org on 2021/09/10 06:05:30 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-22971][tests] Bump testcontainers to 1.16.0 - posted by ch...@apache.org on 2021/09/10 07:20:17 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-22971][tests] Bump testcontainers to 1.16.0 - posted by ch...@apache.org on 2021/09/10 07:22:56 UTC, 0 replies.
- [flink] branch release-1.14 updated (d9e6abf -> df3b723) - posted by dw...@apache.org on 2021/09/10 09:19:22 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-16346][tests] Remove timeout - posted by ch...@apache.org on 2021/09/10 11:11:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints - posted by dw...@apache.org on 2021/09/10 12:08:21 UTC, 0 replies.
- [flink] branch master updated (f5ef5ae -> d79bb47) - posted by ar...@apache.org on 2021/09/10 12:52:35 UTC, 0 replies.
- [flink] 01/04: [FLINK-23864][docs] Add flink-connector-pulsar module to flink-docs, auto generate the config document. - posted by ar...@apache.org on 2021/09/10 12:52:36 UTC, 1 replies.
- [flink] 02/04: [FLINK-23864][connector/pulsar] Release Pulsar Message if user enable poolMessage option. - posted by ar...@apache.org on 2021/09/10 12:52:37 UTC, 1 replies.
- [flink] 03/04: [FLINK-23864][connector/pulsar] Remove PULSAR_AUTO_UPDATE_PARTITIONS option. - posted by ar...@apache.org on 2021/09/10 12:52:38 UTC, 1 replies.
- [flink] 04/04: [FLINK-23864][docs] Add pulsar connector document (Chinese & English). - posted by ar...@apache.org on 2021/09/10 12:52:39 UTC, 1 replies.
- [flink] branch release-1.14 updated (df3b723 -> b32e6a6) - posted by ar...@apache.org on 2021/09/10 12:53:31 UTC, 0 replies.
- [flink] branch master updated (d79bb47 -> ed3b613) - posted by se...@apache.org on 2021/09/10 14:07:24 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix] Improve language for error message when checkpoint is declined due to some tasks being finished already. - posted by se...@apache.org on 2021/09/10 14:09:17 UTC, 0 replies.
- [flink] branch master updated (ed3b613 -> fdf40d2) - posted by ga...@apache.org on 2021/09/13 02:39:06 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished - posted by ga...@apache.org on 2021/09/13 02:39:28 UTC, 0 replies.
- [flink] branch release-1.13 updated (1af7731 -> 763ac52) - posted by jq...@apache.org on 2021/09/13 02:43:53 UTC, 0 replies.
- [flink] 01/02: [hotfix][connector/common] Expose splitFinishedHook in SplitFetcher for fine-grained testing - posted by jq...@apache.org on 2021/09/13 02:43:54 UTC, 0 replies.
- [flink] 02/02: [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher - posted by jq...@apache.org on 2021/09/13 02:43:55 UTC, 0 replies.
- [flink] branch master updated: [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode - posted by di...@apache.org on 2021/09/13 03:11:50 UTC, 0 replies.
- [flink] branch release-1.13 updated (763ac52 -> 978d907) - posted by di...@apache.org on 2021/09/13 03:17:41 UTC, 0 replies.
- [flink] 01/02: [FLINK-24137][python][tests] Upload logs for PyFlink tests - posted by di...@apache.org on 2021/09/13 03:17:42 UTC, 0 replies.
- [flink] 02/02: [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode - posted by di...@apache.org on 2021/09/13 03:17:43 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode - posted by di...@apache.org on 2021/09/13 03:18:15 UTC, 0 replies.
- [flink] branch master updated (e3d7167 -> 9f1c2d8) - posted by di...@apache.org on 2021/09/13 03:22:28 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24244][python] Logging whether it's executed in loopback mode - posted by di...@apache.org on 2021/09/13 03:22:46 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24220][doc]Translate "RESET Statements" page of "SQL" into Chinese (#17224) - posted by ja...@apache.org on 2021/09/13 05:43:25 UTC, 0 replies.
- [flink] branch release-1.12 updated (d249094 -> 16c2bcc) - posted by di...@apache.org on 2021/09/13 05:59:03 UTC, 0 replies.
- [flink] branch master updated (33641f5 -> 77f10a5) - posted by ga...@apache.org on 2021/09/13 06:04:39 UTC, 0 replies.
- [flink] branch release-1.11 updated: [FLINK-24260][python] Limit requests to 2.26.0 or above only for python 3.6+ - posted by di...@apache.org on 2021/09/13 06:04:58 UTC, 0 replies.
- [flink] branch release-1.10 updated (3d95391 -> cb26a2a) - posted by di...@apache.org on 2021/09/13 06:07:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel - posted by pn...@apache.org on 2021/09/13 07:24:21 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel - posted by pn...@apache.org on 2021/09/13 07:25:09 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24245][python] Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in PyFlink - posted by hx...@apache.org on 2021/09/13 07:28:30 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24245][python] Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in PyFlink - posted by hx...@apache.org on 2021/09/13 07:29:22 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24221][docs-zh] Translate "JAR Statements" page of "SQL" into Chinese (#17225) - posted by ja...@apache.org on 2021/09/13 10:14:35 UTC, 0 replies.
- [flink] branch master updated (0313c40 -> 7901f26) - posted by pn...@apache.org on 2021/09/13 10:16:23 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23458][docs] Added the network buffer documentation along with the buffer debloat doc - posted by pn...@apache.org on 2021/09/13 10:16:50 UTC, 0 replies.
- [flink] branch master updated (7901f26 -> a9448d2) - posted by di...@apache.org on 2021/09/13 12:23:22 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24243][python] Cleanup code to use latest API to avoid warnings - posted by di...@apache.org on 2021/09/13 12:23:41 UTC, 0 replies.
- [flink] branch master updated (a9448d2 -> 8d94540) - posted by dw...@apache.org on 2021/09/13 12:51:39 UTC, 0 replies.
- [flink] branch master updated (8d94540 -> 6899a44) - posted by tw...@apache.org on 2021/09/13 12:57:22 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24098] Document FLIP-147 capabiliites and limitations - posted by dw...@apache.org on 2021/09/13 13:01:04 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Adding new sources on overview pages - posted by dw...@apache.org on 2021/09/13 16:02:52 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] Adding new sources on overview pages - posted by dw...@apache.org on 2021/09/13 16:03:29 UTC, 0 replies.
- [flink-statefun] branch master updated: [hotfix][docs] drop unused io overview - posted by sj...@apache.org on 2021/09/13 20:05:36 UTC, 0 replies.
- [flink-statefun] branch master updated: [hotfix][docs] fix documentation build - posted by sj...@apache.org on 2021/09/13 22:35:37 UTC, 0 replies.
- [flink] branch master updated (c81b831 -> 5474f89) - posted by xt...@apache.org on 2021/09/14 01:40:14 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24206][connector/pulsar] Close the pulsar client properly. - posted by xt...@apache.org on 2021/09/14 01:40:36 UTC, 0 replies.
- [flink] branch master updated (5474f89 -> d532f5f) - posted by xt...@apache.org on 2021/09/14 01:58:11 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24212][k8s]fix the problem that kerberos krb5.conf file is mounted as empty directory, not the expected file - posted by xt...@apache.org on 2021/09/14 01:58:32 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24219][docs-zh] Translate "SET Statements" page of "SQL" into Chinese (#17223) - posted by ja...@apache.org on 2021/09/14 02:33:39 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (#17173) (#17252) - posted by yu...@apache.org on 2021/09/14 03:10:34 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (#17173) (#17257) - posted by yu...@apache.org on 2021/09/14 03:11:12 UTC, 0 replies.
- [flink] branch release-1.14 updated (da82cb1 -> b26f7e7) - posted by jq...@apache.org on 2021/09/14 05:35:56 UTC, 0 replies.
- [flink] branch master updated (94c5077 -> e4b2f0c) - posted by di...@apache.org on 2021/09/14 06:37:01 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24267][python][docs] Update the example tutorial to use latest API - posted by di...@apache.org on 2021/09/14 06:37:23 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24276][python] Avoid confusing output when executing in loopback mode - posted by di...@apache.org on 2021/09/14 06:39:59 UTC, 0 replies.
- [flink] branch master updated (e4b2f0c -> cc2ebe5) - posted by di...@apache.org on 2021/09/14 06:40:22 UTC, 0 replies.
- [flink] branch master updated (cc2ebe5 -> 94d0bea) - posted by ga...@apache.org on 2021/09/14 07:04:01 UTC, 0 replies.
- [flink] 01/02: [hotfix][connector] Use null to replace empty pending transaction in 2pc sink - posted by ga...@apache.org on 2021/09/14 07:04:02 UTC, 1 replies.
- [flink] 02/02: [FLINK-24266][checkpoint] Log improvement for aborting checkpoint due to tasks are finishing - posted by ga...@apache.org on 2021/09/14 07:04:03 UTC, 1 replies.
- [flink] branch release-1.14 updated (574e80f -> 753947a) - posted by ga...@apache.org on 2021/09/14 07:04:29 UTC, 0 replies.
- [flink] branch master updated (94d0bea -> 2815aad) - posted by tw...@apache.org on 2021/09/14 07:34:33 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] Fix output of test job - posted by tw...@apache.org on 2021/09/14 07:39:14 UTC, 0 replies.
- [flink] branch master updated (2815aad -> d92540c) - posted by ro...@apache.org on 2021/09/14 07:44:36 UTC, 0 replies.
- [flink] 01/03: [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency - posted by ro...@apache.org on 2021/09/14 07:44:37 UTC, 1 replies.
- [flink] 02/03: [FLINK-23607][state/changelog] Cleanup dependencies of DSTL DFS - posted by ro...@apache.org on 2021/09/14 07:44:38 UTC, 1 replies.
- [flink] 03/03: [FLINK-23607][state/changelog] Document checkpointing.changelog in pom.xml - posted by ro...@apache.org on 2021/09/14 07:44:39 UTC, 1 replies.
- [flink] branch release-1.13 updated (36a33e6 -> 801b1c4) - posted by tw...@apache.org on 2021/09/14 07:49:38 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest - posted by ro...@apache.org on 2021/09/14 07:58:02 UTC, 0 replies.
- [flink-statefun] branch master updated (d18a99e -> d944139) - posted by ig...@apache.org on 2021/09/14 09:54:40 UTC, 0 replies.
- [flink] branch master updated: [FLINK-22275][table] Support random past for timestamp types in datagen connector (#15703) - posted by ja...@apache.org on 2021/09/14 13:01:01 UTC, 0 replies.
- [flink] branch release-1.14 updated (918fde8 -> d008496) - posted by ro...@apache.org on 2021/09/14 13:29:04 UTC, 0 replies.
- [flink] branch master updated (f74db4b -> 724fb3d) - posted by dw...@apache.org on 2021/09/14 19:46:40 UTC, 0 replies.
- [flink] branch master updated (724fb3d -> 2ae7106) - posted by dw...@apache.org on 2021/09/14 19:51:11 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24282][connectors/kafka] Make topic selector for KafkaSink serializable - posted by dw...@apache.org on 2021/09/14 19:52:41 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription. This would make sure Pulsar won't treat the flink reader as a shared consumer. - posted by dw...@apache.org on 2021/09/14 19:53:27 UTC, 0 replies.
- [flink] annotated tag release-1.14.0-rc1 updated (5f2ec45 -> fd84390) - posted by dw...@apache.org on 2021/09/14 20:11:01 UTC, 0 replies.
- [flink] annotated tag release-1.14.0-rc1 updated (fd84390 -> 1fb1031) - posted by dw...@apache.org on 2021/09/14 21:07:54 UTC, 0 replies.
- [flink] 01/01: Commit for release 1.14.0 - posted by dw...@apache.org on 2021/09/14 21:07:55 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24139][table-planner] Push down more predicates through Join in stream mode - posted by go...@apache.org on 2021/09/15 03:11:30 UTC, 0 replies.
- svn commit: r49941 - in /dev/flink/flink-1.14.0-rc1: ./ python/ - posted by dw...@apache.org on 2021/09/15 06:07:27 UTC, 0 replies.
- [flink] branch master updated (f366f77 -> 113956f) - posted by dw...@apache.org on 2021/09/15 07:49:49 UTC, 0 replies.
- [flink] 01/02: [FLINK-21589][docs] Document table pipeline upgrades - posted by dw...@apache.org on 2021/09/15 07:49:50 UTC, 3 replies.
- [flink] 02/02: [hotfix][docs] Add glossary entry for 'Table program' - posted by dw...@apache.org on 2021/09/15 07:49:51 UTC, 2 replies.
- [flink] branch release-1.14 updated (5f2ec45 -> 86f96cd) - posted by dw...@apache.org on 2021/09/15 07:50:44 UTC, 0 replies.
- [flink] branch release-1.13 updated (cf78dc6 -> d4952e9) - posted by dw...@apache.org on 2021/09/15 07:51:39 UTC, 0 replies.
- [flink] branch release-1.12 updated (16c2bcc -> 4adfa04) - posted by dw...@apache.org on 2021/09/15 10:42:23 UTC, 0 replies.
- [flink] 02/02: [hotfix] Fix links in gcs docs - posted by dw...@apache.org on 2021/09/15 10:42:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24217][docs-zh] Translate "LOAD Statements" page of "SQL" into Chinese (#17221) - posted by ja...@apache.org on 2021/09/15 11:52:32 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24059][Connectors/Common][test] Allow SourceReaderTestBase.NUM_SPLITS to be overridden (#17064) - posted by jq...@apache.org on 2021/09/15 12:41:41 UTC, 0 replies.
- [flink] branch master updated (6f07196 -> 2da73ed) - posted by jq...@apache.org on 2021/09/15 12:46:17 UTC, 0 replies.
- [flink] branch master updated (2da73ed -> 583e20d) - posted by da...@apache.org on 2021/09/15 19:15:36 UTC, 0 replies.
- [flink] 01/02: [FLINK-24234][connectors] Added byte based flushing for AsyncSinkWriter - posted by da...@apache.org on 2021/09/15 19:15:37 UTC, 0 replies.
- [flink] 02/02: [FLINK-24234][connectors] Time based flushing for AsyncSinkWriter - posted by da...@apache.org on 2021/09/15 19:15:38 UTC, 0 replies.
- [flink] branch release-1.13 updated (d4952e9 -> fe19395) - posted by lz...@apache.org on 2021/09/16 02:31:17 UTC, 0 replies.
- [flink] branch master updated (583e20d -> 647103c) - posted by ja...@apache.org on 2021/09/16 05:28:13 UTC, 0 replies.
- [flink] branch master updated (647103c -> 7487c30) - posted by hx...@apache.org on 2021/09/16 07:39:25 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24305][python] Limit the protobuf version<3.18 - posted by hx...@apache.org on 2021/09/16 07:41:24 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24305][python] Limit the protobuf version<3.18 - posted by hx...@apache.org on 2021/09/16 07:42:48 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-24305][python] Limit the protobuf version<3.18 - posted by hx...@apache.org on 2021/09/16 07:44:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test - posted by pn...@apache.org on 2021/09/16 08:10:39 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test - posted by pn...@apache.org on 2021/09/16 08:12:49 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test - posted by pn...@apache.org on 2021/09/16 08:13:09 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test - posted by pn...@apache.org on 2021/09/16 08:13:45 UTC, 0 replies.
- [flink] branch master updated: [hotfix] Fix a typo in 'estimatedTimeToConsume(r)BuffersMs' - posted by dw...@apache.org on 2021/09/16 12:20:42 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix] Fix a typo in 'estimatedTimeToConsume(r)BuffersMs' - posted by dw...@apache.org on 2021/09/16 12:21:01 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector. - posted by dw...@apache.org on 2021/09/16 13:21:58 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-24256][sdk] Add a JavaScript SDK - posted by ig...@apache.org on 2021/09/16 15:09:52 UTC, 0 replies.
- [flink-statefun-playground] branch dev updated: [FLINK-24301] use Async transport on all statefun playground examples - posted by sj...@apache.org on 2021/09/16 20:57:39 UTC, 0 replies.
- [flink-statefun-playground] branch release-3.1 updated: [FLINK-24301] use Async transport on all statefun playground examples - posted by sj...@apache.org on 2021/09/16 20:58:47 UTC, 0 replies.
- [flink-statefun-playground] branch dev updated (dffc594 -> cccd603) - posted by sj...@apache.org on 2021/09/16 20:59:38 UTC, 0 replies.
- [flink] branch master updated (b608620 -> c643241) - posted by lz...@apache.org on 2021/09/17 02:00:15 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23180] Do not initialize checkpoint base locations when checkpointing is disabled - posted by ta...@apache.org on 2021/09/17 02:05:56 UTC, 0 replies.
- [flink] branch master updated (164a59a -> 3b6b522) - posted by yu...@apache.org on 2021/09/17 02:15:59 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix] Update frontend-maven-plugin - posted by se...@apache.org on 2021/09/17 10:02:27 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24317][python][tests] Optimize the implementation of Top2 in test_flat_aggregate - posted by hx...@apache.org on 2021/09/17 11:13:06 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24317][python][tests] Optimize the implementation of Top2 in test_flat_aggregate - posted by hx...@apache.org on 2021/09/17 11:14:05 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24317][python][tests] Optimize the implementation of Top2 in test_flat_aggregate - posted by hx...@apache.org on 2021/09/17 11:15:57 UTC, 0 replies.
- [flink] branch master updated (8debdd0 -> 4a89552) - posted by rm...@apache.org on 2021/09/17 13:18:36 UTC, 0 replies.
- [flink] branch release-1.14 updated (c05dd396 -> 5dd99ed) - posted by rm...@apache.org on 2021/09/17 13:19:53 UTC, 0 replies.
- [flink] 01/03: [hotfix][connectors/kafka] Remove unused code from KafkaDynamicSink - posted by rm...@apache.org on 2021/09/17 13:19:54 UTC, 0 replies.
- [flink] 02/03: [FLINK-24281][connectors/kafka] Only allow KafkaSinkBuilder creation with KafkaSink.builder() - posted by rm...@apache.org on 2021/09/17 13:19:55 UTC, 0 replies.
- [flink] 03/03: [FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink - posted by rm...@apache.org on 2021/09/17 13:19:56 UTC, 0 replies.
- [flink] branch master updated (4a89552 -> 8664b36) - posted by rm...@apache.org on 2021/09/17 13:23:31 UTC, 0 replies.
- [flink] branch release-1.14 updated (5dd99ed -> d818ccb) - posted by rm...@apache.org on 2021/09/17 13:31:14 UTC, 0 replies.
- [flink] 01/02: [FLINK-24292][connectors/kafka] Use KafkaSink in examples instead of FlinkKafkaProducer - posted by rm...@apache.org on 2021/09/17 13:31:15 UTC, 0 replies.
- [flink] 02/02: [hotfix][connectors/kafka] Rename EventDeSerializer to EventDeSerializationSchema in examples - posted by rm...@apache.org on 2021/09/17 13:31:16 UTC, 0 replies.
- [flink] branch master updated (8664b36 -> 0bbc91a) - posted by rm...@apache.org on 2021/09/17 14:27:55 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector. - posted by rm...@apache.org on 2021/09/17 14:32:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationHaveALimitedScope. - posted by rm...@apache.org on 2021/09/17 14:34:46 UTC, 0 replies.
- [flink-benchmarks] branch master updated: [FLINK-24300] Added benchmarks for idling chained sources - posted by dw...@apache.org on 2021/09/17 14:56:27 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-24322][js] Various improvements to the consistency and style - posted by ig...@apache.org on 2021/09/17 15:37:02 UTC, 0 replies.
- [flink-web] branch asf-site updated (899a72f -> 1e07048) - posted by se...@apache.org on 2021/09/17 16:05:01 UTC, 0 replies.
- [flink-web] 01/02: Updated Flink roadmap - posted by se...@apache.org on 2021/09/17 16:05:02 UTC, 0 replies.
- [flink-web] 02/02: Re-build Flink roadmap - posted by se...@apache.org on 2021/09/17 16:05:03 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationHaveALimitedScope. - posted by rm...@apache.org on 2021/09/17 17:57:14 UTC, 0 replies.
- [flink] branch master updated (e18d273 -> 82d1dae) - posted by da...@apache.org on 2021/09/17 18:02:38 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24233][runtime] Ignore message about new buffer size if the reader doesn't ready yet - posted by pn...@apache.org on 2021/09/17 18:16:51 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24233][runtime] Ignore message about new buffer size if the reader doesn't ready yet - posted by pn...@apache.org on 2021/09/17 18:17:11 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24300] SourceOperator#getAvailableFuture reuses future - posted by dw...@apache.org on 2021/09/17 19:20:14 UTC, 0 replies.
- [flink] branch master updated (7bacef0 -> 7c8fefa) - posted by dw...@apache.org on 2021/09/17 19:20:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24287][python][tests] Update grpcio version in tox.ini (#17301) - posted by di...@apache.org on 2021/09/18 02:20:54 UTC, 0 replies.
- [flink] branch master updated (aa1cdd0 -> 475a662) - posted by go...@apache.org on 2021/09/18 03:02:51 UTC, 0 replies.
- [flink] annotated tag release-1.14.0-rc2 updated (97a626b -> 7e8acb3) - posted by xt...@apache.org on 2021/09/18 07:21:13 UTC, 0 replies.
- svn commit: r49996 - in /dev/flink/flink-1.14.0-rc2: ./ python/ - posted by xt...@apache.org on 2021/09/18 07:29:08 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint after a savepoint will degenerate into a full checkpoint - posted by ta...@apache.org on 2021/09/18 10:31:27 UTC, 0 replies.
- [flink] branch master updated (475a662 -> be1da48) - posted by ro...@apache.org on 2021/09/18 10:58:41 UTC, 0 replies.
- [flink] branch release-1.14 updated (791c1b9 -> cc19997) - posted by jq...@apache.org on 2021/09/18 13:45:41 UTC, 0 replies.
- [flink] 01/03: [FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified - posted by jq...@apache.org on 2021/09/18 13:45:42 UTC, 0 replies.
- [flink] 02/03: [FLINK-24277][connector/kafka] Remove auto-generated group id in Kafka table source - posted by jq...@apache.org on 2021/09/18 13:45:43 UTC, 0 replies.
- [flink] 03/03: [FLINK-24277][connector/kafka] Add OffsetsInitializerValidator interface for validating offset initializer in KafkaSourceBuilder - posted by jq...@apache.org on 2021/09/18 13:45:44 UTC, 0 replies.
- [flink] branch release-1.13 updated (c9995a9 -> c7c34ed) - posted by jq...@apache.org on 2021/09/18 13:47:14 UTC, 0 replies.
- [flink] 01/02: [FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified - posted by jq...@apache.org on 2021/09/18 13:47:15 UTC, 1 replies.
- [flink] 02/02: [FLINK-24277][connector/kafka] Add OffsetsInitializerValidator interface for validating offset initializer in KafkaSourceBuilder - posted by jq...@apache.org on 2021/09/18 13:47:16 UTC, 1 replies.
- [flink] branch release-1.12 updated (b842230 -> 7249e0d) - posted by jq...@apache.org on 2021/09/18 13:47:38 UTC, 0 replies.
- [flink] branch master updated (be1da48 -> 6e0bd35) - posted by nk...@apache.org on 2021/09/20 07:40:58 UTC, 0 replies.
- [flink] branch release-1.13 updated: [hotfix][docs] fix link from upsert-kafka to kafka Table(!) connector - posted by nk...@apache.org on 2021/09/20 07:43:35 UTC, 0 replies.
- [flink] branch release-1.12 updated: [hotfix][docs] fix link from upsert-kafka to kafka Table(!) connector - posted by nk...@apache.org on 2021/09/20 08:07:49 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] fix link from upsert-kafka to kafka Table(!) connector - posted by nk...@apache.org on 2021/09/20 08:34:15 UTC, 0 replies.
- [flink] branch master updated (6e0bd35 -> 0f16556) - posted by ch...@apache.org on 2021/09/20 08:37:55 UTC, 0 replies.
- [flink] branch release-1.14 updated (026b0cb -> 69b6e60) - posted by ch...@apache.org on 2021/09/20 08:38:34 UTC, 0 replies.
- [flink] 01/02: [hotfix][test] Derive expected files from getFilesToUpload - posted by ch...@apache.org on 2021/09/20 08:38:35 UTC, 0 replies.
- [flink] 02/02: [FLINK-24197] Guard against CLRF being split across chunks - posted by ch...@apache.org on 2021/09/20 08:38:36 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24156][network] Guard against erroneous SocketTimeoutExceptions - posted by ch...@apache.org on 2021/09/20 08:49:25 UTC, 0 replies.
- [flink] branch master updated (5ae8cb0 -> a0cdd60) - posted by dw...@apache.org on 2021/09/21 07:14:54 UTC, 0 replies.
- [flink] 01/02: [hotfix] Refactor PlannerMocks be used as holder of different mocks - posted by dw...@apache.org on 2021/09/21 07:14:55 UTC, 0 replies.
- [flink] 02/02: [FLINK-22942] [sql/planner] Disable UPSERT INTO statement, including a test - posted by dw...@apache.org on 2021/09/21 07:14:56 UTC, 0 replies.
- [flink] branch release-1.14 updated: [release] Create 1.14 release-notes - posted by dw...@apache.org on 2021/09/21 07:46:58 UTC, 0 replies.
- [flink] branch master updated: [release] Create 1.14 release-notes - posted by dw...@apache.org on 2021/09/21 07:47:33 UTC, 0 replies.
- [flink] branch release-1.14 updated (30d7200 -> 36c1b5b) - posted by se...@apache.org on 2021/09/21 08:34:56 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24303][coordination] Failure when creating a source enumerator lead to full failover, not JobManager failure. - posted by se...@apache.org on 2021/09/21 09:03:32 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24303][coordination] Failure when creating a source enumerator lead to full failover, not JobManager failure. - posted by se...@apache.org on 2021/09/21 10:15:08 UTC, 0 replies.
- [flink] branch master updated (d18d1f4 -> 412b49a) - posted by sj...@apache.org on 2021/09/21 13:14:41 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24340] Only print exception on job failure/suspension - posted by ch...@apache.org on 2021/09/21 13:35:20 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24340] Only print exception on job failure/suspension - posted by ch...@apache.org on 2021/09/21 13:36:04 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24340] Only print exception on job failure/suspension - posted by ch...@apache.org on 2021/09/21 13:37:23 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23389] Add integration with Glue Schema Registry JSON data format (#16513) - posted by da...@apache.org on 2021/09/21 16:06:59 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24347][connectors/kafka] Keep idle source readers if parallelism is higher than partitions in KafkaSource - posted by se...@apache.org on 2021/09/21 23:05:12 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24347][connectors/kafka] Keep idle source readers if parallelism is higher than partitions in KafkaSource - posted by se...@apache.org on 2021/09/21 23:11:23 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24347][connectors/kafka] Keep idle source readers if parallelism is higher than partitions in KafkaSource - posted by se...@apache.org on 2021/09/21 23:14:32 UTC, 0 replies.
- [flink-benchmarks] branch test1.13 created (now 0a6b4fc) - posted by ga...@apache.org on 2021/09/22 06:20:12 UTC, 0 replies.
- [flink-benchmarks] 01/01: Fix some compile error test with release-1.13 - posted by ga...@apache.org on 2021/09/22 06:20:13 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users - posted by pn...@apache.org on 2021/09/22 06:37:43 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users - posted by pn...@apache.org on 2021/09/22 06:38:13 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24159][docs][Runtime/Checkpointing] document of entropy injection may mislead users - posted by pn...@apache.org on 2021/09/22 06:39:02 UTC, 0 replies.
- [flink] branch master updated (5559d3d -> 389eb73) - posted by ch...@apache.org on 2021/09/22 07:13:59 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24329][pulsar][tests] Fix port conflict - posted by ch...@apache.org on 2021/09/22 07:16:00 UTC, 0 replies.
- [flink] branch master updated (389eb73 -> af4657b) - posted by ch...@apache.org on 2021/09/22 07:29:32 UTC, 0 replies.
- [flink] branch master updated (af4657b -> b8c6edb) - posted by go...@apache.org on 2021/09/22 08:14:51 UTC, 0 replies.
- [flink] branch master updated (b8c6edb -> 1fd9018) - posted by di...@apache.org on 2021/09/22 08:20:01 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23827][table-planner] Fix ModifiedMonotonicity inference for some nodes - posted by go...@apache.org on 2021/09/22 08:34:27 UTC, 0 replies.
- [flink] branch master updated (1fd9018 -> 6eb29c9) - posted by pn...@apache.org on 2021/09/22 12:47:05 UTC, 0 replies.
- [flink] annotated tag release-1.14.0-rc3 updated (460b386 -> 2759377) - posted by dw...@apache.org on 2021/09/22 12:49:33 UTC, 0 replies.
- [flink-benchmarks] branch test1.14 created (now de6d62f) - posted by ga...@apache.org on 2021/09/22 13:08:39 UTC, 0 replies.
- [flink-benchmarks] 01/01: Fix compile problem - posted by ga...@apache.org on 2021/09/22 13:08:40 UTC, 0 replies.
- svn commit: r50042 - in /dev/flink: flink-1.14.0-rc0/ flink-1.14.0-rc1/ - posted by dw...@apache.org on 2021/09/22 13:45:29 UTC, 0 replies.
- svn commit: r50043 - in /dev/flink/flink-1.14.0-rc3: ./ python/ - posted by dw...@apache.org on 2021/09/22 13:52:31 UTC, 0 replies.
- [flink-benchmarks] branch test1.14 updated: fix compile error - posted by ga...@apache.org on 2021/09/22 15:01:14 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23739][table] BlackHoleSink & PrintSink implement SupportsPartitioning interface - posted by lz...@apache.org on 2021/09/23 02:42:57 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24353][scripts] Respect dynamic configurations when calculating memory sizes. - posted by xt...@apache.org on 2021/09/23 05:51:42 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24353][scripts] Respect dynamic configurations when calculating memory sizes. - posted by xt...@apache.org on 2021/09/23 05:52:04 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24353][scripts] Respect dynamic configurations when calculating memory sizes. - posted by xt...@apache.org on 2021/09/23 05:52:25 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23991][yarn] Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme - posted by gy...@apache.org on 2021/09/23 08:23:36 UTC, 0 replies.
- [flink] branch master updated (5bf8d64 -> f074642) - posted by dw...@apache.org on 2021/09/23 08:49:57 UTC, 0 replies.
- [flink] branch master updated (f074642 -> 1574e1e) - posted by ja...@apache.org on 2021/09/23 09:42:05 UTC, 0 replies.
- [flink] branch master updated (1574e1e -> 21be483) - posted by ch...@apache.org on 2021/09/23 11:11:05 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-24356][remote] Attach a cancellation token to a delayed message - posted by ig...@apache.org on 2021/09/23 11:35:22 UTC, 0 replies.
- [flink] branch master updated (21be483 -> 815191a) - posted by pn...@apache.org on 2021/09/23 12:11:32 UTC, 0 replies.
- [flink] branch release-1.14 updated (f990cd1 -> 464849d) - posted by pn...@apache.org on 2021/09/23 12:11:55 UTC, 0 replies.
- [flink] 01/02: [FLINK-24344][runtime] testTriggerCheckpointAfterIoException throws exception from initializeLocationForCheckpoint rather than from getAndIncrement - posted by pn...@apache.org on 2021/09/23 12:11:56 UTC, 0 replies.
- [flink] 02/02: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization - posted by pn...@apache.org on 2021/09/23 12:11:57 UTC, 0 replies.
- [flink] branch master updated (815191a -> 36ff71f) - posted by wa...@apache.org on 2021/09/23 13:19:52 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24315][k8s] Add retry logic when watching pods - posted by wa...@apache.org on 2021/09/23 13:20:53 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24315][k8s] Add retry logic when watching pods - posted by wa...@apache.org on 2021/09/23 13:24:54 UTC, 0 replies.
- [flink-statefun] branch master updated: [FLINK-24364][e2e] Add message cancellation embedded e2e case - posted by ig...@apache.org on 2021/09/23 13:42:09 UTC, 0 replies.
- [flink] branch master updated (36ff71f -> 61c1ea4) - posted by xt...@apache.org on 2021/09/24 01:38:34 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24336][python] Fix the issue that jar url list may contain empty string. - posted by di...@apache.org on 2021/09/24 01:40:21 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24336][python] Fix the issue that jar url list may contain empty string. - posted by di...@apache.org on 2021/09/24 01:41:02 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24336][python] Fix the issue that jar url list may contain empty string. - posted by di...@apache.org on 2021/09/24 01:41:27 UTC, 0 replies.
- [flink] branch release-1.12 updated: [FLINK-24336][python] Fix the issue that jar url list may contain empty string. - posted by di...@apache.org on 2021/09/24 01:43:43 UTC, 0 replies.
- [flink] branch master updated (ac0d22e -> 7952960) - posted by dw...@apache.org on 2021/09/24 06:43:47 UTC, 0 replies.
- [flink] 01/03: [hotfix] Make it possible to force MockSourceReader to wait for initial splits assignment - posted by dw...@apache.org on 2021/09/24 06:43:48 UTC, 0 replies.
- [flink] 02/03: [FLINK-24280] Initialize base locations for checkpoints lazily in the first checkpoint - posted by dw...@apache.org on 2021/09/24 06:43:49 UTC, 0 replies.
- [flink] 03/03: [FLINK-24280] Support manual checkpoints triggering from a MiniCluster - posted by dw...@apache.org on 2021/09/24 06:43:50 UTC, 0 replies.
- [flink] branch master updated (7952960 -> ca48138) - posted by ch...@apache.org on 2021/09/24 09:31:28 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Remove flink-connector-base as required dependency from the kafka connector - posted by se...@apache.org on 2021/09/24 17:00:52 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] Remove flink-connector-base as required dependency from the kafka connector - posted by se...@apache.org on 2021/09/24 17:01:21 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24271][docs] Add document for special char in JSON_VALUE - posted by lz...@apache.org on 2021/09/26 02:36:26 UTC, 0 replies.
- [flink] branch master updated (9bcc10b -> be581bc) - posted by yu...@apache.org on 2021/09/26 03:05:27 UTC, 0 replies.
- [flink-ml] branch master updated: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables - posted by jq...@apache.org on 2021/09/26 09:43:17 UTC, 0 replies.
- [flink] branch master updated (be581bc -> cd7bf3b) - posted by da...@apache.org on 2021/09/26 21:31:31 UTC, 0 replies.
- [flink] branch master updated (cd7bf3b -> 6c2e605) - posted by xt...@apache.org on 2021/09/27 09:27:56 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Remove the explicit requirement of flink-connector-base, and add missing StartCursor in pulsar connector document. - posted by ar...@apache.org on 2021/09/27 13:05:27 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] Remove the explicit requirement of flink-connector-base, and add missing StartCursor in pulsar connector document. - posted by ar...@apache.org on 2021/09/27 13:06:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by sj...@apache.org on 2021/09/27 14:22:27 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24373][docs] Remove BETA Tag from FLIP-27 Source Docs - posted by sj...@apache.org on 2021/09/27 14:22:53 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24375] Let name of flush thread in RecordWriter contain subtask index. - posted by zh...@apache.org on 2021/09/28 03:02:52 UTC, 0 replies.
- [flink-ml] branch master updated: [hotfix] Fix pom.xml and delete outdated files - posted by ga...@apache.org on 2021/09/28 03:32:19 UTC, 0 replies.
- [flink] branch master updated (5947647 -> c81a530) - posted by xt...@apache.org on 2021/09/28 07:39:59 UTC, 0 replies.
- [flink] branch release-1.14 updated (81d676f -> fcb19e6) - posted by xt...@apache.org on 2021/09/28 07:45:08 UTC, 0 replies.
- [flink] 01/02: [hotfix][runtime][test] Use builder for creating TestingResourceManager. - posted by xt...@apache.org on 2021/09/28 07:45:09 UTC, 0 replies.
- [flink] 02/02: [FLINK-24377][runtime] Actively release TM resource after heartbeat timeout. - posted by xt...@apache.org on 2021/09/28 07:45:10 UTC, 0 replies.
- [flink] branch master updated (c81a530 -> 1261d66) - posted by dw...@apache.org on 2021/09/28 10:46:46 UTC, 0 replies.
- [flink] branch master updated (1261d66 -> 4fe9f52) - posted by ar...@apache.org on 2021/09/28 13:26:20 UTC, 0 replies.
- [flink] 01/02: [hotfix][test] Reduce visibility of test classes in SinkWriterOperatorTest - posted by ar...@apache.org on 2021/09/28 13:26:21 UTC, 1 replies.
- [flink] 02/02: [FLINK-24371][datastream] Call preCommit on SinkWriter although no committer is available - posted by ar...@apache.org on 2021/09/28 13:26:22 UTC, 1 replies.
- [flink] branch release-1.14 updated (fcb19e6 -> 770684b) - posted by ar...@apache.org on 2021/09/28 13:27:21 UTC, 0 replies.
- [flink] branch release-1.13 updated (26616d9 -> 1057f41) - posted by xt...@apache.org on 2021/09/29 01:36:27 UTC, 0 replies.
- svn commit: r50164 - /dev/flink/flink-1.14.0-rc3/ /release/flink/flink-1.14.0/ - posted by xt...@apache.org on 2021/09/29 02:58:15 UTC, 0 replies.
- svn commit: r50165 - /dev/flink/flink-1.14.0-rc2/ - posted by xt...@apache.org on 2021/09/29 03:02:16 UTC, 0 replies.
- [flink] annotated tag release-1.14.0 updated (460b386 -> 4835348) - posted by xt...@apache.org on 2021/09/29 03:06:48 UTC, 0 replies.
- svn commit: r50169 - /release/flink/flink-1.11.4/ - posted by xt...@apache.org on 2021/09/29 07:22:11 UTC, 0 replies.
- [flink] branch master updated: [FLINK-24380][k8s] Terminate the pod if it failed - posted by wa...@apache.org on 2021/09/29 07:46:21 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24380][k8s] Terminate the pod if it failed - posted by wa...@apache.org on 2021/09/29 07:47:15 UTC, 0 replies.
- [flink-docker] branch dev-1.14 updated (7906008 -> 52c78ed) - posted by dw...@apache.org on 2021/09/29 07:47:26 UTC, 0 replies.
- [flink-docker] 01/02: Add GPG key for 1.14.0 release - posted by dw...@apache.org on 2021/09/29 07:47:27 UTC, 0 replies.
- [flink-docker] 02/02: Run tests against 1.14.0 - posted by dw...@apache.org on 2021/09/29 07:47:28 UTC, 0 replies.
- [flink] branch release-1.13 updated: [FLINK-24380][k8s] Terminate the pod if it failed - posted by wa...@apache.org on 2021/09/29 07:48:01 UTC, 0 replies.
- [flink] branch release-1.14 updated: Update japicmp configuration for 1.14.0 - posted by xt...@apache.org on 2021/09/29 08:18:24 UTC, 0 replies.
- [flink] branch master updated (b9fbdf8 -> 13452de) - posted by xt...@apache.org on 2021/09/29 08:19:18 UTC, 0 replies.
- [flink-docker] branch dev-master updated: Add GPG key for 1.14.0 release - posted by dw...@apache.org on 2021/09/29 08:35:43 UTC, 0 replies.
- [flink-docker] branch master updated: Update Dockerfiles for 1.14.0 release - posted by dw...@apache.org on 2021/09/29 08:35:51 UTC, 0 replies.
- [flink-web] branch asf-site updated (1e07048 -> 5242773) - posted by dw...@apache.org on 2021/09/29 10:42:00 UTC, 0 replies.
- [flink-web] 01/02: Add Apache Flink release 1.14.0 Blog post and update links and scripts. - posted by dw...@apache.org on 2021/09/29 10:42:01 UTC, 0 replies.
- [flink-web] 02/02: Rebuild website - posted by dw...@apache.org on 2021/09/29 10:42:02 UTC, 4 replies.
- [flink-web] branch asf-site updated (5242773 -> de5c84d) - posted by dw...@apache.org on 2021/09/29 10:56:09 UTC, 0 replies.
- [flink-web] 01/02: Update stable version to 1.14 - posted by dw...@apache.org on 2021/09/29 10:56:10 UTC, 0 replies.
- [flink] branch master updated: [FLINK-23316][table-runtime][hive] Add test for Custom PartitionCommitPolicy - posted by li...@apache.org on 2021/09/29 11:52:14 UTC, 0 replies.
- [flink] branch master updated: [release] Add 1.14 docs link to the list of previous versions - posted by dw...@apache.org on 2021/09/29 14:14:17 UTC, 0 replies.
- [flink] branch release-1.13 updated: [docs] Update show_outdated_warning - posted by dw...@apache.org on 2021/09/29 14:18:04 UTC, 0 replies.
- [flink-web] branch asf-site updated: Minor fixes to release 1.14 blog post - posted by se...@apache.org on 2021/09/29 15:38:11 UTC, 0 replies.
- [flink] branch master updated (67c8bef -> aba25f1) - posted by tw...@apache.org on 2021/09/29 15:44:20 UTC, 0 replies.
- [flink] branch master updated (aba25f1 -> bbc1779) - posted by sj...@apache.org on 2021/09/29 21:26:30 UTC, 0 replies.
- [flink] branch release-1.14 updated (0d2ef66 -> 282638f) - posted by sj...@apache.org on 2021/09/29 21:28:31 UTC, 0 replies.
- [flink] 01/02: [FLINK-23313][docs] Reintroduce temporal table function documentation - posted by sj...@apache.org on 2021/09/29 21:28:32 UTC, 0 replies.
- [flink] 02/02: [hotfix][docs] Move out the time zone page from streaming concepts section - posted by sj...@apache.org on 2021/09/29 21:28:33 UTC, 0 replies.
- [flink-web] branch asf-site updated (b66c9ba -> ea10c4a) - posted by xt...@apache.org on 2021/09/30 01:47:06 UTC, 0 replies.
- [flink-web] 01/02: Added a hint to the 1.14 RC0 post with a link to the actual release - posted by xt...@apache.org on 2021/09/30 01:47:07 UTC, 0 replies.
- [flink] branch master updated: [hotfix][python][docs] Update the README of PyFlink - posted by di...@apache.org on 2021/09/30 02:25:55 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][python][docs] Update the README of PyFlink - posted by di...@apache.org on 2021/09/30 02:26:59 UTC, 0 replies.
- [flink-web] branch asf-site updated (ea10c4a -> a09dfc6) - posted by pn...@apache.org on 2021/09/30 06:29:19 UTC, 0 replies.
- [flink-web] 01/02: Fixed buffer debloating chart in release-1.14 post - posted by pn...@apache.org on 2021/09/30 06:29:20 UTC, 0 replies.
- [flink-web] branch asf-site updated (a09dfc6 -> c8bdafa) - posted by pn...@apache.org on 2021/09/30 06:37:52 UTC, 0 replies.
- [flink-web] 01/02: Update buffer_debloating to svg - posted by pn...@apache.org on 2021/09/30 06:37:53 UTC, 0 replies.
- [flink] branch release-1.13 updated (d2a5ed4 -> 5027c73) - posted by tw...@apache.org on 2021/09/30 07:06:45 UTC, 0 replies.
- [flink] branch master updated (5b80e1c -> 6b58562) - posted by dw...@apache.org on 2021/09/30 07:33:35 UTC, 0 replies.
- [flink] branch release-1.14 updated: [release][docs] Clean up 1.14 release notes - posted by dw...@apache.org on 2021/09/30 07:33:58 UTC, 0 replies.
- [flink-web] branch asf-site updated (c8bdafa -> d0caef5) - posted by tr...@apache.org on 2021/09/30 09:30:35 UTC, 0 replies.
- [flink] branch release-1.14 updated (9bc8502 -> 24d9856) - posted by ch...@apache.org on 2021/09/30 10:10:00 UTC, 0 replies.
- [flink] 01/06: [FLINK-24058][coordination] Extract TimerService interface - posted by ch...@apache.org on 2021/09/30 10:10:01 UTC, 0 replies.
- [flink] 02/06: [FLINK-24058][coordination] Use ExecutorUtils#gracefulShutdown - posted by ch...@apache.org on 2021/09/30 10:10:02 UTC, 0 replies.
- [flink] 03/06: [FLINK-24058][coordination][tests] Add TestingTimerService - posted by ch...@apache.org on 2021/09/30 10:10:03 UTC, 0 replies.
- [flink] 04/06: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest - posted by ch...@apache.org on 2021/09/30 10:10:04 UTC, 0 replies.
- [flink] 05/06: [FLINK-24058][tests] Cleanup DefaultTimerServiceTest - posted by ch...@apache.org on 2021/09/30 10:10:05 UTC, 0 replies.
- [flink] 06/06: [FLINK-24058][coordination][tests] Add test for TimerService#isValid - posted by ch...@apache.org on 2021/09/30 10:10:06 UTC, 0 replies.
- [flink] branch master updated (6b58562 -> d80d487) - posted by ch...@apache.org on 2021/09/30 10:19:50 UTC, 0 replies.
- [flink] branch release-1.13 updated (5027c73 -> b0bf668) - posted by tw...@apache.org on 2021/09/30 11:50:12 UTC, 0 replies.
- [flink-web] branch asf-site updated: Update buffer_debloating chart once more time - posted by pn...@apache.org on 2021/09/30 13:43:23 UTC, 0 replies.
- [flink] branch master updated: [hotfix][docs] Fix typo in sources doc - posted by sj...@apache.org on 2021/09/30 14:05:33 UTC, 0 replies.
- [flink] branch release-1.14 updated: [hotfix][docs] Fix typo in sources doc - posted by sj...@apache.org on 2021/09/30 14:06:02 UTC, 0 replies.
- [flink] branch master updated (7fbec60 -> ce7481a) - posted by tw...@apache.org on 2021/09/30 14:55:11 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-23519][metrics] Expose state name as varibale if enable state latency tracking - posted by ta...@apache.org on 2021/09/30 16:34:58 UTC, 0 replies.
- [flink] branch release-1.14 updated: [FLINK-24148][state] Add bloom filter option in RocksDBConfiguredOptions - posted by ta...@apache.org on 2021/09/30 16:38:43 UTC, 0 replies.