[jira] [Updated] (FLINK-24813) Improve ImplicitTypeConversionITCase

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
rkhachatryan commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r748044406 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java #

[GitHub] [flink] xuyangzhong opened a new pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

2021-11-11 Thread GitBox
xuyangzhong opened a new pull request #17771: URL: https://github.com/apache/flink/pull/17771 ## What is the purpose of the change *delete the test file ImplicitTypeConversionITCase and union them into the ImplicitConversionEqualsFunctionITCase to have the same code style with CastF

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

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
rkhachatryan commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r748043572 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[jira] [Closed] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-24883. --- Resolution: Duplicate > Use flink web ui to submit the jar throw Job client must be a > Coordinatio

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

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

[jira] [Commented] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442602#comment-17442602 ] Caizhi Weng commented on FLINK-24883: - Hi [~aresyhzhang], thanks for raising this is

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

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

[jira] [Updated] (FLINK-24884) flink flame graph webui bug

2021-11-11 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-24884: - Description: i can not compile success when i port the flame graph feature to our low version of flink.

[GitHub] [flink] MartijnVisser commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-11 Thread GitBox
MartijnVisser commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-966894956 @complone Are you proposing that you want to take over the work on this PR to complete https://issues.apache.org/jira/browse/FLINK-18202 ? -- This is an automated messag

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

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

[jira] [Created] (FLINK-24884) flink flame graph webui bug

2021-11-11 Thread jackylau (Jira)
jackylau created FLINK-24884: Summary: flink flame graph webui bug Key: FLINK-24884 URL: https://issues.apache.org/jira/browse/FLINK-24884 Project: Flink Issue Type: Bug Affects Versions: 1.1

[jira] [Updated] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24883: Component/s: Runtime / Web Frontend > Use flink web ui to submit the jar throw Job client must be

[jira] [Updated] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24883: Component/s: Table SQL / API (was: API / DataStream) > Use flink web ui to su

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

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

[jira] [Updated] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24883: Component/s: API / DataStream > Use flink web ui to submit the jar throw Job client must be a > C

[jira] [Updated] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24883: Description: version: flink verison:1.14.0  java version:1.8 a simple example code: {code:java} p

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

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

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

2021-11-11 Thread GitBox
tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r748035668 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileFormatFactory.java ## @@ -20,39 +20,84 @@ import org.apach

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

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

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

2021-11-11 Thread GitBox
tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r748035668 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileFormatFactory.java ## @@ -20,39 +20,84 @@ import org.apach

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

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

[jira] [Commented] (FLINK-24882) Make SQL format identifier NOT case-sensitive.

2021-11-11 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442599#comment-17442599 ] liwei li commented on FLINK-24882: -- [~airblader] +1 > Make SQL format identifier NOT c

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747999451 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogState.java ## @@ -90,6 +90

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

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

[GitHub] [flink] hililiwei commented on a change in pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-11-11 Thread GitBox
hililiwei commented on a change in pull request #17613: URL: https://github.com/apache/flink/pull/17613#discussion_r748028182 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/BangEqualITCase.scala ## @@ -0,0 +1,71 @

[GitHub] [flink] flinkbot edited a comment on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

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

[GitHub] [flink] hililiwei commented on a change in pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-11-11 Thread GitBox
hililiwei commented on a change in pull request #17613: URL: https://github.com/apache/flink/pull/17613#discussion_r748026286 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/BangEqualITCase.scala ## @@ -0,0 +1,71 @

[GitHub] [flink] flinkbot edited a comment on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

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

[GitHub] [flink] hililiwei commented on a change in pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

2021-11-11 Thread GitBox
hililiwei commented on a change in pull request #17613: URL: https://github.com/apache/flink/pull/17613#discussion_r748025602 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/BangEqualITCase.scala ## @@ -0,0 +1,71 @

[GitHub] [flink] MartijnVisser commented on pull request #17619: [FLINK-23990][runtime-web] Replace custom monaco editor with nz-code-editor

2021-11-11 Thread GitBox
MartijnVisser commented on pull request #17619: URL: https://github.com/apache/flink/pull/17619#issuecomment-966874951 I think that's fine because functionally I don't see an issue with the PR. LGTM -- This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] flinkbot edited a comment on pull request #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

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

[jira] [Created] (FLINK-24883) Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug.

2021-11-11 Thread aresyhzhang (Jira)
aresyhzhang created FLINK-24883: --- Summary: Use flink web ui to submit the jar throw Job client must be a CoordinationRequestGateway. This is a bug. Key: FLINK-24883 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Comment Edited] (FLINK-24877) Implicitly add time attributes for VALUES clause

