[GitHub] [flink] flinkbot edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 4be189160a729c2814f3e2400300632d97e76470 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17436: URL: https://github.com/apache/flink/pull/17436#issuecomment-938641830 ## CI report: * c4fd4fc12dddf7d9a37bf111429158d158f32b2c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * bf7f144b587313f1ab5cd706c52a25587151b923 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * bf7f144b587313f1ab5cd706c52a25587151b923 Azure:

[jira] [Commented] (FLINK-24606) AvroDeserializationSchema buffer is not clean

2021-10-21 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432219#comment-17432219 ] Nicholas Jiang commented on FLINK-24606: [~douheyu], IMO, the decoder in

[GitHub] [flink] flinkbot edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 4be189160a729c2814f3e2400300632d97e76470 Azure:

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

2021-10-21 Thread GitBox
RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-948292117 Could someone help me to advance it ? Thx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Comment Edited] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

2021-10-21 Thread Yuepeng Pan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409327#comment-17409327 ] Yuepeng Pan edited comment on FLINK-15352 at 10/21/21, 6:47 AM: Could

[jira] [Updated] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-21 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24596: Priority: Critical (was: Blocker) > Bugs in sink.buffer-flush before upsert-kafka >

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * dd8d7b161f71cef2099c746f4e54cb62d4b881dd Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * c4bd90be195feb51f8e2535d61779d431b6d1ae4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17436: URL: https://github.com/apache/flink/pull/17436#issuecomment-938641830 ## CI report: * c4fd4fc12dddf7d9a37bf111429158d158f32b2c Azure:

[GitHub] [flink-web] zentol merged pull request #473: Add Flink 1.13.3 release

2021-10-21 Thread GitBox
zentol merged pull request #473: URL: https://github.com/apache/flink-web/pull/473 -- 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] slinkydeveloper commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-21 Thread GitBox
slinkydeveloper commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948377409 @tsreaper I start getting your point of lazyness, but now I wonder, why is Avro different from, for example parquet? In parquet format, I see that when you invoke

[GitHub] [flink] KarmaGYZ opened a new pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

2021-10-21 Thread GitBox
KarmaGYZ opened a new pull request #17533: URL: https://github.com/apache/flink/pull/17533 …ng dynamic config string ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That

[GitHub] [flink] flinkbot edited a comment on pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17518: URL: https://github.com/apache/flink/pull/17518#issuecomment-946526433 ## CI report: * a177b8b7a724a0de1c4f76326c55753eabcc417b Azure:

[GitHub] [flink] zicat opened a new pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

2021-10-21 Thread GitBox
zicat opened a new pull request #17534: URL: https://github.com/apache/flink/pull/17534 … elimination ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

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

2021-10-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24610: --- Labels: pull-request-available (was: ) > Flink projection common expression elimination >

[jira] [Commented] (FLINK-21068) Add new timeout options for Elasticsearch connector

2021-10-21 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432338#comment-17432338 ] Fabian Paul commented on FLINK-21068: - [~karmagyz] thanks for pointing that out. I do not see a

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17493: [FLINK-24019][build][dist] Package Scala APIs separately

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17493: URL: https://github.com/apache/flink/pull/17493#issuecomment-944057092 ## CI report: * 138a13cae9d3fe5b8003f0a50e70cfcb4ee03d6c Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * d16cc0f9e2290406d788453db9f771fe6cbc8637 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * dd8d7b161f71cef2099c746f4e54cb62d4b881dd Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * d16cc0f9e2290406d788453db9f771fe6cbc8637 Azure:

[jira] [Commented] (FLINK-21068) Add new timeout options for Elasticsearch connector

2021-10-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432387#comment-17432387 ] Yangze Guo commented on FLINK-21068: [~fabian.paul] I do notice the FLINK-24323 and it's fair enough

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * dd8d7b161f71cef2099c746f4e54cb62d4b881dd Azure:

[GitHub] [flink] flinkbot commented on pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

2021-10-21 Thread GitBox
flinkbot commented on pull request #17535: URL: https://github.com/apache/flink/pull/17535#issuecomment-948487840 ## CI report: * 743640e83c9caed3f2af3c94ce4aee6228d244bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17518: URL: https://github.com/apache/flink/pull/17518#issuecomment-946526433 ## CI report: * a177b8b7a724a0de1c4f76326c55753eabcc417b Azure:

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

