[flink] branch release-1.13 updated (b9c729e -> a3a776d)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from b9c729e [FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods add

[flink] branch release-1.14 updated (9d114b0 -> dfa47af)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 9d114b0 [FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods add

[flink] 02/04: [FLINK-24366][runtime] Don't log error for failed task restore if the task is already canceled.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e6798c3e40bffeccfc35c84021e63aae41a3ac48 Author: Stephan Ewen AuthorDate: Thu Sep 23 17:47:13 2021 +0200 [FLINK

[flink] 04/04: [FLINK-23842][coordination] Add logging statements in SourceCoordinators for reader registration and split requests.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7a109823a21150c7bea9ba41fc22203cbaf7094f Author: Stephan Ewen AuthorDate: Tue Aug 17 18:31:54 2021 +0200 [FLINK

[flink] 03/04: [FLINK-24255][tests] Test environments respect configuration when being instantiated.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 57253c5fc880fff880526a8954446c8189ac7c72 Author: Stephan Ewen AuthorDate: Fri Aug 27 02:27:10 2021 +0200 [FLINK

[flink] branch master updated (ad16e2c -> 7a10982)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from ad16e2c [FLINK-24889][table] Support casting MULTISET to STRING new c2f510f [hotfix][coordination] Improve hint

[flink] 01/04: [hotfix][coordination] Improve hint to build akka RPC system.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c2f510f670cc26ba85d183d822ef8c41ff6bd068 Author: Stephan Ewen AuthorDate: Thu Nov 18 15:31:29 2021 +0100 [hotfix

[flink-web] branch asf-site updated: Minor fixes to release 1.14 blog post

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 8e9cf5f Minor fixes to release 1.14 blog

[flink] branch release-1.14 updated: [hotfix][docs] Remove flink-connector-base as required dependency from the kafka connector

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 935e2b8 [hotfix][docs] Remove flink

[flink] branch master updated: [hotfix][docs] Remove flink-connector-base as required dependency from the kafka connector

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new a9e256d [hotfix][docs] Remove flink-connector

[flink] branch release-1.13 updated: [FLINK-24347][connectors/kafka] Keep idle source readers if parallelism is higher than partitions in KafkaSource

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 28211c0 [FLINK-24347][connectors

[flink] branch master updated: [FLINK-24347][connectors/kafka] Keep idle source readers if parallelism is higher than partitions in KafkaSource

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d753cf2 [FLINK-24347][connectors/kafka] Keep

[flink] branch release-1.14 updated: [FLINK-24347][connectors/kafka] Keep idle source readers if parallelism is higher than partitions in KafkaSource

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new a595fbb [FLINK-24347][connectors

[flink] branch master updated: [FLINK-24303][coordination] Failure when creating a source enumerator lead to full failover, not JobManager failure.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d18d1f4 [FLINK-24303][coordination] Failure when

[flink] branch release-1.13 updated: [FLINK-24303][coordination] Failure when creating a source enumerator lead to full failover, not JobManager failure.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 600cde4 [FLINK-24303][coordination

[flink] branch release-1.14 updated (30d7200 -> 36c1b5b)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 30d7200 [release] Create 1.14 release-notes add 36c1b5b [FLINK-24303][coordination] Failure when creating

[flink-web] 01/02: Updated Flink roadmap

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git commit c133968a7f57c1a76b084256cbdcc938af2f56d3 Author: martijnvisser AuthorDate: Fri Sep 17 13:40:39 2021 +0200

[flink-web] 02/02: Re-build Flink roadmap

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git commit 1e07048e9e653f3de6b40930fb96dd92c6b1baa8 Author: martijnvisser AuthorDate: Fri Sep 17 17:59:23 2021 +0200 Re

[flink-web] branch asf-site updated (899a72f -> 1e07048)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git. from 899a72f Rebuild website new c133968 Updated Flink roadmap new 1e07048 Re-build Flink roadmap The 2

[flink] branch release-1.14 updated: [hotfix] Update frontend-maven-plugin

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 9c4262e [hotfix] Update frontend

[flink] branch release-1.14 updated: [hotfix] Improve language for error message when checkpoint is declined due to some tasks being finished already.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new 7b213e4 [hotfix] Improve language

[flink] branch master updated (d79bb47 -> ed3b613)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from d79bb47 [FLINK-23864][docs] Add pulsar connector document (Chinese & English). add ed3b613 [hotfix] Imp

[flink] 08/08: [FLINK-23527][core] Clarify semantics of SourceFunction.cancel() with respect to thread interruptions.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit c56ecf3e0acb917f3e302eda7c5f92b73a881c76 Author: Stephan Ewen AuthorDate: Tue Aug 24 16:06:04 2021 +0200

[flink] 05/08: [hotfix] Remove outdated JavaDocs in SourceFunction about deprecated TimeCharacteristic

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 814f2780c855b6e3b3b1d26cc42c9979ba3abc53 Author: Stephan Ewen AuthorDate: Tue Aug 24 15:22:56 2021 +0200

[flink] 06/08: [hotfix] Deduplicate JavaDocs in SourceFunction

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 18e94e44d1ebda41ad8595eac03393ebb17bdfbf Author: Stephan Ewen AuthorDate: Tue Aug 24 15:36:12 2021 +0200

[flink] 07/08: [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 9a26fe9c4e325a9c44bdcc9be3c99aef0a8e1e34 Author: Stephan Ewen AuthorDate: Tue Aug 24 15:37:09 2021 +0200

[flink] branch release-1.14 updated (2459a3c -> c56ecf3)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 2459a3c [FLINK-24213][qs] Use single lock in ServerConnection new 4aa457d [FLINK-22357][core] Upgrades

[flink] 02/08: [hotfix][core] Improve/fix JavaDocs in SplitEnumeratorContext class.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2a13b241b95434e2fd26271cf98a47af936b93e5 Author: Stephan Ewen AuthorDate: Thu Sep 9 15:48:19 2021 +0200

[flink] 04/08: [hotfix][connectors] Deduplicate config default in FutureCompletingBlockingQueue.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2af65df0127db5890cfc3d3f382e2ba7eca44771 Author: Stephan Ewen AuthorDate: Thu Sep 9 16:14:54 2021 +0200

[flink] 03/08: [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit a76854f535f4af4251b038c5c87bfb73e36fdf0f Author: Stephan Ewen AuthorDate: Mon Apr 19 18:22:07 2021 +0200

[flink] 01/08: [FLINK-22357][core] Upgrades API stability of unified source API to @Public (= stable).

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4aa457d75a83f929104ea1a4f7526ce13b06c475 Author: Stephan Ewen AuthorDate: Mon Apr 19 18:05:01 2021 +0200

[flink] branch master updated (76ee66f -> 713f066)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 76ee66f [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified Sink API, Increase robustness for flush

[flink] 04/04: [FLINK-23527][core] Clarify semantics of SourceFunction.cancel() with respect to thread interruptions.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 57efc6980c4a2792e73b270a8dd39d95c9ed6de6 Author: Stephan Ewen AuthorDate: Tue Aug 24 16:06:04 2021 +0200

[flink] 03/04: [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit f89d9049947206cd93cb7c4f3b4a9dfc662ba0dc Author: Stephan Ewen AuthorDate: Tue Aug 24 15:37:09 2021 +0200

[flink] 01/04: [hotfix] Remove outdated JavaDocs in SourceFunction about deprecated TimeCharacteristic

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit c1355ec6f1a3dabcc8467f3674c3569ab5f6fe00 Author: Stephan Ewen AuthorDate: Tue Aug 24 15:22:56 2021 +0200

[flink] branch release-1.13 updated (30fca11 -> 57efc69)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 30fca11 [FLINK-23611][yarn-tests] Disables INFO log messages coming from YARN's ResourceLocalizationService

[flink] 02/04: [hotfix] Deduplicate JavaDocs in SourceFunction

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit cd9a0ae739f89e7d70eb532ded9bc382d32fee25 Author: Stephan Ewen AuthorDate: Tue Aug 24 15:36:12 2021 +0200

[flink] branch master updated (74cdcd7 -> 9136c40)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 74cdcd7 [FLINK-23611][yarn-tests] Disables INFO log messages coming from YARN's ResourceLocalizationService add

[flink] branch release-1.12 updated: [FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.12 by this push: new c22c3da [FLINK-22545][tests] Fix

[flink] branch release-1.13 updated: [FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 6fbdb15 [FLINK-22545][tests] Fix

[flink] branch master updated: [FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d081d9a [FLINK-22545][tests] Fix delayed split

[flink] branch release-1.12 updated (bbae6a1 -> b477faf)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from bbae6a1 [FLINK-23802][kinesis][efo] Request next record from the Flink source thread rather than the AWS SDK

[flink] 01/02: [FLINK-23629][tests] Remove redundant file-async and mem-async test runs from EventTimeWindowCheckpointingITCase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 31b45fc6c48dc0503f1c91ce1b6b0b00c6439a02 Author: Stephan Ewen AuthorDate: Wed Aug 4 18:42:00 2021 +0200 [FLINK-23629

[flink] 02/02: [FLINK-23630][tests] Make EventTimeWindowCheckpointingITCase run on Windows.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c84ebe839b3e1e936e68d2e67496cf7664b35287 Author: Stephan Ewen AuthorDate: Wed Aug 4 19:01:34 2021 +0200 [FLINK-23630

[flink] branch master updated (c675f78 -> c84ebe8)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from c675f78 [FLINK-20731] Introduce new pulsar source connector for flink. new 31b45fc [FLINK-23629][tests] Remove

[flink] branch master updated (b34ef1e -> be82c54)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b34ef1e [FLINK-18783] Load Akka with separate classloader add cc5c9c0 [hotfix][tests] Fix raw generics

[flink] branch master updated (9267a52 -> 7261cba)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9267a52 [FLINK-22452][Connectors/Kafka] Support specifying custom transactional.id prefix in FlinkKafkaProducer

[flink] branch master updated (7cd3554 -> f75e57b)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 7cd3554 [FLINK-23370][table-planner] Propagate Boundedness of ScanRuntimeProviders to Transformation add

[flink] branch release-1.13 updated: [FLINK-22547][tests] Harden OperatorCoordinatorHolderTest.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 950ea33 [FLINK-22547][tests] Harden

[flink] branch release-1.12 updated (adfd85f -> 8f0e13c)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from adfd85f [FLINK-23312][ci] speed up compilation for e2e tests add 8f0e13c [FLINK-22547][tests] Harden

[flink] branch release-1.12 updated (2c3f8f6 -> 331ae2c)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from 2c3f8f6 [FLINK-23233][runtime] Ensure checkpoints confirmed after all the failed events processed

[flink] branch release-1.13 updated: [FLINK-22545][coordination] Fix check during creation of Source Coordinator thread.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 17a294d [FLINK-22545][coordination

[flink] branch master updated (b1c5421 -> 6451a1c)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b1c5421 [hotfix][runtime] Log slot pool status if unable to fulfill job requirements new 4b867d8 [FLINK-22545

[flink] 02/02: [hotfix] Remove unnecessary warning suppression.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6451a1c169fbde44c2c7c458cc717c0fcad01cf9 Author: Stephan Ewen AuthorDate: Tue Jul 13 15:05:25 2021 +0200 [hotfix

[flink] 01/02: [FLINK-22545][coordination] Fix check during creation of Source Coordinator thread.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4b867d8a6c187d6bef45294a6e6a524254410167 Author: Stephan Ewen AuthorDate: Tue Jul 13 14:36:32 2021 +0200 [FLINK

[flink] 02/02: [FLINK-23001][build] Re-enable Scala suffix check for avro-glue-registry module

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 728bb3309b74cf6457c5d0b962018a45e470ed05 Author: Stephan Ewen AuthorDate: Tue Jun 22 20:10:34 2021 +0200

[flink] branch release-1.13 updated (70f7e2d -> 728bb33)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 70f7e2d [hotfix][docs] Improve the documentation about the data types supported in Python DataStream API

[flink] 01/02: [FLINK-23001][build] Fix missing Scala suffix by removing unneeded Scala-dependent dependency

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 51880ee4d17e9042f9d81059c7e83b6f6b53b948 Author: Stephan Ewen AuthorDate: Tue Jun 22 20:08:35 2021 +0200

[flink] branch master updated (a07450d -> 1014636)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a07450d [FLINK-23033][python] Add the missing ObjectArrayTypeInfo (#16220) add 4985672 [FLINK-23001][build

[flink-web] branch asf-site updated (4428950 -> ecd1e79)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git. from 4428950 Rebuild website add 7f4deb8 Adding the Apache Flink Summer Camp add ecd1e79 Rebuild website

[flink] branch release-1.13 updated: [hotfix][tests] Remove timout rule from KafkaTableTestBase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new f027863 [hotfix][tests] Remove

[flink] branch master updated: [hotfix][tests] Remove timout rule from KafkaTableTestBase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 14ae6fe [hotfix][tests] Remove timout rule from

[flink] branch master updated: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with Adaptive Scheduler.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new e676442 [FLINK-22433][tests] Make

[flink] branch release-1.13 updated: [FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with Adaptive Scheduler.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 0dc6326 [FLINK-22433][tests] Make

[flink] branch release-1.12 updated (aada320 -> a555c39)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from aada320 [FLINK-20722][hive] HiveTableSink should copy the record when converting RowData to Row add

[flink] branch master updated (fa0be65 -> e3cfa40)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from fa0be65 [hotfix][table-api] Properly deprecate StreamTableEnvironment.execute add e3cfa40 [FLINK-22345

[flink] branch release-1.13 updated: [FLINK-22345][coordination] Catch pre-mature state restore for Operator Coordinators

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 9400f88 [FLINK-22345][coordination

[flink] branch release-1.13 updated: [FLINK-22345][coordination] Remove incorrect assertion in scheduler

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 41f013d [FLINK-22345][coordination

[flink] branch master updated: [FLINK-22345][coordination] Remove incorrect assertion in scheduler

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 02e7db8 [FLINK-22345][coordination] Remove

[flink] branch master updated: [hotfix][docs][pyflink] Regenerate docs and adjust PyFlink tests fpr FLINK-21694

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 80c1e71 [hotfix][docs][pyflink] Regenerate docs

[flink] branch release-1.13 updated: [FLINK-21694][docs] Regenerate docs for adjusted RocksDB config

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new 749faf6 [FLINK-21694][docs

[flink] branch release-1.13 updated (cc6a608 -> af20495)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from cc6a608 [FLINK-21694][rocksdb] Increase default value

[flink] 01/02: [hotfix][rocksdb] Properly adjust RocksDB config options to new builder pattern

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 285045673c6880cd01a6e0a7f55a542865339ace Author: Stephan Ewen AuthorDate: Tue Apr 20 17:36:06 2021 +0200

[flink] branch release-1.13 updated (dbc74ef -> cc6a608)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from dbc74ef [FLINK-21796][FLINK-17510] Disable tests that use KafkaResource new 2850456 [hotfix][rocksdb

[flink] 02/02: [FLINK-21694][rocksdb] Increase default value for 'state.backend.rocksdb.checkpoint.transfer.thread.num'

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit cc6a608d6be6281485253774a90c0ccce03ae948 Author: Stephan Ewen AuthorDate: Tue Apr 20 17:38:04 2021 +0200

[flink] branch master updated (13d7e55 -> 861a46e)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 13d7e55 [FLINK-21796][FLINK-17510] Disable tests that use KafkaResource add c4678d8 [FLINK-22133][core] Add

[flink] branch release-1.13 updated: [FLINK-22133][core] Add checkpointID to 'SplitEnumerator.snapshotState()'

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.13 by this push: new fdcf730 [FLINK-22133][core] Add

[flink] branch release-1.12 updated (902a0f5 -> d39b3fb)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git. from 902a0f5 [FLINK-20761][hive] Escape the location path when creating input splits (#15625) add 09613ef

[flink] 01/02: [FLINK-21996][coordination] Ensure exactly-once guarantees for OperatorEvent RPCs

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 904536271081f393a8c29341831275080b04255a Author: Stephan Ewen AuthorDate: Wed Apr 14 05:02:55 2021 +0200 [FLINK

[flink] branch master updated (fe41a87 -> 9466e09)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from fe41a87 [FLINK-22276][runtime] Adds workaround for FLINK-22276 new 9045362 [FLINK-21996][coordination] Ensure

[flink] 02/02: [hotfix][coordination] Add safety guard against uncaught exceptions for Future dependent lambdas

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 9466e090bd66906daf1e571328aab70743f31223 Author: Stephan Ewen AuthorDate: Fri Apr 16 18:10:25 2021 +0200 [hotfix

[flink] 09/10: [hotfix][tests] Minor debuggability improvements to CoordinatedSourceRescaleITCase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f858348fc18cd532b9de1f53b055f4983373b46c Author: Stephan Ewen AuthorDate: Wed Apr 14 17:34:16 2021 +0200 [hotfix

[flink] 06/10: [hotfix][coordination] Make failed event valve shutting smoother.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2a225d613f942ea1aaba455cfe933449af167570 Author: Stephan Ewen AuthorDate: Tue Apr 13 10:37:26 2021 +0200 [hotfix

[flink] 10/10: [hotfix][tests] Simplify and harden CoordinatorEventsExactlyOnceITCase

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e3d2e1c49d6bb89d11e9dfc9c171f9d00aff2215 Author: Stephan Ewen AuthorDate: Fri Apr 16 16:48:17 2021 +0200 [hotfix

[flink] 02/10: [FLINK-18071][coordination] (part 2) OperatorCoordinatorHolder does not implement OperatorCoordinator interface any more

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 07fc4477909b6ec2374cc38f8aa445ebfe6b3b4d Author: Stephan Ewen AuthorDate: Sun Apr 11 18:55:14 2021 +0200 [FLINK

[flink] 01/10: [hotfix][coordination] Add Main-Thread check to OperatorEvent sending on Execution.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 11717ced989ace3b46582a68e059fb63c8113c94 Author: Stephan Ewen AuthorDate: Wed Apr 14 15:38:49 2021 +0200 [hotfix

[flink] 08/10: [hotfix][coordination] Remove unnecessary null check

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7f01aeca04329aeb19b1ede659a33eedaf0eca29 Author: Stephan Ewen AuthorDate: Wed Apr 14 11:54:20 2021 +0200 [hotfix

[flink] 07/10: [hotfix][coordination] Reduce lambda nesting for action on CompletableFuture

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b1e18607d08727a62847809638b47346b55ff63b Author: Stephan Ewen AuthorDate: Tue Apr 13 10:44:25 2021 +0200 [hotfix

[flink] 03/10: [FLINK-18071][coordination] (part 3) Adjust OperatorEventValve to accept self-contained "send actions".

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 605d158f013ba0fd43fa0ae68b8936b9288ac715 Author: Stephan Ewen AuthorDate: Sun Apr 11 19:27:01 2021 +0200 [FLINK

[flink] 04/10: [FLINK-18071][coordination] (part 4) Add to Execution a future for states INITIALIZING/RUNNING

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 58c5e8c3cc43ddaee0fa63b8fb209eb2a4006eb7 Author: Stephan Ewen AuthorDate: Sun Apr 11 20:05:47 2021 +0200 [FLINK

[flink] branch master updated (8ae382c -> e3d2e1c)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 8ae382c [FLINK-21346][hotfix] Revert installing required bc for e2e tests new 11717ce [hotfix][coordination

[flink] 07/08: [FLINK-21996][refactor] Pull in-line serialization call into separate statement to improve Exception handling accuracy.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ad54508bda62d7ba0840c5048684fcc83696c43a Author: Stephan Ewen AuthorDate: Sat Apr 10 18:04:35 2021 +0200 [FLINK

[flink] 08/08: [FLINK-18071][coordination] (part 1) All event sending and checkpoint actions for OperatorCoordinator happen in Scheduler Thread

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 4595ec755308ba0608910e67561ba9f7e6e00c43 Author: Stephan Ewen AuthorDate: Sat Apr 10 21:34:44 2021 +0200 [FLINK

[flink] 06/08: [FLINK-21996][refactor] Unify exception handling for Operator Coordinator Events sent to not-running tasks

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8ddd456712d9e964d3c6759482d061076c8d6075 Author: Stephan Ewen AuthorDate: Sat Apr 10 17:38:36 2021 +0200 [FLINK

[flink] 03/08: [FLINK-21996][refactor] Make IteratorSourceReader work with multiple split requests.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit ea4b391784df08661efc0474c9f0b18e17647fba Author: Stephan Ewen AuthorDate: Sat Apr 10 00:43:37 2021 +0200 [FLINK

[flink] 04/08: [FLINK-21996][refactor] Make NumberSequenceSource extensible to allow specifying the number of desired sequence splits.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit d6253f47f9e86771fdb8499df0d98aae3c695e59 Author: Stephan Ewen AuthorDate: Sat Apr 10 00:41:12 2021 +0200 [FLINK

[flink] branch master updated (a871333 -> 4595ec7)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a871333 [FLINK-22144][runtime][runtime-web] Adds more documentation and moves option new 772eb8e [refactor

[flink] 01/08: [refactor][runtime] Update FutureUtils to support delayed completing of a CompletableFuture

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 772eb8ec99530fec7f32cfcfb24537013067a3db Author: Stephan Ewen AuthorDate: Wed Mar 31 19:33:06 2021 +0200 [refactor

[flink] 02/08: [refactor][runtime] Extend AkkaRpcServiceUtils to support instantiating custom AkkaRpcServices.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 0726c9ea609d37fec192fe7159012d793605f916 Author: Stephan Ewen AuthorDate: Wed Mar 31 19:54:00 2021 +0200 [refactor

[flink] 05/08: [FLINK-21996][tests] Add ITCase to test for delayed and failed operator event sending.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit de509fc2439c2cacb02c9caa40168b3765e84ceb Author: Stephan Ewen AuthorDate: Wed Mar 31 19:55:53 2021 +0200 [FLINK

  1   2   3   4   5   6   7   8   9   10   >