[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

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

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

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

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

[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

[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

[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=17401476#comment-17401476 ] Nicholas Jiang commented on FLINK-20726: [~Jianyun Zhao], Is this lack of the document of Pulsar

[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 

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

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

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

[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=17401472#comment-17401472 ] Xintong Song commented on FLINK-23848: --

[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=17401471#comment-17401471 ] Xintong Song commented on FLINK-23828: --

[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=17401470#comment-17401470 ] Xintong Song commented on FLINK-23391: --

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

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

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

[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=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=17401465#comment-17401465 ] zhangbinzaifendou commented on FLINK-23861: --- [~jark] Thank you for your reply! 1 There is no

[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=17401460#comment-17401460 ] Xintong Song commented on FLINK-23525: --

[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=17401462#comment-17401462 ] Xintong Song commented on FLINK-22387: --

[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=17401458#comment-17401458 ] Xintong Song commented on FLINK-23796: --

[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=17401459#comment-17401459 ] Xintong Song commented on FLINK-23848: --

[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

[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=17401457#comment-17401457 ] Xintong Song edited comment on FLINK-22198 at 8/19/21, 3:56 AM: Thanks

[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=17401457#comment-17401457 ] Xintong Song commented on FLINK-22198: -- Thanks for the updates. bq. I don't have the permission to

[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=17401455#comment-17401455 ] Xintong Song commented on FLINK-22889: --

[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=17401454#comment-17401454 ] Qingsheng Ren commented on FLINK-22198: --- Thanks [~xtsong] for the reminder. I had a discussion

[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

[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

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

[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

[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

[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

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

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

[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

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

[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

[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=17401443#comment-17401443 ] Jark Wu commented on FLINK-23861: - IIUC, your main concern is the performance of SET command because it

[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=17401443#comment-17401443 ] Jark Wu edited comment on FLINK-23861 at 8/19/21, 2:30 AM: --- IIUC, your main

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

[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=17401442#comment-17401442 ] Yun Gao commented on FLINK-23829: - Ok, I changed the status~ > SavepointITCase JVM crash on azure >

[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

[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=17401438#comment-17401438 ] Xintong Song commented on FLINK-23829: -- Thanks, [~gaoyunhaii]. BTW, could you please move the

[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

[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=17401437#comment-17401437 ] Xintong Song commented on FLINK-23556: -- Sounds good, thanks. BTW, could you move the ticket to

[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

[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=17401436#comment-17401436 ] Xintong Song commented on FLINK-23493: -- [~hxbks2ks], please move the ticket to in-progress, since

[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=17401434#comment-17401434 ] Xintong Song commented on FLINK-22198: -- [~renqs], BTW, please move the ticket to in-progress as

[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=17401435#comment-17401435 ] Yangze Guo commented on FLINK-23743: [~joemoe] I'm fine with it. I just saw the previous testing

[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=17401432#comment-17401432 ] Xintong Song commented on FLINK-22198: -- [~renqs] [~lindong] I think the latest instance occurred

[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=17401431#comment-17401431 ] Xintong Song commented on FLINK-22198: --

[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

[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

[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=17401428#comment-17401428 ] Paul Lin commented on FLINK-23727: -- [~paul8263] Thanks for your contribution, but the PR involves

[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=17401427#comment-17401427 ] Xintong Song commented on FLINK-22387: --

[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

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

[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

[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

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

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

[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

[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

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

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

[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

[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

[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

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

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

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

[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_r691577741 ## 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_r691573533 ## 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 #16882: [FLINK-23528][kinesis] Do not interrupt main thread during cancellation.

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16882: URL: https://github.com/apache/flink/pull/16882#issuecomment-901186762 ## CI report: * 9ebf91c53e256e47aaa6a7af1b94bd99d499e53a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16883: [FLINK-22217][runtime] Add quotes around job name in job related log …

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16883: URL: https://github.com/apache/flink/pull/16883#issuecomment-901213387 ## CI report: * 6e6bd1dadc897ec438c3f176f7579690f30cf860 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16877: [FLINK-23861][sql-client]flink sql client support dynamic params

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16877: URL: https://github.com/apache/flink/pull/16877#issuecomment-901089685 ## CI report: * d28f807fa7579005eeb231eb9cc5e772f222f85b Azure:

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

[jira] [Commented] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration'

2021-08-18 Thread wuguihu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401305#comment-17401305 ] wuguihu commented on FLINK-23841: - Hi,[~chesnay] Excuse me for taking up your time. I created pull

[jira] [Commented] (FLINK-23859) [typo][flink-core][flink-connectors]fix typo for code

2021-08-18 Thread wuguihu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401304#comment-17401304 ] wuguihu commented on FLINK-23859: - Hi,[~chesnay] Excuse me for taking up your time. I created pull

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

[GitHub] [flink] flinkbot edited a comment on pull request #16879: [FLINK-23840][runtime] Improve confusing log / exception message when…

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16879: URL: https://github.com/apache/flink/pull/16879#issuecomment-901136305 ## CI report: * 6f8434f7ee71aea629edfc4d1e3f77e8c17a1a33 Azure:

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

[GitHub] [flink] flinkbot edited a comment on pull request #16880: [hotfix][flink-kafka-connector][docs] Fix some typos in flink-kafka-connector annotation

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16880: URL: https://github.com/apache/flink/pull/16880#issuecomment-901136372 ## CI report: * d8f377bba18c95536edd372c5438903f849cea69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-08-18 Thread GitBox
flinkbot edited a comment on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900450716 ## CI report: * 2e14eb9abe1a001787baf70a87f604f387e5f753 Azure:

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

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

  1   2   3   4   5   6   >