[
https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401304#comment-17401304
]
wuguihu commented on FLINK-23859:
---------------------------------
Hi,[~chesnay]
Excuse me for taking up your time.
I created pull request for this issue.
Would you like to review it for me.
If there is any problem, please inform me in time.
I will actively revise it in time.
Thank you very much!
> [typo][flink-core][flink-connectors]fix typo for code
> -------------------------------------------------------
>
> Key: FLINK-23859
> URL: https://issues.apache.org/jira/browse/FLINK-23859
> Project: Flink
> Issue Type: Bug
> Reporter: wuguihu
> Priority: Minor
> Labels: pull-request-available
>
> There are some typo issues in these modules.
>
> {code:java}
> # Use the Codespell tool to check typo issue.
> pip install codespell
> codespell -h
> {code}
>
> 1、 codespell flink-java/src
> {code:java}
> flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java:125:
> partioning ==> partitioning
> flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java:128:
> neccessary ==> necessary
> {code}
>
> 2、 codespell flink-clients/
> {code:java}
> flink-clients/src/test/java/org/apache/flink/client/program/DefaultPackagedProgramRetrieverTest.java:545:
> acessible ==> accessible
> {code}
>
> 3、codespell flink-connectors/ -S '*.xml' -S '*.iml' -S '*.txt'
>
> {code:java}
> flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/SourceReaderOptions.java:25:
> tht ==> that
> flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalogTestBase.java:192:
> doens't ==> doesn't
> flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java:96:
> PostgresSQL ==> postgresql
> flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/batch/connectors/cassandra/CustomCassandraAnnotatedPojo.java:38:
> instanciation ==> instantiation
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserCalcitePlanner.java:822:
> partion ==> partition
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserTypeCheckProcFactory.java:943:
> funtion ==> function
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveASTParseDriver.java:55:
> funtion ==> function
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveASTParseDriver.java:51:
> characteres ==> characters
> flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java:436:
> paremeters ==> parameters
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:2369:
> Unkown ==> Unknown
> flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java:75:
> reprsents ==> represents
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveFunctionWrapper.java:28:
> functino ==> function
> flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunction.java:62:
> implemenation
> flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java:70:
> ture ==> true
> flink-connectors/flink-connector-pulsar/src/test/resources/containers/txnStandalone.conf:907:
> partions ==> partitions
> flink-connectors/flink-connector-pulsar/src/test/resources/containers/txnStandalone.conf:468:
> implementatation ==> implementation
> flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/enumerate/BlockSplittingRecursiveEnumerator.java:141:
> bloc ==> block
> flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/SimpleStreamFormat.java:37:
> te ==> the
> flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java:70:
> determin ==> determine
> flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/TopicListSubscriber.java:36:
> hav ==> have
> flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserQBSubQuery.java:555:
> correlatd ==> correlated
> flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java:263:
> intial ==> initial
> flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java:302:
> intial ==> initial
> flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java:249:
> wth ==> with
> flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/writer/FileWriterBucketStateSerializerMigrationTest.java:232:
> comitted ==> committed
> flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQDeserializationSchema.java:96:
> invokation ==> invocation
> flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java:171:
> doesnt ==> doesn't
> {code}
>
> 4、codespell flink-core/ -S '*.xml' -S '*.iml' -S '*.txt'
>
> {code:bash}
> flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerConfigSnapshot.java:194:
> preform ==> perform
> flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java:150:
> aways
> flink-core/src/main/java/org/apache/flink/configuration/ConfigOption.java:164:
> documention ==> documentation
> flink-core/src/main/java/org/apache/flink/configuration/ConfigOption.java:175:
> documention ==> documentation
> flink-core/src/main/java/org/apache/flink/core/fs/RecoverableFsDataOutputStream.java:54:
> retured ==> returned
> flink-core/src/test/java/org/apache/flink/api/common/io/DelimitedInputFormatTest.java:352:
> skipp ==> skip
> flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java:216:
> occurences ==> occurrences
> {code}
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
