[jira] [Updated] (FLINK-22329) Missing credentials in jobconf causes repeated authentication in Hive datasource

2021-05-13 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22329: - Summary: Missing credentials in jobconf causes repeated authentication in Hive datasource

[jira] [Commented] (FLINK-21700) Allow to disable fetching Hadoop delegation token on Yarn

2021-05-13 Thread Junfan Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344323#comment-17344323 ] Junfan Zhang commented on FLINK-21700: -- [~fly_in_gis] [~lirui] Could you help set status to

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344321#comment-17344321 ] Guowei Ma commented on FLINK-20495: ---

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

2021-05-13 Thread GitBox
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:

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

2021-05-13 Thread GitBox
yittg commented on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-841007163 @flinkbot run azure -- 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

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

2021-05-13 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344309#comment-17344309 ] JasonLee commented on FLINK-22655: -- Hi ShengKai I tryed to add ';' after the comment like this –- set

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344306#comment-17344306 ] Guowei Ma commented on FLINK-20420: ---

[jira] [Created] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

2021-05-13 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22662: - Summary: YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail Key: FLINK-22662 URL: https://issues.apache.org/jira/browse/FLINK-22662 Project: Flink

[jira] [Commented] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344305#comment-17344305 ] Guowei Ma commented on FLINK-22195: ---

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344303#comment-17344303 ] Guowei Ma commented on FLINK-17274: ---

[jira] [Commented] (FLINK-22447) when job failed and restore from rocksdb, it produced a exception "Could not load the native RocksDB library"

2021-05-13 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344302#comment-17344302 ] Yun Tang commented on FLINK-22447: -- [~zlzhang0122] From the description of error message, it seems

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

2021-05-13 Thread GitBox
flinkbot edited a comment on pull request #15918: URL: https://github.com/apache/flink/pull/15918#issuecomment-840990852 ## CI report: * 42e95102a1b531ce13d26982fa007bc09d4c304d Azure:

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

