[jira] [Commented] (FLINK-28121) Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17569068#comment-17569068 ] Chengkai Yang commented on FLINK-28121: --- [~hunterLiu] Hi, thanks for your contributions. I think it is better to submit my translations in my own pr of FLINK-28121 instead of joining your pr. Because it is recommended by the community that one pr should only solve one jira issue for the best. > Translate "Extension Points" and "Full Stack Example" in "User-defined > Sources & Sinks" page > - > > Key: FLINK-28121 > URL: https://issues.apache.org/jira/browse/FLINK-28121 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Comment Edited] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556978#comment-17556978 ] Chengkai Yang edited comment on FLINK-28122 at 6/21/22 3:38 PM: Sorry, [~chenzihao] I don't have the authority to assign it to you. Maybe you can ask someone who has the authority to that. But I'm willing to help review it after you pull the request on Github. was (Author: JIRAUSER282569): Sorry, [~chenzihao] I don't have the authority to assign you. Maybe you can ask someone who has the authority to assign this to you. But I'm willing to help review it after you pull the request on Github. > Translate "Overview " and "Project Configuration" in "User-defined Sources & > Sinks" page > - > > Key: FLINK-28122 > URL: https://issues.apache.org/jira/browse/FLINK-28122 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#overview > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#project-configuration -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Comment Edited] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556978#comment-17556978 ] Chengkai Yang edited comment on FLINK-28122 at 6/21/22 3:38 PM: Sorry, [~chenzihao] I don't have the authority to assign it to you. Maybe you can ask someone who has the authority to do that. But I'm willing to help review it after you pull the request on Github. was (Author: JIRAUSER282569): Sorry, [~chenzihao] I don't have the authority to assign it to you. Maybe you can ask someone who has the authority to that. But I'm willing to help review it after you pull the request on Github. > Translate "Overview " and "Project Configuration" in "User-defined Sources & > Sinks" page > - > > Key: FLINK-28122 > URL: https://issues.apache.org/jira/browse/FLINK-28122 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#overview > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#project-configuration -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556978#comment-17556978 ] Chengkai Yang commented on FLINK-28122: --- Sorry, [~chenzihao] I don't have the authority to assign you. Maybe you can ask someone who has the authority to assign this to you. But I'm willing to help review it after you pull the request on Github. > Translate "Overview " and "Project Configuration" in "User-defined Sources & > Sinks" page > - > > Key: FLINK-28122 > URL: https://issues.apache.org/jira/browse/FLINK-28122 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#overview > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#project-configuration -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Comment Edited] (FLINK-16105) Translate "User-defined Sources & Sinks" page of "Table API & SQL" into Chinese
[
https://issues.apache.org/jira/browse/FLINK-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556085#comment-17556085
]
Chengkai Yang edited comment on FLINK-16105 at 6/20/22 2:11 AM:
Hi,[~jark] could you assign this issue to me please?
was (Author: JIRAUSER282569):
Hi,[~jark] could you send this issue to me please?
> Translate "User-defined Sources & Sinks" page of "Table API & SQL" into
> Chinese
>
>
> Key: FLINK-16105
> URL: https://issues.apache.org/jira/browse/FLINK-16105
> Project: Flink
> Issue Type: Sub-task
> Components: chinese-translation, Documentation
>Reporter: Jark Wu
>Priority: Major
> Labels: auto-unassigned, pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> The page url is
> https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sourceSinks.html
> The markdown file is located in {{flink/docs/dev/table/sourceSinks.zh.md}}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
[jira] [Commented] (FLINK-28121) Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556158#comment-17556158 ] Chengkai Yang commented on FLINK-28121: --- [~jark] hi,could you assign this to me? > Translate "Extension Points" and "Full Stack Example" in "User-defined > Sources & Sinks" page > - > > Key: FLINK-28121 > URL: https://issues.apache.org/jira/browse/FLINK-28121 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-28121) Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-28121: -- Description: The links are https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points and https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example was: The link is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points and https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example > Translate "Extension Points" and "Full Stack Example" in "User-defined > Sources & Sinks" page > - > > Key: FLINK-28121 > URL: https://issues.apache.org/jira/browse/FLINK-28121 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-28122: -- Description: The links are https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#overview and https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#project-configuration > Translate "Overview " and "Project Configuration" in "User-defined Sources & > Sinks" page > - > > Key: FLINK-28122 > URL: https://issues.apache.org/jira/browse/FLINK-28122 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The links are > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#overview > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#project-configuration -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-28122: -- Component/s: chinese-translation Documentation > Translate "Overview " and "Project Configuration" in "User-defined Sources & > Sinks" page > - > > Key: FLINK-28122 > URL: https://issues.apache.org/jira/browse/FLINK-28122 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Created] (FLINK-28122) Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page
Chengkai Yang created FLINK-28122: - Summary: Translate "Overview " and "Project Configuration" in "User-defined Sources & Sinks" page Key: FLINK-28122 URL: https://issues.apache.org/jira/browse/FLINK-28122 Project: Flink Issue Type: Improvement Reporter: Chengkai Yang -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-28121) Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page
[ https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-28121: -- Summary: Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page (was: Translate in "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page ) > Translate "Extension Points" and "Full Stack Example" in "User-defined > Sources & Sinks" page > - > > Key: FLINK-28121 > URL: https://issues.apache.org/jira/browse/FLINK-28121 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The link is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points > and > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Created] (FLINK-28121) Translate in "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page
Chengkai Yang created FLINK-28121: - Summary: Translate in "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page Key: FLINK-28121 URL: https://issues.apache.org/jira/browse/FLINK-28121 Project: Flink Issue Type: Improvement Components: chinese-translation, Documentation Reporter: Chengkai Yang The link is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#extension-points and https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#full-stack-example -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-16105) Translate "User-defined Sources & Sinks" page of "Table API & SQL" into Chinese
[
https://issues.apache.org/jira/browse/FLINK-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17556085#comment-17556085
]
Chengkai Yang commented on FLINK-16105:
---
Hi,[~jark] could you send this issue to me please?
> Translate "User-defined Sources & Sinks" page of "Table API & SQL" into
> Chinese
>
>
> Key: FLINK-16105
> URL: https://issues.apache.org/jira/browse/FLINK-16105
> Project: Flink
> Issue Type: Sub-task
> Components: chinese-translation, Documentation
>Reporter: Jark Wu
>Priority: Major
> Labels: auto-unassigned, pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> The page url is
> https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sourceSinks.html
> The markdown file is located in {{flink/docs/dev/table/sourceSinks.zh.md}}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
[jira] [Commented] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554138#comment-17554138 ] Chengkai Yang commented on FLINK-27292: --- Hi,[~casonPig] I noticed that you have taken [FLINK-27291|https://issues.apache.org/jira/browse/FLINK-27291], and it would be nice if you could help to review this issue after [~yangsanity] makes a PR on Github. > Translate the "Data Type Extraction" section of "Data Types" in to Chinese > -- > > Key: FLINK-27292 > URL: https://issues.apache.org/jira/browse/FLINK-27292 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > Attachments: DataTypeExtraction.png > > > This JIRA translate the "Data Type Extraction" section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554086#comment-17554086 ] Chengkai Yang commented on FLINK-27292: --- Sure, [~yangsanity] feel free to contribute! I don't have the authority to assign tickets, [~mvis...@pivotal.io] could you assign this to [~yangsanity]? > Translate the "Data Type Extraction" section of "Data Types" in to Chinese > -- > > Key: FLINK-27292 > URL: https://issues.apache.org/jira/browse/FLINK-27292 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > Attachments: DataTypeExtraction.png > > > This JIRA translate the "Data Type Extraction" section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Comment Edited] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531024#comment-17531024 ] Chengkai Yang edited comment on FLINK-27290 at 5/30/22 3:26 PM: I will work on this after [26588|https://issues.apache.org/jira/browse/FLINK-26588] being merged to make sure the style of this page is accepted by my reviewors. was (Author: JIRAUSER282569): I will work on this after [26588|https://issues.apache.org/jira/browse/FLINK-26588] being reviewed or merged to make sure the style of this page is accepted by my reviewors. > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Affects Version/s: 1.14.3
1.14.2
1.14.0
> Example code in 'Structure of Table API and SQL Programs' is out of date and
> cannot run
> ---
>
> Key: FLINK-27544
> URL: https://issues.apache.org/jira/browse/FLINK-27544
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Affects Versions: 1.14.0, 1.15.0, 1.14.2, 1.14.3, 1.14.4
>Reporter: Chengkai Yang
>Priority: Major
>
> The example code in [Structure of Table API and SQL
> Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
> of ['Concepts & Common
> API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
> is out of date and when user run this piece of code, they will get the
> following result:
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.ValidationException:
> Unable to create a sink for writing table
> 'default_catalog.default_database.SinkTable'.
> Table options are:
> 'connector'='blackhole'
> 'rows-per-second'='1'
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
> at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> at scala.collection.Iterator.foreach(Iterator.scala:937)
> at scala.collection.Iterator.foreach$(Iterator.scala:937)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> at scala.collection.IterableLike.foreach(IterableLike.scala:70)
> at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at scala.collection.TraversableLike.map(TraversableLike.scala:233)
> at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
> at
> org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
> at com.yck.TestTableAPI.main(TestTableAPI.java:43)
> Caused by: org.apache.flink.table.api.ValidationException: Unsupported
> options found for 'blackhole'.
> Unsupported options:
> rows-per-second
> Supported options:
> connector
> property-version
> at
> org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
> at
> org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
> at
> org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
> at
> org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory.createDynamicTableSink(BlackHoleTableSinkFactory.java:64)
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
> ... 19 more
> {code}
> I think this mistake would drive users crazy when they first fry Table API &
> Flink SQL since this is the very first code they see.
> Overall this code is outdated in two places:
> 1. The Query creating temporary table should be
> {code:sql}
> CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
> SourceTable (EXCLUDING OPTIONS)
> {code}
> instead of
> {code:sql}
> CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
> SourceTable
> {code} which missed {code:sql}
> (EXCLUDING OPTIONS)
> {code} sql_like_pattern
> 2. The part creating a source table should be
> {code:java}
> tableEnv.createTemporaryTable("SourceTable",
> TableDescriptor.forConnector("datagen")
> .schema(Schema.newBuilder()
> .column("f0", DataTypes.STRING())
> .build())
> .option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
> .build
[jira] [Commented] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533679#comment-17533679
]
Chengkai Yang commented on FLINK-27544:
---
[~martijnvisser] sure!
> Example code in 'Structure of Table API and SQL Programs' is out of date and
> cannot run
> ---
>
> Key: FLINK-27544
> URL: https://issues.apache.org/jira/browse/FLINK-27544
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Affects Versions: 1.15.0, 1.14.4
>Reporter: Chengkai Yang
>Priority: Major
>
> The example code in [Structure of Table API and SQL
> Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
> of ['Concepts & Common
> API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
> is out of date and when user run this piece of code, they will get the
> following result:
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.ValidationException:
> Unable to create a sink for writing table
> 'default_catalog.default_database.SinkTable'.
> Table options are:
> 'connector'='blackhole'
> 'rows-per-second'='1'
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
> at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> at scala.collection.Iterator.foreach(Iterator.scala:937)
> at scala.collection.Iterator.foreach$(Iterator.scala:937)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> at scala.collection.IterableLike.foreach(IterableLike.scala:70)
> at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at scala.collection.TraversableLike.map(TraversableLike.scala:233)
> at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
> at
> org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
> at com.yck.TestTableAPI.main(TestTableAPI.java:43)
> Caused by: org.apache.flink.table.api.ValidationException: Unsupported
> options found for 'blackhole'.
> Unsupported options:
> rows-per-second
> Supported options:
> connector
> property-version
> at
> org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
> at
> org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
> at
> org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
> at
> org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory.createDynamicTableSink(BlackHoleTableSinkFactory.java:64)
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
> ... 19 more
> {code}
> I think this mistake would drive users crazy when they first fry Table API &
> Flink SQL since this is the very first code they see.
> Overall this code is outdated in two places:
> 1. The Query creating temporary table should be
> {code:sql}
> CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
> SourceTable (EXCLUDING OPTIONS)
> {code}
> instead of
> {code:sql}
> CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
> SourceTable
> {code} which missed {code:sql}
> (EXCLUDING OPTIONS)
> {code} sql_like_pattern
> 2. The part creating a source table should be
> {code:java}
> tableEnv.createTemporaryTable("SourceTable",
> TableDescriptor.forConnector("datagen")
> .schema(Schema.newBuilder()
> .column("f0", DataTypes.STRING())
> .build())
> .option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
> .build());
> {code}
> instead of
> {
[jira] [Commented] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17533584#comment-17533584
]
Chengkai Yang commented on FLINK-27544:
---
cc [~gaoyunhaii] would you mind to take a look at this?
> Example code in 'Structure of Table API and SQL Programs' is out of date and
> cannot run
> ---
>
> Key: FLINK-27544
> URL: https://issues.apache.org/jira/browse/FLINK-27544
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Affects Versions: 1.15.0, 1.14.4
>Reporter: Chengkai Yang
>Priority: Major
>
> The example code in [Structure of Table API and SQL
> Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
> of ['Concepts & Common
> API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
> is out of date and when user run this piece of code, they will get the
> following result:
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.ValidationException:
> Unable to create a sink for writing table
> 'default_catalog.default_database.SinkTable'.
> Table options are:
> 'connector'='blackhole'
> 'rows-per-second'='1'
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
> at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> at scala.collection.Iterator.foreach(Iterator.scala:937)
> at scala.collection.Iterator.foreach$(Iterator.scala:937)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> at scala.collection.IterableLike.foreach(IterableLike.scala:70)
> at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at scala.collection.TraversableLike.map(TraversableLike.scala:233)
> at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
> at
> org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
> at com.yck.TestTableAPI.main(TestTableAPI.java:43)
> Caused by: org.apache.flink.table.api.ValidationException: Unsupported
> options found for 'blackhole'.
> Unsupported options:
> rows-per-second
> Supported options:
> connector
> property-version
> at
> org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
> at
> org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
> at
> org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
> at
> org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory.createDynamicTableSink(BlackHoleTableSinkFactory.java:64)
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
> ... 19 more
> {code}
> I think this mistake would drive users crazy when they first fry Table API &
> Flink SQL since this is the very first code they see.
> Overall this code is outdated in two places:
> 1. The Query creating temporary table should be
> {code:sql}
> CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
> SourceTable (EXCLUDING OPTIONS)
> {code}
> instead of
> {code:sql}
> CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
> SourceTable
> {code} which missed {code:sql}
> (EXCLUDING OPTIONS)
> {code} sql_like_pattern
> 2. The part creating a source table should be
> {code:java}
> tableEnv.createTemporaryTable("SourceTable",
> TableDescriptor.forConnector("datagen")
> .schema(Schema.newBuilder()
> .column("f0", DataTypes.STRING())
> .build())
> .option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
> .build
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='blackhole'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'blackhole'.
Unsupported options:
rows-per-second
Supported options:
connector
property-version
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory.createDynamicTableSink(BlackHoleTableSinkFactory.java:64)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
I think this mistake would drive users crazy when they first fry Table API &
Flink SQL since this is the very first code they see.
Overall this code is outdated in two places:
1. The Query creating temporary table should be
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable (EXCLUDING OPTIONS)
{code}
instead of
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable
{code} which missed {code:sql}
(EXCLUDING OPTIONS)
{code} sql_like_pattern
2. The part creating a source table should be
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
.build());
{code}
instead of
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenOptions.ROWS_PER_SECOND, 100)
.build());
{code}
since the class DataGenOptions was replaced by class DataGenConnectorOptions in
[this
commit|https://github.com/apache/flink/pull/16334/commits/865e71fade2890c584d2aaf28af366249f116f2d#diff-a2b4ad2b1792b147efc81895f0dc1d0d092fbce56f563d1b37b73a2619f29a13]
The test code is in my [github Repository(version
1.15)|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink115/src/main/java/com/yck/TestTableAPI.java#
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='blackhole'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'blackhole'.
Unsupported options:
rows-per-second
Supported options:
connector
property-version
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory.createDynamicTableSink(BlackHoleTableSinkFactory.java:64)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
Overall this code is outdated in two places:
1. The Query creating temporary table should be
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable (EXCLUDING OPTIONS)
{code}
instead of
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable
{code} which missed {code:sql}
(EXCLUDING OPTIONS)
{code} sql_like_pattern
2. The part creating a source table should be
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
.build());
{code}
instead of
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenOptions.ROWS_PER_SECOND, 100)
.build());
{code}
since the class DataGenOptions was replaced by class DataGenConnectorOptions in
[this
commit|https://github.com/apache/flink/pull/16334/commits/865e71fade2890c584d2aaf28af366249f116f2d#diff-a2b4ad2b1792b147efc81895f0dc1d0d092fbce56f563d1b37b73a2619f29a13]
The test code is in my [github Repository(version
1.15)|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink115/src/main/java/com/yck/TestTableAPI.java#L22]
and [version
1.14|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink114/src/main/java/com/yck/TestTableAPI.java]
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='blackhole'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'blackhole'.
Unsupported options:
rows-per-second
Supported options:
connector
property-version
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.blackhole.table.BlackHoleTableSinkFactory.createDynamicTableSink(BlackHoleTableSinkFactory.java:64)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
Overall this code is outdated in two places:
1. The Query creating temporary table should be
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable (EXCLUDING OPTIONS)
{code}
instead of
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable
{code} which missed {code:sql}
(EXCLUDING OPTIONS)
{code} sql_like_pattern
2. The part creating a source table should be
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
.build());
{code}
instead of
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenOptions.ROWS_PER_SECOND, 100)
.build());
{code}
since the class DataGenOptions was replaced by class DataGenConnectorOptions in
[this
commit|https://github.com/apache/flink/pull/16334/commits/865e71fade2890c584d2aaf28af366249f116f2d#diff-a2b4ad2b1792b147efc81895f0dc1d0d092fbce56f563d1b37b73a2619f29a13]
The test code is in my [github
Repository|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink115/src/main/java/com/yck/TestTableAPI.java#L22].
The affected versions are 1.15 and 1.14.
was:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.or
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'print'.
Unsupported options:
rows-per-second
Supported options:
connector
print-identifier
property-version
sink.parallelism
standard-error
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.print.table.PrintTableSinkFactory.createDynamicTableSink(PrintTableSinkFactory.java:88)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
Overall this code is outdated in two places:
1. The Query creating temporary table should be
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable (EXCLUDING OPTIONS)
{code}
instead of
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable
{code} which missed {code:sql}
(EXCLUDING OPTIONS)
{code} sql_like_pattern
2. The part creating a source table should be
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenConnectorOptions.ROWS_PER_SECOND, 1L)
.build());
{code}
instead of
{code:java}
tableEnv.createTemporaryTable("SourceTable",
TableDescriptor.forConnector("datagen")
.schema(Schema.newBuilder()
.column("f0", DataTypes.STRING())
.build())
.option(DataGenOptions.ROWS_PER_SECOND, 100)
.build());
{code}
since the class DataGenOptions was replaced by class DataGenConnectorOptions in
[this
commit|https://github.com/apache/flink/pull/16334/commits/865e71fade2890c584d2aaf28af366249f116f2d#diff-a2b4ad2b1792b147efc81895f0dc1d0d092fbce56f563d1b37b73a2619f29a13]
The test code is in my [github
Repository|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink115/src/main/java/com/yck/TestTableAPI.java#L22].
The affected versions are 1.15 and 1.14.
was:
The example code in [Structure of Table API and SQL
Progra
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'print'.
Unsupported options:
rows-per-second
Supported options:
connector
print-identifier
property-version
sink.parallelism
standard-error
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.print.table.PrintTableSinkFactory.createDynamicTableSink(PrintTableSinkFactory.java:88)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
Overall this code is outdated in two places:
1. The Query creating temporary table should be
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable (EXCLUDING OPTIONS)
{code}
instead of
{code:sql}
CREATE TEMPORARY TABLE SinkTable WITH ('connector' = 'blackhole') LIKE
SourceTable
{code}
The test code is in my [github
Repository|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink115/src/main/java/com/yck/TestTableAPI.java#L22].
The affected versions are 1.15 and 1.14.
was:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'print'.
Unsupported options:
rows-per-second
Supported options:
connector
print-identifier
property-version
sink.parallelism
standard-error
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.print.table.PrintTableSinkFactory.createDynamicTableSink(PrintTableSinkFactory.java:88)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
The test code is in my [github
Repository|https://github.com/ChengkaiYang2022/flink-test/blob/main/flink115/src/main/java/com/yck/TestTableAPI.java#L22]
The affects verisons are 1.15 and 1.14.
was:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.for
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in
'https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs'
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'print'.
Unsupported options:
rows-per-second
Supported options:
connector
print-identifier
property-version
sink.parallelism
standard-error
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.print.table.PrintTableSinkFactory.createDynamicTableSink(PrintTableSinkFactory.java:88)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
was:The example code in
'https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs'
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
> Example code in 'Structure of Table API and SQL Programs' is out of date and
> cannot run
> ---
>
> Key: FLINK-27544
> URL: https://issues.apache.org/jira/browse/FLINK-27544
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Affects Versions: 1.15.0, 1.14.4
>Reporter: Chengkai Yang
>Priority: Major
>
> The example code in
> 'https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs'
> of ['Concepts & Common
> API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
> is out of date and when user run this piece of code, they will get the
> following result:
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.ValidationException:
> Unable to create a sink for writing table
> 'default_catalog.default_database.SinkTable'.
> Table options are:
> 'connector'='print'
> 'rows-per-second'='1'
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
> at
> org.apache.flink.table.planne
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[
https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-27544:
--
Description:
The example code in [Structure of Table API and SQL
Programs|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs]
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.scala:233)
at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:178)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1656)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:782)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:861)
at
org.apache.flink.table.api.internal.TablePipelineImpl.execute(TablePipelineImpl.java:56)
at com.yck.TestTableAPI.main(TestTableAPI.java:43)
Caused by: org.apache.flink.table.api.ValidationException: Unsupported options
found for 'print'.
Unsupported options:
rows-per-second
Supported options:
connector
print-identifier
property-version
sink.parallelism
standard-error
at
org.apache.flink.table.factories.FactoryUtil.validateUnconsumedKeys(FactoryUtil.java:624)
at
org.apache.flink.table.factories.FactoryUtil$FactoryHelper.validate(FactoryUtil.java:914)
at
org.apache.flink.table.factories.FactoryUtil$TableFactoryHelper.validate(FactoryUtil.java:978)
at
org.apache.flink.connector.print.table.PrintTableSinkFactory.createDynamicTableSink(PrintTableSinkFactory.java:88)
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)
... 19 more
{code}
was:
The example code in
'https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs'
of ['Concepts & Common
API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/]
is out of date and when user run this piece of code, they will get the
following result:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unable to create a sink for writing table
'default_catalog.default_database.SinkTable'.
Table options are:
'connector'='print'
'rows-per-second'='1'
at
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:262)
at
org.apache.flink.table.planner.delegation.PlannerBase.getTableSink(PlannerBase.scala:421)
at
org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:222)
at
org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:178)
at
scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
at scala.collection.Iterator.foreach(Iterator.scala:937)
at scala.collection.Iterator.foreach$(Iterator.scala:937)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
at scala.collection.IterableLike.foreach(IterableLike.scala:70)
at scala.collection.IterableLike.foreach$(IterableLike.scala:69)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike.map(TraversableLike.s
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in 'https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs' of ['Concepts & Common API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/] (was: The example code in '') > Example code in 'Structure of Table API and SQL Programs' is out of date and > cannot run > --- > > Key: FLINK-27544 > URL: https://issues.apache.org/jira/browse/FLINK-27544 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.15.0, 1.14.4 >Reporter: Chengkai Yang >Priority: Major > > The example code in > 'https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/#structure-of-table-api-and-sql-programs' > of ['Concepts & Common > API'|https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/common/] -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
[ https://issues.apache.org/jira/browse/FLINK-27544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27544: -- Description: The example code in '' > Example code in 'Structure of Table API and SQL Programs' is out of date and > cannot run > --- > > Key: FLINK-27544 > URL: https://issues.apache.org/jira/browse/FLINK-27544 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.15.0, 1.14.4 >Reporter: Chengkai Yang >Priority: Major > > The example code in '' -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Created] (FLINK-27544) Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run
Chengkai Yang created FLINK-27544: - Summary: Example code in 'Structure of Table API and SQL Programs' is out of date and cannot run Key: FLINK-27544 URL: https://issues.apache.org/jira/browse/FLINK-27544 Project: Flink Issue Type: Improvement Components: Documentation Affects Versions: 1.14.4, 1.15.0 Reporter: Chengkai Yang -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Comment Edited] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531024#comment-17531024 ] Chengkai Yang edited comment on FLINK-27290 at 5/3/22 4:05 AM: --- I will work on this after [26588|https://issues.apache.org/jira/browse/FLINK-26588] being reviewed or merged to make sure the style of this page is accepted by my reviewors. was (Author: JIRAUSER282569): I will work on this after [26588|https://issues.apache.org/jira/browse/FLINK-26588] being reviewed to make sure the style of this page is accepted by my reviewors. > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531024#comment-17531024 ] Chengkai Yang commented on FLINK-27290: --- I will work on this after [26588|https://issues.apache.org/jira/browse/FLINK-26588] being reviewed to make sure the style of this page is accepted by my reviewors. > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Comment Edited] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528769#comment-17528769 ] Chengkai Yang edited comment on FLINK-26588 at 4/27/22 12:52 PM: - [~fsk119] hi ,would you mind to review this? was (Author: JIRAUSER282569): [~fsk119] hi ,would mind to review this? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, pull-request-available, > stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Commented] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17528769#comment-17528769 ] Chengkai Yang commented on FLINK-26588: --- [~fsk119] hi ,would mind to review this? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, pull-request-available, > stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27292: -- Description: This JIRA translate the "Data Type Extraction" section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction The content below the title in the picture below is the specific part of this JIRA to be translated. was: This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction The content below the title in the picture below is the specific part of this JIRA to be translated. > Translate the "Data Type Extraction" section of "Data Types" in to Chinese > -- > > Key: FLINK-27292 > URL: https://issues.apache.org/jira/browse/FLINK-27292 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > Attachments: DataTypeExtraction.png > > > This JIRA translate the "Data Type Extraction" section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27291: -- Description: This JIRA translate the "List of Data Types" section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#list-of-data-types The content below the title in the picture below is the specific part of this JIRA to be translated. was: This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#list-of-data-types The content below the title in the picture below is the specific part of this JIRA to be translated. > Translate the "List of Data Types" section of "Data Types" in to Chinese > > > Key: FLINK-27291 > URL: https://issues.apache.org/jira/browse/FLINK-27291 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > Attachments: ListOfDataTypes.png > > > This JIRA translate the "List of Data Types" section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#list-of-data-types > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-27292) Translate the "Data Type Extraction" section of "Data Types" in to Chinese
Chengkai Yang created FLINK-27292: - Summary: Translate the "Data Type Extraction" section of "Data Types" in to Chinese Key: FLINK-27292 URL: https://issues.apache.org/jira/browse/FLINK-27292 Project: Flink Issue Type: Improvement Components: chinese-translation, Documentation Reporter: Chengkai Yang Attachments: DataTypeExtraction.png This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction The content below the title in the picture below is the specific part of this JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27290: -- Priority: Minor (was: Major) > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27276: -- Priority: Minor (was: Major) > Translate "Data Types" page of "Table API & SQL" in to Chinese > -- > > Key: FLINK-27276 > URL: https://issues.apache.org/jira/browse/FLINK-27276 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The file is docs/content.zh/docs/dev/table/types.md > The link is [Data > Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese
Chengkai Yang created FLINK-27291: - Summary: Translate the "List of Data Types" section of "Data Types" in to Chinese Key: FLINK-27291 URL: https://issues.apache.org/jira/browse/FLINK-27291 Project: Flink Issue Type: Improvement Components: chinese-translation, Documentation Reporter: Chengkai Yang Attachments: ListOfDataTypes.png This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#list-of-data-types The content below the title in the picture below is the specific part of this JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290 ] Chengkai Yang deleted comment on FLINK-27290: --- was (Author: JIRAUSER282569): This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type The content below the title in the picture below is the specific part of this JIRA to be translated. > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Major > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523666#comment-17523666 ] Chengkai Yang commented on FLINK-27290: --- This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type The content below the title in the picture below is the specific part of this JIRA to be translated. > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Major > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27290: -- Description: This JIRA translate the first section in Data Types. The url is https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type The content below the title in the picture below is the specific part of this JIRA to be translated. was:This > Translate the "Data Type" section of "Data Types" in to Chinese > --- > > Key: FLINK-27290 > URL: https://issues.apache.org/jira/browse/FLINK-27290 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Major > Attachments: datatype.png > > > This JIRA translate the first section in Data Types. > The url is > https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type > The content below the title in the picture below is the specific part of this > JIRA to be translated. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-27290) Translate the "Data Type" section of "Data Types" in to Chinese
Chengkai Yang created FLINK-27290: - Summary: Translate the "Data Type" section of "Data Types" in to Chinese Key: FLINK-27290 URL: https://issues.apache.org/jira/browse/FLINK-27290 Project: Flink Issue Type: Improvement Components: chinese-translation, Documentation Reporter: Chengkai Yang Attachments: datatype.png This -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-27276: -- Priority: Major (was: Minor) > Translate "Data Types" page of "Table API & SQL" in to Chinese > -- > > Key: FLINK-27276 > URL: https://issues.apache.org/jira/browse/FLINK-27276 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Major > > The file is docs/content.zh/docs/dev/table/types.md > The link is [Data > Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523543#comment-17523543 ] Chengkai Yang commented on FLINK-27276: --- [~fsk119] Okay sure. > Translate "Data Types" page of "Table API & SQL" in to Chinese > -- > > Key: FLINK-27276 > URL: https://issues.apache.org/jira/browse/FLINK-27276 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The file is docs/content.zh/docs/dev/table/types.md > The link is [Data > Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523541#comment-17523541 ] Chengkai Yang commented on FLINK-27276: --- [~fsk119] sure man.:-) > Translate "Data Types" page of "Table API & SQL" in to Chinese > -- > > Key: FLINK-27276 > URL: https://issues.apache.org/jira/browse/FLINK-27276 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The file is docs/content.zh/docs/dev/table/types.md > The link is [Data > Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27276 ] Chengkai Yang deleted comment on FLINK-27276: --- was (Author: JIRAUSER282569): [~fsk119] sure man.:-) > Translate "Data Types" page of "Table API & SQL" in to Chinese > -- > > Key: FLINK-27276 > URL: https://issues.apache.org/jira/browse/FLINK-27276 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The file is docs/content.zh/docs/dev/table/types.md > The link is [Data > Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523338#comment-17523338 ] Chengkai Yang edited comment on FLINK-26588 at 4/17/22 1:00 PM: Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese before. And I searched around on JIRA, PR on the Github found on one is working on this right now. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? was (Author: JIRAUSER282569): Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese before. And I searched around on JIRA, PR on the Github found on one is working on this. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, pull-request-available, > stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523338#comment-17523338 ] Chengkai Yang edited comment on FLINK-26588 at 4/17/22 1:00 PM: Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese before. And I searched around on JIRA, PR on the Github found on one is working on this. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? was (Author: JIRAUSER282569): Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese. And I searched around on JIRA, PR on the Github found on one is working on this. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, pull-request-available, > stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-27276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523341#comment-17523341 ] Chengkai Yang commented on FLINK-27276: --- This pages has many sections, and the translation workload is relatively large. I will use this issue as a umbrella issue, and create multiple sub-issues to link on this to split the translation work so that the others in the community can join in. > Translate "Data Types" page of "Table API & SQL" in to Chinese > -- > > Key: FLINK-27276 > URL: https://issues.apache.org/jira/browse/FLINK-27276 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Priority: Minor > > The file is docs/content.zh/docs/dev/table/types.md > The link is [Data > Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523338#comment-17523338 ] Chengkai Yang edited comment on FLINK-26588 at 4/17/22 12:10 PM: - Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese. And I searched around on JIRA, PR on the Github found on one is working on this. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? was (Author: JIRAUSER282569): Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese. And I searched around on JIRA, PR on the Github found on one is working on this. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, pull-request-available, > stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523338#comment-17523338 ] Chengkai Yang commented on FLINK-26588: --- Hi,[~martijnvisser] I finished translation work of the CAST part and waiting for the review. Anyway I went through the docs/content.zh/docs/dev/table/types.md's git commit history but It seems that [this page|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/] , I mean the whole page,has never been translated into Chinese. And I searched around on JIRA, PR on the Github found on one is working on this. So I open the [FLINK-27276|https://issues.apache.org/jira/browse/FLINK-27276] on JIRA to translate the whole page. Is that ok?And could you assign FLINK-27276 to me? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, pull-request-available, > stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-27276) Translate "Data Types" page of "Table API & SQL" in to Chinese
Chengkai Yang created FLINK-27276: - Summary: Translate "Data Types" page of "Table API & SQL" in to Chinese Key: FLINK-27276 URL: https://issues.apache.org/jira/browse/FLINK-27276 Project: Flink Issue Type: Sub-task Components: chinese-translation, Documentation Reporter: Chengkai Yang The file is docs/content.zh/docs/dev/table/types.md The link is [Data Types|https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/]. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17523143#comment-17523143 ] Chengkai Yang commented on FLINK-25705: --- The newest pr is https://github.com/apache/flink/pull/19496 > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned, pull-request-available > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after Flink-25830 and > [FLINK-26222|https://issues.apache.org/jira/browse/FLINK-26222]is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522346#comment-17522346 ] Chengkai Yang commented on FLINK-26588: --- Hi [~martijnvisser],I finished half of the translation work.I think I will finish the rest work this weekend and open the PR ASAP. > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Assignee: Chengkai Yang >Priority: Major > Labels: chinese-translation, stale-assigned > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Closed] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang closed FLINK-26222.
-
Resolution: Fixed
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17512241#comment-17512241
]
Chengkai Yang commented on FLINK-26222:
---
Seems already fixed in
https://github.com/apache/flink/commit/3d62a652622cede5f094068d8af3ac591c59c0de
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509627#comment-17509627
]
Chengkai Yang edited comment on FLINK-26222 at 3/22/22, 1:31 PM:
-
Hi,[~MartijnVisser],should we remove this line?If we should remove this
line,could you assign this to me?Happy to fix this.
was (Author: JIRAUSER282569):
Hi,[~MartijnVisser],should we remove this line?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[ https://issues.apache.org/jira/browse/FLINK-26222 ]
Chengkai Yang deleted comment on FLINK-26222:
---
was (Author: JIRAUSER282569):
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter can't send metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/Password authorization anymore.
It take me a few hours to figure that out:D
Should we also mention that InfluxDB reporter only support InfluxDB 1.x in the
documentation?
I will be start a discuss on email list or creat a jira later.
Please ignore this comment.
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509627#comment-17509627
]
Chengkai Yang commented on FLINK-26222:
---
Hi,[~MartijnVisser],should we remove this line?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493928#comment-17493928
]
Chengkai Yang edited comment on FLINK-26222 at 3/21/22, 6:10 AM:
-
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter can't send metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/Password authorization anymore.
It take me a few hours to figure that out:D
Should we also mention that InfluxDB reporter only support InfluxDB 1.x in the
documentation?
I will be start a discuss on email list or creat a jira later.
Please ignore this comment.
was (Author: JIRAUSER282569):
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter can't send metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/Password authorization anymore.
It take me a few hours to figure that out:D
Should we also mention that InfluxDB reporter only support InfluxDB 1.x in the
documentation?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-26588) Translate the new CAST documentation to Chinese
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506033#comment-17506033 ] Chengkai Yang commented on FLINK-26588: --- [~martijnvisser] hi,could you assign this to me? > Translate the new CAST documentation to Chinese > --- > > Key: FLINK-26588 > URL: https://issues.apache.org/jira/browse/FLINK-26588 > Project: Flink > Issue Type: Sub-task > Components: Documentation, Table SQL / API >Affects Versions: 1.15.0 >Reporter: Martijn Visser >Priority: Major > Labels: chinese-translation > > Since FLINK-26125 is now merged, this content change should also be > translated to Chinese. Relevant PR is > https://github.com/apache/flink/pull/18813 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Component/s: Runtime / Metrics
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation, Runtime / Metrics
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493928#comment-17493928
]
Chengkai Yang edited comment on FLINK-26222 at 2/17/22, 1:27 PM:
-
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter can't send metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/Password authorization anymore.
It take me a few hours to figure that out:D
Should we also mention that InfluxDB reporter only support InfluxDB 1.x in the
documentation?
was (Author: JIRAUSER282569):
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter can't send metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/Password authorization anymore.
It take me a few hours to figure that out:D
Should we also mention that InfluxDB report only support InfluxDB 1.x in the
documentation?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Component/s: Documentation
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493928#comment-17493928
]
Chengkai Yang edited comment on FLINK-26222 at 2/17/22, 1:06 PM:
-
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter can't send metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/Password authorization anymore.
It take me a few hours to figure that out:D
Should we also mention that InfluxDB report only support InfluxDB 1.x in the
documentation?
was (Author: JIRAUSER282569):
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter cannot sent metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/password authorization anymore.
I take a few hours to figure that out:D
Should we also mention that InfluxDB report only support InfluxDB 1.x in the
documentation?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493928#comment-17493928
]
Chengkai Yang edited comment on FLINK-26222 at 2/17/22, 1:04 PM:
-
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter cannot sent metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/password authorization anymore.
I take a few hours to figure that out:D
Should we also mention that InfluxDB report only support InfluxDB 1.x in the
documentation?
was (Author: JIRAUSER282569):
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter cannot sent metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/password authorization anymore.
I take a few hours to figure that out:D
Should we also mention this in the documentation?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493928#comment-17493928
]
Chengkai Yang commented on FLINK-26222:
---
Anyway,InfluxDB metric reporter only support InfluxDB 1.x rightnow.This
reporter cannot sent metric data to InfluxDB 2.x cause the InfluxDB 2.x no
longer support User/password authorization anymore.
I take a few hours to figure that out:D
Should we also mention this in the documentation?
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Remove outdated documents in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Summary: Remove outdated documents in "InfluxDB" part of "Metric Reporters"
page (was: Reomve outdated documents in "InfluxDB" part of "Metric Reporters"
page)
> Remove outdated documents in "InfluxDB" part of "Metric Reporters" page
> ---
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Remove outdated line in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Summary: Remove outdated line in "InfluxDB" part of "Metric Reporters" page
(was: Remove outdated documents in "InfluxDB" part of "Metric Reporters" page)
> Remove outdated line in "InfluxDB" part of "Metric Reporters" page
> --
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Description:
Hi,community:
In this
[part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
I think we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." , since the jar is already under
plugins/metrics-influx/ folder.
Users may confused about that.
was:
In this
[part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
I think we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." , since the jar is already under
plugins/metrics-influx/ folder.
Users may confused about that.
> Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
> ---
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Description:
Hi,community:
In this
[part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
I think we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." , since the jar is already under
plugins/metrics-influx/ folder.
Users may confused about that line.
was:
Hi,community:
In this
[part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
I think we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." , since the jar is already under
plugins/metrics-influx/ folder.
Users may confused about that.
> Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
> ---
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> Hi,community:
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that line.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Description:
In this
[part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
I think we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." , since the jar is already under
plugins/metrics-influx/ folder.
Users may confused about that.
was:
In this [part|#influxdb]],
we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." since the jar is already under
plugins/metrics-influx/ folder.
> Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
> ---
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> In this
> [part|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],
> I think we should remove this line:"In order to use this reporter you must
> copy {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." , since the jar is already under
> plugins/metrics-influx/ folder.
> Users may confused about that.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Description:
In this [part|#influxdb]],
we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." since the jar is already under
plugins/metrics-influx/ folder.
was:
In this
[part|[https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb]|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],we]
we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." since the jar is already under
plugins/metrics-influx/ folder.
> Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
> ---
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> In this [part|#influxdb]],
> we should remove this line:"In order to use this reporter you must copy
> {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." since the jar is already under
> plugins/metrics-influx/ folder.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-25705: -- Description: The page url is [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md This issue should be merged after Flink-25830 and [FLINK-26222|https://issues.apache.org/jira/browse/FLINK-26222]is merged or solved. was: The page url is [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md This issue should be merged after [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or solved. > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after Flink-25830 and > [FLINK-26222|https://issues.apache.org/jira/browse/FLINK-26222]is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26222) Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
[
https://issues.apache.org/jira/browse/FLINK-26222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chengkai Yang updated FLINK-26222:
--
Summary: Reomve outdated documents in "InfluxDB" part of "Metric Reporters"
page (was: Delete outdated documents in "InfluxDB" part of "Metric Reporters"
page)
> Reomve outdated documents in "InfluxDB" part of "Metric Reporters" page
> ---
>
> Key: FLINK-26222
> URL: https://issues.apache.org/jira/browse/FLINK-26222
> Project: Flink
> Issue Type: Improvement
>Reporter: Chengkai Yang
>Priority: Minor
>
> In this
> [part|[https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb]|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],we]
> we should remove this line:"In order to use this reporter you must copy
> {{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}}
> folder of your Flink distribution." since the jar is already under
> plugins/metrics-influx/ folder.
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Created] (FLINK-26222) Delete outdated documents in "InfluxDB" part of "Metric Reporters" page
Chengkai Yang created FLINK-26222:
-
Summary: Delete outdated documents in "InfluxDB" part of "Metric
Reporters" page
Key: FLINK-26222
URL: https://issues.apache.org/jira/browse/FLINK-26222
Project: Flink
Issue Type: Improvement
Reporter: Chengkai Yang
In this
[part|[https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb]|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#influxdb],we]
we should remove this line:"In order to use this reporter you must copy
{{/opt/flink-metrics-influxdb-1.14.3.jar}} into the {{plugins/influxdb}} folder
of your Flink distribution." since the jar is already under
plugins/metrics-influx/ folder.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705 ] Chengkai Yang deleted comment on FLINK-25705: --- was (Author: JIRAUSER282569): Hi [~jark] ,Another question,this issue is not a subtask of FLINK-11526 yet,so how to link this issue as a subtask of FLINK-11526? Or should I close this issue,and add a new subtask under FLINK-11526? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after > [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-25705: -- Parent: FLINK-11526 Issue Type: Sub-task (was: Improvement) > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Sub-task > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after > [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489940#comment-17489940 ] Chengkai Yang edited comment on FLINK-25705 at 2/11/22, 1:36 AM: - [~xccui] [~klion26] [~jark] [~RocMarshal] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the [Glossary|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端/指标发送端/指标上报端"，so which Chinese word will be better? was (Author: JIRAUSER282569): [~xccui] [~klion26] [~jark] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the [Glossary|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端/指标发送端/指标上报端"，so which Chinese word will be better? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after > [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489948#comment-17489948 ] Chengkai Yang edited comment on FLINK-25705 at 2/10/22, 3:59 AM: - Hi [~jark] ,Another question,this issue is not a subtask of FLINK-11526 yet,so how to link this issue as a subtask of FLINK-11526? Or should I close this issue,and add a new subtask under FLINK-11526? was (Author: JIRAUSER282569): Hi [~jark] ,Another question,this issue is not a subtask of FLINK-11526 yet,so how to link this issue as a subtask of FLINK-11526? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after > [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489948#comment-17489948 ] Chengkai Yang commented on FLINK-25705: --- Hi [~jark] ,Another question,this issue is not a subtask of FLINK-11526 yet,so how to link this issue as a subtask of FLINK-11526? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after > [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-25705: -- Description: The page url is [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md This issue should be merged after [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or solved. was: The page url is [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md This > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This issue should be merged after > [Flink-25830|https://issues.apache.org/jira/browse/FLINK-25830] is merged or > solved. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chengkai Yang updated FLINK-25705: -- Description: The page url is [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md This was: The page url is https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters] > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md > This -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489940#comment-17489940 ] Chengkai Yang edited comment on FLINK-25705 at 2/10/22, 3:39 AM: - [~xccui] [~klion26] [~jark] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the [Glossary|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端/指标发送端/指标上报端"，so which Chinese word will be better? was (Author: JIRAUSER282569): [~xccui] [~klion26] [~jark] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the [Glossary|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端，指标发送端，指标上报段"，so which Chinese word will be better? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489940#comment-17489940 ] Chengkai Yang edited comment on FLINK-25705 at 2/10/22, 3:38 AM: - [~xccui] [~klion26] [~jark] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the [Glossary|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端，指标发送端，指标上报段"，so which Chinese word will be better? was (Author: JIRAUSER282569): [~xccui] [~klion26] [~jark] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the Glossary[link title|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]|https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications],hhow] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端，指标发送端，指标上报段"，so which Chinese word will be better? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: Chengkai Yang >Assignee: Chengkai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489940#comment-17489940 ] ChengKai Yang commented on FLINK-25705: --- [~xccui] [~klion26] [~jark] Hi,guys,we need to discuss a glossary issue here. The word "Reporter" is not in the Glossary[link title|[https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications]|https://cwiki.apache.org/confluence/display/FLINK/Flink+Translation+Specifications],hhow] The corresponding Chinese word for "Reporter" can be "报送端/发送端/上报端", and the "Metric Reporter" can be translated to "指标报送端，指标发送端，指标上报段"，so which Chinese word will be better? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: ChengKai Yang >Assignee: ChengKai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
[
https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ChengKai Yang updated FLINK-25830:
--
Labels: auto-unassigned (was: )
> Typo mistake in "Metric Report page" of the documentation
> --
>
> Key: FLINK-25830
> URL: https://issues.apache.org/jira/browse/FLINK-25830
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: ChengKai Yang
>Priority: Not a Priority
> Labels: auto-unassigned
>
> Hi, I think I find a typo mistake in the documentation:
> [This page:"Report
> page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
> .
> In the YAML part:
> {code:java}
> ```yaml
> metrics.reporters: my_jmx_reporter,my_other_reporter
> metrics.reporter.my_jmx_reporter.factory.class:
> org.apache.flink.metrics.jmx.JMXReporterFactory
> metrics.reporter.my_jmx_reporter.port: 9020-9040
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> metrics.reporter.my_jmx_reporter.scope.variables.additional:
> cluster_name:my_test_cluster,tag_name:tag_value
> metrics.reporter.my_other_reporter.class:
> org.apache.flink.metrics.graphite.GraphiteReporter
> metrics.reporter.my_other_reporter.host: 192.168.1.1
> metrics.reporter.my_other_reporter.port: 1
> ```
> {code}
> This property:
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> If the user copies this property to the conf/flink-conf.yaml, the user will
> get a warning in the log like this:
> {code:java}
> // code placeholder
> 2022-01-26 22:45:31,642 WARN
> org.apache.flink.configuration.GlobalConfiguration [] - Error while
> trying to split key and value in configuration file
> /opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
> {code}
> So there should have a space between
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
> "job_id;task_attempt_num".
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
[
https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482530#comment-17482530
]
ChengKai Yang edited comment on FLINK-25830 at 1/26/22, 2:54 PM:
-
This is my second Jira issue, maybe someone can assign this to me? Happy to fix
it:D
was (Author: JIRAUSER282569):
This is my second Jira issue, maybe someone can assign this to me? Happy to
help:D
> Typo mistake in "Metric Report page" of the documentation
> --
>
> Key: FLINK-25830
> URL: https://issues.apache.org/jira/browse/FLINK-25830
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: ChengKai Yang
>Priority: Not a Priority
>
> Hi, I think I find a typo mistake in the documentation:
> [This page:"Report
> page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
> .
> In the YAML part:
> {code:java}
> ```yaml
> metrics.reporters: my_jmx_reporter,my_other_reporter
> metrics.reporter.my_jmx_reporter.factory.class:
> org.apache.flink.metrics.jmx.JMXReporterFactory
> metrics.reporter.my_jmx_reporter.port: 9020-9040
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> metrics.reporter.my_jmx_reporter.scope.variables.additional:
> cluster_name:my_test_cluster,tag_name:tag_value
> metrics.reporter.my_other_reporter.class:
> org.apache.flink.metrics.graphite.GraphiteReporter
> metrics.reporter.my_other_reporter.host: 192.168.1.1
> metrics.reporter.my_other_reporter.port: 1
> ```
> {code}
> This property:
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> If the user copies this property to the conf/flink-conf.yaml, the user will
> get a warning in the log like this:
> {code:java}
> // code placeholder
> 2022-01-26 22:45:31,642 WARN
> org.apache.flink.configuration.GlobalConfiguration [] - Error while
> trying to split key and value in configuration file
> /opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
> {code}
> So there should have a space between
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
> "job_id;task_attempt_num".
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
[
https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482530#comment-17482530
]
ChengKai Yang edited comment on FLINK-25830 at 1/26/22, 2:53 PM:
-
This is my second Jira issue, maybe someone can assign this to me? Happy to
help:D
was (Author: JIRAUSER282569):
This is my second Jira issue, maybe someone can assign this to me? Happy to
help:D
> Typo mistake in "Metric Report page" of the documentation
> --
>
> Key: FLINK-25830
> URL: https://issues.apache.org/jira/browse/FLINK-25830
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: ChengKai Yang
>Priority: Not a Priority
>
> Hi, I think I find a typo mistake in the documentation:
> [This page:"Report
> page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
> .
> In the YAML part:
> {code:java}
> ```yaml
> metrics.reporters: my_jmx_reporter,my_other_reporter
> metrics.reporter.my_jmx_reporter.factory.class:
> org.apache.flink.metrics.jmx.JMXReporterFactory
> metrics.reporter.my_jmx_reporter.port: 9020-9040
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> metrics.reporter.my_jmx_reporter.scope.variables.additional:
> cluster_name:my_test_cluster,tag_name:tag_value
> metrics.reporter.my_other_reporter.class:
> org.apache.flink.metrics.graphite.GraphiteReporter
> metrics.reporter.my_other_reporter.host: 192.168.1.1
> metrics.reporter.my_other_reporter.port: 1
> ```
> {code}
> This property:
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> If the user copies this property to the conf/flink-conf.yaml, the user will
> get a warning in the log like this:
> {code:java}
> // code placeholder
> 2022-01-26 22:45:31,642 WARN
> org.apache.flink.configuration.GlobalConfiguration [] - Error while
> trying to split key and value in configuration file
> /opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
> {code}
> So there should have a space between
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
> "job_id;task_attempt_num".
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
[
https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17482530#comment-17482530
]
ChengKai Yang commented on FLINK-25830:
---
This is my second Jira issue, maybe someone can assign this to me? Happy to
help:D
> Typo mistake in "Metric Report page" of the documentation
> --
>
> Key: FLINK-25830
> URL: https://issues.apache.org/jira/browse/FLINK-25830
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: ChengKai Yang
>Priority: Not a Priority
>
> Hi, I think I find a typo mistake in the documentation:
> [This page:"Report
> page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
> .
> In the YAML part:
> {code:java}
> ```yaml
> metrics.reporters: my_jmx_reporter,my_other_reporter
> metrics.reporter.my_jmx_reporter.factory.class:
> org.apache.flink.metrics.jmx.JMXReporterFactory
> metrics.reporter.my_jmx_reporter.port: 9020-9040
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> metrics.reporter.my_jmx_reporter.scope.variables.additional:
> cluster_name:my_test_cluster,tag_name:tag_value
> metrics.reporter.my_other_reporter.class:
> org.apache.flink.metrics.graphite.GraphiteReporter
> metrics.reporter.my_other_reporter.host: 192.168.1.1
> metrics.reporter.my_other_reporter.port: 1
> ```
> {code}
> This property:
> metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
> If the user copies this property to the conf/flink-conf.yaml, the user will
> get a warning in the log like this:
> {code:java}
> // code placeholder
> 2022-01-26 22:45:31,642 WARN
> org.apache.flink.configuration.GlobalConfiguration [] - Error while
> trying to split key and value in configuration file
> /opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
> {code}
> So there should have a space between
> "metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
> "job_id;task_attempt_num".
>
>
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Created] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation
ChengKai Yang created FLINK-25830:
-
Summary: Typo mistake in "Metric Report page" of the documentation
Key: FLINK-25830
URL: https://issues.apache.org/jira/browse/FLINK-25830
Project: Flink
Issue Type: Improvement
Components: Documentation
Reporter: ChengKai Yang
Hi, I think I find a typo mistake in the documentation:
[This page:"Report
page"|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#reporter]
.
In the YAML part:
{code:java}
```yaml
metrics.reporters: my_jmx_reporter,my_other_reporter
metrics.reporter.my_jmx_reporter.factory.class:
org.apache.flink.metrics.jmx.JMXReporterFactory
metrics.reporter.my_jmx_reporter.port: 9020-9040
metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
metrics.reporter.my_jmx_reporter.scope.variables.additional:
cluster_name:my_test_cluster,tag_name:tag_value
metrics.reporter.my_other_reporter.class:
org.apache.flink.metrics.graphite.GraphiteReporter
metrics.reporter.my_other_reporter.host: 192.168.1.1
metrics.reporter.my_other_reporter.port: 1
```
{code}
This property:
metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num
If the user copies this property to the conf/flink-conf.yaml, the user will get
a warning in the log like this:
{code:java}
// code placeholder
2022-01-26 22:45:31,642 WARN
org.apache.flink.configuration.GlobalConfiguration [] - Error while
trying to split key and value in configuration file
/opt/module/flink-1.14.2/conf/flink-conf.yaml:277:
"metrics.reporter.my_jmx_reporter.scope.variables.excludes:job_id;task_attempt_num"
{code}
So there should have a space between
"metrics.reporter.my_jmx_reporter.scope.variables.excludes:" and
"job_id;task_attempt_num".
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479074#comment-17479074 ] ChengKai Yang commented on FLINK-25705: --- Hi,[~jark] ,I want to work on this,can you assign this to me? > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: ChengKai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChengKai Yang updated FLINK-25705: -- Description: The page url is https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md was: The page url is https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#slf4j The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: ChengKai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChengKai Yang updated FLINK-25705: -- Labels: auto-unassigned (was: auto-unassigned pull-request-available) > Translate "Metric Reporters" page of "Deployment" in to Chinese > --- > > Key: FLINK-25705 > URL: https://issues.apache.org/jira/browse/FLINK-25705 > Project: Flink > Issue Type: Improvement > Components: chinese-translation, Documentation >Reporter: ChengKai Yang >Priority: Minor > Labels: auto-unassigned > > The page url is > https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#slf4j > The markdown file is located in > flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese
ChengKai Yang created FLINK-25705: - Summary: Translate "Metric Reporters" page of "Deployment" in to Chinese Key: FLINK-25705 URL: https://issues.apache.org/jira/browse/FLINK-25705 Project: Flink Issue Type: Improvement Components: chinese-translation, Documentation Reporter: ChengKai Yang The page url is https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/metric_reporters/#slf4j The markdown file is located in flink/docs/content.zh/docs/deployment/metric_reporters.md -- This message was sent by Atlassian Jira (v8.20.1#820001)
