[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-24646][iteration] Add operator wrapper for all-round iterations

gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r738976484 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/operator/allround/TwoInputAllRoundWrapperOperatorTest.java ## @@ -0,0 +1,206 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

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

[jira] [Updated] (FLINK-24691) FLINK SQL SUM() causes a precision error

[ https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zongwen Li updated FLINK-24691: --- Description: code:  {code:java} tableEnv.executeSql("select sum(cast( 1.03520274 as decimal(32, 8)))

[jira] [Created] (FLINK-24691) FLINK SQL SUM() causes a precision error

Zongwen Li created FLINK-24691: -- Summary: FLINK SQL SUM() causes a precision error Key: FLINK-24691 URL: https://issues.apache.org/jira/browse/FLINK-24691 Project: Flink Issue Type: Bug

[GitHub] [flink] godfreyhe commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

godfreyhe commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r738902990 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -18,100 +18,43 @

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

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

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

[jira] [Updated] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

[ https://issues.apache.org/jira/browse/FLINK-24690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24690: -- Issue Type: Improvement (was: Bug) > Clarification of buffer size threshold calculati

[GitHub] [flink] flinkbot edited a comment on pull request #17600: [FLINK-24680][runtime/coordinator] Use UserCodeClassLoader when closing coordinator and register hook in ClassLoader to prevent relea

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

[jira] [Created] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

Anton Kalashnikov created FLINK-24690: - Summary: Clarification of buffer size threshold calculation in BufferDebloater Key: FLINK-24690 URL: https://issues.apache.org/jira/browse/FLINK-24690 Proj

[GitHub] [flink] flinkbot commented on pull request #17600: [FLINK-24680][runtime/coordinator] Use UserCodeClassLoader when closing coordinator and register hook in ClassLoader to prevent releasing be

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

[GitHub] [flink] flinkbot commented on pull request #17600: [FLINK-24680][runtime/coordinator] Use UserCodeClassLoader when closing coordinator and register hook in ClassLoader to prevent releasing be

flinkbot commented on pull request #17600: URL: https://github.com/apache/flink/pull/17600#issuecomment-954461335 ## CI report: * 59e9ecea8056701e41ebabe73badd7d5b877 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

godfreyhe closed pull request #17547: URL: https://github.com/apache/flink/pull/17547 -- 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-unsub

[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

[jira] [Updated] (FLINK-24680) Expose UserCodeClassLoader in OperatorCoordinator.Context for registering release hooks

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

[GitHub] [flink] PatrickRen opened a new pull request #17600: [FLINK-24680][runtime/coordinator] Use UserCodeClassLoader when closing coordinator and register hook in ClassLoader to prevent releasing

PatrickRen opened a new pull request #17600: URL: https://github.com/apache/flink/pull/17600 ## What is the purpose of the change This pull request exposes `UserCodeClassLoader` in operator coordinator context, uses `UserCodeClassLoader` when closing coordinator, and register hook i

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

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

flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * Unknown: [CANCELED](TBD) * a98d48127f8d02a4467023ebe6277eea09092ca0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

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

flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * Unknown: [CANCELED](TBD) * a98d48127f8d02a4467023ebe6277eea09092ca0 UNKNOWN Bot commands The @flinkbot bot supports the fol

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

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

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

[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&focusedCommentId=17435769#comment-17435769 ] Aitozi commented on FLINK-24633: Yes, it's caused by the k8s can't not start pod eventua

[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&focusedCommentId=17435768#comment-17435768 ] Aitozi commented on FLINK-24624: Thanks in advance [~wangyang0918] :) > Add clean up ph

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

[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&focusedCommentId=17435764#comment-17435764 ] Mason Chen commented on FLINK-24574: This would enable operators to properly clean u

[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 @@ +/* + * Lic

[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 @@ +/* + * Lic

[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 @@ +/* + * Lic

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

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

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

[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&focusedCommentId=17435750#comment-17435750 ] JING ZHANG commented on FLINK-23919: [~Yuval.Itzchakov] I'm very sorry for late resp

[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: 314fd0a14dfc4b

[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: issues-unsubsc

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

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

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

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

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

[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: ) > yarn.application-attempt-failures-validity-interva

[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 `yarn.application-attempt-failures-validity-interval`

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

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

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

[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: 48fe11dcb

[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&focusedCommentId=17435744#comment-17435744 ] godfrey he commented on FLINK-23614: 1.14.1: 8c7cbcd9744378dccb4b6ab0493c7d273c69dfe

[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 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_r738892692 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/compile/DraftTransformationTranslator.java ## @@ -0,0 +1,69 @@ +/* + * Licensed to

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

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

[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: issues-unsub

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

[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 > yarn.application-attempt-failures-vali

[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&focusedCommentId=17435743#comment-17435743 ] baizhendong commented on FLINK-24688: - I will submit a PR for this problem. > yarn.

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

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

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

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

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

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

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

[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: auto-deprioritized-maj

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

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

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

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

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

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

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

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

[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: auto-deprio

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

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

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

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

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

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

[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 Bot|https:

[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 Bot|https:

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

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

  1   2   3   4   5   >