[GitHub] [flink] xuyangzhong commented on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

xuyangzhong commented on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-954451733 @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

[jira] [Updated] (FLINK-24689) Add log file's time info in loglist

[ https://issues.apache.org/jira/browse/FLINK-24689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fei Feng updated FLINK-24689: - Description: Flink web UI support show all log file info in log dir, but loglist view only has file

[jira] [Created] (FLINK-24689) Add log file's time info in loglist

Fei Feng created FLINK-24689: Summary: Add log file's time info in loglist Key: FLINK-24689 URL: https://issues.apache.org/jira/browse/FLINK-24689 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-tbd][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 9aa8115b9b3fa8cc853f7821c29f939870c79e5d Azure:

[jira] [Commented] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

[ https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435769#comment-17435769 ] Aitozi commented on FLINK-24633: Yes, it's caused by the k8s can't not start pod eventually, this will

[jira] [Commented] (FLINK-24624) Add clean up phase when kubernetes session start failed

[ https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435768#comment-17435768 ] Aitozi commented on FLINK-24624: Thanks in advance [~wangyang0918] :) > Add clean up phase when

[jira] [Issue Comment Deleted] (FLINK-24574) Allow metrics to be removed in UDFs

[ https://issues.apache.org/jira/browse/FLINK-24574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-24574: --- Comment: was deleted (was: This would enable operators to properly clean up metrics. Here is an

[jira] [Commented] (FLINK-24574) Allow metrics to be removed in UDFs

[ https://issues.apache.org/jira/browse/FLINK-24574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435764#comment-17435764 ] Mason Chen commented on FLINK-24574: This would enable operators to properly clean up metrics. Here

[GitHub] [flink-ml] guoweiM commented on a change in pull request #13: [FLINK-7][iteration] Add bounded all-round iteration

guoweiM commented on a change in pull request #13: URL: https://github.com/apache/flink-ml/pull/13#discussion_r738912810 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/BoundedAllRoundStreamIterationITCase.java ## @@ -0,0 +1,229 @@ +/* + *

[GitHub] [flink-ml] guoweiM commented on a change in pull request #13: [FLINK-7][iteration] Add bounded all-round iteration

guoweiM commented on a change in pull request #13: URL: https://github.com/apache/flink-ml/pull/13#discussion_r738912753 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/BoundedAllRoundStreamIterationITCase.java ## @@ -0,0 +1,229 @@ +/* + *

[GitHub] [flink-ml] guoweiM commented on a change in pull request #13: [FLINK-7][iteration] Add bounded all-round iteration

guoweiM commented on a change in pull request #13: URL: https://github.com/apache/flink-ml/pull/13#discussion_r738912568 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/BoundedAllRoundStreamIterationITCase.java ## @@ -0,0 +1,229 @@ +/* + *

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738911586 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/operators/SequenceSource.java ## @@ -0,0 +1,60 @@ +/* + * Licensed to the

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738910248 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/UnboundedStreamIterationITCase.java ## @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738910762 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/UnboundedStreamIterationITCase.java ## @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738910304 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/UnboundedStreamIterationITCase.java ## @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738910248 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/UnboundedStreamIterationITCase.java ## @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738909961 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/UnboundedStreamIterationITCase.java ## @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738909854 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/itcases/UnboundedStreamIterationITCase.java ## @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738909199 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationFactory.java ## @@ -0,0 +1,248 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738908621 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationFactory.java ## @@ -0,0 +1,248 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] guoweiM commented on a change in pull request #12: [FLINK-6][iteration] add unbounded iteration.

guoweiM commented on a change in pull request #12: URL: https://github.com/apache/flink-ml/pull/12#discussion_r738908528 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationFactory.java ## @@ -0,0 +1,248 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-23919) PullUpWindowTableFunctionIntoWindowAggregateRule generates invalid Calc for Window TVF

[ https://issues.apache.org/jira/browse/FLINK-23919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435750#comment-17435750 ] JING ZHANG commented on FLINK-23919: [~Yuval.Itzchakov] I'm very sorry for late response. I would

[jira] [Resolved] (FLINK-24678) Correct the metric name of map state contains latency

[ https://issues.apache.org/jira/browse/FLINK-24678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24678. -- Resolution: Fixed Merged master: b1a409ef1c53a24d717c789eea8c09ddbc94f7f1 release-1.14:

[GitHub] [flink] Myasuka merged pull request #17587: [FLINK-24678][runtime/metrics] Correct the metric name of map state contains latency

Myasuka merged pull request #17587: URL: https://github.com/apache/flink/pull/17587 -- 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 #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

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

[GitHub] [flink] iyupeng commented on a change in pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

iyupeng commented on a change in pull request #17344: URL: https://github.com/apache/flink/pull/17344#discussion_r738899089 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala ## @@ -1002,6 +1001,12 @@ abstract

[GitHub] [flink] flinkbot edited a comment on pull request #17599: [FLINK-24688][yarn] update yarn.application-attempt-failures-validity-interval with a available link

flinkbot edited a comment on pull request #17599: URL: https://github.com/apache/flink/pull/17599#issuecomment-954365768 ## CI report: * c5f876bd22315ada410fa8168426e166ebf764bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

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

[GitHub] [flink] flinkbot commented on pull request #17599: [FLINK-24688][yarn] update yarn.application-attempt-failures-validity-interval with a available link

flinkbot commented on pull request #17599: URL: https://github.com/apache/flink/pull/17599#issuecomment-954366398 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 #17599: [FLINK-24688][yarn] update yarn.application-attempt-failures-validity-interval with a available link

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

[jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

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

[GitHub] [flink] ZhendongBai opened a new pull request #17599: [FLINK-24688][yarn] update yarn.application-attempt-failures-validity-interval with a available link

ZhendongBai opened a new pull request #17599: URL: https://github.com/apache/flink/pull/17599 update yarn.application-attempt-failures-validity-interval with a available link ## What is the purpose of the change The

[GitHub] [flink-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738895485 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java ## @@ -0,0 +1,228 @@ +/* + * Licensed to

[GitHub] [flink-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738894860 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java ## @@ -0,0 +1,228 @@ +/* + * Licensed to

[GitHub] [flink-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738894469 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftExecutionEnvironment.java ## @@ -0,0 +1,228 @@ +/* + * Licensed to

[jira] [Closed] (FLINK-15987) SELECT 1.0e0 / 0.0e0 throws NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-15987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-15987. -- Resolution: Fixed Fixed in 1.15.0: 8c603d8d07984ec136fe5b1778ccb39b039c5d75 Fixed in 1.14.1:

[GitHub] [flink] iyupeng commented on a change in pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

iyupeng commented on a change in pull request #17344: URL: https://github.com/apache/flink/pull/17344#discussion_r738893985 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala ## @@ -1002,6 +1001,12 @@ abstract

[jira] [Updated] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-23614: --- Fix Version/s: 1.14.1 > The resulting scale of TRUNCATE(DECIMAL, ...) is not correct >

[jira] [Commented] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

[ https://issues.apache.org/jira/browse/FLINK-23614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435744#comment-17435744 ] godfrey he commented on FLINK-23614: 1.14.1: 8c7cbcd9744378dccb4b6ab0493c7d273c69dfef > The

[GitHub] [flink-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738892692 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + * Licensed

[GitHub] [flink-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738892692 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + * Licensed

[jira] [Updated] (FLINK-15987) SELECT 1.0e0 / 0.0e0 throws NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-15987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15987: --- Fix Version/s: 1.13.4 1.14.1 1.15.0 > SELECT 1.0e0 / 0.0e0

[GitHub] [flink-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738891560 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + * Licensed

[GitHub] [flink] godfreyhe closed pull request #17546: [FLINK-15987][tabel-planner-blink]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

godfreyhe closed pull request #17546: URL: https://github.com/apache/flink/pull/17546 -- 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-ml] guoweiM commented on a change in pull request #11: [FLINK-24649][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

guoweiM commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r738891560 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + * Licensed

[jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

[ https://issues.apache.org/jira/browse/FLINK-24688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] baizhendong updated FLINK-24688: Fix Version/s: (was: 1.9.4) 1.15.0 >

[jira] [Commented] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

[ https://issues.apache.org/jira/browse/FLINK-24688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435743#comment-17435743 ] baizhendong commented on FLINK-24688: - I will submit a PR for this problem. >

[jira] [Updated] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

[ https://issues.apache.org/jira/browse/FLINK-24688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] baizhendong updated FLINK-24688: Description: yarn.application-attempt-failures-validity-interval property was added in 

[jira] [Created] (FLINK-24688) yarn.application-attempt-failures-validity-interval link url is invalid

baizhendong created FLINK-24688: --- Summary: yarn.application-attempt-failures-validity-interval link url is invalid Key: FLINK-24688 URL: https://issues.apache.org/jira/browse/FLINK-24688 Project: Flink

[GitHub] [flink] RocMarshal edited a comment on pull request #17463: [Hotfix] Fix typos.

RocMarshal edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-944947844 Hi, @klion26 @dianfu , here is a minor typo. Would you like to help me to check it ? Thank you very much. -- This is an automated message from the Apache Git

[GitHub] [flink] tsreaper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r73589 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,207 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #17597: [FLINK-24686][doccMake doc clear on AsyncFunction#timeout() overriding

flinkbot edited a comment on pull request #17597: URL: https://github.com/apache/flink/pull/17597#issuecomment-954182107 ## CI report: * 092334cdf65ef2db2e3d8f464a543f98763a6ec1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-tbd][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 9aa8115b9b3fa8cc853f7821c29f939870c79e5d Azure:

[GitHub] [flink] flinkbot commented on pull request #17598: [WIP][FLINK-tbd][connectors][formats] Add FileSource support for reading CSV files.

flinkbot commented on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282833 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 #17598: [WIP][FLINK-tbd][connectors][formats] Add FileSource support for reading CSV files.

flinkbot commented on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 9aa8115b9b3fa8cc853f7821c29f939870c79e5d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] afedulov opened a new pull request #17598: [WIP][FLINK-tbd][connectors][formats] Add FileSource support for reading CSV files.

afedulov opened a new pull request #17598: URL: https://github.com/apache/flink/pull/17598 This PR adds a new implementation of `StreamFormat` called `DelimitedFormat`. The format allows breaking consumed data by a specified delimiter pattern and deserializing produced blocks of bytes

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18996: --- Labels: auto-deprioritized-critical auto-deprioritized-major (was:

[jira] [Updated] (FLINK-13719) Update Yarn E2E test docker image to run on Java 11

[ https://issues.apache.org/jira/browse/FLINK-13719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13719: --- Labels: auto-deprioritized-major (was: auto-deprioritized-major stale-major)

[jira] [Updated] (FLINK-21263) Job hangs under backpressure

[ https://issues.apache.org/jira/browse/FLINK-21263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21263: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails

[ https://issues.apache.org/jira/browse/FLINK-5671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5671: -- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-21212) Can no longer cast INT to DATE

[ https://issues.apache.org/jira/browse/FLINK-21212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21212: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-23394) Add the HbaseOptions to the configuration generator

[ https://issues.apache.org/jira/browse/FLINK-23394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23394: --- Labels: auto-deprioritized-major starter (was: stale-major starter) Priority: Minor

[jira] [Updated] (FLINK-21227) Upgrade Protobof 3.7.0 for (power)ppc64le support

[ https://issues.apache.org/jira/browse/FLINK-21227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21227: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-23882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23882: --- Labels: auto-deprioritized-major starter (was: stale-major starter) Priority: Minor

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

[ https://issues.apache.org/jira/browse/FLINK-22949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22949: --- Labels: auto-deprioritized-blocker auto-deprioritized-critical auto-deprioritized-major

[jira] [Updated] (FLINK-21309) Metrics of JobManager and TaskManager overwrite each other in pushgateway

[ https://issues.apache.org/jira/browse/FLINK-21309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21309: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs or after running tow days

[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21325: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

[ https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21219: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-20935) can't write flink configuration to tmp file and add it to local resource in yarn session mode

[ https://issues.apache.org/jira/browse/FLINK-20935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20935: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-21379) Elasticsearch (v6.3.1) sink end-to-end test fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21379: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21320) Stream from FlinkKafkaShuffle.persistentKeyBy does not end if upstream ends

[ https://issues.apache.org/jira/browse/FLINK-21320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21320: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21385) AvroDeserializationSchema corrupted after getting invalid data

[ https://issues.apache.org/jira/browse/FLINK-21385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21385: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21291) FlinkKafka Consumer can't dynamic discover the partition update

[ https://issues.apache.org/jira/browse/FLINK-21291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21291: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-21310) unexpected behavior of DataStream union

[ https://issues.apache.org/jira/browse/FLINK-21310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21310: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-7029) Documentation for WindowFunction is confusing

[ https://issues.apache.org/jira/browse/FLINK-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7029: -- Labels: auto-deprioritized-minor documentation (was: documentation stale-minor)

[jira] [Updated] (FLINK-6099) not able to auto infer the row type when getting information from jdbc vertica

[ https://issues.apache.org/jira/browse/FLINK-6099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6099: -- Labels: auto-deprioritized-minor newbie (was: newbie stale-minor) Priority: Not a

[jira] [Updated] (FLINK-23778) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23778: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23828: --- Labels: stale-assigned test-stability (was: test-stability) I am the [Flink Jira

[GitHub] [flink] flinkbot edited a comment on pull request #17596: [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario

flinkbot edited a comment on pull request #17596: URL: https://github.com/apache/flink/pull/17596#issuecomment-954155629 ## CI report: * 74340eedf471bd8896c5e04615391d391a6ea18d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * 7e8209d6c05454c4ad642a2f3e71d044a2bb65b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17593: [FLINK-24603][e2e] Add test for Scala-free Flink

flinkbot edited a comment on pull request #17593: URL: https://github.com/apache/flink/pull/17593#issuecomment-953774184 ## CI report: * 4ca2a2eeaf401789da55b5a15dd6a0e86306cfd9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * 716a79d6c46b930226baf5fa4ed38ee83d859987 Azure:

[jira] [Updated] (FLINK-24687) flink-table uber jar should not include flink-connector-files dependency

[ https://issues.apache.org/jira/browse/FLINK-24687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-24687: - Description: flink-table-common currently depends on flink-connector-files due to 

[jira] [Created] (FLINK-24687) flink-table uber jar should not include flink-connector-files dependency

Thomas Weise created FLINK-24687: Summary: flink-table uber jar should not include flink-connector-files dependency Key: FLINK-24687 URL: https://issues.apache.org/jira/browse/FLINK-24687 Project:

[jira] [Updated] (FLINK-24686) Make doc clear on AsyncFunction::timeout() overriding

[ https://issues.apache.org/jira/browse/FLINK-24686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-24686: Affects Version/s: 1.14.0 1.13.3 > Make doc clear on AsyncFunction::timeout()

[GitHub] [flink] flinkbot edited a comment on pull request #17597: [FLINK-24686][doccMake doc clear on AsyncFunction#timeout() overriding

flinkbot edited a comment on pull request #17597: URL: https://github.com/apache/flink/pull/17597#issuecomment-954182107 ## CI report: * 092334cdf65ef2db2e3d8f464a543f98763a6ec1 Azure:

[GitHub] [flink] flinkbot commented on pull request #17597: [FLINK-24686][doccMake doc clear on AsyncFunction#timeout() overriding

flinkbot commented on pull request #17597: URL: https://github.com/apache/flink/pull/17597#issuecomment-954184905 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 #17597: [FLINK-24686][doccMake doc clear on AsyncFunction#timeout() overriding

flinkbot commented on pull request #17597: URL: https://github.com/apache/flink/pull/17597#issuecomment-954182107 ## CI report: * 092334cdf65ef2db2e3d8f464a543f98763a6ec1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24686) Make doc clear on AsyncFunction::timeout() overriding

[ https://issues.apache.org/jira/browse/FLINK-24686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24686: --- Labels: pull-request-available (was: ) > Make doc clear on AsyncFunction::timeout()

[GitHub] [flink] qinjunjerry opened a new pull request #17597: [FLINK-24686][doccMake doc clear on AsyncFunction#timeout() overriding

qinjunjerry opened a new pull request #17597: URL: https://github.com/apache/flink/pull/17597 ## What is the purpose of the change Sometimes, a user overrides AsyncFunction#timeout() with an empty method or with only logging code. This causes the timeout does not signal back to the

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 5671d4022e56a6623fcfe36d4a1a0961b60372e8 Azure:

[jira] [Created] (FLINK-24686) Make doc clear on AsyncFunction::timeout() overriding

Jun Qin created FLINK-24686: --- Summary: Make doc clear on AsyncFunction::timeout() overriding Key: FLINK-24686 URL: https://issues.apache.org/jira/browse/FLINK-24686 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435647#comment-17435647 ] Roman Khachatryan commented on FLINK-24611: --- Thanks for the feedback!   I agree that option

[GitHub] [flink] flinkbot edited a comment on pull request #17596: [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario

flinkbot edited a comment on pull request #17596: URL: https://github.com/apache/flink/pull/17596#issuecomment-954155629 ## CI report: * 74340eedf471bd8896c5e04615391d391a6ea18d Azure:

[GitHub] [flink] flinkbot commented on pull request #17596: [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario

flinkbot commented on pull request #17596: URL: https://github.com/apache/flink/pull/17596#issuecomment-954155629 ## CI report: * 74340eedf471bd8896c5e04615391d391a6ea18d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17596: [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario

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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 575b125cf69ed466ec6fb0977f8d062859bd209c Azure:

[GitHub] [flink] qinjunjerry opened a new pull request #17596: [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario

qinjunjerry opened a new pull request #17596: URL: https://github.com/apache/flink/pull/17596 backport of PR #17299 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 575b125cf69ed466ec6fb0977f8d062859bd209c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 575b125cf69ed466ec6fb0977f8d062859bd209c Azure:

  1   2   3   4   5   >