Trigger nightly tests for FLINK-7289 #2
Closed
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Add config option to enable to evenly spread out slots across all available TaskExecutors.
…e slots When listing available slots stored in the SlotPool and the SlotSharingManager, the system will now also calculate the utilization of the owning TaskExecutor wrt the job.
The EvenlySpreadOutLocationPreferenceSlotSelectionStrategy is a special implementation of the LocationPreferenceSlotSelectionStrategy which tries to evenly spread out the workload across all TaskExecutors by choosing the slot with the least utilization if there is a tie wrt the locality.
…ENLY_SPREAD_OUT_SLOTS_STRATEGY If ClusterOptions#EVENLY_SPREAD_OUT_SLOTS_STRATEGY is enabled, then Flink will use the evenly spread out location preference strategy to spread out the workload as much as possible. This closes #9928.
…r stop the coordinator Currently, we just check whether coordinator has been stopped in eager pre-check, if the coordinator stopped after eager pre-check has been done, we'll trigger a new checkpoint even if the coordinator has been stopped. In this commit we'll prevent triggering new checkpoint in such case. [hotfix] extract common logic for checkpoint trigger check [hotfix] Get rid of Mockito in test This closes #10111.
…hema This closes #10096
…rsion This closes #10069 .
… get the catalog from catalog name This closes #10039
This closes #10039
…fully/partially qualified names in blink This closes #10039
…name and use un-escaped identifier as toString The display name of functions shouldn't be normalized and escaped, otherwise, a lot of planner tests will fail. However, FunctionIdentifier enforce to normalize names when construction. This makes it impossible to get the original name. The normalization can happen out of FunctionIdentifier.
…orTable This also changes the parameter of FunctionLookup#lookupFunction from FunctionIdentifier UnresolvedIdentifier. The qualifying happens in FunctionCatalog which holds CatalogManager.
…nd flatMap function This closes #9999
This closes #9992
…ermark to CatalogTable
…face to generate watermark from current row
…enerator from RexNode
…rmark assigner in translateToPlan
…qlexec package to operations package SqlToOperationConverter is in org.apache.flink.table.planner.operations package.
This closes #10120.
flinkbot
pushed a commit
that referenced
this pull request
Nov 8, 2021
flinkbot
pushed a commit
that referenced
this pull request
Nov 22, 2021
flinkbot
pushed a commit
that referenced
this pull request
Jan 21, 2022
flinkbot
pushed a commit
that referenced
this pull request
Jan 21, 2022
flinkbot
pushed a commit
that referenced
this pull request
Jan 21, 2022
…dirty JobResults We don't want to retrigger jobs that finished already based on the JobResultStore.
flinkbot
pushed a commit
that referenced
this pull request
Jan 21, 2022
flinkbot
pushed a commit
that referenced
this pull request
Jan 21, 2022
flinkbot
pushed a commit
that referenced
this pull request
Jan 21, 2022
…dirty JobResults We don't want to retrigger jobs that finished already based on the JobResultStore.
flinkbot
pushed a commit
that referenced
this pull request
Jan 22, 2022
…erProcess This change covers now all cases for recovery.
flinkbot
pushed a commit
that referenced
this pull request
Jan 23, 2022
flinkbot
pushed a commit
that referenced
this pull request
Jan 23, 2022
flinkbot
pushed a commit
that referenced
this pull request
Feb 3, 2022
…o be used by both the local and global cleanup
flinkbot
pushed a commit
that referenced
this pull request
Feb 3, 2022
flinkbot
pushed a commit
that referenced
this pull request
Feb 3, 2022
flinkbot
pushed a commit
that referenced
this pull request
Feb 3, 2022
flinkbot
pushed a commit
that referenced
this pull request
Feb 3, 2022
flinkbot
pushed a commit
that referenced
this pull request
Feb 3, 2022
flinkbot
pushed a commit
that referenced
this pull request
Oct 18, 2022
[FLINK-29644] Added Flink Kubernetes operator documentation links
flinkbot
pushed a commit
that referenced
this pull request
Sep 6, 2023
flinkbot
pushed a commit
that referenced
this pull request
Nov 2, 2023
flinkbot
pushed a commit
that referenced
this pull request
Jan 31, 2024
check db key overlap before ingest and only ingest with NO_KEY_OVERLA…
flinkbot
pushed a commit
that referenced
this pull request
Apr 2, 2024
[FLINK-34440] Add support for debezium protobuf Co-authored-by: Anupam Aggarwal <anupam.aggarwal@gmail.com> Co-authored-by: dawid <dawid.wysakowicz@gmail.com>
flinkbot
pushed a commit
that referenced
this pull request
Aug 6, 2024
* Adds Compiled Plan annotations to BatchExecSort and BatchExecExchange. * Tests the new annotations with the existing SortTestPrograms.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Bump FRocksDB version to
io.github.myasukafrocksdbjni5.17.2-artisans-3.0This includes dataArtisans/frocksdb#5 and dataArtisans/frocksdb#4