2021-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442542#comment-17442542 ] Jingsong Lee edited comment on FLINK-24877 at 11/12/21, 6:46 AM: -

[jira] [Commented] (FLINK-24877) Implicitly add time attributes for VALUES clause

2021-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442588#comment-17442588 ] Jingsong Lee commented on FLINK-24877: -- Conceptually, values is more like a bounded

[jira] [Comment Edited] (FLINK-24877) Implicitly add time attributes for VALUES clause

2021-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442542#comment-17442542 ] Jingsong Lee edited comment on FLINK-24877 at 11/12/21, 6:43 AM: -

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-11-11 Thread GitBox
RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262 @MartijnVisser @Airblader @wuchong Excuse me, Could you help me to check it if you have free time ? Thanks a lot. -- This is an automated message from the Apache Git

[GitHub] [flink] complone edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-11 Thread GitBox
complone edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-966850088 @wuchong @libenchao @maosuhan Hello, everyone. Our company is working on the unfinished protobuf-format. I noticed that this featrue has not been in progress for thre

[jira] [Commented] (FLINK-24882) Make SQL format identifier NOT case-sensitive.

2021-11-11 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442579#comment-17442579 ] Ingo Bürk commented on FLINK-24882: --- IMO it is a fair expectation that quoted values a

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2021-11-11 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442578#comment-17442578 ] Nicholas Jiang commented on FLINK-22793: [~nicholasjiang], yes of course. > Hyb

[jira] [Updated] (FLINK-24880) Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs

2021-11-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24880: Description: The following exception shown when executing PyFlink jobs according to the demo show in [ht

[GitHub] [flink] complone commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-11-11 Thread GitBox
complone commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-966850088 @wuchong @libenchao @maosuhan Hello, everyone. Our company is working on the unfinished protobuf-format. I noticed that this featrue has not been in progress for three month

[jira] [Updated] (FLINK-24880) Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs

2021-11-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24880: Summary: Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs (wa

[jira] [Updated] (FLINK-24880) reports error messages "OverflowError: timeout value is too large"

2021-11-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24880: Issue Type: Improvement (was: Bug) > reports error messages "OverflowError: timeout value is too large"

[jira] [Updated] (FLINK-24880) reports error messages "OverflowError: timeout value is too large"

2021-11-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24880: Summary: reports error messages "OverflowError: timeout value is too large" (was: pyflink 官网demo运行报错Over

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747999451 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogState.java ## @@ -90,6 +90

[GitHub] [flink] flinkbot edited a comment on pull request #17770: [FLINK-24272][Connectors / FileSystem] FileSystem compaction should throw unsupported exception in at-least-once mode

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

[GitHub] [flink] flinkbot commented on pull request #17770: [FLINK-24272][Connectors / FileSystem] FileSystem compaction should throw unsupported exception in at-least-once mode

2021-11-11 Thread GitBox
flinkbot commented on pull request #17770: URL: https://github.com/apache/flink/pull/17770#issuecomment-966847489 ## CI report: * 4aae7ec969fd36a4e174c00f4d46812caaedaa4c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #17770: [FLINK-24272][Connectors / FileSystem] FileSystem compaction should throw unsupported exception in at-least-once mode

2021-11-11 Thread GitBox
flinkbot commented on pull request #17770: URL: https://github.com/apache/flink/pull/17770#issuecomment-966847014 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

[jira] [Updated] (FLINK-24272) FileSystem compaction should throw unsupported exception in at-least-once mode

2021-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24272: --- Labels: pull-request-available (was: ) > FileSystem compaction should throw unsupported exc

[GitHub] [flink] hililiwei opened a new pull request #17770: [FLINK-24272][Connectors / FileSystem] FileSystem compaction should throw unsupported exception in at-least-once mode

2021-11-11 Thread GitBox
hililiwei opened a new pull request #17770: URL: https://github.com/apache/flink/pull/17770 ## What is the purpose of the change FileSystem compaction should throw unsupported exception in at-least-once mode https://issues.apache.org/jira/browse/FLINK-24272

[GitHub] [flink] flinkbot edited a comment on pull request #17655: [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files

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

[GitHub] [flink] flinkbot edited a comment on pull request #17655: [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files

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

[jira] [Updated] (FLINK-24880) pyflink 官网demo运行报错OverflowError: timeout value is too large

2021-11-11 Thread wangdonglin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangdonglin updated FLINK-24880: Environment: Python 3.6.8 (tags/v3.6.8:3c6b436a57, Dec 24 2018, 00:16:47) [MSC v.1916 64 bit (AMD

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747958590 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java ## @@ -

[GitHub] [flink] curcur edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-966795230 Thanks @rkhachatryan ! > Thanks for the PR @curcur, I've left some comments, PTAL. > > PR description says it's verified by unit tests, but I couldn't find any

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

2021-11-11 Thread GitBox
flinkbot edited a comment on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-965029957 ## CI report: * 6190a85b1377c999c5f0f9e998f008624194501b 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-24703][connectors][formats] Add FileSource support for reading CSV files.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

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

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

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

[GitHub] [flink] flinkbot edited a comment on pull request #17769: [hotfix][docs]Example Change the interval day precision limit

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

[GitHub] [flink] flinkbot edited a comment on pull request #17760: [FLINK-24830][examples] Update DataStream WordCount example

2021-11-11 Thread GitBox
flinkbot edited a comment on pull request #17760: URL: https://github.com/apache/flink/pull/17760#issuecomment-965756145 ## CI report: * 3633f6917d2939616c6ec07fa55c908b54a0e7d0 UNKNOWN * 47d7f94bffc310ddcb5e68a792896cbf57cdf619 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747958349 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -600,

[GitHub] [flink] curcur edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-966795230 Thanks @rkhachatryan ! > Thanks for the PR @curcur, I've left some comments, PTAL. > > PR description says it's verified by unit tests, but I couldn't find any

[GitHub] [flink] curcur commented on pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-966795230 > Thanks for the PR @curcur, I've left some comments, PTAL. > > PR description says it's verified by unit tests, but I couldn't find any (and the existing tests don't cover

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747958911 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java ## @@ -

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747958590 ## File path: flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java ## @@ -

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747958349 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -600,

[GitHub] [flink] curcur commented on a change in pull request #17462: [FLINK-23170] Write metadata after materialization

2021-11-11 Thread GitBox
curcur commented on a change in pull request #17462: URL: https://github.com/apache/flink/pull/17462#discussion_r747957300 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogState.java ## @@ -90,6 +90

[jira] [Updated] (FLINK-24882) Make SQL format identifier NOT case-sensitive.

2021-11-11 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moses updated FLINK-24882: -- Description: If I use upper-case format identifier like below: {code:java} CREATE TABLE t_table_1 (a INT) WITH

[jira] [Created] (FLINK-24882) Make SQL format identifier NOT case-sensitive.

2021-11-11 Thread Moses (Jira)
Moses created FLINK-24882: - Summary: Make SQL format identifier NOT case-sensitive. Key: FLINK-24882 URL: https://issues.apache.org/jira/browse/FLINK-24882 Project: Flink Issue Type: Improvement

[GitHub] [flink] viirya commented on a change in pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

2021-11-11 Thread GitBox
viirya commented on a change in pull request #17582: URL: https://github.com/apache/flink/pull/17582#discussion_r747955432 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesTaskManagerFactory.java ## @@ -54,6 +63,7 @@ public

[jira] [Created] (FLINK-24881) When the Source is back pressured, the checkpoint interval may not take effect

2021-11-11 Thread Zongwen Li (Jira)
Zongwen Li created FLINK-24881: -- Summary: When the Source is back pressured, the checkpoint interval may not take effect Key: FLINK-24881 URL: https://issues.apache.org/jira/browse/FLINK-24881 Project: F

[GitHub] [flink] viirya commented on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

2021-11-11 Thread GitBox
viirya commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-966790147 Ah, this was done many months ago actually, though it is just submitted recently. So I may miss some details now. The issue should be happened like: Job manager will

[jira] [Closed] (FLINK-21605) Uniform the format of property name in the flink configuration file.

2021-11-11 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moses closed FLINK-21605. - Resolution: Abandoned > Uniform the format of property name in the flink configuration file. > -

[jira] [Closed] (FLINK-22427) Support DEFAULT value syntax to simplify data clean process

2021-11-11 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moses closed FLINK-22427. - Resolution: Abandoned > Support DEFAULT value syntax to simplify data clean process > --

[GitHub] [flink] yangjunhan commented on pull request #17619: [FLINK-23990][runtime-web] Replace custom monaco editor with nz-code-editor

2021-11-11 Thread GitBox
yangjunhan commented on pull request #17619: URL: https://github.com/apache/flink/pull/17619#issuecomment-966787195 @MartijnVisser Thank you for the review! I followed the steps you mentioned but failed to reproduce the errors. As far as I know, the involved pages do not contain any editor

[jira] [Closed] (FLINK-22685) Write data to hive table in batch mode throws FileNotFoundException.

2021-11-11 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Moses closed FLINK-22685. - Resolution: Auto Closed > Write data to hive table in batch mode throws FileNotFoundException. > ---

[GitHub] [flink] RocMarshal commented on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-11-11 Thread GitBox
RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262 @MartijnVisser @Airblader Excuse me, Could you help me to check it if you have free time ? Thanks a lot. -- This is an automated message from the Apache Git Service. To res

[GitHub] [flink] flinkbot commented on pull request #17769: [hotfix][docs]Example Change the interval day precision limit

2021-11-11 Thread GitBox
flinkbot commented on pull request #17769: URL: https://github.com/apache/flink/pull/17769#issuecomment-966779630 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 #17769: [hotfix][docs]Example Change the interval day precision limit

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

[GitHub] [flink] SteNicholas commented on pull request #17763: [FLINK-24784][runtime] Enable state.backend.latency-track.state-name-as-variable by default

2021-11-11 Thread GitBox
SteNicholas commented on pull request #17763: URL: https://github.com/apache/flink/pull/17763#issuecomment-966779420 @Myasuka , could you please take a look for this pull request? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [flink] flinkbot commented on pull request #17769: [hotfix][docs]Example Change the interval day precision limit

2021-11-11 Thread GitBox
flinkbot commented on pull request #17769: URL: https://github.com/apache/flink/pull/17769#issuecomment-966778618 ## CI report: * 368bc9392c03094c593408840a5fc790a4c66073 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

2021-11-11 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442555#comment-17442555 ] WangMinChao commented on FLINK-24855: -     Hi,[~chesnay] [~Leonard Xu] ,The follow

[GitHub] [flink] jelly-1203 closed pull request #17769: Example Change the interval day precision limit

2021-11-11 Thread GitBox
jelly-1203 closed pull request #17769: URL: https://github.com/apache/flink/pull/17769 -- 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-unsu

[GitHub] [flink] jelly-1203 opened a new pull request #17769: Example Change the interval day precision limit

2021-11-11 Thread GitBox
jelly-1203 opened a new pull request #17769: URL: https://github.com/apache/flink/pull/17769 Flink uses the precision limit of interval day in the documentation to be 6, and the source code has a precision limit of 3 for DAY_INTERVAL_TYPES after reviewing the source code ## What is

[GitHub] [flink] flinkbot edited a comment on pull request #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-11-11 Thread GitBox
ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r747938890 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/util/LogLevelExtension.java ## @@ -0,0 +1,114 @@ +/* + *

[jira] [Updated] (FLINK-24880) pyflink 官网demo运行报错OverflowError: timeout value is too large

2021-11-11 Thread wangdonglin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangdonglin updated FLINK-24880: Description: 运行pyflink官网demo,[https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

2021-11-11 Thread GitBox
ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r747507035 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java ## @@

[jira] [Comment Edited] (FLINK-24871) Flink SQL hive reports IndexOutOfBoundsException when using trim in where clause

2021-11-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442546#comment-17442546 ] luoyuxia edited comment on FLINK-24871 at 11/12/21, 2:08 AM: -

[jira] [Commented] (FLINK-24871) Flink SQL hive reports IndexOutOfBoundsException when using trim in where clause

2021-11-11 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442546#comment-17442546 ] luoyuxia commented on FLINK-24871: -- [~Jiangang]  It's not a problem. Acutally, it's exp

[jira] [Created] (FLINK-24880) pyflink 官网demo运行报错OverflowError: timeout value is too large

2021-11-11 Thread wangdonglin (Jira)
wangdonglin created FLINK-24880: --- Summary: pyflink 官网demo运行报错OverflowError: timeout value is too large Key: FLINK-24880 URL: https://issues.apache.org/jira/browse/FLINK-24880 Project: Flink Is

[jira] [Commented] (FLINK-24877) Implicitly add time attributes for VALUES clause

2021-11-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442542#comment-17442542 ] Jingsong Lee commented on FLINK-24877: -- > This means that any timestamp can be used

[jira] [Created] (FLINK-24879) ReducingStateDescriptor Constructor forgets to check ReduceFunction instanceof RichFunction

2021-11-11 Thread bx123 (Jira)
bx123 created FLINK-24879: - Summary: ReducingStateDescriptor Constructor forgets to check ReduceFunction instanceof RichFunction Key: FLINK-24879 URL: https://issues.apache.org/jira/browse/FLINK-24879 Project

[GitHub] [flink] RocMarshal commented on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number o

2021-11-11 Thread GitBox
RocMarshal commented on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-966724208 > What are you trying to solve? Could you please fill out the PR form correctly? I understand what your are doing on technical side but I don't understand why it's necessary.

[jira] [Commented] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

2021-11-11 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442517#comment-17442517 ] Yuepeng Pan commented on FLINK-24489: - In my limited read, I hope to reduce the numb

  1   2   3   4   5   6   >