[GitHub] [flink] XComp commented on a change in pull request #19116: [FLINK-26616][tests] Remove deadlines from CommonTestUtils

2022-03-28 Thread GitBox
XComp commented on a change in pull request #19116: URL: https://github.com/apache/flink/pull/19116#discussion_r837117843 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java ## @@ -445,7 +445,7 @@ public

[jira] [Commented] (FLINK-26894) Support custom validator implementations

2022-03-28 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513852#comment-17513852 ] Matyas Orhidi commented on FLINK-26894: --- I support the idea to make the validators

[jira] [Closed] (FLINK-26896) Logging - Support yaml/xml/json format in Log4j2

2022-03-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26896. -- Resolution: Duplicate This is a duplicate of https://issues.apache.org/jira/browse/FLINK-16883

[GitHub] [flink] MartijnVisser commented on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-28 Thread GitBox
MartijnVisser commented on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1081480257 @imaffe I think you need to rebase to resolve the conflict since I've just merged your other documentation PR -- This is an automated message from the Apache Git Servic

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

2022-03-28 Thread ZhuoYu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513850#comment-17513850 ] ZhuoYu Chen commented on FLINK-24351: - hi [~gaoyunhaii]  I would be happy to complet

[GitHub] [flink] flinkbot edited a comment on pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19229: URL: https://github.com/apache/flink/pull/19229#issuecomment-1077649038 ## CI report: * 0b740b03b1849daa259e6dfcca103b7490e24d3b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19255: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19255: URL: https://github.com/apache/flink/pull/19255#issuecomment-1080556417 ## CI report: * 31e41eae0a519fa55caff343bbd06912eeeb3a09 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19229: URL: https://github.com/apache/flink/pull/19229#issuecomment-1077649038 ## CI report: * 0b740b03b1849daa259e6dfcca103b7490e24d3b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19255: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19255: URL: https://github.com/apache/flink/pull/19255#issuecomment-1080556417 ## CI report: * 31e41eae0a519fa55caff343bbd06912eeeb3a09 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-26845) Document testing guidelines

2022-03-28 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513845#comment-17513845 ] Salva edited comment on FLINK-26845 at 3/29/22, 6:41 AM: - Are th

[jira] [Commented] (FLINK-26845) Document testing guidelines

2022-03-28 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513845#comment-17513845 ] Salva commented on FLINK-26845: --- Are there any short-term plans for addressing this issue

[GitHub] [flink] MartijnVisser commented on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
MartijnVisser commented on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1081461685 @imaffe Thanks, I've merged it. Will you also create the backport to the `release-1.15` branch? -- This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-26028) Write documentation for new PulsarSink

2022-03-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513844#comment-17513844 ] Martijn Visser commented on FLINK-26028: Fixed in master: eb69863412300eaf178db8

[GitHub] [flink] MartijnVisser merged pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
MartijnVisser merged pull request #19056: URL: https://github.com/apache/flink/pull/19056 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-u

[GitHub] [flink] Mulavar commented on a change in pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-28 Thread GitBox
Mulavar commented on a change in pull request #19229: URL: https://github.com/apache/flink/pull/19229#discussion_r837104729 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -383,6 +383,8 @@ Heap state backend 会额外存储一个包括用户状态以及时间戳的 Jav - 当前开启 TTL

[GitHub] [flink] MartijnVisser commented on pull request #19255: [hotfix] Fix CsvRowDataDeserializationSchema constructor

2022-03-28 Thread GitBox
MartijnVisser commented on pull request #19255: URL: https://github.com/apache/flink/pull/19255#issuecomment-1081460333 @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 sp

[jira] [Updated] (FLINK-26904) Update load(...) of all Stage subclasses to use StreamTableEnvironment

2022-03-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-26904: - Description: Currently every Stage subclass uses static `load(StreamExecutionEnvironment, String)` to l

[GitHub] [flink] MartijnVisser commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-03-28 Thread GitBox
MartijnVisser commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1081455636 @ZhangChaoming I hope that @Airblader or @slinkydeveloper can take care of the review -- This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Updated] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator

2022-03-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26903: --- Labels: pull-request-available (was: ) > Add correct NOTICE file to flink-kubernetes-operat

[jira] [Commented] (FLINK-26881) Stop with savepoint should pick up the targetDirectory from Flink configuration

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513839#comment-17513839 ] Gyula Fora commented on FLINK-26881: [~wangyang0918] I have seen this somewhere but

[jira] [Created] (FLINK-26905) Re-add FlinkDeploymentList and FlinkSessionJobList classes

2022-03-28 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26905: -- Summary: Re-add FlinkDeploymentList and FlinkSessionJobList classes Key: FLINK-26905 URL: https://issues.apache.org/jira/browse/FLINK-26905 Project: Flink Issue

[jira] [Updated] (FLINK-26881) Stop with savepoint should pick up the targetDirectory from Flink configuration

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26881: --- Fix Version/s: (was: kubernetes-operator-1.0.0) > Stop with savepoint should pick up the targetD

[jira] [Assigned] (FLINK-26904) Update load(...) of all Stage subclasses to use StreamTableEnvironment

2022-03-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-26904: Assignee: Yunfeng Zhou (was: Dong Lin) > Update load(...) of all Stage subclasses to use StreamT

[jira] [Commented] (FLINK-26894) Support custom validator implementations

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513837#comment-17513837 ] Gyula Fora commented on FLINK-26894: I agree with the SPI part that would be a good

[jira] [Commented] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513836#comment-17513836 ] Gyula Fora commented on FLINK-26903: Let me know if you need any help with checking

[jira] [Assigned] (FLINK-26904) Update load(...) of all Stage subclasses to use StreamTableEnvironment

2022-03-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-26904: Assignee: Dong Lin (was: Yunfeng Zhou) > Update load(...) of all Stage subclasses to use StreamT

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 669e3388f3088d9b6ebbf5fd027ed7da954c09dc Azure: [PENDING](https://dev.azure.com/apache-f

[jira] [Assigned] (FLINK-26904) Update load(...) of all Stage subclasses to use StreamTableEnvironment

2022-03-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-26904: Assignee: Yunfeng Zhou > Update load(...) of all Stage subclasses to use StreamTableEnvironment >

[jira] [Commented] (FLINK-26893) Validate checkpoint config with last-state upgrade mode

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513834#comment-17513834 ] Gyula Fora commented on FLINK-26893: This ticket is for the DefaultDeploymentValidat

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * 669e3388f3088d9b6ebbf5fd027ed7da954c09dc Azure: [PENDING](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-26892) Observe current status before validating CR changes

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513831#comment-17513831 ] Gyula Fora commented on FLINK-26892: The problem is that the wrong config stays ther

[GitHub] [flink] imaffe commented on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-28 Thread GitBox
imaffe commented on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1081445719 @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] [Created] (FLINK-26904) Update load(...) of all Stage subclasses to use StreamTableEnvironment

2022-03-28 Thread Dong Lin (Jira)
Dong Lin created FLINK-26904: Summary: Update load(...) of all Stage subclasses to use StreamTableEnvironment Key: FLINK-26904 URL: https://issues.apache.org/jira/browse/FLINK-26904 Project: Flink

[GitHub] [flink] imaffe commented on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
imaffe commented on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1081444830 @MartijnVisser Hi Martin, the CI has succeed ~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-26895) Improve cancelWithSavepoint timeout error message

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513829#comment-17513829 ] Gyula Fora commented on FLINK-26895: We should clearly highlight the need for manual

