[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 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

2021-10-26 Thread GitBox
JingsongLi commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r736213484 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileFormatFactory.java ## @@ -20,39 +20,135 @@ import org.ap

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-948396321 ## CI report: * 1b3591a9697dc708dd83ac8839b91bd383834f38 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tsreaper closed pull request #17565: [FLINK-24630][avro] Implement row projection in AvroToRowDataConverters#createRowConverter

2021-10-26 Thread GitBox
tsreaper closed pull request #17565: URL: https://github.com/apache/flink/pull/17565 -- 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-unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils"

2021-10-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434159#comment-17434159 ] Sergey Nuyanzin commented on FLINK-24638: - yes I'm testing with master, probably

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] pnowojski commented on a change in pull request #17473: [FLINK-24470][runtime] EMA calculation move to BufferDebloater

2021-10-26 Thread GitBox
pnowojski commented on a change in pull request #17473: URL: https://github.com/apache/flink/pull/17473#discussion_r736238309 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/bufferdebloat/BufferSizeEMA.java ## @@ -0,0 +1,58 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24544) Failure when using Kafka connector in Table API with Avro and Confluent schema registry

2021-10-26 Thread Peter Schrott (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434165#comment-17434165 ] Peter Schrott commented on FLINK-24544: --- I found a workaround for that issue - whi

[GitHub] [flink] pnowojski commented on a change in pull request #17473: [FLINK-24470][runtime] EMA calculation move to BufferDebloater

2021-10-26 Thread GitBox
pnowojski commented on a change in pull request #17473: URL: https://github.com/apache/flink/pull/17473#discussion_r736241227 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/bufferdebloat/BufferSizeEMA.java ## @@ -0,0 +1,58 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 3f69f95a54c392c758d8f76922efbfd810983baf Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * c25eee9cc5022426c3f0703e65ec5e41722b9975 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-24640) CEIL, FLOOR built-in functions for Timestamp should respect DST

2021-10-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24640: Affects Version/s: 1.14.0 > CEIL, FLOOR built-in functions for Timestamp should respect DS

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints

2021-10-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24384: -- Assignee: Feifan Wang > Count checkpoints failed in trigger phase into numberOfFailed

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 756027340bfe8a48fd5947c6eddd8db22beca44a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] twalthr commented on a change in pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

2021-10-26 Thread GitBox
twalthr commented on a change in pull request #17549: URL: https://github.com/apache/flink/pull/17549#discussion_r736287726 ## File path: docs/data/sql_functions.yml ## @@ -766,6 +766,27 @@ json: ) ) ``` + - sql: JSON_OBJECTAGG([KEY] key VALUE value [ {

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * c904e97695ec22ed3d3b9fb2a3fce7f8bb13494c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * ea6ee40c799a4e29be9cb9c61924111d7332 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * 6f62f5d3d687a09a591b26747df386ba8db46a54 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * 6f62f5d3d687a09a591b26747df386ba8db46a54 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] AHeise merged pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

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

[GitHub] [flink] AHeise commented on pull request #17465: [FLINK-24488][connectors/kafka] KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-26 Thread GitBox
AHeise commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-951731517 Thank you for your contribution! Could you please create a backport PR for 1.14? -- This is an automated message from the Apache Git Service. To respond to the message, please

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

2021-10-26 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-24611: -- Description: When a checkpoint is aborted, JM discards any state that was sent to it a

[jira] [Commented] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-26 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434209#comment-17434209 ] Arvid Heise commented on FLINK-24488: - Merged into master as 0df9e1e6b85238458a65b14

[jira] [Updated] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-26 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-24488: Fix Version/s: 1.15.0 > KafkaRecordSerializationSchemaBuilder does not forward timestamp > ---

[GitHub] [flink] KarmaGYZ commented on pull request #17470: [FLINK-22240][runtime] Cleanup logs in ExternalResourceUtils

2021-10-26 Thread GitBox
KarmaGYZ commented on pull request #17470: URL: https://github.com/apache/flink/pull/17470#issuecomment-951734169 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #17470: [FLINK-22240][runtime] Cleanup logs in ExternalResourceUtils

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17470: URL: https://github.com/apache/flink/pull/17470#issuecomment-943069241 ## CI report: * b4dd4441332c6913f75dead27ea15cda53f37b53 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17470: [FLINK-22240][runtime] Cleanup logs in ExternalResourceUtils

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17470: URL: https://github.com/apache/flink/pull/17470#issuecomment-943069241 ## CI report: * b4dd4441332c6913f75dead27ea15cda53f37b53 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 1740f472b8e16bf6759756822d177b60f3b0c42c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils"

2021-10-26 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434218#comment-17434218 ] Francesco Guardiani commented on FLINK-24638: - Ok, thank you for reporting,

