[GitHub] [flink] flinkbot commented on pull request #15912: [FLINK-22656] FIX TYPO

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

[jira] [Commented] (FLINK-20454) Allow to read metadata for debezium-avro-confluent format

[ https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343867#comment-17343867 ] hailong wang commented on FLINK-20454: -- [~caozhen1937] Sure, thanks for taking this. > Allow to

[GitHub] [flink] rmetzger closed pull request #15121: The method $(String) is undefined for the type TableExample

rmetzger closed pull request #15121: URL: https://github.com/apache/flink/pull/15121 -- 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] rmetzger commented on pull request #15121: The method $(String) is undefined for the type TableExample

rmetzger commented on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-840614031 Please post questions to the u...@flink.apache.org mailing list: https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list -- This is an automated message

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343954#comment-17343954 ] JasonLee commented on FLINK-22655: -- hi Jark the The submission order is as follows {{sql-client.sh -i 

[jira] [Updated] (FLINK-22658) Remove Deprecated util class TableConnectorUtil

[ https://issues.apache.org/jira/browse/FLINK-22658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22658: --- Labels: pull-request-available (was: ) > Remove Deprecated util class TableConnectorUtil >

[GitHub] [flink] wangxianghu opened a new pull request #15914: [FLINK-22658][table-common] Remove Deprecated util class TableConnectorUtil

wangxianghu opened a new pull request #15914: URL: https://github.com/apache/flink/pull/15914 ## What is the purpose of the change Remove and replace `TableConnectorUtil` with `TableConnectorUtils` ## Brief change log Remove `TableConnectorUtil` ##

[jira] [Updated] (FLINK-22658) Remove Deprecated util class TableConnectorUtil

[ https://issues.apache.org/jira/browse/FLINK-22658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xianghu Wang updated FLINK-22658: - Component/s: Table SQL / Runtime > Remove Deprecated util class TableConnectorUtil >

[GitHub] [flink] HuangXingBo opened a new pull request #15913: [FLINK-22649][python][table-planner-blink] Support StreamExecPythonCalc json serialization/deserialization

HuangXingBo opened a new pull request #15913: URL: https://github.com/apache/flink/pull/15913 ## What is the purpose of the change *This pull request Support StreamExecPythonCalc json serialization/deserialization* ## Brief change log - *Support StreamExecPythonCalc

[jira] [Updated] (FLINK-22649) Support StreamExecPythonCalc json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15906: [FLINK-19796][table] Explicit casting should be made if the type of a…

flinkbot edited a comment on pull request #15906: URL: https://github.com/apache/flink/pull/15906#issuecomment-839807373 ## CI report: * d1baacbc486e54423a659cbab87ed5c45f159edf Azure:

[GitHub] [flink] flinkbot commented on pull request #15915: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

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

[jira] [Comment Edited] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job

[ https://issues.apache.org/jira/browse/FLINK-22574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17343486#comment-17343486 ] Robert Metzger edited comment on FLINK-22574 at 5/13/21, 2:51 PM: --

[jira] [Closed] (FLINK-22574) Adaptive Scheduler: Can not cancel restarting job

[ https://issues.apache.org/jira/browse/FLINK-22574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22574. -- Fix Version/s: 1.14.0 Resolution: Fixed > Adaptive Scheduler: Can not cancel

[GitHub] [flink] rmetzger commented on a change in pull request #15884: [FLINK-22266] Fix stop-with-savepoint operation in AdaptiveScheduler

rmetzger commented on a change in pull request #15884: URL: https://github.com/apache/flink/pull/15884#discussion_r631893153 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -60,8 +69,16 @@ this.context =

[GitHub] [flink] flinkbot commented on pull request #15913: [FLINK-22649][python][table-planner-blink] Support StreamExecPythonCalc json serialization/deserialization

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

[GitHub] [flink] flinkbot commented on pull request #15913: [FLINK-22649][python][table-planner-blink] Support StreamExecPythonCalc json serialization/deserialization

flinkbot commented on pull request #15913: URL: https://github.com/apache/flink/pull/15913#issuecomment-840510415 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-22592) numBuffersInLocal is always zero when using unaligned checkpoints

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

[GitHub] [flink] SteNicholas opened a new pull request #15915: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

SteNicholas opened a new pull request #15915: URL: https://github.com/apache/flink/pull/15915 ## What is the purpose of the change *`numBuffersInLocal` is always zero when using unaligned checkpoints, because `LocalRecoveredInputChannel#toInputChannelInternal` is passing wrong

[GitHub] [flink] flinkbot edited a comment on pull request #15915: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

flinkbot edited a comment on pull request #15915: URL: https://github.com/apache/flink/pull/15915#issuecomment-840539693 ## CI report: * 0fa29a2e66df7afd64d87d4edd70e6f66335352a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15912: [FLINK-22656] FIX TYPO

flinkbot edited a comment on pull request #15912: URL: https://github.com/apache/flink/pull/15912#issuecomment-840507754 ## CI report: * 6c3e401b9fb56ed39841eecf0babce4a0c8bd057 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

flinkbot edited a comment on pull request #15911: URL: https://github.com/apache/flink/pull/15911#issuecomment-840400324 ## CI report: * 01776a42b55761b5277214ba3ef63b68257f3aa2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

flinkbot edited a comment on pull request #15911: URL: https://github.com/apache/flink/pull/15911#issuecomment-840400324 ## CI report: * 01776a42b55761b5277214ba3ef63b68257f3aa2 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

dannycranmer commented on a change in pull request #15830: URL: https://github.com/apache/flink/pull/15830#discussion_r631794648 ## File path: docs/content.zh/docs/connectors/datastream/kinesis.md ## @@ -126,6 +126,45 @@ shard IDs are not consecutive (as result of dynamic

[GitHub] [flink] flinkbot edited a comment on pull request #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

flinkbot edited a comment on pull request #15911: URL: https://github.com/apache/flink/pull/15911#issuecomment-840400324 ## CI report: * 01776a42b55761b5277214ba3ef63b68257f3aa2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15913: [FLINK-22649][python][table-planner-blink] Support StreamExecPythonCalc json serialization/deserialization

flinkbot edited a comment on pull request #15913: URL: https://github.com/apache/flink/pull/15913#issuecomment-840516258 ## CI report: * 0dea984584314c7e6c57d4bdcbbdd1276de7dff9 Azure:

[GitHub] [flink] flinkbot commented on pull request #15915: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

flinkbot commented on pull request #15915: URL: https://github.com/apache/flink/pull/15915#issuecomment-840525709 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 #15906: [FLINK-19796][table] Explicit casting should be made if the type of a…

flinkbot edited a comment on pull request #15906: URL: https://github.com/apache/flink/pull/15906#issuecomment-839807373 ## CI report: * 26e541325a507d36910dbd9a7c56c990587ae656 Azure:

[GitHub] [flink] SteNicholas commented on pull request #15915: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

SteNicholas commented on pull request #15915: URL: https://github.com/apache/flink/pull/15915#issuecomment-840525841 @pnowojski , if you are available, please help to review this simple change. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #15914: [FLINK-22658][table-common] Remove Deprecated util class TableConnectorUtil

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

[GitHub] [flink] flinkbot edited a comment on pull request #15913: [FLINK-22649][python][table-planner-blink] Support StreamExecPythonCalc json serialization/deserialization

flinkbot edited a comment on pull request #15913: URL: https://github.com/apache/flink/pull/15913#issuecomment-840516258 ## CI report: * 0dea984584314c7e6c57d4bdcbbdd1276de7dff9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15914: [FLINK-22658][table-common] Remove Deprecated util class TableConnectorUtil

flinkbot edited a comment on pull request #15914: URL: https://github.com/apache/flink/pull/15914#issuecomment-840526114 ## CI report: * 977d52a3a88cb0ab45eafee6f9fc060d54e48b6f Azure:

[jira] [Created] (FLINK-22658) Remove Deprecated util class TableConnectorUtil

Xianghu Wang created FLINK-22658: Summary: Remove Deprecated util class TableConnectorUtil Key: FLINK-22658 URL: https://issues.apache.org/jira/browse/FLINK-22658 Project: Flink Issue Type:

[jira] [Created] (FLINK-22657) HiveParserDDLSemanticAnalyzer can directly return operations

Rui Li created FLINK-22657: -- Summary: HiveParserDDLSemanticAnalyzer can directly return operations Key: FLINK-22657 URL: https://issues.apache.org/jira/browse/FLINK-22657 Project: Flink Issue

[GitHub] [flink] cshuo commented on a change in pull request #15906: [FLINK-19796][table] Explicit casting should be made if the type of a…

cshuo commented on a change in pull request #15906: URL: https://github.com/apache/flink/pull/15906#discussion_r631765645 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql/SqlArrayFunction.java ## @@ -0,0 +1,71 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15912: [FLINK-22656] FIX TYPO

flinkbot edited a comment on pull request #15912: URL: https://github.com/apache/flink/pull/15912#issuecomment-840507754 ## CI report: * 6c3e401b9fb56ed39841eecf0babce4a0c8bd057 Azure:

[GitHub] [flink] flinkbot commented on pull request #15914: [FLINK-22658][table-common] Remove Deprecated util class TableConnectorUtil

flinkbot commented on pull request #15914: URL: https://github.com/apache/flink/pull/15914#issuecomment-840520248 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 #15914: [FLINK-22658][table-common] Remove Deprecated util class TableConnectorUtil

flinkbot edited a comment on pull request #15914: URL: https://github.com/apache/flink/pull/15914#issuecomment-840526114 ## CI report: * 977d52a3a88cb0ab45eafee6f9fc060d54e48b6f Azure:

[GitHub] [flink] qqibrow opened a new pull request #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

qqibrow opened a new pull request #15916: URL: https://github.com/apache/flink/pull/15916 https://issues.apache.org/jira/browse/FLINK-22164 -- 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] [Created] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

wangqinghuan created FLINK-22659: Summary: 'execution.checkpointing.interval' missing in Flink doc Key: FLINK-22659 URL: https://issues.apache.org/jira/browse/FLINK-22659 Project: Flink

[jira] [Commented] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344052#comment-17344052 ] Rainie Li commented on FLINK-22659: ---  can you assign this one to me? :) >

[GitHub] [flink] flinkbot edited a comment on pull request #15915: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

flinkbot edited a comment on pull request #15915: URL: https://github.com/apache/flink/pull/15915#issuecomment-840539693 ## CI report: * 0fa29a2e66df7afd64d87d4edd70e6f66335352a Azure:

[GitHub] [flink] flinkbot commented on pull request #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

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

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * 820e584e9b62bb727f9b87dd613e55f71cf2cff9 Azure:

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344124#comment-17344124 ] Mathieu Druart commented on FLINK-15440: Hello [~Leonard Xu], you closed this issue as

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * 820e584e9b62bb727f9b87dd613e55f71cf2cff9 Azure:

[jira] [Commented] (FLINK-22164) Add jobId and JobName variable to JobManager metrics in per-job deployment mode

[ https://issues.apache.org/jira/browse/FLINK-22164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344078#comment-17344078 ] Lu Niu commented on FLINK-22164: [~trohrmann] This is the POC code for adding this feature

[GitHub] [flink] flinkbot commented on pull request #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

flinkbot commented on pull request #15916: URL: https://github.com/apache/flink/pull/15916#issuecomment-840766291 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] [Created] (FLINK-22660) Incorrect flink documentation example

Tejas Budukh created FLINK-22660: Summary: Incorrect flink documentation example Key: FLINK-22660 URL: https://issues.apache.org/jira/browse/FLINK-22660 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

flinkbot edited a comment on pull request #15916: URL: https://github.com/apache/flink/pull/15916#issuecomment-840778962 ## CI report: * 3be4eb0e5171836dd03265ca6b8b595496939831 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

flinkbot edited a comment on pull request #15911: URL: https://github.com/apache/flink/pull/15911#issuecomment-840400324 ## CI report: * 3f65cec93d80e507b64cff2672ab10cd4990d7aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * a41211d988c460b411ec7c5bca8dec0a4305bb87 Azure:

[GitHub] [flink] HubertChen opened a new pull request #15917: [hotfix] [docs] Fix PunctuatedAssigner Scala example

HubertChen opened a new pull request #15917: URL: https://github.com/apache/flink/pull/15917 ## What is the purpose of the change The PunctuatedAssigner example written in Scala does not correctly implement the WatermarkGenerator interface. The overridden methods were missing a

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * Unknown: [CANCELED](TBD) * a0732d2ee2f9cc9745ea0eb739e428ea6fc34271 UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Comment Edited] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344233#comment-17344233 ] Mathieu Druart edited comment on FLINK-15440 at 5/14/21, 2:22 AM: --

[jira] [Comment Edited] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344233#comment-17344233 ] Mathieu Druart edited comment on FLINK-15440 at 5/14/21, 2:21 AM: --

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344248#comment-17344248 ] Guowei Ma commented on FLINK-22593: ---

[jira] [Commented] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

[ https://issues.apache.org/jira/browse/FLINK-21411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344247#comment-17344247 ] yangxiao commented on FLINK-21411: -- com.data-artisans frocksdbjni 5.17.2-artisans-2.0   The JAR

[GitHub] [flink] flinkbot edited a comment on pull request #15917: [hotfix] [docs] Fix PunctuatedAssigner Scala example

flinkbot edited a comment on pull request #15917: URL: https://github.com/apache/flink/pull/15917#issuecomment-840932660 ## CI report: * 1770eee25226317719499022a11c3b7bfc99e0af Azure:

[jira] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344270#comment-17344270 ] JasonLee edited comment on FLINK-22655 at 5/14/21, 2:55 AM: Hi

[jira] [Commented] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344282#comment-17344282 ] Terry Wang commented on FLINK-22654: I reproduce this problem in my local environment, and it's a

[jira] [Updated] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22654: --- Labels: pull-request-available (was: ) > SqlCreateTable toString()/unparse() lose

[GitHub] [flink] yittg commented on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

yittg commented on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-840937187 Hi @tillrohrmann, i just rebased this PR to the newest master to try to pass the AZP. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] godfreyhe merged pull request #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

godfreyhe merged pull request #15911: URL: https://github.com/apache/flink/pull/15911 -- 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 #15812: remove slotpoolImpl

flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * ba56eafaf3d23325b3cecbd54bdac28cb30eaa97 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15906: [FLINK-19796][table] Explicit casting should be made if the type of a…

flinkbot edited a comment on pull request #15906: URL: https://github.com/apache/flink/pull/15906#issuecomment-839807373 ## CI report: * d1baacbc486e54423a659cbab87ed5c45f159edf Azure:

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344261#comment-17344261 ] Shengkai Fang commented on FLINK-22655: --- Hi, [~JasonLee]. Could you offer the LOG for more

[jira] [Commented] (FLINK-21411) The components on which Flink depends may contain vulnerabilities. If yes, fix them.

[ https://issues.apache.org/jira/browse/FLINK-21411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344265#comment-17344265 ] yangxiao commented on FLINK-21411: -- Is CVE-2019-12900 vulnerability triggered when we use

[GitHub] [flink] flinkbot commented on pull request #15918: [FLINK-22654][table] fix SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

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

[GitHub] [flink] JingsongLi commented on a change in pull request #15906: [FLINK-19796][table] Explicit casting should be made if the type of a…

JingsongLi commented on a change in pull request #15906: URL: https://github.com/apache/flink/pull/15906#discussion_r632269727 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/utils/SqlValidatorUtils.java ## @@ -0,0

[GitHub] [flink] flinkbot commented on pull request #15917: [hotfix] [docs] Fix PunctuatedAssigner Scala example

flinkbot commented on pull request #15917: URL: https://github.com/apache/flink/pull/15917#issuecomment-840923502 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-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangqinghuan updated FLINK-22659: - Description:  Flink deployment configuration describe how to configure checkpointing in

[jira] [Updated] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangqinghuan updated FLINK-22659: - Description:  Flink deployment configuration describe how to configure checkpointing in

[jira] [Closed] (FLINK-15064) Remove XmlOutput util class in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-15064. -- Resolution: Fixed Fixed in 1.14.0: d241759b89ae3455afae5e434a9384ebdc3c1f5f > Remove XmlOutput util

[GitHub] [flink] flinkbot edited a comment on pull request #15917: [hotfix] [docs] Fix PunctuatedAssigner Scala example

flinkbot edited a comment on pull request #15917: URL: https://github.com/apache/flink/pull/15917#issuecomment-840932660 ## CI report: * 1770eee25226317719499022a11c3b7bfc99e0af Azure:

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344224#comment-17344224 ] Kurt Young commented on FLINK-15440: [~Mathieu Druart] IIRC this issue can be addressed by setting

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344232#comment-17344232 ] Leonard Xu commented on FLINK-15440: Hi [~Mathieu Druart] I didn't obtain information about 

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344254#comment-17344254 ] Guowei Ma commented on FLINK-22613: ---

[jira] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344261#comment-17344261 ] Shengkai Fang edited comment on FLINK-22655 at 5/14/21, 2:44 AM: - Hi,

[jira] [Updated] (FLINK-22661) HiveInputFormatPartitionReader can return invalid data

[ https://issues.apache.org/jira/browse/FLINK-22661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22661: --- Description: This happens when there're multiple splits to read, and an extra record is returned when we

[jira] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344287#comment-17344287 ] Shengkai Fang edited comment on FLINK-22655 at 5/14/21, 3:42 AM: - I

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344287#comment-17344287 ] Shengkai Fang commented on FLINK-22655: --- I think the main reason is the {{ExtendedParser}} has no

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344262#comment-17344262 ] forideal commented on FLINK-22472: -- [~Leonard Xu] If the success file has been submitted and the data

[jira] [Commented] (FLINK-22639) ClassLoaderUtil cannot print classpath of FlinkUserCodeClassLoader

[ https://issues.apache.org/jira/browse/FLINK-22639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344263#comment-17344263 ] Shengkai Fang commented on FLINK-22639: --- +1 to support it > ClassLoaderUtil cannot print

[jira] [Assigned] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-22659: Assignee: Rainie Li > 'execution.checkpointing.interval' missing in Flink doc >

[jira] [Commented] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344300#comment-17344300 ] Yun Tang commented on FLINK-22659: -- [~rainieli], already assigned to you, please go ahead. >

[jira] [Updated] (FLINK-22628) Fix web page display bug

[ https://issues.apache.org/jira/browse/FLINK-22628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] quyanghaoren updated FLINK-22628: - Summary: Fix web page display bug (was: Modify web page display problem) > Fix web page

[jira] [Commented] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344214#comment-17344214 ] wangqinghuan commented on FLINK-22659: -- I don't have permission to assign issue. How to deal

[jira] [Updated] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

[ https://issues.apache.org/jira/browse/FLINK-22659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangqinghuan updated FLINK-22659: - Description:  Flink deployment configuration describe how to configure checkpointing in

[GitHub] [flink] flinkbot commented on pull request #15917: [hotfix] [docs] Fix PunctuatedAssigner Scala example

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

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344233#comment-17344233 ] Mathieu Druart commented on FLINK-15440: [~ykt836] thanks for the clarification. So if I

[GitHub] [flink] dianfu commented on a change in pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

dianfu commented on a change in pull request #15877: URL: https://github.com/apache/flink/pull/15877#discussion_r631760702 ## File path: flink-python/pyflink/fn_execution/beam/beam_coders.py ## @@ -64,274 +58,39 @@ def __repr__(self): common_urns.coders.LENGTH_PREFIX.urn,

[jira] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

[ https://issues.apache.org/jira/browse/FLINK-15440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344235#comment-17344235 ] Mathieu Druart commented on FLINK-15440: [~Leonard Xu] I was just assuming that it is was a

[jira] [Commented] (FLINK-22595) RocksDBStateBackendWindowITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344245#comment-17344245 ] Guowei Ma commented on FLINK-22595: ---

[jira] [Comment Edited] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344248#comment-17344248 ] Guowei Ma edited comment on FLINK-22593 at 5/14/21, 2:35 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * Unknown: [CANCELED](TBD) * a0732d2ee2f9cc9745ea0eb739e428ea6fc34271 Azure:

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344273#comment-17344273 ] Leonard Xu commented on FLINK-22472: Yes, this may lead to your downstream tasks read empty data. 

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344277#comment-17344277 ] forideal commented on FLINK-22472: -- [~Leonard Xu] Thank you for your suggestion and look forward to

[jira] [Commented] (FLINK-22660) Incorrect flink documentation example

[ https://issues.apache.org/jira/browse/FLINK-22660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344158#comment-17344158 ] Seth Wiesman commented on FLINK-22660: -- cc [~twalthr] > Incorrect flink documentation example >

[jira] [Updated] (FLINK-22660) Incorrect flink documentation example

[ https://issues.apache.org/jira/browse/FLINK-22660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-22660: - Priority: Major (was: Critical) > Incorrect flink documentation example >

  1   2   >