[GitHub] [flink-web] infoverload commented on a change in pull request #460: Add blog post - Implement custom source connector for Table API and SQL

2021-08-18 Thread GitBox
infoverload commented on a change in pull request #460: URL: https://github.com/apache/flink-web/pull/460#discussion_r691836358 ## File path: _posts/2021-08-16-connector-table-sql-api-part2.md ## @@ -0,0 +1,434 @@ +--- +layout: post +title: "Implementing a custom source connec

[GitHub] [flink] flinkbot commented on pull request #16892: [hotfix][docs] Update IDE Setup guide

2021-08-18 Thread GitBox
flinkbot commented on pull request #16892: URL: https://github.com/apache/flink/pull/16892#issuecomment-901655151 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

[GitHub] [flink] Airblader opened a new pull request #16892: [hotfix][docs] Update IDE Setup guide

2021-08-18 Thread GitBox
Airblader opened a new pull request #16892: URL: https://github.com/apache/flink/pull/16892 ## What is the purpose of the change This PR updates the IDE setup guide. I made some bigger structural changes such as reducing the heading levels, re-ordering sections and extracting a shar

[GitHub] [flink] flinkbot commented on pull request #16891: [FLINK-23868][Client] JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread GitBox
flinkbot commented on pull request #16891: URL: https://github.com/apache/flink/pull/16891#issuecomment-901650730 ## CI report: * 2b86ed20df9153056202c1b1550ce9a451626b69 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16887: URL: https://github.com/apache/flink/pull/16887#issuecomment-901570019 ## CI report: * 2d7ead01d06725c50cc41af410a20af132dd2635 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901118206 ## CI report: * 9c3804581cb63e72a72a72a05ffd76640c49927c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * c34ba95f4220031885b7d11ff7c601d3b000c9b1 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-23861) flink sql client support dynamic params

2021-08-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401496#comment-17401496 ] Jark Wu commented on FLINK-23861: - Thanks [~zhangbinzaifendou], I just think performance

[jira] [Commented] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401491#comment-17401491 ] Paul Lin commented on FLINK-23868: -- Since this is a minor fix, to facilitate the discus

[GitHub] [flink] flinkbot commented on pull request #16891: [FLINK-23868][Client] JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread GitBox
flinkbot commented on pull request #16891: URL: https://github.com/apache/flink/pull/16891#issuecomment-901634319 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-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23868: - Description: Environments prints job execution results to stdout by default and provides a flag `suppres

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * d73a6ff8b8eb25198ec374300d96744f36144dad Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901118206 ## CI report: * 9c3804581cb63e72a72a72a05ffd76640c49927c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23868: --- Labels: pull-request-available (was: ) > JobExecutionResult printed event if suppressSysout

[GitHub] [flink] link3280 opened a new pull request #16891: [FLINK-23868][Client] JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread GitBox
link3280 opened a new pull request #16891: URL: https://github.com/apache/flink/pull/16891 ## What is the purpose of the change Environments prints job execution results to stdout by default and provided a flag `suppressSysout` to disable the behavior. This flag is useful when submi

[GitHub] [flink] hapihu edited a comment on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
hapihu edited a comment on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901628257 ```bash #8、 codespell flink-formats/ -S '*.xml' -S '*.iml' -S '*.txt' -S '*/target/*' flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/Abs

[GitHub] [flink] hapihu edited a comment on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
hapihu edited a comment on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901629744 ```bash # 1、 codespell flink-java/ -S '*.xml' -S '*.iml' -S '*.txt' -S '*/target/*' flink-java/src/main/java/org/apache/flink/api/java/DataSet.java:1538: write

[GitHub] [flink] hapihu commented on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
hapihu commented on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901629744 # 1、 codespell flink-java/ -S '*.xml' -S '*.iml' -S '*.txt' -S '*/target/*' flink-java/src/main/java/org/apache/flink/api/java/DataSet.java:1538: writen ==> written

[GitHub] [flink] hapihu commented on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
hapihu commented on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901628257 #8、 codespell flink-formats/ -S '*.xml' -S '*.iml' -S '*.txt' -S '*/target/*' flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVect

