[jira] [Updated] (FLINK-7380) Limit usage of Row type

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

[jira] [Updated] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

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

[jira] [Updated] (FLINK-7392) Enable more predicate push-down in joins

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

[jira] [Updated] (FLINK-22898) HiveParallelismInference limit return wrong parallelism

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

[jira] [Updated] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

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

[jira] [Updated] (FLINK-7403) Remove expandLocalRef() before code generation

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

[jira] [Updated] (FLINK-7423) Always reuse an instance to get elements from the inputFormat

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

[jira] [Updated] (FLINK-7401) EnvironmentInformation.getMaxJvmHeapMemory does not return the value given via -Xmx

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

[jira] [Updated] (FLINK-7275) Differentiate between normal and power-user cli options in Gelly examples

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

[jira] [Updated] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API

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

[jira] [Updated] (FLINK-13648) Support "IS NOT DISTINCT FROM" operator in lookup join

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

[jira] [Updated] (FLINK-13788) Document state migration constraints on keys

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

[jira] [Updated] (FLINK-13172) JVM crash with dynamic netty-tcnative wrapper to openSSL on some OS

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

[jira] [Updated] (FLINK-13696) Revisit & update Flink's public API annotations

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

[jira] [Updated] (FLINK-22450) SQL parser fails to parse subquery containing INTERSECT in a view

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

[jira] [Updated] (FLINK-13479) Cassandra POJO Sink - Prepared Statement query does not have deterministic ordering of columns - causing prepared statement cache overflow

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

[jira] [Updated] (FLINK-13771) Support kqueue Netty transports (MacOS)

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

[jira] [Updated] (FLINK-13695) Integrate checkpoint notifications into StreamTask's lifecycle

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

[jira] [Updated] (FLINK-18602) Support specific offset for topic list for kafka connector

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

[jira] [Updated] (FLINK-22418) The currently activated tab in the same page isn't consistent

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

[jira] [Updated] (FLINK-13470) Enhancements to Flink Table API for blink planner

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

[jira] [Closed] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