[jira] [Assigned] (FLINK-24638) Unknown variable or type "org.apache.flink.table.utils.DateTimeUtils"

2021-10-26 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-24638: --- Assignee: Francesco Guardiani > Unknown variable or type "org.apache.flink.

[jira] [Created] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

2021-10-26 Thread Hadiiiiiiiii (Jira)
Hadi created FLINK-24641: Summary: Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file. Key: FLINK-24641 URL: https://issues.apache.org/jira/browse/FLINK-24641

[jira] [Updated] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

2021-10-26 Thread Hadiiiiiiiii (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hadi updated FLINK-24641: - Attachment: screenshot-1.png > Flink SQL FileSystem read hdfs Path, when Path's file name change

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * 368a7c41cde52ad3c0fde6c30e95ddf5308f8c16 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

2021-10-26 Thread Hadiiiiiiiii (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hadi updated FLINK-24641: - Description: Hello, big bro. when I use the Flink SQL to read HDFS Files like this: {code:java}

[jira] [Created] (FLINK-24642) Implements unified iteration to support algorithms in flink-ml

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24642: --- Summary: Implements unified iteration to support algorithms in flink-ml Key: FLINK-24642 URL: https://issues.apache.org/jira/browse/FLINK-24642 Project: Flink Issue T

[jira] [Created] (FLINK-24643) Introduce the flink-ml-iteration module and iteration api

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24643: --- Summary: Introduce the flink-ml-iteration module and iteration api Key: FLINK-24643 URL: https://issues.apache.org/jira/browse/FLINK-24643 Project: Flink Issue Type: S

[jira] [Created] (FLINK-24644) Introduce Add broadcast output to broadcast events to all the downstream tasks

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24644: --- Summary: Introduce Add broadcast output to broadcast events to all the downstream tasks Key: FLINK-24644 URL: https://issues.apache.org/jira/browse/FLINK-24644 Project: Flink

[jira] [Updated] (FLINK-24643) Introduce the flink-ml-iteration module and iteration api

2021-10-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24643: Fix Version/s: 0.1.0 > Introduce the flink-ml-iteration module and iteration api > ---

[jira] [Updated] (FLINK-24643) Introduce the flink-ml-iteration module and iteration api

2021-10-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24643: Component/s: Library / Machine Learning > Introduce the flink-ml-iteration module and iteration api >

[jira] [Created] (FLINK-24645) Implements the feedback mechanism and the controller operators

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24645: --- Summary: Implements the feedback mechanism and the controller operators Key: FLINK-24645 URL: https://issues.apache.org/jira/browse/FLINK-24645 Project: Flink Issue T

[jira] [Created] (FLINK-24646) Add operator wrapper for all-round iterations

2021-10-26 Thread Yun Gao (Jira)
Yun Gao created FLINK-24646: --- Summary: Add operator wrapper for all-round iterations Key: FLINK-24646 URL: https://issues.apache.org/jira/browse/FLINK-24646 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #17470: [FLINK-22240][runtime] Cleanup logs in ExternalResourceUtils

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17470: URL: https://github.com/apache/flink/pull/17470#issuecomment-943069241 ## CI report: * b4dd4441332c6913f75dead27ea15cda53f37b53 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xmarker opened a new pull request #17566: [FLINK-24488][connectors/kafka] Fix KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-26 Thread GitBox
xmarker opened a new pull request #17566: URL: https://github.com/apache/flink/pull/17566 This PR cherry-picks the PR from #17465 to the release-1.14 branch. @AHeise -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot commented on pull request #17566: [FLINK-24488][connectors/kafka] Fix KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-26 Thread GitBox
flinkbot commented on pull request #17566: URL: https://github.com/apache/flink/pull/17566#issuecomment-951775362 -- 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 unsubsc

[jira] [Assigned] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception

2021-10-26 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24647: --- Assignee: Fabian Paul > ClusterUncaughtExceptionHandler does not log the exception > --

[jira] [Created] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception

2021-10-26 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24647: --- Summary: ClusterUncaughtExceptionHandler does not log the exception Key: FLINK-24647 URL: https://issues.apache.org/jira/browse/FLINK-24647 Project: Flink Issu

[jira] [Updated] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception

2021-10-26 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24647: Description: If an uncaught exception occurs and the uncaught exception handler is configured to

[GitHub] [flink] flinkbot edited a comment on pull request #17566: [FLINK-24488][connectors/kafka] Fix KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17566: URL: https://github.com/apache/flink/pull/17566#issuecomment-951775362 ## CI report: * fd2f03ac56ebf970cfb5f3fd66746ff0ebe1d189 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-24610) Flink projection common expression elimination

2021-10-26 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-24610: -- Description: Flink sql projection not support reusing common expression in code generator. For exampl

[GitHub] [flink] fapaul opened a new pull request #17567: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set

2021-10-26 Thread GitBox
fapaul opened a new pull request #17567: URL: https://github.com/apache/flink/pull/17567 ## What is the purpose of the change Log thrown exception if UncaughtExceptionHandleMode.LOG is set ## Brief change log - Include thrown exception in log statement

[jira] [Updated] (FLINK-24647) ClusterUncaughtExceptionHandler does not log the exception

2021-10-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24647: --- Labels: pull-request-available (was: ) > ClusterUncaughtExceptionHandler does not log the e

[GitHub] [flink] flinkbot commented on pull request #17567: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set

2021-10-26 Thread GitBox
flinkbot commented on pull request #17567: URL: https://github.com/apache/flink/pull/17567#issuecomment-951796381 ## CI report: * 190090ac0cc7ad59c1650f64deee4ede4d0970d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17567: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set

2021-10-26 Thread GitBox
flinkbot commented on pull request #17567: URL: https://github.com/apache/flink/pull/17567#issuecomment-951797743 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 edited a comment on pull request #17567: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtExceptionHandleMode.LOG is set

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17567: URL: https://github.com/apache/flink/pull/17567#issuecomment-951796381 ## CI report: * 190090ac0cc7ad59c1650f64deee4ede4d0970d2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fapaul opened a new pull request #17568: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtE…

2021-10-26 Thread GitBox
fapaul opened a new pull request #17568: URL: https://github.com/apache/flink/pull/17568 …xceptionHandleMode.LOG is set Unchanged backport of #17567 -- 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 t

[GitHub] [flink] flinkbot commented on pull request #17568: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtE…

2021-10-26 Thread GitBox
flinkbot commented on pull request #17568: URL: https://github.com/apache/flink/pull/17568#issuecomment-951803688 ## CI report: * 4ea15150f13ad122fa7c3839160fbe4ffa026ed8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17568: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtE…

2021-10-26 Thread GitBox
flinkbot commented on pull request #17568: URL: https://github.com/apache/flink/pull/17568#issuecomment-951804848 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 edited a comment on pull request #17568: [FLINK-24647][runtime/coordination] Log thrown exception if UncaughtE…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17568: URL: https://github.com/apache/flink/pull/17568#issuecomment-951803688 ## CI report: * 4ea15150f13ad122fa7c3839160fbe4ffa026ed8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

2021-10-26 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4627: -- Labels: auto-unassigned stale-minor (was: auto-unassigned) I am the [Flink Jira Bot|https://gi

[GitHub] [flink] zentol commented on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-26 Thread GitBox
zentol commented on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-951808837 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * bb80cf155d7e802f2b486dedf37d6e60dbf0a5d8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * bb80cf155d7e802f2b486dedf37d6e60dbf0a5d8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] alpreu commented on pull request #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

2021-10-26 Thread GitBox
alpreu commented on pull request #17539: URL: https://github.com/apache/flink/pull/17539#issuecomment-951821847 Looks good to me now :) -- 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 specif

[GitHub] [flink] alpreu commented on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-26 Thread GitBox
alpreu commented on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-951824424 Just cherry-picked 8eb432b for debugging reasons, has to be dropped before final merge -- This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] alpreu commented on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-26 Thread GitBox
alpreu commented on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-951826387 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-929172201 ## CI report: * Unknown: [CANCELED](TBD) * 8eb432b3be4d996f8927e94c422c11a8b3f241fd UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] flinkbot edited a comment on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 4429082ae3c4a676bdf92bb3c96620adaf2f89f8 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-26 Thread GitBox
flinkbot edited a comment on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-929172201 ## CI report: * Unknown: [CANCELED](TBD) * 8eb432b3be4d996f8927e94c422c11a8b3f241fd Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[jira] [Commented] (FLINK-24610) Flink projection common expression elimination

2021-10-26 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434275#comment-17434275 ] Lyn Zhang commented on FLINK-24610: --- [~jark] Please help to review this issue if you a

[jira] [Created] (FLINK-24648) Ceil, floor for some timeunit return wrong results or fail with CompileException

2021-10-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24648: --- Summary: Ceil, floor for some timeunit return wrong results or fail with CompileException Key: FLINK-24648 URL: https://issues.apache.org/jira/browse/FLINK-24648

[jira] [Updated] (FLINK-24648) Ceil, floor for some timeunit return wrong results or fail with CompileException

2021-10-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24648: Description: There are issues 1. for {{TIMESTAMP WITHOUT TIMEZONE}} and {{DATE}} it return

[jira] [Updated] (FLINK-24648) Ceil, floor for some timeunit return wrong results or fail with CompileException

2021-10-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24648: Affects Version/s: 1.14.0 > Ceil, floor for some timeunit return wrong results or fail wit

  1   2   3   4   >