[jira] [Created] (FLINK-24783) Improve state backend monitoring experience and usability

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24783: Summary: Improve state backend monitoring experience and usability Key: FLINK-24783 URL: https://issues.apache.org/jira/browse/FLINK-24783 Project: Flink Issue

[jira] [Created] (FLINK-24786) Introduce metrics of RocksDB's statistis

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24786: Summary: Introduce metrics of RocksDB's statistis Key: FLINK-24786 URL: https://issues.apache.org/jira/browse/FLINK-24786 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24785) Relocate RocksDB's log under flink log directory by default

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24785: Summary: Relocate RocksDB's log under flink log directory by default Key: FLINK-24785 URL: https://issues.apache.org/jira/browse/FLINK-24785 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread GitBox
flinkbot commented on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961689762 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 #17681: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17681: URL: https://github.com/apache/flink/pull/17681#issuecomment-960861704 ## CI report: * 1e4d3186bbefcceabac4ac27b2eede5891545e54 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * d15531819bd9663e8dcf7fd67e895da2112ff42d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * e07496c3522be15e47be43c8dae3b17e08745e72 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-05 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r74341 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-05 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743412694 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java ## @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-05 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743412553 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java ## @@ -0,0 +1,324 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-05 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743413672 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-05 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743413672 ## File path: flink-ml-api/src/test/java/org/apache/flink/ml/api/core/StageTest.java ## @@ -0,0 +1,345 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

2021-11-05 Thread GitBox
lindong28 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r743413889 ## File path: flink-ml-api/pom.xml ## @@ -38,6 +38,34 @@ under the License. ${flink.version} provided + + + org.apache.flink

[GitHub] [flink] flinkbot edited a comment on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 2304b6d9ef29100c23d5c0b00b97b95a91b19192 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 ## CI report: * 8ca91f13df7b3d17d2137e008e51acbcb4067c97 Azure:

[GitHub] [flink] JasonLeeCoding opened a new pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-05 Thread GitBox
JasonLeeCoding opened a new pull request #17690: URL: https://github.com/apache/flink/pull/17690 ## What is the purpose of the change *Modify the error example in the Flink document* ## Brief change log *(for example:)* - *The TaskInfo is stored in the

[jira] [Updated] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24490: --- Labels: pull-request-available (was: ) > The sample code is wrong in Apache Kafka

[GitHub] [flink] flinkbot commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-05 Thread GitBox
flinkbot commented on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 -- 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 #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 01a4524c33cf83bfa9f75004a5b960529cb8f660 Azure:

[GitHub] [flink] flinkbot commented on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread GitBox
flinkbot commented on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 490945024167ca8cc8b2845514d587d27f967b5d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24784) Enable state.backend.latency-track.state-name-as-variable by default

2021-11-05 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24784: - Description: This could help improve the usablility of state access latency. > Enable

[jira] [Commented] (FLINK-24551) BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration

2021-11-05 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439059#comment-17439059 ] Anton Kalashnikov commented on FLINK-24551: --- [~ym], No, this doesn't need to be merged to

[jira] [Created] (FLINK-24784) Enable state.backend.latency-track.state-name-as-variable by default

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24784: Summary: Enable state.backend.latency-track.state-name-as-variable by default Key: FLINK-24784 URL: https://issues.apache.org/jira/browse/FLINK-24784 Project: Flink

[jira] [Updated] (FLINK-24783) Improve state backend monitoring experience and usability

2021-11-05 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24783: - Component/s: Runtime / Metrics > Improve state backend monitoring experience and usability >

[jira] [Created] (FLINK-24787) Add more details of state latency tracking documentation

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24787: Summary: Add more details of state latency tracking documentation Key: FLINK-24787 URL: https://issues.apache.org/jira/browse/FLINK-24787 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 490945024167ca8cc8b2845514d587d27f967b5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure:

[GitHub] [flink] Zakelly commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-05 Thread GitBox
Zakelly commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-961669486 @Myasuka Thanks for the help. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 77824d10edb3fd299c242865a3a03fe08e540a85 Azure:

[GitHub] [flink] SteNicholas opened a new pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread GitBox
SteNicholas opened a new pull request #17691: URL: https://github.com/apache/flink/pull/17691 ## What is the purpose of the change There are some SQL functions which currently return VARCHAR(2000). With more strict CAST behavior from FLINK-24413, this could become an issue.

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 01a4524c33cf83bfa9f75004a5b960529cb8f660 Azure:

