[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

[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 -

[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:

[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:

[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=17332957#comment-17332957 ] Dong Lin edited comment on FLINK-22085 at 4/27/21, 5:53 AM: Thank you

[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:

[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=17332957#comment-17332957 ] Dong Lin commented on FLINK-22085: -- Thank you [~dwysakowicz] for the information. For the first test

[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

[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

[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=17332945#comment-17332945 ] Rui Li commented on FLINK-22408: [~aidenma] OK. I think we can fix this issue in release-1.12 branch. We

[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:

[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:

[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:

[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

[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

[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=17332939#comment-17332939 ] Jark Wu commented on FLINK-22485: - Sorry, [~zuston], I misunderstand your problem. Flink CLI already

[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=17332939#comment-17332939 ] Jark Wu edited comment on FLINK-22485 at 4/27/21, 5:35 AM: --- Sorry, [~zuston],

[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=17331442#comment-17331442 ] Rui Li edited comment on FLINK-22294 at 4/27/21, 5:33 AM: -- Fixed in master:

[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,

[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

[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

[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 —

[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 —

[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=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=17332935#comment-17332935 ] Junfan Zhang commented on FLINK-22485: -- Attach detailed info version: 1.12.1 Component: Flink cli

[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

[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:

[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

[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

[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

[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

[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.

[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

[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=17332912#comment-17332912 ] Jark Wu commented on FLINK-22485: - Which version are you using [~zuston]? We just supported sync/async

[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=17332910#comment-17332910 ] Ma Jun edited comment on FLINK-22408 at 4/27/21, 3:54 AM: -- Hi [~lirui] Thank！I

[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:

[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 *

[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=17332910#comment-17332910 ] Ma Jun commented on FLINK-22408: Hi [~lirui] Thank！I got it! I know that if there is a subsequent

[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=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

[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 @@ +/* + *

[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:

[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=17332902#comment-17332902 ] Shengkai Fang commented on FLINK-22460: --- It seems the input schema is not as same as the sink

[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

[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=17332900#comment-17332900 ] Junfan Zhang commented on FLINK-22485: -- Any ideas on it? [~jark] [~lirui] > Support client attach

[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:

[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:

[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 *

[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

[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:

[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:

[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 *

[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 @@ +/* + *

[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=17332850#comment-17332850 ] Jark Wu commented on FLINK-22451: - {{ withColumns}} and {{withoutColumns}} are also shortcuts similar to

[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:

[GitHub] [flink] tisonkun merged pull request #15756: [hotfix][docs] Removed duplicate 'is'

tisonkun merged pull request #15756: URL: https://github.com/apache/flink/pull/15756 -- 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,

[jira] [Closed] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases

[ https://issues.apache.org/jira/browse/FLINK-22470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22470. --- Resolution: Fixed Merged to - master via bef98cf0ba168dd4f0b2c8614d2179cec8b54ff8 - release-1.13 via

[GitHub] [flink] dianfu closed pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

dianfu closed pull request #15765: URL: https://github.com/apache/flink/pull/15765 -- 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, please

[GitHub] [flink] dianfu commented on pull request #15765: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

dianfu commented on pull request #15765: URL: https://github.com/apache/flink/pull/15765#issuecomment-827266624 Closed via fbd38b53197c244af5ed3af54cebdee75b393a1d -- 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] dianfu closed pull request #15766: [FLINK-22470][python] Make sure that the root cause of the exception encountered during compiling the job was exposed to users in all cases

dianfu closed pull request #15766: URL: https://github.com/apache/flink/pull/15766 -- 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, please

[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_r620795286 ## File path: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala ## @@ -447,17 +447,17 @@ class

[jira] [Closed] (FLINK-22074) testRequirementCheckOnlyTriggeredOnce(org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest) failed

[ https://issues.apache.org/jira/browse/FLINK-22074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22074. Resolution: Fixed Fixed via * master (1.14): 6236473f8fb90cbde9673d1fa0c51659bc9e0c8c *

[GitHub] [flink] xintongsong closed pull request #15751: [FLINK-22074][test] Harden FineGrainedSlotManagerTest#testRequirement…

xintongsong closed pull request #15751: URL: https://github.com/apache/flink/pull/15751 -- 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,

[jira] [Comment Edited] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332834#comment-17332834 ] Zhu Zhu edited comment on FLINK-17726 at 4/27/21, 1:50 AM: --- I think it is a

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332834#comment-17332834 ] Zhu Zhu commented on FLINK-17726: - I think it is a potential issue and is not a real production problem

[GitHub] [flink] xintongsong closed pull request #15748: [hotfix][coordination] Add log for slot allocation in FineGrainedSlot…

xintongsong closed pull request #15748: URL: https://github.com/apache/flink/pull/15748 -- 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,

[GitHub] [flink] JingsongLi commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

JingsongLi commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r620782487 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

JingsongLi commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r620781908 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

JingsongLi commented on a change in pull request #15760: URL: https://github.com/apache/flink/pull/15760#discussion_r620781485 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/window/WindowJoinOperator.java ## @@

[GitHub] [flink] JingsongLi merged pull request #15752: [FLINK-19606][table-runtime-blink] Refactor JoinConditionWithFullFilters from an inner class in AbstractStreamingJoinOperator to a common utilit

JingsongLi merged pull request #15752: URL: https://github.com/apache/flink/pull/15752 -- 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,

[GitHub] [flink] flinkbot edited a comment on pull request #15774: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.14)

flinkbot edited a comment on pull request #15774: URL: https://github.com/apache/flink/pull/15774#issuecomment-827133461 ## CI report: * 5fbd84949babc1e127bc8d6d951ed75dffda4151 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15773: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.12)

flinkbot edited a comment on pull request #15773: URL: https://github.com/apache/flink/pull/15773#issuecomment-827133382 ## CI report: * ece7df21556a92a2711f39cc46d41aa094392eb7 Azure:

[jira] [Updated] (FLINK-21938) Add documentation about how to test Python UDFs

[ https://issues.apache.org/jira/browse/FLINK-21938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21938: --- Labels: auto-unassigned pull-request-available (was: pull-request-available

[jira] [Commented] (FLINK-21938) Add documentation about how to test Python UDFs

[ https://issues.apache.org/jira/browse/FLINK-21938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332797#comment-17332797 ] Flink Jira Bot commented on FLINK-21938: This issue was marked "stale-assigned" and has not

[GitHub] [flink] mans2singh commented on pull request #15756: [hotfix][docs] Removed duplicate 'is'

mans2singh commented on pull request #15756: URL: https://github.com/apache/flink/pull/15756#issuecomment-827188168 Hello @wuchong @leonardBang - Can you please review this PR ? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #15772: [FLINK-21131][webui] Alignment timeout displayed in checkpoint config…

flinkbot edited a comment on pull request #15772: URL: https://github.com/apache/flink/pull/15772#issuecomment-827092251 ## CI report: * fbafed45312a6d55e2a65e666833c115c0a0f07a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15774: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.14)

flinkbot edited a comment on pull request #15774: URL: https://github.com/apache/flink/pull/15774#issuecomment-827133461 ## CI report: * 5fbd84949babc1e127bc8d6d951ed75dffda4151 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15773: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.12)

flinkbot edited a comment on pull request #15773: URL: https://github.com/apache/flink/pull/15773#issuecomment-827133382 ## CI report: * ece7df21556a92a2711f39cc46d41aa094392eb7 Azure:

[GitHub] [flink] flinkbot commented on pull request #15774: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.14)

flinkbot commented on pull request #15774: URL: https://github.com/apache/flink/pull/15774#issuecomment-827133461 ## CI report: * 5fbd84949babc1e127bc8d6d951ed75dffda4151 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15773: [FLINK-22479][Kinesis][Consumer] Potential lock-up under error condition (Flink 1.12)

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

[jira] [Commented] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix.

[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332718#comment-17332718 ] Austin Cawley-Edwards commented on FLINK-22441: --- Adding the "drop Scala 2.11 support"

[GitHub] [flink] flinkbot commented on pull request #15774: [FLINK-22479[Kinesis][Consumer] Potential lock-up under error condition (Flink 1.14)

flinkbot commented on pull request #15774: URL: https://github.com/apache/flink/pull/15774#issuecomment-827123991 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

[GitHub] [flink] flinkbot commented on pull request #15773: [FLINK-22479[Kinesis][Consumer] Potential lock-up under error condition (Flink 1.12)

flinkbot commented on pull request #15773: URL: https://github.com/apache/flink/pull/15773#issuecomment-827122947 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

[jira] [Updated] (FLINK-22479) [Kinesis][Consumer] Potential lock-up under error condition

[ https://issues.apache.org/jira/browse/FLINK-22479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22479: --- Labels: pull-request-available (was: ) > [Kinesis][Consumer] Potential lock-up under error

[GitHub] [flink] dannycranmer opened a new pull request #15774: [FLINK-22479[Kinesis][Consumer] Potential lock-up under error condition (Flink 1.14)

dannycranmer opened a new pull request #15774: URL: https://github.com/apache/flink/pull/15774 ## What is the purpose of the change Pull in the following fixes from AWS fork: * Fix issue where `KinesisDataFetcher.shutdownFetcher()` hangs

[GitHub] [flink] dannycranmer opened a new pull request #15773: [FLINK-22479[Kinesis][Consumer] Potential lock-up under error condition (Flink 1.12)

dannycranmer opened a new pull request #15773: URL: https://github.com/apache/flink/pull/15773 ## What is the purpose of the change Pull in the following fixes from AWS fork: * Fix issue where `KinesisDataFetcher.shutdownFetcher()` hangs

  1   2   3   4   5   6   >