This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch benchmark-request
in repository https://gitbox.apache.org/repos/asf/flink.git.
discard cffa1ae Bump lz4-java to 1.8.0
add ed39fb2 [FLINK-23395] Bump Okhttp to 3.14.9
new a2ad139 [FLINK-23329][build] Bump flink-shaded to 14.0
new 36e0224 Adjust guava package
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (cffa1ae)
\
N -- N -- N refs/heads/benchmark-request (36e0224)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../application/JarManifestParserTest.java | 4 +--
.../cassandra/CassandraInputFormatBase.java | 2 +-
.../source/HBaseRowDataAsyncLookupFunction.java | 4 +--
.../connector/hbase2/HBaseConnectorITCase.java | 2 +-
.../HBaseRowDataAsyncLookupFunctionTest.java | 2 +-
.../hbase/source/HBaseRowDataLookupFunction.java | 4 +--
.../connectors/hive/FlinkEmbeddedHiveRunner.java | 2 +-
.../connectors/hive/FlinkStandaloneHiveRunner.java | 4 +--
.../connector/jdbc/table/JdbcLookupFunction.java | 4 +--
.../jdbc/table/JdbcRowDataLookupFunction.java | 4 +--
.../connectors/kafka/FlinkKafkaProducer.java | 2 +-
.../internals/FlinkKafkaInternalProducer.java | 2 +-
.../kafka/FlinkKafkaInternalProducerITCase.java | 2 +-
.../connectors/kafka/KafkaConsumerTestBase.java | 2 +-
.../kafka/shuffle/KafkaShuffleITCase.java | 4 +--
.../kinesis/testutils/KinesisPubsubClient.java | 2 +-
...inesisDataFetcherForShardConsumerException.java | 2 +-
.../GuavaFlinkConnectorRateLimiter.java | 2 +-
.../apache/flink/configuration/CoreOptions.java | 4 +--
.../core/classloading/ComponentClassLoader.java | 2 +-
.../java/org/apache/flink/core/fs/FileSystem.java | 8 +++---
.../flink/core/plugin/DefaultPluginManager.java | 2 +-
.../main/java/org/apache/flink/util/FileUtils.java | 4 +--
.../flink/configuration/ConfigOptionTest.java | 2 +-
.../apache/flink/core/plugin/PluginConfigTest.java | 2 +-
flink-dist/pom.xml | 2 +-
flink-dist/src/main/resources/META-INF/NOTICE | 2 +-
.../org/apache/flink/dist/BashJavaUtilsITCase.java | 2 +-
.../flink-end-to-end-tests-common/pom.xml | 1 -
.../flink-glue-schema-registry-test/pom.xml | 2 ++
.../flink-metrics-reporter-prometheus-test/pom.xml | 1 -
.../tests/queryablestate/QsStateProducer.java | 2 +-
.../kinesis/test/KinesisTableApiITCase.java | 2 +-
.../flink-avro-glue-schema-registry/pom.xml | 2 ++
flink-kubernetes/pom.xml | 18 +++++-------
.../decorators/FlinkConfMountDecorator.java | 2 +-
.../decorators/KerberosMountDecorator.java | 2 +-
.../decorators/PodTemplateMountDecorator.java | 2 +-
.../src/main/resources/META-INF/NOTICE | 6 ++--
.../flink/kubernetes/KubernetesTestUtils.java | 2 +-
.../flink/cep/nfa/sharedbuffer/SharedBuffer.java | 2 +-
.../apache/flink/cep/nfa/AfterMatchSkipITCase.java | 2 +-
.../org/apache/flink/cep/nfa/GreedyITCase.java | 2 +-
.../java/org/apache/flink/cep/nfa/GroupITCase.java | 2 +-
.../flink/cep/nfa/IterativeConditionsITCase.java | 2 +-
.../java/org/apache/flink/cep/nfa/NFAITCase.java | 2 +-
.../org/apache/flink/cep/nfa/NotPatternITCase.java | 2 +-
.../apache/flink/cep/nfa/SameElementITCase.java | 4 +--
.../apache/flink/cep/nfa/TimesOrMoreITCase.java | 2 +-
.../org/apache/flink/cep/nfa/TimesRangeITCase.java | 2 +-
.../apache/flink/cep/nfa/UntilConditionITCase.java | 2 +-
.../flink/cep/nfa/compiler/NFACompilerTest.java | 2 +-
.../apache/flink/cep/operator/CEPOperatorTest.java | 2 +-
.../apache/flink/cep/utils/TestSharedBuffer.java | 4 +--
.../state/api/runtime/OperatorIDGenerator.java | 2 +-
flink-metrics/flink-metrics-datadog/pom.xml | 10 ++++++-
.../src/main/resources/META-INF/NOTICE | 4 +--
.../src/main/resources/META-INF/NOTICE | 4 +--
.../flink/optimizer/dag/SingleInputNode.java | 2 +-
.../apache/flink/optimizer/dag/TwoInputNode.java | 2 +-
.../apache/flink/client/python/PythonEnvUtils.java | 2 +-
.../flink/client/python/PythonFunctionFactory.java | 8 +++---
.../env/beam/ProcessPythonEnvironmentManager.java | 2 +-
.../flink/streaming/api/utils/PythonTypeUtils.java | 2 +-
.../flink/table/runtime/arrow/ArrowUtils.java | 2 +-
.../flink/table/runtime/arrow/ArrowUtilsTest.java | 2 +-
.../arrow/sources/ArrowSourceFunctionTestBase.java | 2 +-
.../queryablestate/network/AbstractServerBase.java | 2 +-
.../flink/queryablestate/network/Client.java | 2 +-
.../runtime/webmonitor/handlers/JarRunHandler.java | 2 +-
.../webmonitor/handlers/utils/JarHandlerUtils.java | 2 +-
flink-runtime/pom.xml | 1 +
.../flink/runtime/blob/FileSystemBlobStore.java | 2 +-
.../runtime/checkpoint/TaskStateSnapshot.java | 2 +-
.../runtime/clusterframework/BootstrapTools.java | 4 +--
.../dispatcher/FileExecutionGraphInfoStore.java | 12 ++++----
.../runtime/dispatcher/JobDispatcherFactory.java | 2 +-
.../entrypoint/SessionClusterEntrypoint.java | 2 +-
.../runtime/io/network/api/TaskEventHandler.java | 4 +--
.../runtime/io/network/netty/NettyServer.java | 2 +-
.../network/partition/PipelinedSubpartition.java | 2 +-
.../partition/consumer/RemoteInputChannel.java | 2 +-
.../network/partition/consumer/UnionInputGate.java | 2 +-
.../flink/runtime/metrics/ReporterSetup.java | 2 +-
.../runtime/rest/handler/AbstractHandler.java | 2 +-
.../handler/async/CompletedOperationCache.java | 8 +++---
.../job/checkpoints/CheckpointStatsCache.java | 4 +--
.../AbstractTaskManagerFileHandler.java | 8 +++---
.../scheduler/adaptive/JobGraphJobInformation.java | 2 +-
.../org/apache/flink/runtime/state/StateUtil.java | 2 +-
.../changelog/ChangelogStateBackendHandle.java | 2 +-
.../changelog/StateChangelogStorageLoader.java | 2 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 4 +--
.../TaskExecutorMemoryConfiguration.java | 2 +-
.../util/config/memory/ManagedMemoryUtils.java | 4 +--
.../stats/TaskStatsRequestCoordinator.java | 2 +-
.../threadinfo/JobVertexThreadInfoTracker.java | 4 +--
.../zookeeper/ZooKeeperStateHandleStore.java | 2 +-
.../CheckpointCoordinatorRestoringTest.java | 2 +-
.../checkpoint/CheckpointCoordinatorTest.java | 2 +-
.../InflightDataRescalingDescriptorUtil.java | 2 +-
.../channel/RecordingChannelStateWriter.java | 4 +--
.../SequentialChannelStateReaderImplTest.java | 2 +-
.../FileExecutionGraphInfoStoreTest.java | 4 +--
.../DefaultExecutionGraphConstructionTest.java | 2 +-
.../utils/TestFailoverStrategyFactory.java | 2 +-
.../filecache/FileCacheReadsFromBlobTest.java | 2 +-
.../io/network/buffer/LocalBufferPoolTest.java | 2 +-
.../JobMasterPartitionTrackerImplTest.java | 2 +-
.../TaskExecutorPartitionTrackerImplTest.java | 2 +-
.../partition/consumer/LocalInputChannelTest.java | 2 +-
.../partition/consumer/RemoteInputChannelTest.java | 2 +-
.../partition/consumer/SingleInputGateTest.java | 2 +-
.../io/network/util/TestPooledBufferProvider.java | 2 +-
.../topology/DefaultLogicalTopologyTest.java | 2 +-
.../slotpool/DefaultAllocatedSlotPoolTest.java | 2 +-
.../slotpool/DefaultDeclarativeSlotPoolTest.java | 2 +-
.../runtime/metrics/MetricRegistryImplTest.java | 2 +-
.../runtime/metrics/util/MetricUtilsTest.java | 2 +-
.../operators/AbstractOuterJoinTaskTest.java | 2 +-
.../runtime/operators/LeftOuterJoinTaskTest.java | 2 +-
.../runtime/operators/RightOuterJoinTaskTest.java | 2 +-
.../CoordinatorEventsExactlyOnceITCase.java | 2 +-
.../hash/InPlaceMutableHashTableTest.java | 25 ++++++++++++----
.../slotmanager/DeclarativeSlotManagerTest.java | 2 +-
.../LeastUtilizationSlotMatchingStrategyTest.java | 2 +-
.../runtime/scheduler/DefaultSchedulerTest.java | 2 +-
.../adapter/DefaultExecutionTopologyTest.java | 4 +--
.../DefaultSchedulingPipelinedRegionTest.java | 2 +-
.../FailureHandlingResultSnapshotTest.java | 2 +-
.../RootExceptionHistoryEntryTest.java | 2 +-
.../flink/runtime/security/SecurityUtilsTest.java | 2 +-
.../runtime/shuffle/NettyShuffleUtilsTest.java | 2 +-
.../state/InternalPriorityQueueTestBase.java | 2 +-
.../flink/runtime/state/StateBackendTestBase.java | 2 +-
.../ttl/TtlMapStateAllEntriesTestContext.java | 2 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 2 +-
.../taskexecutor/TaskManagerRunnerStartupTest.java | 2 +-
.../taskexecutor/slot/TaskSlotTableImplTest.java | 2 +-
.../apache/flink/runtime/util/ManualTicker.java | 2 +-
.../flink/runtime/util/ResourceCounterTest.java | 2 +-
.../apache/flink/runtime/util/RunnablesTest.java | 2 +-
.../scala/typeutils/TraversableSerializer.scala | 2 +-
.../state/RocksDBCachingPriorityQueueSet.java | 2 +-
.../streaming/api/graph/StreamGraphHasherV2.java | 6 ++--
.../api/operators/OperatorSnapshotFutures.java | 2 +-
.../api/operators/StreamOperatorStateHandler.java | 2 +-
.../transformations/CoFeedbackTransformation.java | 2 +-
.../transformations/FeedbackTransformation.java | 2 +-
.../transformations/LegacySinkTransformation.java | 2 +-
.../transformations/OneInputTransformation.java | 2 +-
.../transformations/PartitionTransformation.java | 2 +-
.../api/transformations/ReduceTransformation.java | 2 +-
.../transformations/SideOutputTransformation.java | 2 +-
.../api/transformations/SinkTransformation.java | 2 +-
.../TimestampsAndWatermarksTransformation.java | 2 +-
.../transformations/TwoInputTransformation.java | 2 +-
.../api/transformations/UnionTransformation.java | 2 +-
.../api/windowing/evictors/DeltaEvictor.java | 2 +-
.../recovery/DemultiplexingRecordDeserializer.java | 2 +-
.../recovery/RescalingStreamTaskNetworkInput.java | 2 +-
.../windowing/EvictingWindowOperator.java | 6 ++--
.../streaming/runtime/tasks/OperatorChain.java | 2 +-
.../streaming/api/AggregationFunctionTest.java | 2 +-
.../api/graph/StreamingJobGraphGeneratorTest.java | 2 +-
.../api/operators/co/IntervalJoinOperatorTest.java | 4 +--
.../source/SourceOperatorEventTimeTest.java | 2 +-
.../checkpointing/CheckpointedInputGateTest.java | 2 +-
.../DemultiplexingRecordDeserializerTest.java | 2 +-
.../windowing/ContinuousEventTimeTriggerTest.java | 2 +-
.../operators/windowing/CountTriggerTest.java | 2 +-
.../DynamicEventTimeSessionWindowsTest.java | 2 +-
.../DynamicProcessingTimeSessionWindowsTest.java | 2 +-
.../windowing/EventTimeSessionWindowsTest.java | 2 +-
.../operators/windowing/EventTimeTriggerTest.java | 2 +-
.../operators/windowing/MergingWindowSetTest.java | 2 +-
.../ProcessingTimeSessionWindowsTest.java | 2 +-
.../windowing/ProcessingTimeTriggerTest.java | 2 +-
.../operators/windowing/WindowOperatorTest.java | 4 +--
.../runtime/tasks/SourceStreamTaskTestBase.java | 2 +-
.../tasks/SubtaskCheckpointCoordinatorTest.java | 2 +-
.../flink/streaming/util/TestHarnessUtil.java | 2 +-
.../flink/table/client/cli/CliClientITCase.java | 2 +-
.../functions/sql/SqlCumulateTableFunction.java | 2 +-
.../sql/SqlFirstLastValueAggFunction.java | 2 +-
.../planner/functions/sql/SqlHopTableFunction.java | 2 +-
.../planner/functions/sql/SqlListAggFunction.java | 2 +-
.../functions/sql/SqlTumbleTableFunction.java | 2 +-
.../functions/sql/SqlWindowTableFunction.java | 2 +-
.../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 2 +-
.../nodes/exec/stream/StreamExecIntervalJoin.java | 2 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 2 +-
.../nodes/exec/stream/StreamExecWindowJoin.java | 2 +-
.../plan/schema/FlinkPreparingTableBase.java | 6 ++--
.../plan/utils/RelDescriptionWriterImpl.java | 2 +-
.../apache/flink/table/planner/utils/Expander.java | 2 +-
.../plan/schema/LegacyTableSourceTable.scala | 2 +-
.../planner/catalog/CatalogConstraintTest.java | 2 +-
.../flink/table/formats/raw/RawFormatFactory.java | 2 +-
.../table/runtime/generated/CompileUtils.java | 4 +--
.../operators/rank/AppendOnlyTopNFunction.java | 4 +--
.../runtime/operators/rank/FastTop1Function.java | 10 +++----
.../operators/rank/UpdatableTopNFunction.java | 10 +++----
.../apache/flink/table/runtime/util/JsonUtils.java | 2 +-
.../window/slicing/SliceAssignerTestBase.java | 2 +-
.../UdfStreamOperatorCheckpointingITCase.java | 2 +-
.../checkpointing/UnalignedCheckpointITCase.java | 2 +-
.../UnalignedCheckpointStressITCase.java | 2 +-
.../checkpointing/UnalignedCheckpointTestBase.java | 4 +--
.../utils/CancellingIntegerSource.java | 2 +-
.../test/plugin/DefaultPluginManagerTest.java | 2 +-
.../test/streaming/runtime/IntervalJoinITCase.java | 2 +-
.../flink/yarn/YARNHighAvailabilityITCase.java | 2 +-
.../yarn/YARNSessionCapacitySchedulerITCase.java | 4 +--
.../flink/yarn/YARNSessionFIFOSecuredITCase.java | 2 +-
.../flink/yarn/testjob/YarnTestArchiveJob.java | 2 +-
.../flink/yarn/testjob/YarnTestCacheJob.java | 2 +-
.../apache/flink/yarn/FlinkYarnSessionCliTest.java | 2 +-
.../flink/yarn/YarnResourceManagerDriverTest.java | 2 +-
pom.xml | 33 +++++++++++++---------
220 files changed, 331 insertions(+), 306 deletions(-)