[jira] [Updated] (FLINK-26639) Publish flink-kubernetes-operator snapshot artifacts

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26639: --- Summary: Publish flink-kubernetes-operator snapshot artifacts (was: Publish flink-kubernetes-operat

[jira] [Updated] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26639: --- Fix Version/s: kubernetes-operator-1.0.0 (was: kubernetes-operator-0.1.0) > P

[jira] [Assigned] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26639: -- Assignee: Gyula Fora > Publish flink-kubernetes-operator maven artifacts > --

[jira] [Updated] (FLINK-26639) Publish flink-kubernetes-operator snapshot artifacts

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26639: --- Parent: (was: FLINK-25963) Issue Type: Improvement (was: Sub-task) > Publish flink-kube

[jira] [Assigned] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26639: -- Assignee: (was: Gyula Fora) > Publish flink-kubernetes-operator maven artifacts > ---

[jira] [Assigned] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

2022-03-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26639: -- Assignee: (was: Gyula Fora) > Publish flink-kubernetes-operator maven artifacts > ---

[jira] [Updated] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator

2022-03-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26903: -- Priority: Blocker (was: Critical) > Add correct NOTICE file to flink-kubernetes-operator > --

[jira] [Assigned] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator

2022-03-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26903: - Assignee: Yang Wang > Add correct NOTICE file to flink-kubernetes-operator > --

[jira] [Commented] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator

2022-03-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513825#comment-17513825 ] Yang Wang commented on FLINK-26903: --- I will work on this and attach a PR soon. > Add

[jira] [Commented] (FLINK-26897) Provide an additional way to add dependency files to k8s

2022-03-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513818#comment-17513818 ] Yang Wang commented on FLINK-26897: --- I do not think this is a concrete requirement. If

[jira] [Created] (FLINK-26903) Add correct NOTICE file to flink-kubernetes-operator

2022-03-28 Thread Yang Wang (Jira)
Yang Wang created FLINK-26903: - Summary: Add correct NOTICE file to flink-kubernetes-operator Key: FLINK-26903 URL: https://issues.apache.org/jira/browse/FLINK-26903 Project: Flink Issue Type: Bu

[jira] [Commented] (FLINK-25605) Batch get statistics of multiple partitions instead of get one by one

2022-03-28 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513804#comment-17513804 ] tartarus commented on FLINK-25605: -- [~jingzhang]  Please assign this issue to me and I'

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2022-03-28 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513799#comment-17513799 ] Aitozi commented on FLINK-18356: [~martijnvisser] Thanks for your information, I have ad

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * 376d4be60e208ccc4c07656508f168b453750f6c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26895) Improve cancelWithSavepoint timeout error message

2022-03-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513793#comment-17513793 ] Nicholas Jiang commented on FLINK-26895: Does the cancelWithSavepoint timeout er

[jira] [Comment Edited] (FLINK-26892) Observe current status before validating CR changes

2022-03-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513791#comment-17513791 ] Biao Geng edited comment on FLINK-26892 at 3/29/22, 4:10 AM: -

[jira] [Comment Edited] (FLINK-26892) Observe current status before validating CR changes

2022-03-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513791#comment-17513791 ] Biao Geng edited comment on FLINK-26892 at 3/29/22, 4:09 AM: -

[jira] [Commented] (FLINK-26892) Observe current status before validating CR changes

2022-03-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513791#comment-17513791 ] Biao Geng commented on FLINK-26892: --- In our current implementation, validation error s

[jira] [Closed] (FLINK-26634) Update Chinese version of Elasticsearch connector docs

2022-03-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26634. --- Fix Version/s: 1.15.0 1.16.0 Resolution: Resolved > Update Chinese version of Elas

[jira] [Commented] (FLINK-26634) Update Chinese version of Elasticsearch connector docs

2022-03-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513788#comment-17513788 ] Yun Gao commented on FLINK-26634: - Merged on master via 498afbdab38aea70be25a15f4e0103c5

[GitHub] [flink] gaoyunhaii closed pull request #19101: [FLINK-26634][docs-zh] Update Chinese version of Elasticsearch connector docs

2022-03-28 Thread GitBox
gaoyunhaii closed pull request #19101: URL: https://github.com/apache/flink/pull/19101 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #19259: [FLINK-23890] impove cep operator timer register policy

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19259: URL: https://github.com/apache/flink/pull/19259#issuecomment-1080640748 ## CI report: * b512cff4e231b845fc60f2cbf1e337ab8eeaba8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19259: [FLINK-23890] impove cep operator timer register policy

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19259: URL: https://github.com/apache/flink/pull/19259#issuecomment-1080640748 ## CI report: * b512cff4e231b845fc60f2cbf1e337ab8eeaba8c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

2022-03-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513785#comment-17513785 ] Yun Gao commented on FLINK-24351: - Hi [~monster#12], I have a double check of this part,

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

