[FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType #17084
Conversation
This file contains hidden or 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
…ming from unaligned checkpoints In the initial implementation of rescaling channel data we assumed that the subtasks indices are the same for all input gates. This assumptions does not hold when there are different partitioners. It can happen e.g. in case of a broadcast with a keyed input. The commit tracks the subtask indices separately for each partition and input gate. This closes apache#16019
…e SQL file in SQL Client This closes apache#16059
…th empty schema This closes apache#15638
…ng rescale edges in EdgeManagerBuildUtil This closes apache#16071
…to Chinese. This closes apache#16061.
…egment in order to avoid extracting it from the bufferBuilder (cherry picked from commit 3974687)
…erences counting (cherry picked from commit 1051ea9)
…rship of the input Buffer (cherry picked from commit 2293362)
…el#onBuffer in javadoc (cherry picked from commit bc8c739)
…ble" page This closes apache#16098
…ata file is ready This closes apache#16099
…dBeExecutedInShutdownHook Hardens the ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook by increasing the timeout from 3s to 10s.
…erEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook This closes apache#16111.
…rg.hamcrest.MatcherAssert.assertThat
…support top1 This closes apache#16088
…e compared to other similarly named methods
…rceOperatorStreamTask
… for SourceTasks This commit is fixing a bug of checkpointStartDelay being not set in CheckpointMetrics of SourceStreamTask and SourceOperatorStreamTask.
…tbeat exceptions in log This closes apache#16127
….heap.size. This closes apache#16143
… Configuration page This closes apache#16725.
… tests due to Python 3.7 was removed from debian
This commit reverts the change that we store the logs under FLINK_DIR/logs because this can make the e2e tests fail if the directory does not exist. Now we store the logs under FLINK_DIR/log This closes apache#16982.
…ary tables This closes apache#16960.
…ializer and MapDataSerializer This closes apache#16998.
…in KafkaTableTestBase (apache#16897)
…d to end tests due to Python 3.7 was removed from debian" This reverts commit f998da0
…on to use conda to install Python This closes apache#17014.
In order to avoid that we don't log failure causes of failed jobs (e.g. initialization errors), this commit lets the Dispatcher log the failure cause when archiving the job. This will ensure that there will be always a record of what happened in the logs of the Dispatcher. This closes apache#17013.
…r commit instead of per partition
This commit makes the handler that is used for the testConcurrentQueries shareable so that Netty won't fail if another pipeline is created.
…ction This commit replaces the Client.pendingConnections and .establishedConnections with a single data structure connections of type ServerConnection. The logic of a pending and established conneciton is moved into this class. This allows to get rid of concurrent access to the Client data structures. This closes apache#16915.
The problem was that we output the number of state entries at the time when the checkpoint is confirmed. However, at this point in time we might have already added more elements to the map. Hence, we risk reporting more elements than are actually contained in the checkpoint. The solution is to remember what the element count was when creating the checkpoint. This closes apache#17028.
…ultDispatcherRunner This commit logs on info level when the DefaultDispatcherRunner was granted or revoked its leadership. This closes apache#17034.
… in changelog inference for DAG optimizing This closes apache#16979 (cherry picked from commit ffd2520)
…e checkpoint notifications
… in TupleTypeInfo This closes apache#17046.
…ecTemporalSort operator didn't support LocalZonedTimestampType
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
20 participants
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.
What is the purpose of the change
StreamExecOverAggregateandStreamExecTemporalSortoperators didn't support LocalZonedTimestampTypeBrief change log
LogicalTypeChecks#isRowtimeAttribute()utils to check the rowtime attributeVerifying this change
Does this pull request potentially affect one of the following parts:
@Public(Evolving): (no)Documentation