[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g

2022-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497319#comment-17497319 ] Jark Wu commented on FLINK-26204: - [~jingzhang] do you want to have a look this problem? > set

[jira] [Commented] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

2022-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497317#comment-17497317 ] Jark Wu commented on FLINK-26348: - +1 for this. The project push down should also be able to pass

[jira] [Updated] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

2022-02-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26348: Component/s: Table SQL / Planner > Maybe ChangelogNormalize should ignore unused columns when deduplicate

[jira] [Created] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

2022-02-24 Thread Kenyore (Jira)
Kenyore created FLINK-26348: --- Summary: Maybe ChangelogNormalize should ignore unused columns when deduplicate Key: FLINK-26348 URL: https://issues.apache.org/jira/browse/FLINK-26348 Project: Flink

[jira] [Updated] (FLINK-26347) Should use Flink system Classloader (AppClassloader) when deserializing RPC message

2022-02-24 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-26347: Description: FLINK-25742 removed the redundant serialization of RPC invocation at Flink side.

[jira] [Updated] (FLINK-26141) Support last-state upgrade mode

2022-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26141: --- Labels: pull-request-available (was: ) > Support last-state upgrade mode >

[jira] [Commented] (FLINK-26347) Should use Flink system Classloader (AppClassloader) when deserializing RPC message

2022-02-24 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497288#comment-17497288 ] Yingjie Cao commented on FLINK-26347: - cc [~guoyangze] . > Should use Flink system Classloader

[jira] [Created] (FLINK-26347) Should use Flink system Classloader (AppClassloader) when deserializing RPC message

2022-02-24 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-26347: --- Summary: Should use Flink system Classloader (AppClassloader) when deserializing RPC message Key: FLINK-26347 URL: https://issues.apache.org/jira/browse/FLINK-26347

[jira] [Commented] (FLINK-26331) Make max retries configurable

2022-02-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497286#comment-17497286 ] Matthias Pohl commented on FLINK-26331: --- Looking through different configuration parameters

[jira] [Updated] (FLINK-26331) Make max retries configurable

2022-02-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26331: -- Description: Right now, the retry mechanism is hard-coded to {{Integer.MAX_VALUE}}. We want

[jira] [Resolved] (FLINK-26267) Add common params interface in ML Python API

2022-02-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-26267. -- Resolution: Done Merged into master via d14e1f481ec3e8b154a46a003e3a4fd59614f34a > Add

[jira] [Updated] (FLINK-26267) Add common params interface in ML Python API

2022-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26267: --- Labels: pull-request-available (was: ) > Add common params interface in ML Python API >

[GitHub] [flink-ml] HuangXingBo closed pull request #65: [FLINK-26267][ml][python] Add common params interface in ML Python API

2022-02-24 Thread GitBox
HuangXingBo closed pull request #65: URL: https://github.com/apache/flink-ml/pull/65 -- 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:

[jira] [Updated] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26160: Fix Version/s: 1.15.0 > Pulsar Connector: stopCursor description should be changed. Connector

[jira] [Updated] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26160: Component/s: Documentation > Pulsar Connector: stopCursor description should be changed.

[jira] [Updated] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26160: Affects Version/s: 1.15.0 > Pulsar Connector: stopCursor description should be changed. Connector

[jira] [Updated] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26160: Affects Version/s: 1.14.3 > Pulsar Connector: stopCursor description should be changed. Connector

[jira] [Commented] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

2022-02-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497277#comment-17497277 ] Fabian Paul commented on FLINK-26160: - Merged in master: 6080c7885d02c11b7aef8f24a26f1c794b6953d7 >

[jira] [Assigned] (FLINK-26331) Make max retries configurable

2022-02-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-26331: - Assignee: Matthias Pohl > Make max retries configurable >

[GitHub] [flink] fapaul merged pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

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

[GitHub] [flink] fapaul commented on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-24 Thread GitBox
fapaul commented on pull request #18780: URL: https://github.com/apache/flink/pull/18780#issuecomment-1049651600 @imaffe can you also backport this change to release-1.14? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-24626) Flink JDBC Sink may lose data in left join

2022-02-24 Thread Kenyore (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenyore closed FLINK-24626. --- Resolution: Abandoned > Flink JDBC Sink may lose data in left join >

[jira] [Created] (FLINK-26346) Add statistics collecting to sst files

2022-02-24 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-26346: --- Summary: Add statistics collecting to sst files Key: FLINK-26346 URL: https://issues.apache.org/jira/browse/FLINK-26346 Project: Flink Issue Type: Sub-task

[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-02-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 6a86accf9fa9592f21ceb1432eaf206526ab3097 Azure:

[jira] [Comment Edited] (FLINK-26301) Test AvroParquet format

2022-02-24 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497019#comment-17497019 ] Jing Ge edited comment on FLINK-26301 at 2/24/22, 9:16 AM: --- 1. you are

[GitHub] [flink] fapaul commented on pull request #18781: [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question

2022-02-24 Thread GitBox
fapaul commented on pull request #18781: URL: https://github.com/apache/flink/pull/18781#issuecomment-1049640517 @imaffe Can you also backport this to the `release-1.14` branch? AFAIK the PulsarSource was already part of 1.14 -- This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-26159) Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption

2022-02-24 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497271#comment-17497271 ] Fabian Paul commented on FLINK-26159: - Merged in master: 52df489063ae90af73c663dc6abbe42e3794f1ac >

[GitHub] [flink] JingGe commented on pull request #18896: [FLINK-26186][test] update the API_ANNOTATIONS rule

2022-02-24 Thread GitBox
JingGe commented on pull request #18896: URL: https://github.com/apache/flink/pull/18896#issuecomment-1049638365 @Airblader Would you like to review this PR? Many thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] fapaul merged pull request #18781: [FLINK-26159][doc] add description for MAX_FETCH_RECORD related question

2022-02-24 Thread GitBox
fapaul merged pull request #18781: URL: https://github.com/apache/flink/pull/18781 -- 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:

[jira] [Commented] (FLINK-26336) Deletion should remove HA related configmaps also

2022-02-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497266#comment-17497266 ] Yang Wang commented on FLINK-26336: --- I think I get your point. If we update the state in the

[GitHub] [flink] flinkbot edited a comment on pull request #18904: [hotfix]fix method name typos

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18904: URL: https://github.com/apache/flink/pull/18904#issuecomment-1049624714 ## CI report: * 4d8363bb79758f96b2c88b3df15454873472a8ab Azure:

[GitHub] [flink] flinkbot commented on pull request #18904: [hotfix]fix method name typos

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

[GitHub] [flink] flinkbot commented on pull request #18904: [hotfix]fix method name typos

2022-02-24 Thread GitBox
flinkbot commented on pull request #18904: URL: https://github.com/apache/flink/pull/18904#issuecomment-1049624714 ## CI report: * 4d8363bb79758f96b2c88b3df15454873472a8ab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] Tartarus0zm commented on pull request #18904: [hotfix]fix method name typos

2022-02-24 Thread GitBox
Tartarus0zm commented on pull request #18904: URL: https://github.com/apache/flink/pull/18904#issuecomment-1049622831 @beyond1920 @wuchong please take a look, if you have time, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] Tartarus0zm opened a new pull request #18904: [hotfix]fix method name typos

2022-02-24 Thread GitBox
Tartarus0zm opened a new pull request #18904: URL: https://github.com/apache/flink/pull/18904 ## What is the purpose of the change fix method name typos ## Brief change log tesInvalidCastBetweenNumericAndTimestampLtz -> testInvalidCastBetweenNumericAndTimestampLtz

[jira] [Updated] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is gre

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-26204: - Attachment: output-of-window-tvf-test.png > set table.optimizer.distinct-agg.split.enabled to true and

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

2022-02-24 Thread GitBox
fapaul commented on a change in pull request #18345: URL: https://github.com/apache/flink/pull/18345#discussion_r813658020 ## File path:

[jira] [Comment Edited] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257 ] Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:43 AM: I've reproduced

[jira] [Comment Edited] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257 ] Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:41 AM: I've reproduced

[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257 ] Paul Lin commented on FLINK-26204: -- I've reproduced the problem with minimum external dependencies.

[jira] [Updated] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is gre

2022-02-24 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-26204: - Attachment: WindowTvfTest.java > set table.optimizer.distinct-agg.split.enabled to true and using

[jira] [Commented] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

2022-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497256#comment-17497256 ] Till Rohrmann commented on FLINK-26086: --- Thanks for fixing this issue [~nyingping]. > fixed some

[jira] [Assigned] (FLINK-26086) fixed some causing ambiguities including the 'shit' comment

2022-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26086: - Assignee: nyingping > fixed some causing ambiguities including the 'shit' comment >

[jira] [Assigned] (FLINK-26267) Add common params interface in ML Python API

2022-02-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-26267: Assignee: Huang Xingbo > Add common params interface in ML Python API >

[jira] [Closed] (FLINK-26266) Support Vector and Matrix

2022-02-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-26266. Resolution: Fixed Merged into master via 10cae7b7a656f68dc4ea9f5bdc32441c141e0bbf > Support

[jira] [Assigned] (FLINK-26266) Support Vector and Matrix

2022-02-24 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-26266: Assignee: Huang Xingbo > Support Vector and Matrix > - > >

[GitHub] [flink] flinkbot edited a comment on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18780: URL: https://github.com/apache/flink/pull/18780#issuecomment-1040253405 ## CI report: * ab7fd6e2e3ddf8597a88ed7bac2f1ce2a0af4f0c Azure:

[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-02-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 6a86accf9fa9592f21ceb1432eaf206526ab3097 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18780: URL: https://github.com/apache/flink/pull/18780#issuecomment-1040253405 ## CI report: * ab7fd6e2e3ddf8597a88ed7bac2f1ce2a0af4f0c Azure:

[GitHub] [flink-ml] HuangXingBo closed pull request #64: [FLINK-26266][ml][python] Support Vector and Matrix in ML Python API

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

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

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 6a86accf9fa9592f21ceb1432eaf206526ab3097 Azure:

[GitHub] [flink] imaffe commented on pull request #18780: [FLINK-26160][pulsar][doc] update the doc of setUnboundedStopCursor()

2022-02-24 Thread GitBox
imaffe commented on pull request #18780: URL: https://github.com/apache/flink/pull/18780#issuecomment-1049607143 @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] imaffe commented on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-02-24 Thread GitBox
imaffe commented on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1049607236 @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] [Assigned] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

2022-02-24 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-26340: - Assignee: Galen Warren > Add ability in Golang SDK to create new statefun.Context from

[GitHub] [flink] fapaul commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-24 Thread GitBox
fapaul commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r813634648 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -313,7 +329,14

[jira] [Updated] (FLINK-26266) Support Vector and Matrix

2022-02-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26266: --- Labels: pull-request-available (was: ) > Support Vector and Matrix >

[GitHub] [flink-ml] dianfu commented on a change in pull request #64: [FLINK-26266][ml][python] Support Vector and Matrix in ML Python API

2022-02-24 Thread GitBox
dianfu commented on a change in pull request #64: URL: https://github.com/apache/flink-ml/pull/64#discussion_r813634159 ## File path: flink-ml-python/pyflink/ml/core/linalg.py ## @@ -0,0 +1,544 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18607: [FLINK-24345] [docs] Translate "File Systems" page of "Internals" int…

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18607: URL: https://github.com/apache/flink/pull/18607#issuecomment-1027976960 ## CI report: * b19db486c3ddb25117a3aadda79002708db46d00 Azure:

[jira] [Assigned] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

2022-02-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26178: -- Assignee: Biao Geng > Use the same enum for expected and observed jobstate (JobState / >

[jira] [Commented] (FLINK-26327) throw not a literal exception in callContext.getArgumentValue when getTypeInference

2022-02-24 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497243#comment-17497243 ] Spongebob commented on FLINK-26327: --- {code:java} //代码占位符 Exception in thread "main"

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-24 Thread GitBox
flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 6d23d5651638281b39766cf214cbbb2b111a4da7 Azure:

<    1   2   3   4   5   6