2022-03-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513784#comment-17513784 ] Yun Gao commented on FLINK-24351: - Merged the PR of translating data/sql_functions_zh.ym

[jira] [Assigned] (FLINK-26743) [umbrella] Build Document for Table Store

2022-03-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26743: Assignee: Jingsong Lee > [umbrella] Build Document for Table Store >

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 53861a48a63041cdb9ea4fe411d58a4489a51be9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26902) Introduce benchmark document for table store

2022-03-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26902: Summary: Introduce benchmark document for table store Key: FLINK-26902 URL: https://issues.apache.org/jira/browse/FLINK-26902 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-26900) Introduce Best Practices document for table store

2022-03-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26900: - Description: # Eventual Mode # Transaction Mode ChanglogAll # Without Log System # ... was

[jira] [Updated] (FLINK-26900) Introduce Best Practices document for table store

2022-03-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26900: - Description: # Eventual Mode # Transaction Mode ChanglogAll # Without Log System # ... >

[GitHub] [flink] gaoyunhaii closed pull request #17789: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2022-03-28 Thread GitBox
gaoyunhaii closed pull request #17789: URL: https://github.com/apache/flink/pull/17789 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[jira] [Created] (FLINK-26901) Introduce config options document for table store

2022-03-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26901: Summary: Introduce config options document for table store Key: FLINK-26901 URL: https://issues.apache.org/jira/browse/FLINK-26901 Project: Flink Issue Type:

[jira] [Created] (FLINK-26900) Introduce Best Practices document for table store

2022-03-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26900: Summary: Introduce Best Practices document for table store Key: FLINK-26900 URL: https://issues.apache.org/jira/browse/FLINK-26900 Project: Flink Issue Type:

[jira] [Created] (FLINK-26899) Introduce query table document for table store

2022-03-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26899: Summary: Introduce query table document for table store Key: FLINK-26899 URL: https://issues.apache.org/jira/browse/FLINK-26899 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-26898) Introduce creating table document for table store

2022-03-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26898: Summary: Introduce creating table document for table store Key: FLINK-26898 URL: https://issues.apache.org/jira/browse/FLINK-26898 Project: Flink Issue Type:

[GitHub] [flink] Myasuka commented on a change in pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-28 Thread GitBox
Myasuka commented on a change in pull request #19229: URL: https://github.com/apache/flink/pull/19229#discussion_r837024698 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -383,6 +383,8 @@ Heap state backend 会额外存储一个包括用户状态以及时间戳的 Jav - 当前开启 TTL

[jira] [Updated] (FLINK-26771) Hive dialect supports to compare boolean type with numeric type

2022-03-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26771: - Parent: FLINK-26360 Issue Type: Sub-task (was: Improvement) > Hive dialect supports to compare

[GitHub] [flink] gaoyunhaii closed pull request #19144: [hotfix][release] Update the compatibility table for the release 1.14 and 1.15

2022-03-28 Thread GitBox
gaoyunhaii closed pull request #19144: URL: https://github.com/apache/flink/pull/19144 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsu

[jira] [Commented] (FLINK-26893) Validate checkpoint config with last-state upgrade mode

2022-03-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513781#comment-17513781 ] Nicholas Jiang commented on FLINK-26893: Does the validation if checkpointing is

[jira] [Commented] (FLINK-26894) Support custom validator implementations

2022-03-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513780#comment-17513780 ] Nicholas Jiang commented on FLINK-26894: About specifying custom validator imple

[jira] [Assigned] (FLINK-26896) Logging - Support yaml/xml/json format in Log4j2

2022-03-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-26896: Assignee: Moses > Logging - Support yaml/xml/json format in Log4j2 >

[jira] [Created] (FLINK-26897) Provide an additional way to add dependency files to k8s

2022-03-28 Thread liuzhuo (Jira)
liuzhuo created FLINK-26897: --- Summary: Provide an additional way to add dependency files to k8s Key: FLINK-26897 URL: https://issues.apache.org/jira/browse/FLINK-26897 Project: Flink Issue Type: Ne

[jira] [Commented] (FLINK-26878) get previous window values in udf

