flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [flink] branch master updated (61b5b0a -> 6628237)
Date Wed, 01 Sep 2021 11:40:19 GMT
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(-)

Mime
View raw message