[GitHub] [flink] hapihu commented on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
hapihu commented on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901625661 ```bash 7、codespell flink-examples/ -S '*.xml' -S '*.iml' -S '*.txt' -S '*/target/*' flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/strea

[GitHub] [flink] hapihu commented on pull request #16878: [FLINK-23859][typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread GitBox
hapihu commented on pull request #16878: URL: https://github.com/apache/flink/pull/16878#issuecomment-901623657 ```bash 5、codespell flink-dist/ -S '*.xml' -S '*.iml' -S '*.txt' -S '*/target/*' flink-dist/src/main/flink-bin/bin/config.sh:378: Auxilliary ==> Auxiliary flin

[jira] [Updated] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-23868: - Description: Environments prints job execution results to stdout by default and provided a flag `suppres

[jira] [Created] (FLINK-23868) JobExecutionResult printed event if suppressSysout is on

2021-08-18 Thread Paul Lin (Jira)
Paul Lin created FLINK-23868: Summary: JobExecutionResult printed event if suppressSysout is on Key: FLINK-23868 URL: https://issues.apache.org/jira/browse/FLINK-23868 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

2021-08-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401476#comment-17401476 ] Nicholas Jiang commented on FLINK-20726: [~Jianyun Zhao], Is this lack of the do

[jira] [Updated] (FLINK-23856) Support all JSON methods in PyFlink

2021-08-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23856: Component/s: API / Python > Support all JSON methods in PyFlink > --- > >

[jira] [Closed] (FLINK-23757) Support JSON_EXISTS / JSON_VALUE methods in pyFlink

2021-08-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23757. --- Fix Version/s: 1.14.0 Resolution: Fixed Merged to master via ba9b4f1039037d4a2da4f90a2f83612ccf2fa708

[GitHub] [flink] dianfu closed pull request #16874: [FLINK-23757][python] Support json_exists and json_value

2021-08-18 Thread GitBox
dianfu closed pull request #16874: URL: https://github.com/apache/flink/pull/16874 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #16886: [FLINK-23727][core] Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16886: URL: https://github.com/apache/flink/pull/16886#issuecomment-901539563 ## CI report: * dcf915f4bd81ce935f935792de2effd0e8ffe634 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-23867) FlinkKafkaInternalProducerITCase.testCommitTransactionAfterClosed fails with IllegalStateException

2021-08-18 Thread Xintong Song (Jira)
Xintong Song created FLINK-23867: Summary: FlinkKafkaInternalProducerITCase.testCommitTransactionAfterClosed fails with IllegalStateException Key: FLINK-23867 URL: https://issues.apache.org/jira/browse/FLINK-2386

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401472#comment-17401472 ] Xintong Song commented on FLINK-23848: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401471#comment-17401471 ] Xintong Song commented on FLINK-23828: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401470#comment-17401470 ] Xintong Song commented on FLINK-23391: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901589961 ## CI report: * d73a6ff8b8eb25198ec374300d96744f36144dad Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16888: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16888: URL: https://github.com/apache/flink/pull/16888#issuecomment-901589942 ## CI report: * 796d67e230bf26f1f4437eb53be4560ec49ec846 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16890: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16890: URL: https://github.com/apache/flink/pull/16890#issuecomment-901589996 ## CI report: * 05d7697f85fa7b58cf55bc1dc3bcb0b963875f59 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-23861) flink sql client support dynamic params

2021-08-18 Thread zhangbinzaifendou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401465#comment-17401465 ] zhangbinzaifendou edited comment on FLINK-23861 at 8/19/21, 4:29 AM: -

[jira] [Commented] (FLINK-23861) flink sql client support dynamic params

2021-08-18 Thread zhangbinzaifendou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401465#comment-17401465 ] zhangbinzaifendou commented on FLINK-23861: --- [~jark] Thank you for your reply!

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401460#comment-17401460 ] Xintong Song commented on FLINK-23525: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401462#comment-17401462 ] Xintong Song commented on FLINK-22387: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23796) UnalignedCheckpointRescaleITCase JVM crash on Azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401458#comment-17401458 ] Xintong Song commented on FLINK-23796: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401459#comment-17401459 ] Xintong Song commented on FLINK-23848: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23848) PulsarSourceITCase is failed on Azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23848: - Priority: Critical (was: Major) > PulsarSourceITCase is failed on Azure > -

[jira] [Created] (FLINK-23866) KafkaTransactionLogITCase.testGetTransactionsToAbort fails with IllegalStateException

2021-08-18 Thread Xintong Song (Jira)
Xintong Song created FLINK-23866: Summary: KafkaTransactionLogITCase.testGetTransactionsToAbort fails with IllegalStateException Key: FLINK-23866 URL: https://issues.apache.org/jira/browse/FLINK-23866

[GitHub] [flink] flinkbot commented on pull request #16888: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
flinkbot commented on pull request #16888: URL: https://github.com/apache/flink/pull/16888#issuecomment-901589942 ## CI report: * 796d67e230bf26f1f4437eb53be4560ec49ec846 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Comment Edited] (FLINK-22198) KafkaTableITCase hang.

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401457#comment-17401457 ] Xintong Song edited comment on FLINK-22198 at 8/19/21, 3:56 AM: --

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401457#comment-17401457 ] Xintong Song commented on FLINK-22198: -- Thanks for the updates. bq. I don't have t

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401455#comment-17401455 ] Xintong Song commented on FLINK-22889: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-18 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401454#comment-17401454 ] Qingsheng Ren commented on FLINK-22198: --- Thanks [~xtsong] for the reminder. I had

[GitHub] [flink] flinkbot commented on pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

2021-08-18 Thread GitBox
flinkbot commented on pull request #16889: URL: https://github.com/apache/flink/pull/16889#issuecomment-901583304 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

[GitHub] [flink] flinkbot commented on pull request #16890: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
flinkbot commented on pull request #16890: URL: https://github.com/apache/flink/pull/16890#issuecomment-901583296 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

[GitHub] [flink] flinkbot edited a comment on pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16887: URL: https://github.com/apache/flink/pull/16887#issuecomment-901570019 ## CI report: * 2d7ead01d06725c50cc41af410a20af132dd2635 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] HuangXingBo opened a new pull request #16890: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
HuangXingBo opened a new pull request #16890: URL: https://github.com/apache/flink/pull/16890 ## What is the purpose of the change *This pull request will fix the NPE in Python UDTF* ## Brief change log - *Change the logic of emitResult in Python Table Function Ope

[GitHub] [flink] hapihu opened a new pull request #16889: [FLINK-16152][doc-zh]Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese

2021-08-18 Thread GitBox
hapihu opened a new pull request #16889: URL: https://github.com/apache/flink/pull/16889 Translate "Operator/index"(docs/content.zh/docs/dev/datastream/operators/overview.md) into Chinese -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot commented on pull request #16888: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
flinkbot commented on pull request #16888: URL: https://github.com/apache/flink/pull/16888#issuecomment-901582081 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

[GitHub] [flink] HuangXingBo opened a new pull request #16888: [FLINK-23765][python] Fix the NPE in Python UDTF

2021-08-18 Thread GitBox
HuangXingBo opened a new pull request #16888: URL: https://github.com/apache/flink/pull/16888 ## What is the purpose of the change *This pull request will fix the NPE in Python UDTF* ## Brief change log - *Change the logic of emitResult in Python Table Function Ope

[jira] [Updated] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-08-18 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucao updated FLINK-23865: --- Description: code: {code:java} Table table = tbEnv.fromValues(DataTypes.ROW( DataTypes.FIELD("innerP

[jira] [Created] (FLINK-23865) Class cast error caused by nested Pojo in legacy outputConversion

2021-08-18 Thread zoucao (Jira)
zoucao created FLINK-23865: -- Summary: Class cast error caused by nested Pojo in legacy outputConversion Key: FLINK-23865 URL: https://issues.apache.org/jira/browse/FLINK-23865 Project: Flink Issue

[GitHub] [flink] zhuzhurk closed pull request #16842: [FLINK-23806][runtime] Avoid StackOverflowException when a large scale job failed to acquire enough slots in time

2021-08-18 Thread GitBox
zhuzhurk closed pull request #16842: URL: https://github.com/apache/flink/pull/16842 -- 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. To unsubscribe, e-mail: issues-unsubs

[GitHub] [flink] flinkbot commented on pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
flinkbot commented on pull request #16887: URL: https://github.com/apache/flink/pull/16887#issuecomment-901570019 ## CI report: * 2d7ead01d06725c50cc41af410a20af132dd2635 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * 521e19eecadf39a226c5b5be4ed5348485656eab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] SteNicholas commented on pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
SteNicholas commented on pull request #16887: URL: https://github.com/apache/flink/pull/16887#issuecomment-901563667 @wuchong , thanks for the review. I have removed the note for `table.dynamic-table-options.enabled` in `hints.md`. Please take a look. -- This is an automated message from

[jira] [Commented] (FLINK-23861) flink sql client support dynamic params

2021-08-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401443#comment-17401443 ] Jark Wu commented on FLINK-23861: - IIUC, your main concern is the performance of SET com

[jira] [Comment Edited] (FLINK-23861) flink sql client support dynamic params

2021-08-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401443#comment-17401443 ] Jark Wu edited comment on FLINK-23861 at 8/19/21, 2:30 AM: --- II

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * 521e19eecadf39a226c5b5be4ed5348485656eab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23829) SavepointITCase JVM crash on azure

2021-08-18 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401442#comment-17401442 ] Yun Gao commented on FLINK-23829: - Ok, I changed the status~ > SavepointITCase JVM cras

[GitHub] [flink] flinkbot commented on pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
flinkbot commented on pull request #16887: URL: https://github.com/apache/flink/pull/16887#issuecomment-901559968 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-23829) SavepointITCase JVM crash on azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401438#comment-17401438 ] Xintong Song commented on FLINK-23829: -- Thanks, [~gaoyunhaii]. BTW, could you pleas

[GitHub] [flink] wuchong commented on a change in pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
wuchong commented on a change in pull request #16887: URL: https://github.com/apache/flink/pull/16887#discussion_r691727770 ## File path: docs/content/docs/dev/table/sql/queries/hints.md ## @@ -50,8 +50,7 @@ these options can be specified flexibly in per-table scope within eac

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401437#comment-17401437 ] Xintong Song commented on FLINK-23556: -- Sounds good, thanks. BTW, could you move th

[jira] [Updated] (FLINK-23743) Test the fine-grained resource management

2021-08-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-23743: --- Parent: FLINK-21924 Issue Type: Sub-task (was: Improvement) > Test the fine-grained resourc

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401436#comment-17401436 ] Xintong Song commented on FLINK-23493: -- [~hxbks2ks], please move the ticket to in-p

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401434#comment-17401434 ] Xintong Song commented on FLINK-22198: -- [~renqs], BTW, please move the ticket to in

[jira] [Commented] (FLINK-23743) Test the fine-grained resource management

2021-08-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401435#comment-17401435 ] Yangze Guo commented on FLINK-23743: [~joemoe] I'm fine with it. I just saw the prev

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401432#comment-17401432 ] Xintong Song commented on FLINK-22198: -- [~renqs] [~lindong] I think the latest inst

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401431#comment-17401431 ] Xintong Song commented on FLINK-22198: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-23755) Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23755: --- Labels: pull-request-available (was: ) > Modify the default value of table.dynamic-table-op

[GitHub] [flink] SteNicholas opened a new pull request #16887: [FLINK-23755][table] Modify the default value of table.dynamic-table-options.enabled to true

2021-08-18 Thread GitBox
SteNicholas opened a new pull request #16887: URL: https://github.com/apache/flink/pull/16887 ## What is the purpose of the change *The table option `table.dynamic-table-options.enabled` is used to enable the `OPTIONS` hint used to specify table options dynamically, which default va

[jira] [Commented] (FLINK-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401428#comment-17401428 ] Paul Lin commented on FLINK-23727: -- [~paul8263] Thanks for your contribution, but the P

[GitHub] [flink] RocMarshal commented on pull request #16852: [FLINK-13636][docs-zh]Translate the "Flink DataStream API Programming Guide" page into Chinese

2021-08-18 Thread GitBox
RocMarshal commented on pull request #16852: URL: https://github.com/apache/flink/pull/16852#issuecomment-901551930 Thanks @hapihu for the contribution and @wuchong trust. Please let me check it step by step. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

2021-08-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401427#comment-17401427 ] Xintong Song commented on FLINK-22387: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] bytesandwich commented on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-08-18 Thread GitBox
bytesandwich commented on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-901549266 Hi @XComp I just switched jobs so I was out for a bit. I see how you envision the test and I implemented it that way. PTAL! -- This is an automated message from the Apach

[GitHub] [flink] flinkbot edited a comment on pull request #16886: [FLINK-23727][core] Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16886: URL: https://github.com/apache/flink/pull/16886#issuecomment-901539563 ## CI report: * dcf915f4bd81ce935f935792de2effd0e8ffe634 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] camilesing commented on pull request #16823: [FLINK-23845][docs]improve PushGatewayReporter config:deleteOnShutdown de…

2021-08-18 Thread GitBox
camilesing commented on pull request #16823: URL: https://github.com/apache/flink/pull/16823#issuecomment-901540056 @tsreaper hi, can you review it? thx -- 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 t

[GitHub] [flink] camilesing edited a comment on pull request #16629: [FLINK-23847][connectors][kafka] improve error message when valueDeseriali…

2021-08-18 Thread GitBox
camilesing edited a comment on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-901539082 @tsreaper hi, can you review it? thx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #16886: [FLINK-23727][core] Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread GitBox
flinkbot commented on pull request #16886: URL: https://github.com/apache/flink/pull/16886#issuecomment-901539563 ## CI report: * dcf915f4bd81ce935f935792de2effd0e8ffe634 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] camilesing commented on pull request #16629: [FLINK-23847][connectors][kafka] improve error message when valueDeseriali…

2021-08-18 Thread GitBox
camilesing commented on pull request #16629: URL: https://github.com/apache/flink/pull/16629#issuecomment-901539082 @tsreape hi, can you review it? thx -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * 521e19eecadf39a226c5b5be4ed5348485656eab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #15898: URL: https://github.com/apache/flink/pull/15898#issuecomment-838996225 ## CI report: * 521e19eecadf39a226c5b5be4ed5348485656eab Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16886: [FLINK-23727][core] Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread GitBox
flinkbot commented on pull request #16886: URL: https://github.com/apache/flink/pull/16886#issuecomment-901524380 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-23727) Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23727: --- Labels: pull-request-available (was: ) > Skip null values in SimpleStringSchema#deserialize

[GitHub] [flink] paul8263 opened a new pull request #16886: [FLINK-23727][core] Skip null values in SimpleStringSchema#deserialize

2021-08-18 Thread GitBox
paul8263 opened a new pull request #16886: URL: https://github.com/apache/flink/pull/16886 ## What is the purpose of the change Fixe the issue that the resulting scale of TRUNCATE(DECIMAL, ...) is not correct. ## Brief change log - flink-core/src/main/java/org/apac

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16885: URL: https://github.com/apache/flink/pull/16885#issuecomment-901300956 ## CI report: * 507d2f8129e46bac8a31f5cc6371e1d627c16b2b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22644) Translate "Native Kubernetes" page into Chinese

2021-08-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22644: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned pull-reque

[jira] [Updated] (FLINK-18574) DownloadPipelineArtifact failes occasionally

2021-08-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18574: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

2021-08-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22416: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16885: URL: https://github.com/apache/flink/pull/16885#issuecomment-901300956 ## CI report: * 42f46f71429e3bd703b451cdab8a486542abf283 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16838: URL: https://github.com/apache/flink/pull/16838#issuecomment-899337835 ## CI report: * 92f938c7b00a357e2fc58fd2532385a6a4b72516 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rkhachatryan commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-18 Thread GitBox
rkhachatryan commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r691590608 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/materializer/PeriodicMaterializer.java ##

[GitHub] [flink] rkhachatryan commented on a change in pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-18 Thread GitBox
rkhachatryan commented on a change in pull request #16606: URL: https://github.com/apache/flink/pull/16606#discussion_r691587190 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/materializer/PeriodicMaterializer.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #16884: [FLINK-22221][runtime] Log instantiations of FileChannelManager to pr…

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16884: URL: https://github.com/apache/flink/pull/16884#issuecomment-901259128 ## CI report: * afd09ac3fd8ff1a0dff955aa8e142a0d5b3ec638 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   6   >