[jira] [Commented] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

[ https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350801#comment-17350801 ] Piotr Nowojski commented on FLINK-16641: Hey [~kevin.cyj], sorry for the delay. I'm currently

[jira] [Updated] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry

[ https://issues.apache.org/jira/browse/FLINK-22763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samuel Fiddis updated FLINK-22763: -- Description: In PyFlink, attempting to connect to a avro-confluent kafka stream where the

[jira] [Updated] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry

[ https://issues.apache.org/jira/browse/FLINK-22763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samuel Fiddis updated FLINK-22763: -- Description: In PyFlink, attempting to connect to a avro-confluent kafka stream where the

[jira] [Commented] (FLINK-22762) cannot use set table.sql-dialect=hive;

[ https://issues.apache.org/jira/browse/FLINK-22762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350797#comment-17350797 ] JasonLee commented on FLINK-22762: -- Hi xueluo, I tested it according to your above process and no

[jira] [Updated] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry

[ https://issues.apache.org/jira/browse/FLINK-22763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samuel Fiddis updated FLINK-22763: -- Summary: avro-confluent format does not allow for authorization credentials to be supplied to

[jira] [Created] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registery

Samuel Fiddis created FLINK-22763: - Summary: avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registery Key: FLINK-22763 URL:

[GitHub] [flink] wuchong closed pull request #10880: [FLINK-15469][SQL] Update UpsertStreamTableSink and RetractStreamTabl…

wuchong closed pull request #10880: URL: https://github.com/apache/flink/pull/10880 -- 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. For queries about this service,

[GitHub] [flink] cuspymd commented on a change in pull request #15986: [FLINK-22155][table] EXPLAIN statement should validate insert and query separately

cuspymd commented on a change in pull request #15986: URL: https://github.com/apache/flink/pull/15986#discussion_r638441450 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java ## @@ -844,16

[jira] [Assigned] (FLINK-22760) HiveParser::setCurrentTimestamp fails with hive-3.1.2

[ https://issues.apache.org/jira/browse/FLINK-22760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-22760: -- Assignee: 罗宇侠 (was: Rui Li) > HiveParser::setCurrentTimestamp fails with hive-3.1.2 >

[jira] [Updated] (FLINK-22762) cannot use set table.sql-dialect=hive;

[ https://issues.apache.org/jira/browse/FLINK-22762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22762: Component/s: (was: API / Core) Connectors / Hive > cannot use set

[GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

paul8263 commented on a change in pull request #15927: URL: https://github.com/apache/flink/pull/15927#discussion_r638417597 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoadersTest.java ## @@ -208,6 +212,50 @@

[GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

paul8263 commented on a change in pull request #15927: URL: https://github.com/apache/flink/pull/15927#discussion_r638417384 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoadersTest.java ## @@ -208,6 +212,50 @@

[jira] [Commented] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350763#comment-17350763 ] Yang Wang commented on FLINK-22663: --- The reason why decreasing the value of

[GitHub] [flink] flinkbot edited a comment on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation

flinkbot edited a comment on pull request #15994: URL: https://github.com/apache/flink/pull/15994#issuecomment-847462495 ## CI report: * 627c38a4894445368e1a9d249dff9a588d089e02 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * 77caa970a0350585ebeb226e2d823e74b12511be Azure:

[GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

paul8263 commented on a change in pull request #15927: URL: https://github.com/apache/flink/pull/15927#discussion_r638418295 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoadersTest.java ## @@ -208,6 +212,64 @@

[GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

paul8263 commented on a change in pull request #15927: URL: https://github.com/apache/flink/pull/15927#discussion_r638418219 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoadersTest.java ## @@ -208,6 +212,64 @@

[jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350748#comment-17350748 ] John Phelan commented on FLINK-21439: - Do we need to create a {{FailureHandlingResult}} in order to

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * 44a0ac6333880616e97e1401aa9e2f38c0de087e Azure:

[jira] [Commented] (FLINK-22762) cannot use set table.sql-dialect=hive;

[ https://issues.apache.org/jira/browse/FLINK-22762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350731#comment-17350731 ] xingyuan cheng commented on FLINK-22762: I will pay attention to this issue > cannot use set

[jira] [Updated] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22038: - Labels: (was: stale-assigned) > Update TopN node to be without rowNumber if rowNumber field is projected out

[jira] [Commented] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350730#comment-17350730 ] Andy commented on FLINK-22038: -- Hi, I'm still working on this, sorry for late response. > Update TopN node

[jira] [Created] (FLINK-22762) cannot use set table.sql-dialect=hive;

xueluo created FLINK-22762: -- Summary: cannot use set table.sql-dialect=hive; Key: FLINK-22762 URL: https://issues.apache.org/jira/browse/FLINK-22762 Project: Flink Issue Type: Bug

[GitHub] [flink] zoucao commented on pull request #15987: [FLINK-22437][table-planner-blink]set parallelism for not null filter

zoucao commented on pull request #15987: URL: https://github.com/apache/flink/pull/15987#issuecomment-847478203 Hi @godfreyhe，if you are free please leave some comments about this pr. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * 44a0ac6333880616e97e1401aa9e2f38c0de087e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation

flinkbot edited a comment on pull request #15994: URL: https://github.com/apache/flink/pull/15994#issuecomment-847462495 ## CI report: * 627c38a4894445368e1a9d249dff9a588d089e02 Azure:

[GitHub] [flink] flinkbot commented on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation

flinkbot commented on pull request #15994: URL: https://github.com/apache/flink/pull/15994#issuecomment-847462495 ## CI report: * 627c38a4894445368e1a9d249dff9a588d089e02 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation

flinkbot commented on pull request #15994: URL: https://github.com/apache/flink/pull/15994#issuecomment-847457097 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] alec-brooks opened a new pull request #15994: Fix typo in JDBC Execution Options Documentation

alec-brooks opened a new pull request #15994: URL: https://github.com/apache/flink/pull/15994 The method is `withBatchSize` ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC.

[jira] [Updated] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16027: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-15861) Change TableEnvironmentImpl to StreamTableEnvironmentImpl in python blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15861: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-15922) Show "Warn - received late message for checkpoint" only when checkpoint actually expired

[ https://issues.apache.org/jira/browse/FLINK-15922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15922: --- Labels: auto-deprioritized-major usability (was: stale-major usability) Priority:

[jira] [Updated] (FLINK-22440) UpsertKafkaTableITCase fail due to create topic timeout

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

[jira] [Updated] (FLINK-22662) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail

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

[jira] [Updated] (FLINK-16024) support filter pushdown in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16024: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

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

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

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

[jira] [Updated] (FLINK-15378) StreamFileSystemSink supported mutil hdfs plugins.

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

[jira] [Updated] (FLINK-18640) Fix PostgresDialect doesn't quote the identifiers

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

[jira] [Updated] (FLINK-15693) Stop receiving incoming RPC messages when RpcEndpoint is closing

[ https://issues.apache.org/jira/browse/FLINK-15693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15693: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15471: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-15740) Remove Deadline#timeLeft()

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

[jira] [Updated] (FLINK-15924) Detect and log blocking main thread operations

[ https://issues.apache.org/jira/browse/FLINK-15924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15924: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-15325) Input location preference which affects task distribution may make certain job performance worse

[ https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15325: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16023: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-18541) Verify the Elasticsearch authentication option in end to end test

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

[jira] [Updated] (FLINK-15524) Some links in Chinese documents points to English documents by mistake

[ https://issues.apache.org/jira/browse/FLINK-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15524: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16116) Remove shading from oss filesystems build

[ https://issues.apache.org/jira/browse/FLINK-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16116: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

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

[jira] [Updated] (FLINK-15928) Batch mode in blink planner caused IndexOutOfBoundsException error

[ https://issues.apache.org/jira/browse/FLINK-15928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15928: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

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

[jira] [Updated] (FLINK-16277) StreamTableEnvironment.toAppendStream fails with Decimal types

[ https://issues.apache.org/jira/browse/FLINK-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16277: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

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

[jira] [Updated] (FLINK-21755) Remove flink-runtime dependency from metric reporters

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

[GitHub] [flink] flinkbot edited a comment on pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * d55f8912d2aea880925f4aa631467e8f9679d501 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * d55f8912d2aea880925f4aa631467e8f9679d501 Azure:

[jira] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350597#comment-17350597 ] Alexey Trenikhin commented on FLINK-12675: -- Does new  Source interface support suspend/resume ?

[GitHub] [flink] flinkbot edited a comment on pull request #15993: Merge pull request #1 from apache/master

flinkbot edited a comment on pull request #15993: URL: https://github.com/apache/flink/pull/15993#issuecomment-847105250 ## CI report: * 59c93763d7b2c0fe314d429ea547ef09a8193863 Azure:

[jira] [Updated] (FLINK-22761) Cannot remove POJO fields

[ https://issues.apache.org/jira/browse/FLINK-22761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ygor Allan de Fraga updated FLINK-22761: Description: I tested a schema evolution in a state using POJO and no problem was

[jira] [Updated] (FLINK-22761) Cannot remove POJO fields

[ https://issues.apache.org/jira/browse/FLINK-22761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ygor Allan de Fraga updated FLINK-22761: Description: I tested a schema evolution in a state using POJO and no problem was

[GitHub] [flink] flinkbot edited a comment on pull request #15993: Merge pull request #1 from apache/master

flinkbot edited a comment on pull request #15993: URL: https://github.com/apache/flink/pull/15993#issuecomment-847105250 ## CI report: * 59c93763d7b2c0fe314d429ea547ef09a8193863 Azure:

[GitHub] [flink] flinkbot commented on pull request #15993: Merge pull request #1 from apache/master

flinkbot commented on pull request #15993: URL: https://github.com/apache/flink/pull/15993#issuecomment-847105250 ## CI report: * 59c93763d7b2c0fe314d429ea547ef09a8193863 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-22761) Cannot remove POJO fields

Ygor Allan de Fraga created FLINK-22761: --- Summary: Cannot remove POJO fields Key: FLINK-22761 URL: https://issues.apache.org/jira/browse/FLINK-22761 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #15993: Merge pull request #1 from apache/master

flinkbot commented on pull request #15993: URL: https://github.com/apache/flink/pull/15993#issuecomment-847090768 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] wuhutongchao opened a new pull request #15993: Merge pull request #1 from apache/master

wuhutongchao opened a new pull request #15993: URL: https://github.com/apache/flink/pull/15993 1 ## 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

[GitHub] [flink] wuhutongchao commented on pull request #15993: Merge pull request #1 from apache/master

wuhutongchao commented on pull request #15993: URL: https://github.com/apache/flink/pull/15993#issuecomment-847087303 1 -- 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.

[GitHub] [flink] echauchot commented on pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

echauchot commented on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-847084989 @AHeise same comment as in https://github.com/apache/flink/pull/15156#issuecomment-847073898 ParquetInputFormat.java was removed -- This is an automated message from the

[GitHub] [flink] echauchot edited a comment on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

echauchot edited a comment on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-847073898 @AHeise ParquetInputFormat base class was removed since I submitted my PR hence the compilation issues, commit ce3631af7313855f675e29b8faa386f6e5a2d43c removed it.

[GitHub] [flink] echauchot commented on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

echauchot commented on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-847073898 @AHeise ParquetInputFormat base class was removed since I submitted my PR hence the compilation issues, commit ce3631af7313855f675e29b8faa386f6e5a2d43c removed it. This

[GitHub] [flink] flinkbot edited a comment on pull request #15992: [FLINK-22759][docs] Correct the applicability of some RocksDB related options as per operator

flinkbot edited a comment on pull request #15992: URL: https://github.com/apache/flink/pull/15992#issuecomment-846929996 ## CI report: * b0bb65f033ea4817a3e33137430f794f4d7814f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * e7bacdbc8fb620fe2e6c81ff2c664dbd8ab6cc19 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * 44a0ac6333880616e97e1401aa9e2f38c0de087e Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #15939: [FLINK-15390][Connectors/ORC][Connectors/Hive]List/Map/Struct types support for vectorized orc reader

lirui-apache commented on a change in pull request #15939: URL: https://github.com/apache/flink/pull/15939#discussion_r636891521 ## File path: flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcArrayColumnVector.java ## @@ -0,0 +1,49 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #15987: [FLINK-22437][table-planner-blink]set parallelism for not null filter

flinkbot edited a comment on pull request #15987: URL: https://github.com/apache/flink/pull/15987#issuecomment-845883196 ## CI report: * d47f5f72fafd68587477c49fbe2b365a511a0cc3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * 40bdaf053a4781b5d2555be62850288d72b70729 Azure:

[GitHub] [flink] JasonLeeCoding commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

JasonLeeCoding commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-847018314 OK , Thanks for your review -- 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

[jira] [Created] (FLINK-22760) HiveParser::setCurrentTimestamp fails with hive-3.1.2

Rui Li created FLINK-22760: -- Summary: HiveParser::setCurrentTimestamp fails with hive-3.1.2 Key: FLINK-22760 URL: https://issues.apache.org/jira/browse/FLINK-22760 Project: Flink Issue Type: Bug

[GitHub] [flink] wenlong88 commented on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

wenlong88 commented on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-846982062 LGTM -- 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.

[GitHub] [flink] zicat commented on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

zicat commented on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-846980370 @wenlong88 Please help to review this PR again, thx. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system

[ https://issues.apache.org/jira/browse/FLINK-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16775: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-18981) Support column comment for Hive tables

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

[jira] [Updated] (FLINK-19016) Checksum mismatch when restore from RocksDB

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

[jira] [Updated] (FLINK-19558) Umbrella Ticket for upgrading the REST API

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

[jira] [Updated] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16774: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

[ https://issues.apache.org/jira/browse/FLINK-16698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16698: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16682) Make batch size configurable for orc reader

[ https://issues.apache.org/jira/browse/FLINK-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16682: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16552) Cannot include Option fields in any Table join

[ https://issues.apache.org/jira/browse/FLINK-16552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16552: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16548: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16324: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16751) Expose bind port for Flink metric query service

[ https://issues.apache.org/jira/browse/FLINK-16751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16751: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16421) Changing default catalog to hive without changing default database fails

[ https://issues.apache.org/jira/browse/FLINK-16421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16421: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16468: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16452) Insert into static partition doesn't support order by or limit

[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16452: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices.

[ https://issues.apache.org/jira/browse/FLINK-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16701: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16506: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16080) Translate "Table API & SQL" pages into Chinese

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

[jira] [Updated] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16612: --- Labels: Client JobName RESTful auto-deprioritized-major (was: Client JobName RESTful

[jira] [Updated] (FLINK-16731) Support SHOW PARTITIONS table command in TableEnvironment and SQL Client

[ https://issues.apache.org/jira/browse/FLINK-16731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16731: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Commented] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350348#comment-17350348 ] Yun Gao commented on FLINK-21578: - I'll continue to consider this issue in the next release. >

[jira] [Commented] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown

[ https://issues.apache.org/jira/browse/FLINK-22663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350345#comment-17350345 ] Jinhong Liu commented on FLINK-22663: - It is really strange, but all the issues I mentioned before 

  1   2   >