This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 61b5b0a [FLINK-24087][connector-kafka] Avoid importing Table API
classes for DataStream API programs
add 6628237 [FLINK-23859] Fix typos
No new revisions were added by this update.
Summary of changes:
docs/content/docs/deployment/elastic_scaling.md | 2 +-
.../flink/client/program/DefaultPackagedProgramRetrieverTest.java | 2 +-
.../flink/connector/base/source/reader/SourceReaderOptions.java | 2 +-
.../batch/connectors/cassandra/CustomCassandraAnnotatedPojo.java | 2 +-
.../file/src/enumerate/BlockSplittingRecursiveEnumerator.java | 2 +-
.../flink/connector/file/src/reader/SimpleStreamFormat.java | 2 +-
.../sink/writer/FileWriterBucketStateSerializerMigrationTest.java | 2 +-
.../connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java | 2 +-
.../apache/flink/table/functions/hive/HiveFunctionWrapper.java | 2 +-
.../table/planner/delegation/hive/HiveParserCalcitePlanner.java | 2 +-
.../planner/delegation/hive/HiveParserTypeCheckProcFactory.java | 2 +-
.../table/planner/delegation/hive/copy/HiveASTParseDriver.java | 4 ++--
.../delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java | 2 +-
.../table/planner/delegation/hive/copy/HiveParserQBParseInfo.java | 2 +-
.../table/planner/delegation/hive/copy/HiveParserQBSubQuery.java | 2 +-
.../planner/delegation/hive/copy/HiveParserWindowingSpec.java | 2 +-
.../java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java | 2 +-
.../kafka/source/enumerator/subscriber/TopicListSubscriber.java | 2 +-
.../reader/deserializer/KafkaRecordDeserializationSchema.java | 2 +-
.../streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java | 4 ++--
.../flink/streaming/connectors/kafka/KafkaConsumerTestBase.java | 2 +-
.../connectors/kinesis/config/ConsumerConfigConstants.java | 2 +-
.../connectors/kinesis/internals/KinesisDataFetcher.java | 2 +-
.../streaming/connectors/kinesis/util/KinesisConfigUtil.java | 2 +-
.../connector/pulsar/source/enumerator/cursor/StartCursor.java | 2 +-
.../src/test/resources/containers/txnStandalone.conf | 4 ++--
.../streaming/connectors/rabbitmq/RMQDeserializationSchema.java | 2 +-
.../flink/api/common/typeutils/TypeSerializerConfigSnapshot.java | 2 +-
.../java/org/apache/flink/configuration/CheckpointingOptions.java | 2 +-
.../main/java/org/apache/flink/configuration/ConfigOption.java | 4 ++--
.../org/apache/flink/core/fs/RecoverableFsDataOutputStream.java | 2 +-
.../src/main/java/org/apache/flink/util/InstantiationUtil.java | 2 +-
.../org/apache/flink/api/common/io/DelimitedInputFormatTest.java | 2 +-
flink-core/src/test/java/org/apache/flink/types/RecordTest.java | 2 +-
flink-dist/src/main/flink-bin/bin/config.sh | 4 ++--
.../org/apache/flink/changelog/fs/FsStateChangelogOptions.java | 2 +-
.../streaming/tests/NettyShuffleMemoryControlTestProgram.java | 2 +-
flink-end-to-end-tests/flink-python-test/python/python_job.py | 2 +-
flink-end-to-end-tests/test-scripts/common_yarn_docker.sh | 2 +-
flink-end-to-end-tests/test-scripts/kafka-common.sh | 2 +-
.../flink/examples/java/misc/CollectionExecutionExample.java | 2 +-
.../java/org/apache/flink/streaming/examples/join/WindowJoin.java | 4 ++--
.../apache/flink/streaming/scala/examples/join/WindowJoin.scala | 8 ++++----
.../org/apache/flink/formats/avro/RowDataToAvroConverters.java | 2 +-
.../java/org/apache/flink/formats/avro/typeutils/AvroFactory.java | 2 +-
.../apache/flink/orc/nohive/vector/AbstractOrcNoHiveVector.java | 2 +-
.../java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java | 2 +-
flink-java/src/main/java/org/apache/flink/api/java/DataSet.java | 2 +-
.../org/apache/flink/api/java/operators/PartitionOperator.java | 4 ++--
49 files changed, 59 insertions(+), 59 deletions(-)