[jira] [Updated] (FLINK-24786) Introduce RocksDB's statistis related options

2021-11-05 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24786: - Summary: Introduce RocksDB's statistis related options (was: Introduce metrics of RocksDB's statistis)

[GitHub] [flink] flinkbot edited a comment on pull request #17681: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17681: URL: https://github.com/apache/flink/pull/17681#issuecomment-960861704 ## CI report: * 1e4d3186bbefcceabac4ac27b2eede5891545e54 Azure:

[jira] [Updated] (FLINK-24786) Introduce RocksDB's statistics related options

2021-11-05 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24786: - Description: Currently, Flink only support RocksDB's native metrics of property related. However, such

[jira] [Updated] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24586: --- Labels: pull-request-available (was: ) > SQL functions should return STRING instead of

[jira] [Created] (FLINK-24788) Report RocksDB statistics as metrics

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24788: Summary: Report RocksDB statistics as metrics Key: FLINK-24788 URL: https://issues.apache.org/jira/browse/FLINK-24788 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * be6b66f05a5ffd4f9bdf470d2637b281cde9cb7f Azure:

[GitHub] [flink] echauchot commented on a change in pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
echauchot commented on a change in pull request #17640: URL: https://github.com/apache/flink/pull/17640#discussion_r743657988 ## File path: docs/content/docs/connectors/datastream/formats/hadoop.md ## @@ -0,0 +1,38 @@ +--- +title: "Hadoop" +weight: 4 +type: docs +aliases: +

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * be6b66f05a5ffd4f9bdf470d2637b281cde9cb7f Azure:

[jira] [Closed] (FLINK-24609) flink-rpc-akka uses wrong Scala version property for parser-combinators

2021-11-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24609. Resolution: Fixed master: d0c00aca3bf49c457ba4edc64a436174ee461703 1.14:

[jira] [Updated] (FLINK-24001) Support evaluating individual window table-valued function in runtime