[ https://issues.apache.org/jira/browse/FLINK-15586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-15586. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Updated] (FLINK-13867) Write file only once when doing blocking broadcast shuffle

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

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

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

[jira] [Updated] (FLINK-22411) Checkpoint failed caused by Mkdirs failed to create file, the path for Flink state.checkpoints.dir in docker-compose can not work from Flink Operations Playground

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

[jira] [Updated] (FLINK-13950) should report an error if hive table partition keys are not in the last schema fields

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

[jira] [Closed] (FLINK-17477) resumeConsumption call should happen as quickly as possible to minimise latency

[ https://issues.apache.org/jira/browse/FLINK-17477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-17477. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Closed] (FLINK-19537) Processed in-flight bytes metric is not accurate

[ https://issues.apache.org/jira/browse/FLINK-19537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-19537. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Updated] (FLINK-20791) Support local aggregate push down for Blink batch planner

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

[jira] [Updated] (FLINK-21184) Support temporary table/function for hive connector

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

[jira] [Updated] (FLINK-21456) TableResult#print() should correctly stringify values of all data types in SQL format

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

[jira] [Updated] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

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

[GitHub] [flink] flinkbot edited a comment on pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

flinkbot edited a comment on pull request #16102: URL: https://github.com/apache/flink/pull/16102#issuecomment-856195315 ## CI report: * 7c83973c43ec0b6114c9c38e75aa751ae3b89000 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

flinkbot edited a comment on pull request #16102: URL: https://github.com/apache/flink/pull/16102#issuecomment-856195315 ## CI report: * 7c83973c43ec0b6114c9c38e75aa751ae3b89000 Azure:

[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 ] Maciej Bryński updated FLINK-22984: --- Priority: Critical (was: Major) > UnsupportedOperationException when using Python UDF to

[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 ] Maciej Bryński updated FLINK-22984: --- Description: Hi, I'm trying to use output of Python UDF (parse_data) to set watermark for

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

Maciej Bryński created FLINK-22984: -- Summary: UnsupportedOperationException when using Python UDF to generate watermark Key: FLINK-22984 URL: https://issues.apache.org/jira/browse/FLINK-22984

[GitHub] [flink] flinkbot edited a comment on pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

flinkbot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-824854089 ## CI report: * d0a2206ba3fa48643f99b335a30516508be599e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

flinkbot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-824854089 ## CI report: * ae490b08b7ba5f1815622f8cf833b0220bc380e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

flinkbot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-824854089 ## CI report: * ae490b08b7ba5f1815622f8cf833b0220bc380e1 Azure:

[jira] [Commented] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363025#comment-17363025 ] Maciej Bryński commented on FLINK-22982: When using java UDF everything is working fine. >

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

echauchot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-860752853 Addressed your comments and squashed. Also fixed the spotless compile issue PTAL -- This is an automated message from the Apache Git Service. To respond to the

[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-860752853 Addressed your comments and squashed. PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

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

echauchot commented on a change in pull request #15725: URL: https://github.com/apache/flink/pull/15725#discussion_r651021811 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat.java ## @@ -168,6 +176,16 @@ public void

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

echauchot commented on a change in pull request #15725: URL: https://github.com/apache/flink/pull/15725#discussion_r651021292 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat.java ## @@ -97,11 +97,13 @@ */

[jira] [Commented] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362959#comment-17362959 ] Maciej Bryński commented on FLINK-22982: I have same exception when using different SQL function

[jira] [Commented] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362958#comment-17362958 ] Bhagi commented on FLINK-22965: --- Hi can you update on this.still issue exists > Association with remote

[jira] [Created] (FLINK-22983) Support lazy evaluation in Flink SQL

Maciej Bryński created FLINK-22983: -- Summary: Support lazy evaluation in Flink SQL Key: FLINK-22983 URL: https://issues.apache.org/jira/browse/FLINK-22983 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22982) java.lang.ClassCastException when using Python UDF

Maciej Bryński created FLINK-22982: -- Summary: java.lang.ClassCastException when using Python UDF Key: FLINK-22982 URL: https://issues.apache.org/jira/browse/FLINK-22982 Project: Flink Issue

[jira] [Updated] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-22982: --- Description: Hi, I'm trying to use Python UDF with logical condition as argument.  

[jira] [Assigned] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman reassigned FLINK-21308: Assignee: Igal Shilman > Cancel "sendAfter" > -- > >

[jira] [Commented] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362943#comment-17362943 ] Igal Shilman commented on FLINK-21308: -- Hello [~stephanpelikan], I'm working on adding support for

[GitHub] [flink] flinkbot edited a comment on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

flinkbot edited a comment on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852114839 ## CI report: * 1ff384971b1065846e483e43900d7c09584bc663 Azure:

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

AHeise commented on a change in pull request #15725: URL: https://github.com/apache/flink/pull/15725#discussion_r650899088 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetInputFormat.java ## @@ -168,6 +176,16 @@ public void

[jira] [Updated] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22946: --- Fix Version/s: 1.13.2 1.14.0 > Network buffer deadlock introduced by

[jira] [Commented] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362905#comment-17362905 ] Piotr Nowojski commented on FLINK-22946: Hi [~guokuai.huang], thanks for reporting this issue. I

[jira] [Updated] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22946: --- Priority: Critical (was: Blocker) > Network buffer deadlock introduced by unaligned

[GitHub] [flink] zentol commented on pull request #16150: [FLINK-22878][core] Allow prefix syntax for ConfigOption.mapType

zentol commented on pull request #16150: URL: https://github.com/apache/flink/pull/16150#issuecomment-860586021 Just to double-check, are both syntaxes yaml compliant? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-7546) Support SUBMULTISET_OF Operator for Multiset SQL type

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

[jira] [Updated] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks

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

[jira] [Updated] (FLINK-7545) Support MEMBER OF Operator for Multiset SQL type

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

[jira] [Updated] (FLINK-7946) Add an option to truncate IDs to 8 characters

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

[jira] [Updated] (FLINK-8003) Support named ROW in Flink SQL

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

[jira] [Updated] (FLINK-7697) Add metrics for Elasticsearch Sink

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

[jira] [Updated] (FLINK-7554) Add a testing RuntimeContext to test utilities

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

[jira] [Updated] (FLINK-8236) Allow to set the parallelism of table queries

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

[jira] [Updated] (FLINK-7492) Memsql Connector

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

[jira] [Updated] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor

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

[jira] [Updated] (FLINK-7913) Add support for Kafka default partitioner

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

[jira] [Updated] (FLINK-8180) Refactor driver outputs

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

[jira] [Updated] (FLINK-7859) Allow field annotations to define TypeInformation

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

[jira] [Updated] (FLINK-8293) Rework Flink's type and serialization docs

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

[jira] [Updated] (FLINK-8090) Improve error message when registering different states under the same name.

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

[jira] [Updated] (FLINK-8277) Optimize code generation by using local references

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

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

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

[jira] [Updated] (FLINK-14079) Full data type support in planner

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

[jira] [Updated] (FLINK-14098) Support multiple statements for TableEnvironment

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

[jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope

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

[jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface

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

[jira] [Updated] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

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

[jira] [Updated] (FLINK-14410) Retrieve CharacterFilter once after registration

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

[jira] [Updated] (FLINK-14379) Supplement documentation about raw state

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

[jira] [Updated] (FLINK-14569) use flink to deal with batch task,when parallelism granter than 1, always 1 or 2 records loss

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

[jira] [Updated] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

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

[jira] [Updated] (FLINK-14625) Eliminate cross join in multi join to reduce cost

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

[jira] [Updated] (FLINK-14748) Migrate duration and memory size related ConfigOptions to typed options

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

[jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client

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

[jira] [Updated] (FLINK-14479) Strange exceptions found in log file after executing `test_udf.py`

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

[jira] [Updated] (FLINK-13954) Clean up ExecutionEnvironment / JobSubmission code paths

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

[GitHub] [flink] flinkbot edited a comment on pull request #15972: Add common source and operator metrics.

flinkbot edited a comment on pull request #15972: URL: https://github.com/apache/flink/pull/15972#issuecomment-844955772 ## CI report: * b81abcfa1dd746e706613b45895b2520c099b18f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15972: Add common source and operator metrics.

flinkbot edited a comment on pull request #15972: URL: https://github.com/apache/flink/pull/15972#issuecomment-844955772 ## CI report: * 51b78cc242ed0514bcd6c5ccf745a089bc46816e Azure:

[jira] [Commented] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362854#comment-17362854 ] Till Rohrmann commented on FLINK-22483: --- Hi [~edu05], I think one idea could be to move the

[jira] [Updated] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

[ https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22483: -- Labels: (was: stale-critical) > Recover checkpoints when JobMaster gains leadership >

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362848#comment-17362848 ] Till Rohrmann commented on FLINK-10644: --- Hi [~wangwj] at the moment I am a bit busy. That's why I

[jira] [Updated] (FLINK-22255) AdaptiveScheduler improvements/bugs

[ https://issues.apache.org/jira/browse/FLINK-22255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22255: -- Labels: (was: stale-major) > AdaptiveScheduler improvements/bugs >

[jira] [Assigned] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22073: Assignee: luoyuxia > ParquetFileCompactionITCase fails on Azure >

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362830#comment-17362830 ] Dawid Wysakowicz commented on FLINK-22073: -- Sure [~luoyuxia], I'll assign it to you. Thanks! >

[GitHub] [flink] flinkbot edited a comment on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

flinkbot edited a comment on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852114839 ## CI report: * a5eb4dd79253aa7e969f7da415a20b55912ae63c Azure:

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17362826#comment-17362826 ] luoyuxia commented on FLINK-22073: -- Hey [~dwysakowicz]  I would like to take a look at the issue. >

[GitHub] [flink] flinkbot edited a comment on pull request #16046: [FLINK-22737][table-planner-blink] Introduce CURRENT_WATERMARK()

flinkbot edited a comment on pull request #16046: URL: https://github.com/apache/flink/pull/16046#issuecomment-852114839 ## CI report: * a5eb4dd79253aa7e969f7da415a20b55912ae63c Azure:

<    1   2   3   4   >