2022-03-28 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513777#comment-17513777 ] Moses commented on FLINK-26878: --- [~karthik_jagadeeswaran] You may try to use another windo

[jira] [Updated] (FLINK-26313) Add Transformer and Estimator of OnlineKMeans

2022-03-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-26313: - Summary: Add Transformer and Estimator of OnlineKMeans (was: Support Online KMeans in Flink ML) > Add

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #73: [FLINK-26626] Add Transformer and Estimator for StandardScaler

2022-03-28 Thread GitBox
yunfengzhou-hub commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r836355995 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScaler.java ## @@ -0,0 +1,295 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-26896) Logging - Support yaml/xml/json format in Log4j2

2022-03-28 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513773#comment-17513773 ] Moses commented on FLINK-26896: --- I think it's a nice improvement and I'd like to take this

[GitHub] [flink-ml] lindong28 merged pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-28 Thread GitBox
lindong28 merged pull request #70: URL: https://github.com/apache/flink-ml/pull/70 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-28 Thread GitBox
zhipeng93 edited a comment on pull request #70: URL: https://github.com/apache/flink-ml/pull/70#issuecomment-1081346919 @lindong28 Thanks for the review. This PR LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink-ml] zhipeng93 commented on pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-28 Thread GitBox
zhipeng93 commented on pull request #70: URL: https://github.com/apache/flink-ml/pull/70#issuecomment-1081346919 @lindong28 Thanks for the review. This PR looks good to me~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Comment Edited] (FLINK-26835) WordCountSubclassPOJOITCase failed on azure

2022-03-28 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513110#comment-17513110 ] Moses edited comment on FLINK-26835 at 3/29/22, 2:38 AM: - [~twal

[GitHub] [flink] ZhangChaoming commented on pull request #19219: [FLINK-26835][serialization] Fix concurrent modification exception

2022-03-28 Thread GitBox
ZhangChaoming commented on pull request #19219: URL: https://github.com/apache/flink/pull/19219#issuecomment-1081339761 @pnowojski Could you please help to check this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Created] (FLINK-26896) Logging - Support yaml/xml/json format in Log4j2

2022-03-28 Thread Koala Lam (Jira)
Koala Lam created FLINK-26896: - Summary: Logging - Support yaml/xml/json format in Log4j2 Key: FLINK-26896 URL: https://issues.apache.org/jira/browse/FLINK-26896 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-26881) Stop with savepoint should pick up the targetDirectory from Flink configuration

2022-03-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513771#comment-17513771 ] Yang Wang commented on FLINK-26881: --- An unrelated question about the fix versions. Sho

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * 19e1dacb381fc9719b4d7a97b2d1bedb2f1c0592 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-26879) LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

2022-03-28 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26879: -- Description: We should avoid creating a hybrid source when the latest/from_timestamp mode is enabled,

[jira] [Updated] (FLINK-26879) LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

2022-03-28 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26879: -- Description: We should avoid creating a hybrid source when the latest/from_timestamp mode is enabled,

[jira] [Updated] (FLINK-26879) LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work

2022-03-28 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26879: -- Summary: LogStartupMode.LATEST and LogStartupMode.FROM_TIMESTAMP don't work (was: LogStartupMode.LATE

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * 19e1dacb381fc9719b4d7a97b2d1bedb2f1c0592 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 53861a48a63041cdb9ea4fe411d58a4489a51be9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-26880) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure

2022-03-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513769#comment-17513769 ] Dian Fu edited comment on FLINK-26880 at 3/29/22, 2:30 AM: --- >F

[jira] [Closed] (FLINK-26880) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure

2022-03-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26880. --- Resolution: Duplicate I think it should be the same issue as FLINK-24241. I'm closing this as duplicate. >

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * 19e1dacb381fc9719b4d7a97b2d1bedb2f1c0592 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-28 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 53861a48a63041cdb9ea4fe411d58a4489a51be9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] syhily commented on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

2022-03-28 Thread GitBox
syhily commented on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1081332292 @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

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-28 Thread GitBox
ZhangChaoming commented on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1081331636 @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 sp

  1   2   3   4   5   >