[jira] [Updated] (FLINK-23859) Fix typos

["Chesnay Schepler (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler updated FLINK-23859:
-------------------------------------
    Summary: Fix typos  (was: [typo][flink-core][flink-connectors]fix typo for code  )

> Fix typos
> ---------
>
>                 Key: FLINK-23859
>                 URL: https://issues.apache.org/jira/browse/FLINK-23859
>             Project: Flink
>          Issue Type: Technical Debt
>            Reporter: wuguihu
>            Assignee: wuguihu
>            Priority: Not a Priority
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> 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)