2021-11-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24001: --- Release Note: (was: Flink now supports evaluating individual window table-valued

[jira] [Closed] (FLINK-24706) AkkaInvocationHandler silently ignores deserialization errors

2021-11-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24706. Resolution: Fixed master: e932aad8ff5ac953f1e73193dda22da9f242851e 1.14:

[jira] [Comment Edited] (FLINK-24609) flink-rpc-akka uses wrong Scala version property for parser-combinators

2021-11-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439271#comment-17439271 ] Chesnay Schepler edited comment on FLINK-24609 at 11/5/21, 1:42 PM:

[jira] [Updated] (FLINK-24772) Update user document for individual window table-valued function

2021-11-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24772: --- Release Note: Flink now supports evaluating individual window table-valued functions, so

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * be6b66f05a5ffd4f9bdf470d2637b281cde9cb7f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * be6b66f05a5ffd4f9bdf470d2637b281cde9cb7f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17697: [FLINK-24796][ci] Reduce size of compile build artifact

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17697: URL: https://github.com/apache/flink/pull/17697#issuecomment-961911493 ## CI report: * 439adf16684577d090efbd8868c4550e75182453 Azure:

[GitHub] [flink] zentol commented on a change in pull request #17696: [FLINK-24765][kafka] Bump Kafka version to 2.8

2021-11-05 Thread GitBox
zentol commented on a change in pull request #17696: URL: https://github.com/apache/flink/pull/17696#discussion_r743682100 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -111,6 +111,15 @@ under the License. test +

[GitHub] [flink] AHeise merged pull request #17646: [FLINK-24740][testinfrastructure] Update testcontainers dependency to v1.16.2

2021-11-05 Thread GitBox
AHeise merged pull request #17646: URL: https://github.com/apache/flink/pull/17646 -- 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 #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * be6b66f05a5ffd4f9bdf470d2637b281cde9cb7f Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #17229: [FLINK-23381][state] Back-pressure on reaching state change to upload limit

2021-11-05 Thread GitBox
dawidwys commented on a change in pull request #17229: URL: https://github.com/apache/flink/pull/17229#discussion_r743688024 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/BatchingStateChangeUploader.java ## @@ -121,18 +127,17 @@ public

[GitHub] [flink] AHeise merged pull request #17648: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-11-05 Thread GitBox
AHeise merged pull request #17648: URL: https://github.com/apache/flink/pull/17648 -- 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] zentol merged pull request #17671: [FLINK-24749][coordination] Reuse CheckpointStatsTracker

2021-11-05 Thread GitBox
zentol merged pull request #17671: URL: https://github.com/apache/flink/pull/17671 -- 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] AHeise commented on pull request #17682: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-11-05 Thread GitBox
AHeise commented on pull request #17682: URL: https://github.com/apache/flink/pull/17682#issuecomment-961925059 I just realized that 1.12 will probably not have a new release, so we can omit this backport. I would have merged it without compilation issue but it seems to require some more

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * a3961daf02049b4f3956045e0c06eb0fdee55e35 Azure:

[jira] [Resolved] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-11-05 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20443. - Fix Version/s: 1.13.4 1.14.1 Resolution: Fixed >

[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

2021-11-05 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439285#comment-17439285 ] Yun Gao commented on FLINK-24801: - Another Instance: 

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * be6b66f05a5ffd4f9bdf470d2637b281cde9cb7f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 5b8ef0d842c6c865384ef5bc3304666a1de19e2d Azure:

[jira] [Commented] (FLINK-24799) KafkaDynamicTableFactoryTest.testTableSourceWithKeyValueAndMetadata fails on Azure

2021-11-05 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439286#comment-17439286 ] Yun Gao commented on FLINK-24799: -

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 5b8ef0d842c6c865384ef5bc3304666a1de19e2d Azure:

[GitHub] [flink] AHeise commented on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
AHeise commented on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-961928372 > @AHeise @MartijnVisser 2 general questions: > > 1. the current PR is a port of [this PR](https://github.com/apache/flink/pull/17523/files) for 1.13 that was asked

[jira] [Commented] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-11-05 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439283#comment-17439283 ] Arvid Heise commented on FLINK-20443: - Merged into 1.13 as

[jira] [Commented] (FLINK-22631) Metrics are incorrect when task finished

2021-11-05 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439295#comment-17439295 ] Yun Gao commented on FLINK-22631: - Hi [~kanata163], very thanks for reporting this issue! I think this

[GitHub] [flink] twalthr commented on a change in pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-05 Thread GitBox
twalthr commented on a change in pull request #17658: URL: https://github.com/apache/flink/pull/17658#discussion_r743706344 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/BinaryToStringCastRule.java ## @@

[jira] [Created] (FLINK-24803) Fix cast BINARY/VARBINARY to STRING

2021-11-05 Thread Timo Walther (Jira)
Timo Walther created FLINK-24803: Summary: Fix cast BINARY/VARBINARY to STRING Key: FLINK-24803 URL: https://issues.apache.org/jira/browse/FLINK-24803 Project: Flink Issue Type: Sub-task

[GitHub] [flink] twalthr commented on a change in pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-05 Thread GitBox
twalthr commented on a change in pull request #17658: URL: https://github.com/apache/flink/pull/17658#discussion_r743708460 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/rules/RowToStringCastRule.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the num

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-961748638 ## CI report: * d04e7822113ea65023d9311494cb67343d92fc34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17663: [FLINK-24738][runtime] Ignoring buffer size announcement if the channel is released already

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17663: URL: https://github.com/apache/flink/pull/17663#issuecomment-959548410 ## CI report: * e95e8ceeb1b8990e029358dac5731e50415c7383 Azure:

[GitHub] [flink] flinkbot commented on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

2021-11-05 Thread GitBox
flinkbot commented on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * d28d9de9abaa5a88cc75fa9fee51f9cbb5916fbb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * 4a9dc503d534287eee41c54d8857930443df1b3b UNKNOWN * 645775f4c9b284df25623ca9400ccfc04d038f75 Azure:

[GitHub] [flink] lincoln-lil opened a new pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

2021-11-05 Thread GitBox
lincoln-lil opened a new pull request #17699: URL: https://github.com/apache/flink/pull/17699 ## What is the purpose of the change The root cause of this case is `FlinkChangelogModeInferenceProgram` didn't consider the case when sink's primary key differs from input's upsert keys

[GitHub] [flink] flinkbot commented on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

2021-11-05 Thread GitBox
flinkbot commented on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963496 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 #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

2021-11-05 Thread GitBox
flinkbot commented on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 0c179381e200fa5f41136a61235ce4e4106de419 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

2021-11-05 Thread GitBox
flinkbot commented on pull request #17700: URL: https://github.com/apache/flink/pull/17700#issuecomment-961973169 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 #17700: [FLINK-24773][kafka] Fail job if unhandled exception occurs during committing

2021-11-05 Thread GitBox
flinkbot commented on pull request #17700: URL: https://github.com/apache/flink/pull/17700#issuecomment-961972204 ## CI report: * 228e5a9f2d227c5311ad12af866a16c8ba58c80b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * d28d9de9abaa5a88cc75fa9fee51f9cbb5916fbb Azure:

[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

2021-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439339#comment-17439339 ] Till Rohrmann commented on FLINK-24801: --- cc [~chesnay], is this something related to your recent

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * d28d9de9abaa5a88cc75fa9fee51f9cbb5916fbb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * 54234852c5fb3629dda8af9a1161723c7d38fed5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * 54234852c5fb3629dda8af9a1161723c7d38fed5 Azure:

[GitHub] [flink] flinkbot commented on pull request #17701: [FLINK-24294][streaming] Register all stream task resources to one cl…

2021-11-05 Thread GitBox
flinkbot commented on pull request #17701: URL: https://github.com/apache/flink/pull/17701#issuecomment-962009686 ## CI report: * a3b7be98fcdef1f8b6596fecf0c2e21442ae99c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17701: [FLINK-24294][streaming] Register all stream task resources to one cl…

2021-11-05 Thread GitBox
flinkbot commented on pull request #17701: URL: https://github.com/apache/flink/pull/17701#issuecomment-962009959 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 #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * d28d9de9abaa5a88cc75fa9fee51f9cbb5916fbb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619732 ## CI report: * b76e02bc31eb3d1c6e757e7cbc0cd1561777844c Azure:

[jira] [Updated] (FLINK-14527) Add integration tests for PostgreSQL and MySQL dialects in Flink JDBC module

2021-11-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-14527: --- Summary: Add integration tests for PostgreSQL and MySQL dialects in Flink JDBC module

[jira] [Assigned] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-14527: -- Assignee: (was: Martijn Visser) > Add integeration tests for PostgreSQL and

[jira] [Comment Edited] (FLINK-24746) Alibaba maven mirror is unstable

2021-11-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438924#comment-17438924 ] Chesnay Schepler edited comment on FLINK-24746 at 11/5/21, 8:43 AM:

[jira] [Commented] (FLINK-24746) Alibaba maven mirror is unstable

2021-11-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439087#comment-17439087 ] Chesnay Schepler commented on FLINK-24746: -- Initial results look fine, updating the other

[GitHub] [flink] flinkbot edited a comment on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 490945024167ca8cc8b2845514d587d27f967b5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17691: [FLINK-24586][table] SQL functions should return STRING instead of VARCHAR(2000)

2021-11-05 Thread GitBox
flinkbot edited a comment on pull request #17691: URL: https://github.com/apache/flink/pull/17691#issuecomment-961688928 ## CI report: * 490945024167ca8cc8b2845514d587d27f967b5d Azure:

[jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API

2021-11-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439094#comment-17439094 ] Chesnay Schepler commented on FLINK-24427: -- [~MartijnVisser] What's your timeline for this

[GitHub] [flink] Myasuka commented on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-05 Thread GitBox
Myasuka commented on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-961722042 The CI failed, @Zakelly do you have local green result? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] tsreaper commented on pull request #17672: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

2021-11-05 Thread GitBox
tsreaper commented on pull request #17672: URL: https://github.com/apache/flink/pull/17672#issuecomment-961729196 Sorry for misleading. As all test classes are in the same class path, if we create a new udf class in test it will still be loaded by the default class loader. One way to work

[jira] [Comment Edited] (FLINK-19142) Local recovery can be broken if slot hijacking happened during a full restart

2021-11-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438675#comment-17438675 ] Zhu Zhu edited comment on FLINK-19142 at 11/5/21, 9:25 AM: --- Fixed in

[jira] [Closed] (FLINK-24316) Refactor IntermediateDataSet to have only one consumer

2021-11-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-24316. --- Resolution: Duplicate > Refactor IntermediateDataSet to have only one consumer >

[jira] [Updated] (FLINK-24316) Refactor IntermediateDataSet to have only one consumer

2021-11-05 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-24316: Fix Version/s: (was: 1.15.0) > Refactor IntermediateDataSet to have only one consumer >

[jira] [Updated] (FLINK-17951) Improve the console message after executing a PyFlink job

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

[jira] [Updated] (FLINK-24792) OperatorCoordinatorSchedulerTest crashed JVM on AZP

2021-11-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24792: -- Attachment: logs-cron_adaptive_scheduler-test_cron_adaptive_scheduler_core-1636065425.zip >

[jira] [Updated] (FLINK-17993) read schema from orc file

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

  1   2   3   4   5   6   7   8   9   10   >