[GitHub] [flink] flinkbot commented on pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

flinkbot commented on pull request #15777: URL: https://github.com/apache/flink/pull/15777#issuecomment-827362986 ## CI report: * 4efc4f94ce52c83115b109ce568a700ece6ac77c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15775: [FLINK-22456][runtime] Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

flinkbot edited a comment on pull request #15775: URL: https://github.com/apache/flink/pull/15775#issuecomment-827352333 ## CI report: * b58f06d7acf3667165b00f242267c70bccb78f55 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

flinkbot edited a comment on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 7abd504d29417b4f19677f289089d52a973b78f0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-22424) Writing to already released buffers potentially causing data corruption during job failover/cancellation

[ https://issues.apache.org/jira/browse/FLINK-22424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332007#comment-17332007 ] Piotr Nowojski edited comment on FLINK-22424 at 4/27/21, 6:55 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * b99e1a12c74051454d211b0094c986b8741dd28f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] KarmaGYZ commented on pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

KarmaGYZ commented on pull request #15777: URL: https://github.com/apache/flink/pull/15777#issuecomment-827358232 Thanks for the update. LGTM. Do you have other concerns? @tillrohrmann -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] tony810430 commented on pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

tony810430 commented on pull request #15777: URL: https://github.com/apache/flink/pull/15777#issuecomment-827357165 @KarmaGYZ thanks for review. have updated the generated docs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] dawidwys commented on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

dawidwys commented on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827356185 This looks like a sensible change to me. However I'd prefer to have a second opinion from one of the current maintainers of the OperatorCoordinator. Could you take a look @Step

[GitHub] [flink] flinkbot commented on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

flinkbot commented on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827352419 ## CI report: * 7abd504d29417b4f19677f289089d52a973b78f0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15775: [FLINK-22456][runtime] Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

flinkbot commented on pull request #15775: URL: https://github.com/apache/flink/pull/15775#issuecomment-827352333 ## CI report: * b58f06d7acf3667165b00f242267c70bccb78f55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332974#comment-17332974 ] Dawid Wysakowicz commented on FLINK-20329: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] KarmaGYZ edited a comment on pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

KarmaGYZ edited a comment on pull request #15777: URL: https://github.com/apache/flink/pull/15777#issuecomment-827345697 Thanks for preparing this PR, @tony810430 . You can execute the following command to generate docs for configs: `mvn clean package -Dgenerate-config-docs -pl flink-doc

[jira] [Commented] (FLINK-22488) KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost"

[ https://issues.apache.org/jira/browse/FLINK-22488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332973#comment-17332973 ] Dawid Wysakowicz commented on FLINK-22488: -- Before diving into debugging the is

[jira] [Updated] (FLINK-15455) Enable TCP connection reuse across multiple jobs.

[ https://issues.apache.org/jira/browse/FLINK-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-15455: Labels: (was: stale-major) > Enable TCP connection reuse across multiple jobs. > ---

[GitHub] [flink] KarmaGYZ commented on pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

KarmaGYZ commented on pull request #15777: URL: https://github.com/apache/flink/pull/15777#issuecomment-827345697 Thanks for preparing this PR, @tony810430 . You can execute the following command to rebuild the doc: `mvn clean package -Dgenerate-config-docs -pl flink-docs -am -nsu -Dski

[jira] [Commented] (FLINK-22478) confluent schema registry avro (de)serialization https support

[ https://issues.apache.org/jira/browse/FLINK-22478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332969#comment-17332969 ] Lars Bachmann commented on FLINK-22478: --- [~twalthr] that is correct - it is a dupl

[GitHub] [flink] flinkbot commented on pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

flinkbot commented on pull request #15777: URL: https://github.com/apache/flink/pull/15777#issuecomment-827343499 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

[ https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22476: Affects Version/s: 1.13.0 > Extend the description of the config option `execution.target` > -

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 0500d84f78d8fdb967b077fb024fda0cd4ba2d6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22476) Extend the description of the config option `execution.target`

[ https://issues.apache.org/jira/browse/FLINK-22476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22476: --- Labels: pull-request-available (was: ) > Extend the description of the config option `execu

[GitHub] [flink] tony810430 opened a new pull request #15777: [FLINK-22476] Extend the description of the config option `execution.target`

tony810430 opened a new pull request #15777: URL: https://github.com/apache/flink/pull/15777 ## What is the purpose of the change update the description of `execution.targets` ## Brief change log - add `yarn-application` and `kubernetes-application` into desscription

[jira] [Updated] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22294: --- Fix Version/s: 1.13.1 1.14.0 > Hive reading fail when getting file numbers on different f

[jira] [Resolved] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22294. Resolution: Fixed > Hive reading fail when getting file numbers on different filesystem > nameservices >

[jira] [Assigned] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22294: -- Assignee: Junfan Zhang > Hive reading fail when getting file numbers on different filesystem > names

[GitHub] [flink] wuchong commented on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

wuchong commented on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-827336694 Some tests are failed, please have a check @cshuo . -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

flinkbot commented on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827336542 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-22456) Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

[ https://issues.apache.org/jira/browse/FLINK-22456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332959#comment-17332959 ] Li commented on FLINK-22456:         Maybe you mean users can query and generate the Splits

[GitHub] [flink] lindong28 commented on pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

lindong28 commented on pull request #15776: URL: https://github.com/apache/flink/pull/15776#issuecomment-827335784 Ping @dawidwys for review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot commented on pull request #15775: [FLINK-22456][runtime] Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

flinkbot commented on pull request #15775: URL: https://github.com/apache/flink/pull/15775#issuecomment-827335712 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-22488) KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost"

[ https://issues.apache.org/jira/browse/FLINK-22488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22488: --- Labels: pull-request-available (was: ) > KafkaSourceLegacyITCase.testOneToOneSources failed

[GitHub] [flink] lindong28 opened a new pull request #15776: [FLINK-22488][hotfix] Update SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover

lindong28 opened a new pull request #15776: URL: https://github.com/apache/flink/pull/15776 ## Contribution Checklist This PR updated SubtaskGatewayImpl to specify the cause of sendEvent() failure when triggering task failover. This change is useful to understand why the event could

[jira] [Updated] (FLINK-22456) Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

[ https://issues.apache.org/jira/browse/FLINK-22456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22456: --- Labels: pull-request-available (was: ) > Support InitializeOnMaster and FinalizeOnMaster to

[GitHub] [flink] kanata163 opened a new pull request #15775: [FLINK-22456][runtime] Support InitializeOnMaster and FinalizeOnMaster to be used in InputFormat

kanata163 opened a new pull request #15775: URL: https://github.com/apache/flink/pull/15775 ## What is the purpose of the change *Support `InitializeOnMaster` and `FinalizeOnMaster` to be used in InputFormat* ## Brief change log - `InputOutputFormatVertex`

[GitHub] [flink] flinkbot edited a comment on pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

flinkbot edited a comment on pull request #15746: URL: https://github.com/apache/flink/pull/15746#issuecomment-826269766 ## CI report: * 08cf1b3d72dbf729d6de14c8d508b10b5d1a20b1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 0500d84f78d8fdb967b077fb024fda0cd4ba2d6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332957#comment-17332957 ] Dong Lin edited comment on FLINK-22085 at 4/27/21, 5:53 AM:

[GitHub] [flink] curcur edited a comment on pull request #15674: [FLINK-22311] [connector/jdbc] Validate maxRetries for XA Sink

curcur edited a comment on pull request #15674: URL: https://github.com/apache/flink/pull/15674#issuecomment-827331397 doc checks seem to fail: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=17083&view=logs&j=c5d67f7d-375d-5407-4743-f9d0c4436a81&t=38411795-40c

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332957#comment-17332957 ] Dong Lin commented on FLINK-22085: -- Thank you [~dwysakowicz] for the information. For

[GitHub] [flink] wuchong commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

wuchong commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r620886208 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6 +149,116

[GitHub] [flink] curcur commented on pull request #15674: [FLINK-22311] [connector/jdbc] Validate maxRetries for XA Sink

curcur commented on pull request #15674: URL: https://github.com/apache/flink/pull/15674#issuecomment-827331397 doc checks seem to fail: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the speci

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

[ https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332945#comment-17332945 ] Rui Li commented on FLINK-22408: [~aidenma] OK. I think we can fix this issue in release

[jira] [Created] (FLINK-22488) KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost"

Dong Lin created FLINK-22488: Summary: KafkaSourceLegacyITCase.testOneToOneSources failed due to "OperatorEvent from an OperatorCoordinator to a task was lost" Key: FLINK-22488 URL: https://issues.apache.org/jira/brow

[GitHub] [flink] flinkbot edited a comment on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

flinkbot edited a comment on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826589720 ## CI report: * 0dcb773365ec16118d2b4c0f55910441bc6d7d58 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

flinkbot edited a comment on pull request #15746: URL: https://github.com/apache/flink/pull/15746#issuecomment-826269766 ## CI report: * 08cf1b3d72dbf729d6de14c8d508b10b5d1a20b1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

rmetzger commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-827326084 Yeah, I'm happy to help, I also think I know what's causing this, but I don't know how to resolve it 😢 I pushed this PR onto - my Personal CI, where it passed withou

[GitHub] [flink] todd5167 commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

todd5167 commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r620879361 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6 +149,11

[jira] [Commented] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332939#comment-17332939 ] Jark Wu commented on FLINK-22485: - Sorry, [~zuston], I misunderstand your problem. Flink

[jira] [Comment Edited] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332939#comment-17332939 ] Jark Wu edited comment on FLINK-22485 at 4/27/21, 5:35 AM: --- So

[jira] [Comment Edited] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331442#comment-17331442 ] Rui Li edited comment on FLINK-22294 at 4/27/21, 5:33 AM: -- Fixe

[GitHub] [flink] lirui-apache closed pull request #15750: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

lirui-apache closed pull request #15750: URL: https://github.com/apache/flink/pull/15750 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, p

[jira] [Updated] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22485: Component/s: (was: Table SQL / Client) Command Line Client > Support client attach on

[GitHub] [flink] lirui-apache commented on pull request #15750: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

lirui-apache commented on pull request #15750: URL: https://github.com/apache/flink/pull/15750#issuecomment-827324483 Pushed to release-1.13 via 7a4a18da90521fe3c0758d4579441c50907f368b -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] curcur commented on a change in pull request #15720: [FLINK-22289] Update JDBC XA sink docs

curcur commented on a change in pull request #15720: URL: https://github.com/apache/flink/pull/15720#discussion_r620850140 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -167,15 +177,24 @@ env ps.setDouble(4, t.price);

[jira] [Resolved] (FLINK-22092) HiveConf can cache hiveSiteURL from classpath and cause FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-22092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-22092. Resolution: Fixed > HiveConf can cache hiveSiteURL from classpath and cause FileNotFoundException > --

[GitHub] [flink-web] loniecc commented on pull request #386: [FLINK-13679] Translate "Code Style - Preamble" page into Chinese

loniecc commented on pull request #386: URL: https://github.com/apache/flink-web/pull/386#issuecomment-827322217 > @loniecc thanks for the contribution, will give it a review soon. thx，have reslove all ， please review -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-web] loniecc commented on a change in pull request #386: [FLINK-13679] Translate "Code Style - Preamble" page into Chinese

loniecc commented on a change in pull request #386: URL: https://github.com/apache/flink-web/pull/386#discussion_r620874828 ## File path: contributing/code-style-and-quality-preamble.zh.md ## @@ -1,25 +1,23 @@ --- -title: "Apache Flink Code Style and Quality Guide — Preamble"

[GitHub] [flink-web] loniecc commented on a change in pull request #386: [FLINK-13679] Translate "Code Style - Preamble" page into Chinese

loniecc commented on a change in pull request #386: URL: https://github.com/apache/flink-web/pull/386#discussion_r620874392 ## File path: contributing/code-style-and-quality-preamble.zh.md ## @@ -1,25 +1,23 @@ --- -title: "Apache Flink Code Style and Quality Guide — Preamble"

[jira] [Comment Edited] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332935#comment-17332935 ] Junfan Zhang edited comment on FLINK-22485 at 4/27/21, 5:22 AM: --

[jira] [Commented] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332935#comment-17332935 ] Junfan Zhang commented on FLINK-22485: -- Attach detailed info version: 1.12.1 Compon

[GitHub] [flink] wangwei1025 commented on a change in pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

wangwei1025 commented on a change in pull request #15746: URL: https://github.com/apache/flink/pull/15746#discussion_r620868599 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/RowDataVectorizer.java ## @@ -151,8 +160,114 @@ private static void s

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * 11130e794b07aa9215035e5c204766295a4f50fe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] FuyaoLi2017 commented on pull request #15602: [FLINK-22264][docs] Fix misleading statement about Flink Job Cluster Kubernetes Support in Flink Architecture page

FuyaoLi2017 commented on pull request #15602: URL: https://github.com/apache/flink/pull/15602#issuecomment-827307615 @tillrohrmann Hello Till, just have one small question, why the committer username of this PR appears as fuyli instead of @FuyaoLi2017 ? fuyli is my alias for my company's

[GitHub] [flink] curcur commented on a change in pull request #15720: [FLINK-22289] Update JDBC XA sink docs

curcur commented on a change in pull request #15720: URL: https://github.com/apache/flink/pull/15720#discussion_r620850140 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -167,15 +177,24 @@ env ps.setDouble(4, t.price);

[GitHub] [flink] curcur commented on a change in pull request #15720: [FLINK-22289] Update JDBC XA sink docs

curcur commented on a change in pull request #15720: URL: https://github.com/apache/flink/pull/15720#discussion_r620846546 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -32,8 +32,15 @@ To use it, add the following dependency to your project (along with yo

[GitHub] [flink] curcur commented on a change in pull request #15720: [FLINK-22289] Update JDBC XA sink docs

curcur commented on a change in pull request #15720: URL: https://github.com/apache/flink/pull/15720#discussion_r620846546 ## File path: docs/content/docs/connectors/datastream/jdbc.md ## @@ -32,8 +32,15 @@ To use it, add the following dependency to your project (along with yo

[GitHub] [flink] curcur commented on pull request #15720: [FLINK-22289] Update JDBC XA sink docs

curcur commented on pull request #15720: URL: https://github.com/apache/flink/pull/15720#issuecomment-827302091 > Thanks for the PR @curcur. > > Should we also remove this warning: > > > Attention: In 1.13, Flink JDBC sink does not support exactly-once mode with MySQL or other

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-827297699 @rmetzger, thanks for help looking into this. :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r620837563 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterCommitter.java ## @@ -0,0 +1,150 @@

[jira] [Updated] (FLINK-22487) Support `print` to print logs in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-22487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-22487: - Description: Currently, if users want to print logs, they need to use logging module. {code:pyt

[GitHub] [flink] lirui-apache commented on a change in pull request #15746: [FLINK-17783][Table SQL/Ecosystem]Add array,map,row types support for orc row writer

lirui-apache commented on a change in pull request #15746: URL: https://github.com/apache/flink/pull/15746#discussion_r620826305 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/RowDataVectorizer.java ## @@ -151,8 +160,114 @@ private static void

[jira] [Created] (FLINK-22487) Support `print` to print logs in PyFlink

Huang Xingbo created FLINK-22487: Summary: Support `print` to print logs in PyFlink Key: FLINK-22487 URL: https://issues.apache.org/jira/browse/FLINK-22487 Project: Flink Issue Type: New Feat

[jira] [Commented] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332912#comment-17332912 ] Jark Wu commented on FLINK-22485: - Which version are you using [~zuston]? We just suppor

[jira] [Updated] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22485: Component/s: Table SQL / Client > Support client attach on application mode >

[GitHub] [flink] wuchong commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

wuchong commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r620825538 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -478,6 +481,17 @@ SqlAlterTable SqlAlterTable() :

[jira] [Comment Edited] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

[ https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332910#comment-17332910 ] Ma Jun edited comment on FLINK-22408 at 4/27/21, 3:54 AM: -- Hi [

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 0500d84f78d8fdb967b077fb024fda0cd4ba2d6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[jira] [Commented] (FLINK-22408) Flink Table Parsr Hive Drop Partitions Syntax unparse is Error

[ https://issues.apache.org/jira/browse/FLINK-22408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332910#comment-17332910 ] Ma Jun commented on FLINK-22408: Hi [~lirui] Thank！I got it! I know that if there is a s

[jira] [Comment Edited] (FLINK-21513) Rethink up-/down-/restartingTime metrics

[ https://issues.apache.org/jira/browse/FLINK-21513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329947#comment-17329947 ] Steven Zhen Wu edited comment on FLINK-21513 at 4/27/21, 3:41 AM:

[GitHub] [flink] ZhangChaoming removed a comment on pull request #15749: [hotfix][docs] Fix typo.

ZhangChaoming removed a comment on pull request #15749: URL: https://github.com/apache/flink/pull/15749#issuecomment-826467604 @rmetzger Excuse me? The pipeline failed for the reason that `table.local-time-zone` does not exist. But I did not modify any about this option. -- This is an a

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r620812109 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/GSFileSystemFactory.java ## @@ -0,0 +1,136 @@ +/* + * License

[GitHub] [flink] flinkbot edited a comment on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

flinkbot edited a comment on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826589720 ## CI report: * 03b1c6bc999ee92a23eb0a0b84a368f2643e841d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22460) Conversion to relational algebra failed due to NOT NULL modifier

[ https://issues.apache.org/jira/browse/FLINK-22460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332902#comment-17332902 ] Shengkai Fang commented on FLINK-22460: --- It seems the input schema is not as same

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r620824056 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriter.java ## @@ -0,0 +1,145 @@ +/* + *

[jira] [Created] (FLINK-22486) Wrong results of the IN operator

Shengkai Fang created FLINK-22486: - Summary: Wrong results of the IN operator Key: FLINK-22486 URL: https://issues.apache.org/jira/browse/FLINK-22486 Project: Flink Issue Type: Bug

[GitHub] [flink] wuchong commented on a change in pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

wuchong commented on a change in pull request #15768: URL: https://github.com/apache/flink/pull/15768#discussion_r620820408 ## File path: docs/content/docs/dev/table/functions/udfs.md ## @@ -171,6 +171,52 @@ env.createTemporarySystemFunction("SubstringFunction", new SubstringF

[jira] [Commented] (FLINK-22485) Support client attach on application mode

[ https://issues.apache.org/jira/browse/FLINK-22485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332900#comment-17332900 ] Junfan Zhang commented on FLINK-22485: -- Any ideas on it? [~jark] [~lirui] > Suppor

[jira] [Created] (FLINK-22485) Support client attach on application mode

Junfan Zhang created FLINK-22485: Summary: Support client attach on application mode Key: FLINK-22485 URL: https://issues.apache.org/jira/browse/FLINK-22485 Project: Flink Issue Type: Improve

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r620824056 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriter.java ## @@ -0,0 +1,145 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 0500d84f78d8fdb967b077fb024fda0cd4ba2d6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] wydhcws commented on a change in pull request #15742: [FLINK-22442][CEP] Fix Using scala api to change the TimeCharacteristic o…

wydhcws commented on a change in pull request #15742: URL: https://github.com/apache/flink/pull/15742#discussion_r620818295 ## File path: flink-libraries/flink-cep-scala/src/test/scala/org/apache/flink/cep/scala/CEPScalaApiPatternStreamTest.scala ## @@ -0,0 +1,67 @@ +package o

[GitHub] [flink] zuston commented on pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-827278120 @XComp Done -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r620815613 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterState.java ## @@ -0,0 +1,158 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #15763: [FLINK-22364][doc] Translate the page of "Data Sources" to Chinese.

flinkbot edited a comment on pull request #15763: URL: https://github.com/apache/flink/pull/15763#issuecomment-826589720 ## CI report: * 03b1c6bc999ee92a23eb0a0b84a368f2643e841d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15745: [FLINK-22304][table] Refactor some interfaces for TVF based window to…

flinkbot edited a comment on pull request #15745: URL: https://github.com/apache/flink/pull/15745#issuecomment-826249839 ## CI report: * c9df5fedbcb6ce93f3a7576cf35753af3ffab6b4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r620812109 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/main/java/org/apache/flink/fs/gs/GSFileSystemFactory.java ## @@ -0,0 +1,136 @@ +/* + * License

[jira] [Commented] (FLINK-22451) Support (*) as parameter of table UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-22451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17332850#comment-17332850 ] Jark Wu commented on FLINK-22451: - {{ withColumns}} and {{withoutColumns}} are also shor

  1   2   3   4   5   6   >