[jira] [Updated] (FLINK-22511) Fix the bug of non-composite result type in Python TableAggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-22511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22511: Fix Version/s: 1.13.1 1.14.0 > Fix the bug of non-composite result type in Python Table

[jira] [Comment Edited] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344365#comment-17344365 ] Zhenhao Li edited comment on FLINK-13414 at 5/14/21, 6:51 AM:

[jira] [Comment Edited] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344365#comment-17344365 ] Zhenhao Li edited comment on FLINK-13414 at 5/14/21, 6:51 AM:

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344365#comment-17344365 ] Zhenhao Li commented on FLINK-13414: [~Davidho] Supporting Scala is hard for a proje

[GitHub] [flink] dianfu commented on a change in pull request #15780: [FLINK-22487][python] Support `print` to print logs in PyFlink

dianfu commented on a change in pull request #15780: URL: https://github.com/apache/flink/pull/15780#discussion_r632316870 ## File path: flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py ## @@ -25,5 +25,44 @@ import apache_beam.runners.worker.sdk_worker_main +

[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: * e525c3ddf9151a8d8594c0320b31bb4ebdd1b4c4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

flinkbot commented on pull request #15919: URL: https://github.com/apache/flink/pull/15919#issuecomment-841044014 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot edited a comment on pull request #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: * a0732d2ee2f9cc9745ea0eb739e428ea6fc34271 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] ghandzhipeng opened a new pull request #15919: [hotfix][docs] Fix typos in BatchTask, MutableRecordReader and Priori…

ghandzhipeng opened a new pull request #15919: URL: https://github.com/apache/flink/pull/15919 …tizedDeque ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-

[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&focusedCommentId=17344354#comment-17344354 ] Rainie Li commented on FLINK-22659: --- Thanks Yun. > 'execution.checkpointing.interval'

[jira] [Commented] (FLINK-19796) Error results when use constant decimal array

[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344351#comment-17344351 ] Jingsong Lee commented on FLINK-19796: -- Thanks [~icshuo] assigned > Error results

[jira] [Assigned] (FLINK-19796) Error results when use constant decimal array

[ https://issues.apache.org/jira/browse/FLINK-19796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19796: Assignee: Shuo Cheng > Error results when use constant decimal array > --

[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&focusedCommentId=17344348#comment-17344348 ] Shengkai Fang commented on FLINK-22655: --- OK... It seems we can't use comment aroun

[jira] [Commented] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344345#comment-17344345 ] Jingsong Lee commented on FLINK-15390: -- Thanks [~wangwei1025], assigned? Hope I fou

[jira] [Assigned] (FLINK-15390) List/Map/Struct types support for vectorized orc reader

[ https://issues.apache.org/jira/browse/FLINK-15390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15390: Assignee: Wang Wei > List/Map/Struct types support for vectorized orc reader > --

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-21700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344323#comment-17344323 ] Junfan Zhang commented on FLINK-21700: -- [~fly_in_gis] [~lirui] Could you help set s

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

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344321#comment-17344321 ] Guowei Ma commented on FLINK-20495: --- https://dev.azure.com/apache-flink/apache-flink/_

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

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

[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&focusedCommentId=17344309#comment-17344309 ] JasonLee commented on FLINK-22655: -- Hi ShengKai I tryed to add ';' after the comment li

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

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344306#comment-17344306 ] Guowei Ma commented on FLINK-20420: --- https://dev.azure.com/apache-flink/apache-flink/_

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

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

[ https://issues.apache.org/jira/browse/FLINK-22195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344305#comment-17344305 ] Guowei Ma commented on FLINK-22195: --- https://dev.azure.com/apache-flink/apache-flink/_

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

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344303#comment-17344303 ] Guowei Ma commented on FLINK-17274: --- https://dev.azure.com/apache-flink/apache-flink/_

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

[ https://issues.apache.org/jira/browse/FLINK-22447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344302#comment-17344302 ] Yun Tang commented on FLINK-22447: -- [~zlzhang0122] From the description of error messag

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

flinkbot edited a comment on pull request #15918: URL: https://github.com/apache/flink/pull/15918#issuecomment-840990852 ## CI report: * 42e95102a1b531ce13d26982fa007bc09d4c304d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17344300#comment-17344300 ] Yun Tang commented on FLINK-22659: -- [~rainieli], already assigned to you, please go ahe

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

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

[jira] [Assigned] (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 ] 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 --

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

[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&focusedCommentId=17344287#comment-17344287 ] Shengkai Fang edited comment on FLINK-22655 at 5/14/21, 3:42 AM: -

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

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

[GitHub] [flink] zjuwangg opened a new pull request #15918: [FLINK-22654][table] fix SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

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 toString()/u

[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&focusedCommentId=17344282#comment-17344282 ] Terry Wang commented on FLINK-22654: I reproduce this problem in my local environmen

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344280#comment-17344280 ] Guowei Ma commented on FLINK-22613: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17344277#comment-17344277 ] forideal commented on FLINK-22472: -- [~Leonard Xu] Thank you for your suggestion and loo

[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&focusedCommentId=17344273#comment-17344273 ] Leonard Xu commented on FLINK-22472: Yes, this may lead to your downstream tasks rea

[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&focusedCommentId=17344270#comment-17344270 ] JasonLee edited comment on FLINK-22655 at 5/14/21, 2:55 AM:

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17344270#comment-17344270 ] JasonLee edited comment on FLINK-22655 at 5/14/21, 2:54 AM:

[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&focusedCommentId=17344270#comment-17344270 ] JasonLee commented on FLINK-22655: -- Hi ShengKai,Sorry I made a mistake last night. I us

[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&focusedCommentId=17344265#comment-17344265 ] yangxiao commented on FLINK-21411: -- Is CVE-2019-12900 vulnerability triggered when we u

[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&focusedCommentId=17344263#comment-17344263 ] Shengkai Fang commented on FLINK-22639: --- +1 to support it > ClassLoaderUtil canno

[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&focusedCommentId=17344262#comment-17344262 ] forideal commented on FLINK-22472: -- [~Leonard Xu] If the success file has been submitt

[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&focusedCommentId=17344261#comment-17344261 ] Shengkai Fang edited comment on FLINK-22655 at 5/14/21, 2:44 AM: -

[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&focusedCommentId=17344261#comment-17344261 ] Shengkai Fang commented on FLINK-22655: --- Hi, [~JasonLee]. Could you offer the LOG

[jira] [Commented] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344257#comment-17344257 ] Guowei Ma commented on FLINK-22198: --- https://dev.azure.com/apache-flink/apache-flink/_

[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: * 03f0eb7244fcd3c670bf55fd3f692e370af6c864 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[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&focusedCommentId=17344248#comment-17344248 ] Guowei Ma edited comment on FLINK-22593 at 5/14/21, 2:35 AM: -

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344252#comment-17344252 ] Guowei Ma commented on FLINK-17274: --- https://dev.azure.com/apache-flink/apache-flink/_

[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&focusedCommentId=17344250#comment-17344250 ] Jark Wu commented on FLINK-22655: - Could you take a look [~fsk119]? > When using -i op

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

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

[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&focusedCommentId=17344247#comment-17344247 ] yangxiao commented on FLINK-21411: -- com.data-artisans frocksdbjni 5.17.2-artisans-2

[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&focusedCommentId=17344245#comment-17344245 ] Guowei Ma commented on FLINK-22595: --- https://dev.azure.com/apache-flink/apache-flink/_

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

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

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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&focusedCommentId=17344233#comment-17344233 ] Mathieu Druart commented on FLINK-15440: [~ykt836] thanks for the clarification.

[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&focusedCommentId=17344232#comment-17344232 ] Leonard Xu commented on FLINK-15440: Hi [~Mathieu Druart] I didn't obtain informati

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

[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 ] Jark Wu updated FLINK-22658: Component/s: Table SQL / API > Remove Deprecated util class TableConnectorUtil > -

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

[ 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

flinkbot edited a comment on pull request #15917: URL: https://github.com/apache/flink/pull/15917#issuecomment-840932660 ## CI report: * 1770eee25226317719499022a11c3b7bfc99e0af Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17344224#comment-17344224 ] Kurt Young commented on FLINK-15440: [~Mathieu Druart] IIRC this issue can be addres

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

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

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

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

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

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

[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&focusedCommentId=17344214#comment-17344214 ] wangqinghuan commented on FLINK-22659: -- I don't have permission to assign issue. Ho

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

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

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

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

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

[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&focusedCommentId=17344158#comment-17344158 ] Seth Wiesman commented on FLINK-22660: -- cc [~twalthr] > Incorrect flink documentat

[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&focusedCommentId=17344124#comment-17344124 ] Mathieu Druart commented on FLINK-15440: Hello [~Leonard Xu], you closed this is

[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 #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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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&focusedCommentId=17344078#comment-17344078 ] Lu Niu commented on FLINK-22164: [~trohrmann] This is the POC code for adding this featu

  1   2   >