2021-05-13 Thread Yun Tang (Jira)
[ 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

2021-05-13 Thread Yun Tang (Jira)
[ 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. >

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

2021-05-13 Thread GitBox
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 #15918: [FLINK-22654][table] fix SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

2021-05-13 Thread GitBox
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

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

2021-05-13 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22654: -- Assignee: Terry Wang > SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

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

2021-05-13 Thread Shengkai Fang (Jira)
[ 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] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ 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

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

2021-05-13 Thread GitBox
flinkbot commented on pull request #15918: URL: https://github.com/apache/flink/pull/15918#issuecomment-840982776 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-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

2021-05-13 Thread ASF GitHub Bot (Jira)
[ 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] zjuwangg opened a new pull request #15918: [FLINK-22654][table] fix SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

2021-05-13 Thread GitBox
zjuwangg opened a new pull request #15918: URL: https://github.com/apache/flink/pull/15918 ## What is the purpose of the change * Fix SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks * ## Brief change log - * 42e9510 fix SqlCreateTable

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

2021-05-13 Thread Terry Wang (Jira)
[ 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-22661) HiveInputFormatPartitionReader can return invalid data

2021-05-13 Thread Rui Li (Jira)
[ 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] [Created] (FLINK-22661) HiveInputFormatPartitionReader can return invalid data

2021-05-13 Thread Rui Li (Jira)
Rui Li created FLINK-22661: -- Summary: HiveInputFormatPartitionReader can return invalid data Key: FLINK-22661 URL: https://issues.apache.org/jira/browse/FLINK-22661 Project: Flink Issue Type: Bug

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

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344280#comment-17344280 ] Guowei Ma commented on FLINK-22613: ---

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

2021-05-13 Thread forideal (Jira)
[ 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-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-13 Thread Leonard Xu (Jira)
[ 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] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread JasonLee (Jira)
[ 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

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

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

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

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

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

2021-05-13 Thread JasonLee (Jira)
[ 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:54 AM: Hi

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

2021-05-13 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344270#comment-17344270 ] JasonLee commented on FLINK-22655: -- Hi ShengKai,Sorry I made a mistake last night. I used -- not - 

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

2021-05-13 Thread yangxiao (Jira)
[ 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

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

2021-05-13 Thread Shengkai Fang (Jira)
[ 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] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-13 Thread forideal (Jira)
[ 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] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ 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] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ 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-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344257#comment-17344257 ] Guowei Ma commented on FLINK-22198: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

2021-05-13 Thread GitBox
flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * 03f0eb7244fcd3c670bf55fd3f692e370af6c864 Azure:

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

2021-05-13 Thread GitBox
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] [Comment Edited] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

2021-05-13 Thread Guowei Ma (Jira)
[ 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: -

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

2021-05-13 Thread Guowei Ma (Jira)
[ 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] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2021-05-13 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344252#comment-17344252 ] Guowei Ma commented on FLINK-17274: ---

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

2021-05-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344250#comment-17344250 ] Jark Wu commented on FLINK-22655: - Could you take a look [~fsk119]? > When using -i option to

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

2021-05-13 Thread Guowei Ma (Jira)
[ 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.

2021-05-13 Thread yangxiao (Jira)
[ 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

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

2021-05-13 Thread Guowei Ma (Jira)
[ 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-15440) Enable savepoint support for Table & SQL program

2021-05-13 Thread Mathieu Druart (Jira)
[ 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

2021-05-13 Thread Mathieu Druart (Jira)
[ 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-15440) Enable savepoint support for Table & SQL program

2021-05-13 Thread Mathieu Druart (Jira)
[ 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

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

2021-05-13 Thread GitBox
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,

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

2021-05-13 Thread GitBox
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 edited a comment on pull request #15812: remove slotpoolImpl

2021-05-13 Thread GitBox
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 #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-05-13 Thread GitBox
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] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

2021-05-13 Thread Mathieu Druart (Jira)
[ 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

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

2021-05-13 Thread Leonard Xu (Jira)
[ 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 

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

2021-05-13 Thread GitBox
yittg commented on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-840951206 @flinkbot run azure -- 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

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

2021-05-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22658: Component/s: Table SQL / API > Remove Deprecated util class TableConnectorUtil >

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

2021-05-13 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22658: --- Assignee: Xianghu Wang > Remove Deprecated util class TableConnectorUtil >

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

2021-05-13 Thread GitBox
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

2021-05-13 Thread Kurt Young (Jira)
[ 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] [Closed] (FLINK-15064) Remove XmlOutput util class in blink planner

2021-05-13 Thread godfrey he (Jira)
[ 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] godfreyhe merged pull request #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

2021-05-13 Thread GitBox
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] yittg commented on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-05-13 Thread GitBox
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,

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

2021-05-13 Thread wangqinghuan (Jira)
[ 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

2021-05-13 Thread wangqinghuan (Jira)
[ 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

2021-05-13 Thread GitBox
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-22659) 'execution.checkpointing.interval' missing in Flink doc

2021-05-13 Thread wangqinghuan (Jira)
[ 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

2021-05-13 Thread wangqinghuan (Jira)
[ 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

2021-05-13 Thread GitBox
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

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

2021-05-13 Thread GitBox
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

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

2021-05-13 Thread quyanghaoren (Jira)
[ 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] [Updated] (FLINK-22660) Incorrect flink documentation example

2021-05-13 Thread Seth Wiesman (Jira)
[ 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 >

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

2021-05-13 Thread Seth Wiesman (Jira)
[ 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] [Commented] (FLINK-15440) Enable savepoint support for Table & SQL program

2021-05-13 Thread Mathieu Druart (Jira)
[ 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

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

2021-05-13 Thread Tejas Budukh (Jira)
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 #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-13 Thread GitBox
flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * a41211d988c460b411ec7c5bca8dec0a4305bb87 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

2021-05-13 Thread GitBox
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 #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

2021-05-13 Thread GitBox
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 commented on pull request #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

2021-05-13 Thread GitBox
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

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

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

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

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

2021-05-13 Thread GitBox
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] [Commented] (FLINK-22164) Add jobId and JobName variable to JobManager metrics in per-job deployment mode

2021-05-13 Thread Lu Niu (Jira)
[ 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] qqibrow opened a new pull request #15916: [WIP] PoC add jobName and jobId tag in jobMananger process metric

2021-05-13 Thread GitBox
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] [Commented] (FLINK-22659) 'execution.checkpointing.interval' missing in Flink doc

2021-05-13 Thread Rainie Li (Jira)
[ 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

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

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

2021-05-13 Thread wangqinghuan (Jira)
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

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

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

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

2021-05-13 Thread GitBox
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 #15911: [FLINK-15064][table-planner-blink] Remove XmlOutput util class in blink planner since Calcite has fixed the issue

2021-05-13 Thread GitBox
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

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

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

2021-05-13 Thread JasonLee (Jira)
[ 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 

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

2021-05-13 Thread GitBox
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 =

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

2021-05-13 Thread Robert Metzger (Jira)
[ 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

2021-05-13 Thread Robert Metzger (Jira)
[ 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 pull request #15121: The method $(String) is undefined for the type TableExample

2021-05-13 Thread GitBox
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

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

2021-05-13 Thread GitBox
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] dannycranmer commented on a change in pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-13 Thread GitBox
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

  1   2   >