[jira] [Commented] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese
[ https://issues.apache.org/jira/browse/FLINK-21903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326209#comment-17326209 ] zhaoxing commented on FLINK-21903: -- cc [~flink-jira-bot] . I will continue to maintain this PR, please review it for me quickly > Translate "Importing Flink into an IDE" page into Chinese > - > > Key: FLINK-21903 > URL: https://issues.apache.org/jira/browse/FLINK-21903 > Project: Flink > Issue Type: Task > Components: chinese-translation, Documentation >Reporter: zhaoxing >Assignee: zhaoxing >Priority: Major > Labels: pull-request-available > > The page url is > [https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/flinkDev/ide_setup.html] > The markdown file is located in 'docs/content.zh/docs/flinkDev/ide_setup.md' > now. > The doc is still in English on the master branch. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese
[ https://issues.apache.org/jira/browse/FLINK-21903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhaoxing updated FLINK-21903: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Translate "Importing Flink into an IDE" page into Chinese > - > > Key: FLINK-21903 > URL: https://issues.apache.org/jira/browse/FLINK-21903 > Project: Flink > Issue Type: Task > Components: chinese-translation, Documentation >Reporter: zhaoxing >Assignee: zhaoxing >Priority: Major > Labels: pull-request-available > > The page url is > [https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/flinkDev/ide_setup.html] > The markdown file is located in 'docs/content.zh/docs/flinkDev/ide_setup.md' > now. > The doc is still in English on the master branch. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese
[ https://issues.apache.org/jira/browse/FLINK-21903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319832#comment-17319832 ] zhaoxing commented on FLINK-21903: -- [~liguangyu] sorry，I have submitted a PR,cc [~jark] could you help to review this? thanks > Translate "Importing Flink into an IDE" page into Chinese > - > > Key: FLINK-21903 > URL: https://issues.apache.org/jira/browse/FLINK-21903 > Project: Flink > Issue Type: Task > Components: chinese-translation, Documentation >Reporter: zhaoxing >Assignee: zhaoxing >Priority: Major > Labels: pull-request-available > > The page url is > [https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/flinkDev/ide_setup.html] > The markdown file is located in 'docs/content.zh/docs/flinkDev/ide_setup.md' > now. > The doc is still in English on the master branch. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese
[ https://issues.apache.org/jira/browse/FLINK-21903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305871#comment-17305871 ] zhaoxing commented on FLINK-21903: -- cc [~jark] I am willing to do it. Can you assign it to me? thank you > Translate "Importing Flink into an IDE" page into Chinese > - > > Key: FLINK-21903 > URL: https://issues.apache.org/jira/browse/FLINK-21903 > Project: Flink > Issue Type: Task > Components: chinese-translation, Documentation >Reporter: zhaoxing >Priority: Major > > The page url is > [https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/flinkDev/ide_setup.html] > The markdown file is located in 'docs/content.zh/docs/flinkDev/ide_setup.md' > now. > The doc is still in English on the master branch. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-21903) Translate "Importing Flink into an IDE" page into Chinese
zhaoxing created FLINK-21903: Summary: Translate "Importing Flink into an IDE" page into Chinese Key: FLINK-21903 URL: https://issues.apache.org/jira/browse/FLINK-21903 Project: Flink Issue Type: Task Components: chinese-translation, Documentation Reporter: zhaoxing The page url is [https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/flinkDev/ide_setup.html] The markdown file is located in 'docs/content.zh/docs/flinkDev/ide_setup.md' now. The doc is still in English on the master branch. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21493) Flink Command Line Interface Document can add command usage
[ https://issues.apache.org/jira/browse/FLINK-21493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305411#comment-17305411 ] zhaoxing commented on FLINK-21493: -- cc [~zhisheng] [~jark] I am willing to do it. Can you assign it to me? thank you > Flink Command Line Interface Document can add command usage > --- > > Key: FLINK-21493 > URL: https://issues.apache.org/jira/browse/FLINK-21493 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.12.0 >Reporter: zhisheng >Priority: Major > > Flink 1.11 document has command usage > [https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/cli.html#usage] > but Flink 1.12 the usage was removed just list the cli actions > [https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/cli.html#cli-actions|https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/cli.html#cli-actions.] > Sometime find the actions parameter and usage information is inconvenient, > can community add the original usage document? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-21814) flink CollectSink error info unfriendly
[ https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305386#comment-17305386 ] zhaoxing edited comment on FLINK-21814 at 3/20/21, 10:34 AM: - hi, [~Peihui]I [~jark] I am willing to do it. Can you assign it to me? thank you was (Author: zhaoxing): hi, [~Peihui]I [~jark] am willing to do it. Can you assign it to me? thank you > flink CollectSink error info unfriendly > --- > > Key: FLINK-21814 > URL: https://issues.apache.org/jira/browse/FLINK-21814 > Project: Flink > Issue Type: Improvement >Affects Versions: 1.12.2 >Reporter: Peihui He >Priority: Minor > Labels: pull-request-available > Fix For: 1.12.3 > > > org.apache.flink.streaming.experimental.CollectSink initialization need host > and port. When Network is unavailable, i will get the error: > java.io.IOException: Cannot connect to the client to send back the stream > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:86) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.net.ConnectException: Connection refused (Connection refused) > at java.net.PlainSocketImpl.socketConnect(Native Method) > at > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476) > at > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218) > at > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200) > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394) > at java.net.Socket.connect(Socket.java:606) > at java.net.Socket.connect(Socket.java:555) > at java.net.Socket.(Socket.java:451) > at java.net.Socket.(Socket.java:261) > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:82) > ... 11 more > > However, i couldn't know the host and port. > > Hope the error info could includ the host and port. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-21814) flink CollectSink error info unfriendly
[ https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305386#comment-17305386 ] zhaoxing edited comment on FLINK-21814 at 3/20/21, 10:06 AM: - hi, [~Peihui]I [~jark] am willing to do it. Can you assign it to me? thank you was (Author: zhaoxing): hi, [~Peihui]I am willing to do it. Can you assign it to me? thank you > flink CollectSink error info unfriendly > --- > > Key: FLINK-21814 > URL: https://issues.apache.org/jira/browse/FLINK-21814 > Project: Flink > Issue Type: Improvement >Affects Versions: 1.12.2 >Reporter: Peihui He >Priority: Minor > Labels: pull-request-available > Fix For: 1.12.3 > > > org.apache.flink.streaming.experimental.CollectSink initialization need host > and port. When Network is unavailable, i will get the error: > java.io.IOException: Cannot connect to the client to send back the stream > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:86) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.net.ConnectException: Connection refused (Connection refused) > at java.net.PlainSocketImpl.socketConnect(Native Method) > at > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476) > at > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218) > at > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200) > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394) > at java.net.Socket.connect(Socket.java:606) > at java.net.Socket.connect(Socket.java:555) > at java.net.Socket.(Socket.java:451) > at java.net.Socket.(Socket.java:261) > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:82) > ... 11 more > > However, i couldn't know the host and port. > > Hope the error info could includ the host and port. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21814) flink CollectSink error info unfriendly
[ https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305386#comment-17305386 ] zhaoxing commented on FLINK-21814: -- hi, [~Peihui]I am willing to do it. Can you assign it to me? thank you > flink CollectSink error info unfriendly > --- > > Key: FLINK-21814 > URL: https://issues.apache.org/jira/browse/FLINK-21814 > Project: Flink > Issue Type: Improvement >Affects Versions: 1.12.2 >Reporter: Peihui He >Priority: Minor > Labels: pull-request-available > Fix For: 1.12.3 > > > org.apache.flink.streaming.experimental.CollectSink initialization need host > and port. When Network is unavailable, i will get the error: > java.io.IOException: Cannot connect to the client to send back the stream > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:86) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.net.ConnectException: Connection refused (Connection refused) > at java.net.PlainSocketImpl.socketConnect(Native Method) > at > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476) > at > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218) > at > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200) > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394) > at java.net.Socket.connect(Socket.java:606) > at java.net.Socket.connect(Socket.java:555) > at java.net.Socket.(Socket.java:451) > at java.net.Socket.(Socket.java:261) > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:82) > ... 11 more > > However, i couldn't know the host and port. > > Hope the error info could includ the host and port. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21814) flink CollectSink error info unfriendly
[ https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304888#comment-17304888 ] zhaoxing commented on FLINK-21814: -- hi This is my first time to submit code to an open source project. Please point out the shortcomings for me. Thank you very much > flink CollectSink error info unfriendly > --- > > Key: FLINK-21814 > URL: https://issues.apache.org/jira/browse/FLINK-21814 > Project: Flink > Issue Type: Improvement >Affects Versions: 1.12.2 >Reporter: Peihui He >Priority: Minor > Labels: pull-request-available > Fix For: 1.12.3 > > > org.apache.flink.streaming.experimental.CollectSink initialization need host > and port. When Network is unavailable, i will get the error: > java.io.IOException: Cannot connect to the client to send back the stream > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:86) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.net.ConnectException: Connection refused (Connection refused) > at java.net.PlainSocketImpl.socketConnect(Native Method) > at > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476) > at > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218) > at > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200) > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394) > at java.net.Socket.connect(Socket.java:606) > at java.net.Socket.connect(Socket.java:555) > at java.net.Socket.(Socket.java:451) > at java.net.Socket.(Socket.java:261) > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:82) > ... 11 more > > However, i couldn't know the host and port. > > Hope the error info could includ the host and port. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21814) flink CollectSink error info unfriendly
[ https://issues.apache.org/jira/browse/FLINK-21814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304721#comment-17304721 ] zhaoxing commented on FLINK-21814: -- I am willing to do it. Can you assign it to me? thank you [|https://issues.apache.org/jira/secure/AddComment!default.jspa?id=13365705] > flink CollectSink error info unfriendly > --- > > Key: FLINK-21814 > URL: https://issues.apache.org/jira/browse/FLINK-21814 > Project: Flink > Issue Type: Improvement >Affects Versions: 1.12.2 >Reporter: Peihui He >Priority: Minor > Fix For: 1.12.3 > > > org.apache.flink.streaming.experimental.CollectSink initialization need host > and port. When Network is unavailable, i will get the error: > java.io.IOException: Cannot connect to the client to send back the stream > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:86) > at > org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) > at > org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) > at > org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:46) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain.initializeStateAndOpenOperators(OperatorChain.java:426) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$2(StreamTask.java:535) > at > org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:525) > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:565) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) > at java.lang.Thread.run(Thread.java:748) > Caused by: java.net.ConnectException: Connection refused (Connection refused) > at java.net.PlainSocketImpl.socketConnect(Native Method) > at > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476) > at > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218) > at > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200) > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394) > at java.net.Socket.connect(Socket.java:606) > at java.net.Socket.connect(Socket.java:555) > at java.net.Socket.(Socket.java:451) > at java.net.Socket.(Socket.java:261) > at > org.apache.flink.streaming.experimental.CollectSink.open(CollectSink.java:82) > ... 11 more > > However, i couldn't know the host and port. > > Hope the error info could includ the host and port. -- This message was sent by Atlassian Jira (v8.3.4#803005)
