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

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

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

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

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

[ 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-23425) The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup

[ 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

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

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-23526) py36-cython: commands failed on Azure

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

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

[ 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

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

[ 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-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ 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

[ 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-23964) Add shaded netty tcnative artifact to lib/ in the docker image

[ 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-21232) Introduce pluggable Hadoop delegation token providers

[ 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

[ 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-23520) Improve StateFun <-> DataStream Interop

[ 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

[ 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

[ 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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24609: --- Labels: pull-request-available (was: ) > flink-rpc-akka uses wrong Scala version property

[GitHub] [flink] zentol opened a new pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

zentol opened a new pull request #17535: URL: https://github.com/apache/flink/pull/17535 Maven does not properly resolve `dependencyManagement` entries if the parent/child module declare one for the same dependency with different properties being used in the `artifactId.` Our builds were

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

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 #17493: [FLINK-24019][build][dist] Package Scala APIs separately

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 #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

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 #17454: [FLINK-24500][table] Moved DecimalDataUtils and SqlDateTimeUtils to table-common

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

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

slinkydeveloper commented on pull request #17454: URL: https://github.com/apache/flink/pull/17454#issuecomment-948474111 > Can we move the DecimalDataUtils class into org.apache.flink.table.data.utils instead? I've moved `DecimalDataUtils` back to where it was, and just manually

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

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 #17534: [FLINK-24610][table-planner] Support sql projection common expression…

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…

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…

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…

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…

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-21068) Add new timeout options for Elasticsearch connector

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

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 #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 3616cbfa7a3d536f132a2fb2f8a758974cbcfef0 Azure:

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432327#comment-17432327 ] Chesnay Schepler commented on FLINK-24294: -- Isn't this something where the guava Closer can

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

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 #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * 390c1ee73543cca5238bf9ff74f7c884d4a2e95a Azure:

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

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…

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

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

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

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…

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

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…

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 #17515: [FLINK-24575][table-runtime] Migrate TestRowDataCsvInputFormat to DeserializationSchemaFactory

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

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

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

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

[ 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

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

[ 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

[ 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] [Updated] (FLINK-24610) Flink projection common expression elimination

[ 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

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

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-24610) Flink projection common expression elimination

[ 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] flinkbot edited a comment on pull request #17515: [FLINK-24575][table-runtime] Migrate TestRowDataCsvInputFormat to DeserializationSchemaFactory

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…

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…

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

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 commented on pull request #17534: [FLINK-24610][table-planner] Support sql projection common expression…

flinkbot commented on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948414124 ## CI report: * 5b63e4f006233b086c33f093432228e01b7eab1d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot commented on pull request #17534: URL: https://github.com/apache/flink/pull/17534#issuecomment-948413769 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-24610) Flink projection common expression elimination

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

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

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

[ 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

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

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] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

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

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

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

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

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

Chesnay Schepler created FLINK-24609: Summary: flink-rpc-akka uses wrong Scala version property for parser-combinators Key: FLINK-24609 URL: https://issues.apache.org/jira/browse/FLINK-24609

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

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

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

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r733463476 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java ## @@ -103,33 +106,56 @@ * }

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

flinkbot edited a comment on pull request #17533: URL: https://github.com/apache/flink/pull/17533#issuecomment-948396321 ## CI report: * 5d34492f1f5bafd4d725a6740640feac1c2434ea Azure:

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

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

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

tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_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

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…

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] flinkbot commented on pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24541: --- Labels: pull-request-available (was: ) > ConfigurationUtils#assembleDynamicConfigsStr

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

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] JingGe edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

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] slinkydeveloper edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

slinkydeveloper edited a comment 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

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

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] twalthr commented on a change in pull request #17515: [FLINK-24575][table-runtime] Migrate TestRowDataCsvInputFormat to DeserializationSchemaFactory

twalthr commented on a change in pull request #17515: URL: https://github.com/apache/flink/pull/17515#discussion_r733431078 ## File path: flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/filesystem/TestCsvDeserializationSchema.java ## @@ -0,0 +1,126 @@ +/*

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

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] flinkbot edited a comment on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

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

[jira] [Commented] (FLINK-24563) Comparing timstamp_ltz with random string throws NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-24563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432274#comment-17432274 ] Timo Walther commented on FLINK-24563: -- Tests re-enabled in master:

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

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

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

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

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

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] twalthr closed pull request #17512: [FLINK-24563][table-planner][test] Re-enable tests for invalid strings->timestamp_tz cast

twalthr closed pull request #17512: URL: https://github.com/apache/flink/pull/17512 -- 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] xuyangzhong commented on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

xuyangzhong commented on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-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] slinkydeveloper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

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

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

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] xuyangzhong commented on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

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 edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

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

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

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] [Assigned] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters

[ 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] tsreaper edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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,

<    1   2   3   4   5   >