2021-10-21 Thread GitBox
guoweiM commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r733358268 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTracker.java ## @@ -0,0 +1,145 @@ +/* + *

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

2021-10-21 Thread GitBox
JingGe edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948313648 @tsreaper > > > For point 1, the uncompressed data size should be controlled by `StreamFormat.FETCH_IO_SIZE`. It might not be very precise to control the heap

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

2021-10-21 Thread GitBox
tsreaper edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948333809 @JingGe > "record" is the abstract concept, it does not mean the record in avro. Are you suggesting an avro `StreamFormat` which produces an avro block,

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

2021-10-21 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 can not reuse common expression in code generator. For example the

[jira] [Commented] (FLINK-24294) Resources leak in the StreamTask constructor

2021-10-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432308#comment-17432308 ] Anton Kalashnikov commented on FLINK-24294: --- It is not easy because the easiest way to do so

[jira] [Issue Comment Deleted] (FLINK-24294) Resources leak in the StreamTask constructor

2021-10-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24294: -- Comment: was deleted (was: It is not easy because the easiest way to do so is to

[jira] [Commented] (FLINK-24294) Resources leak in the StreamTask constructor

2021-10-21 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432307#comment-17432307 ] Anton Kalashnikov commented on FLINK-24294: --- It is not easy because the easiest way to do so

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 356ff14e4347563bbc8aecebc9a5edd8ef5b32a2 Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

[jira] [Commented] (FLINK-17782) Add array,map,row types support for parquet row writer

2021-10-21 Thread sujun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432332#comment-17432332 ] sujun commented on FLINK-17782: --- hi [~lzljs3620320] , Maybe I can add three new writers(ArrayWriter,

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

2021-10-21 Thread GitBox
nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r733530706 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/AbstractAsynchronousOperationHandlersTest.java ## @@ -194,11

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 356ff14e4347563bbc8aecebc9a5edd8ef5b32a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17493: [FLINK-24019][build][dist] Package Scala APIs separately

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17493: URL: https://github.com/apache/flink/pull/17493#issuecomment-944057092 ## CI report: * 138a13cae9d3fe5b8003f0a50e70cfcb4ee03d6c Azure:

[jira] [Updated] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark

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

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

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23394: --- Labels: stale-major starter (was: starter) I am the [Flink Jira

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

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23882: --- Labels: stale-major starter (was: starter) I am the [Flink Jira

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

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

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

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

[jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

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

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

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

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

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

[jira] [Updated] (FLINK-23526) py36-cython: commands failed on Azure

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

[GitHub] [flink] flinkbot commented on pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

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

[jira] [Updated] (FLINK-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup

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

[jira] [Commented] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters

2021-10-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432253#comment-17432253 ] Yangze Guo commented on FLINK-24541: cc [~xtsong] > ConfigurationUtils#assembleDynamicConfigsStr

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

2021-10-21 Thread GitBox
tsreaper commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948333809 @JingGe > "record" is the abstract concept, it does not mean the record in avro. Are you suggesting an avro `StreamFormat` which produces an avro block, instead

[jira] [Assigned] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters

2021-10-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-24541: Assignee: Yangze Guo > ConfigurationUtils#assembleDynamicConfigsStr should consider

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

2021-10-21 Thread GitBox
slinkydeveloper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r733405522 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,190 @@ +/* + *

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

2021-10-21 Thread GitBox
slinkydeveloper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r733405522 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,190 @@ +/* + *

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * c4bd90be195feb51f8e2535d61779d431b6d1ae4 Azure:

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

2021-10-21 Thread GitBox
xuyangzhong commented on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-948346716 @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

[GitHub] [flink] xuyangzhong commented on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

2021-10-21 Thread GitBox
xuyangzhong commented on pull request #17436: URL: https://github.com/apache/flink/pull/17436#issuecomment-948346629 @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

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

2021-10-21 Thread GitBox
flinkbot commented on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-948396533 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] tsreaper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

[GitHub] [flink] akalash commented on a change in pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-21 Thread GitBox
akalash commented on a change in pull request #17440: URL: https://github.com/apache/flink/pull/17440#discussion_r733419066 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java ## @@ -195,22 +195,26 @@ public

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

2021-10-21 Thread GitBox
flinkbot commented on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-948396321 ## CI report: * 5d34492f1f5bafd4d725a6740640feac1c2434ea UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2021-10-21 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 can not reuse common expression in runtime stage. For example the

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-21 Thread GitBox
slinkydeveloper commented on a change in pull request #17454: URL: https://github.com/apache/flink/pull/17454#discussion_r733489478 ## File path: flink-table/flink-table-runtime/pom.xml ## @@ -103,7 +103,7 @@ under the License. Dependencies that

[GitHub] [flink] flinkbot edited a comment on pull request #17515: [FLINK-24575][table-runtime] Migrate TestRowDataCsvInputFormat to DeserializationSchemaFactory

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17515: URL: https://github.com/apache/flink/pull/17515#issuecomment-946422818 ## CI report: * e9ddaedd9e89fe2efcee26e27c54f53690bb5eb4 Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-940730352 ## CI report: * 356ff14e4347563bbc8aecebc9a5edd8ef5b32a2 Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21232: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-assigned

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

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

[jira] [Updated] (FLINK-23964) Add shaded netty tcnative artifact to lib/ in the docker image

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23964: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22197: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available

[jira] [Updated] (FLINK-24228) [FLIP-171] Firehose implementation of Async Sink

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24228: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-23520) Improve StateFun <-> DataStream Interop

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23520: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-24328) Long term fix for receiving new buffer size before network reader configured

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24328: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

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

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

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21207: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-23241) Translate the page of "Working with State " into Chinese

2021-10-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23241: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[GitHub] [flink] flinkbot edited a comment on pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17518: URL: https://github.com/apache/flink/pull/17518#issuecomment-946526433 ## CI report: * a177b8b7a724a0de1c4f76326c55753eabcc417b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * f7c2d004a9d29fb2c3445445ed32ba9e9bb74e78 Azure:

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

2021-10-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18996: --- Fix Version/s: 1.15.0 > Avoid disorder for time interval join >

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

2021-10-21 Thread GitBox
tsreaper edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948333809 @JingGe > "record" is the abstract concept, it does not mean the record in avro. Are you suggesting an avro `StreamFormat` which produces an avro block,

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

2021-10-21 Thread GitBox
tsreaper edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948333809 @JingGe > "record" is the abstract concept, it does not mean the record in avro. Are you suggesting an avro `StreamFormat` which produces an avro block,

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

2021-10-21 Thread GitBox
JingGe edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948391521 @tsreaper > Are you suggesting an avro `StreamFormat` which produces an avro block, instead of a Flink row data, at a time? If yes we'll need another operator

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

2021-10-21 Thread GitBox
JingGe commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948391521 @tsreaper > Are you suggesting an avro `StreamFormat` which produces an avro block, instead of a Flink row data, at a time? If yes we'll need another operator after the

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * f09d671bd530b29cfc8ed31c1300179a97698576 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

2021-10-21 Thread GitBox
twalthr commented on a change in pull request #17454: URL: https://github.com/apache/flink/pull/17454#discussion_r733464579 ## File path: flink-table/flink-table-runtime/pom.xml ## @@ -103,7 +103,7 @@ under the License. Dependencies that are not

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

2021-10-21 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-24610: - Summary: Flink projection common expression elimination Key: FLINK-24610 URL: https://issues.apache.org/jira/browse/FLINK-24610 Project: Flink Issue Type:

[GitHub] [flink] fapaul commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-10-21 Thread GitBox
fapaul commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r733480109 ## File path: flink-formats/flink-avro/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-formats

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

[GitHub] [flink] fapaul commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-10-21 Thread GitBox
fapaul commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r733491320 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,189 @@ +/* + *

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

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

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

2021-10-21 Thread GitBox
flinkbot edited a comment on pull request #17535: URL: https://github.com/apache/flink/pull/17535#issuecomment-948487840 ## CI report: * 743640e83c9caed3f2af3c94ce4aee6228d244bb Azure:

[jira] [Created] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API

2021-10-21 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24608: --- Summary: Sinks built with the unified sink framework do not receive timestamps when used in Table API Key: FLINK-24608 URL: https://issues.apache.org/jira/browse/FLINK-24608

  1   2   3   4   5   >