[jira] [Closed] (FLINK-22057) Client submit job remotely to Flink cluster through Loadbalancer rest service --failed

[ https://issues.apache.org/jira/browse/FLINK-22057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22057. - Resolution: Information Provided > Client submit job remotely to Flink cluster through Loadbalan

[jira] [Closed] (FLINK-22938) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-22938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22938. - Resolution: Information Provided > Slot request bulk is not fulfillable! Could not allocate the

[jira] [Closed] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22139. - Resolution: Information Provided > Flink Jobmanager & Task Manger logs are not writing to the lo

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

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22662: Assignee: Xintong Song > YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

[jira] [Updated] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21608: - Labels: test-stability (was: auto-deprioritized-major test-stability) > YARNHighAvailabilityITC

[jira] [Closed] (FLINK-22285) YARNHighAvailabilityITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-22285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22285. Resolution: Duplicate > YARNHighAvailabilityITCase hangs > > >

[jira] [Updated] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21608: - Priority: Major (was: Minor) > YARNHighAvailabilityITCase.testClusterClientRetrieval fails with

[jira] [Created] (FLINK-23016) Job client must be a Coordination Request Gateway when submit a job on web ui

wen qi created FLINK-23016: -- Summary: Job client must be a Coordination Request Gateway when submit a job on web ui Key: FLINK-23016 URL: https://issues.apache.org/jira/browse/FLINK-23016 Project: Flink

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364699#comment-17364699 ] Robert Metzger commented on FLINK-22593: https://dev.azure.com/rmetzger/Flink/_b

[jira] [Comment Edited] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364691#comment-17364691 ] lynn1.zhang edited comment on FLINK-22994 at 6/17/21, 4:42 AM: ---

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364691#comment-17364691 ] lynn1.zhang commented on FLINK-22994: - public static void main(String[] args) {f

[jira] [Comment Edited] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364676#comment-17364676 ] Jingsong Lee edited comment on FLINK-22994 at 6/17/21, 4:27 AM: --

[jira] [Comment Edited] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364676#comment-17364676 ] Jingsong Lee edited comment on FLINK-22994 at 6/17/21, 4:24 AM: --

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364676#comment-17364676 ] Jingsong Lee commented on FLINK-22994: -- [~zicat] I didn't say the conversion is no

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364674#comment-17364674 ] Jingsong Lee commented on FLINK-22994: -- BTW, please update the description which is

[jira] [Assigned] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22994: Assignee: lynn1.zhang > Improve the performance of invoking nesting udf > ---

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364673#comment-17364673 ] Jingsong Lee commented on FLINK-22994: -- [~zicat] I think this is a good improvement

[jira] [Commented] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364672#comment-17364672 ] Xintong Song commented on FLINK-22980: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as BinaryData, like BinaryStringData. W

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

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22662: - Labels: test-stability (was: auto-deprioritized-critical test-stability) > YARNHighAvailability

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

[ https://issues.apache.org/jira/browse/FLINK-22662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364671#comment-17364671 ] Xintong Song commented on FLINK-22662: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-23015) Implement streaming window Deduplicate operator

JING ZHANG created FLINK-23015: -- Summary: Implement streaming window Deduplicate operator Key: FLINK-23015 URL: https://issues.apache.org/jira/browse/FLINK-23015 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-23014) Support streaming window Deduplicate in planner

JING ZHANG created FLINK-23014: -- Summary: Support streaming window Deduplicate in planner Key: FLINK-23014 URL: https://issues.apache.org/jira/browse/FLINK-23014 Project: Flink Issue Type: Sub-t

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364668#comment-17364668 ] Jingsong Lee commented on FLINK-22994: -- [~zicat] OK, I see... you gave a wrong exam

[jira] [Updated] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22891: - Affects Version/s: 1.13.1 > FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails

[jira] [Reopened] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22891: -- > FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure > -

[jira] [Commented] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364667#comment-17364667 ] Xintong Song commented on FLINK-22891: -- New instance on the 1.13 branch. https://d

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364666#comment-17364666 ] lynn1.zhang commented on FLINK-22994: - [^StringConverterTest.java] I also test the S

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Attachment: StringConverterTest.java > Improve the performance of invoking nesting udf > -

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364665#comment-17364665 ] Xintong Song commented on FLINK-22702: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23013) Introduce faker source connector

[ https://issues.apache.org/jira/browse/FLINK-23013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364660#comment-17364660 ] Jingsong Lee commented on FLINK-23013: -- [~jark] Thanks for the information. @[~kna

[jira] [Commented] (FLINK-23013) Introduce faker source connector

[ https://issues.apache.org/jira/browse/FLINK-23013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364659#comment-17364659 ] Jark Wu commented on FLINK-23013: - [~knaufk] already open sourced a flink faker connecto

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364658#comment-17364658 ] lynn1.zhang commented on FLINK-22994: - Hi [~lzljs3620320], ipip return the type of m

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Attachment: Test.java > Improve the performance of invoking nesting udf >

[jira] [Created] (FLINK-23013) Introduce faker source connector

Jingsong Lee created FLINK-23013: Summary: Introduce faker source connector Key: FLINK-23013 URL: https://issues.apache.org/jira/browse/FLINK-23013 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364645#comment-17364645 ] Wei-Che Wei commented on FLINK-22970: - Hi [~Leonard Xu] Could you assign this jira t

[jira] [Comment Edited] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364644#comment-17364644 ] Wei-Che Wei edited comment on FLINK-23012 at 6/17/21, 2:46 AM: ---

[jira] [Commented] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364644#comment-17364644 ] Wei-Che Wei commented on FLINK-23012: - Hi [~jark] > Add v1.13 docs link in "Pick Do

[jira] [Closed] (FLINK-22899) ValuesUpsertSinkFunction needs to use global upsert

[ https://issues.apache.org/jira/browse/FLINK-22899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22899. Resolution: Fixed Fixed via: master: 3a4036129865fcddb809335b3a55a949a75dc8ca > ValuesUpsertSink

[jira] [Commented] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364640#comment-17364640 ] Jingsong Lee commented on FLINK-22994: -- [~zicat] I mean, the cost of the converter 

[jira] [Updated] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

[ https://issues.apache.org/jira/browse/FLINK-23012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23012: Description: https://ci.apache.org/projects/flink/flink-docs-master/ !image-2021-06-17-10-26-29-125.png|

[jira] [Created] (FLINK-23012) Add v1.13 docs link in "Pick Docs Version" for master branch

Jark Wu created FLINK-23012: --- Summary: Add v1.13 docs link in "Pick Docs Version" for master branch Key: FLINK-23012 URL: https://issues.apache.org/jira/browse/FLINK-23012 Project: Flink Issue Typ

[jira] [Updated] (FLINK-22983) Support lazy evaluation of Python UDF in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22983: - Component/s: (was: Table SQL / Runtime) API / Python > Support lazy evaluat

[jira] [Commented] (FLINK-22983) Support lazy evaluation of Python UDF in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364638#comment-17364638 ] Jingsong Lee commented on FLINK-22983: -- [~maver1ck] Thanks for the explanation. >

[jira] [Updated] (FLINK-15455) Enable TCP connection reuse across multiple jobs.

[ https://issues.apache.org/jira/browse/FLINK-15455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-15455: Labels: (was: stale-major) > Enable TCP connection reuse across multiple jobs. > ---

[jira] [Commented] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364632#comment-17364632 ] Xintong Song commented on FLINK-22980: -- https://dev.azure.com/apache-flink/apache-f

[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&focusedCommentId=17364607#comment-17364607 ] Eduardo Winpenny Tejedor commented on FLINK-22483: -- OK [~trohrmann] I s

[jira] [Updated] (FLINK-17987) KafkaITCase.testStartFromGroupOffsets fails with SchemaException: Error reading field

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

[jira] [Updated] (FLINK-12046) Increase records per invocation for serializerAvro benchmark to stabilize it

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

[jira] [Updated] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog

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

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community ma

[jira] [Updated] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[jira] [Updated] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java

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

[jira] [Updated] (FLINK-4808) Allow skipping failed checkpoints

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

[jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

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

[jira] [Updated] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups

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

[jira] [Updated] (FLINK-4498) Better Cassandra sink documentation

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

[jira] [Updated] (FLINK-4855) Add partitionedKeyBy to DataStream

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

[jira] [Updated] (FLINK-4854) Efficient Batch Operator in Streaming

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

[jira] [Updated] (FLINK-22932) RocksDBStateBackendWindowITCase fails with savepoint timeout

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

[jira] [Updated] (FLINK-22533) Allow creating custom metrics

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

[jira] [Updated] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails

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

[jira] [Updated] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

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

[jira] [Updated] (FLINK-22584) Use protobuf-shaded in StateFun core.

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

[jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

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

[jira] [Updated] (FLINK-4965) AllPairsShortestPaths

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

[jira] [Updated] (FLINK-22945) StackOverflowException can happen when a large scale job is CANCELING/FAILING

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

[jira] [Updated] (FLINK-15455) Enable TCP connection reuse across multiple jobs.

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

[jira] [Updated] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

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

[jira] [Updated] (FLINK-12022) Enable StreamWriter to update file length on sync flush

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

[jira] [Updated] (FLINK-12008) Support read a whole directory or multiple input data files for read apis of HadoopInputs

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

[jira] [Updated] (FLINK-12061) Add more window operator contract tests to table runtime

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

[jira] [Updated] (FLINK-12138) Limit input split count of each source task for better failover experience

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

[jira] [Updated] (FLINK-12045) Support force migration between incompatible state schemas/serializers

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

[jira] [Updated] (FLINK-12113) User code passing to fromCollection(Iterator, Class) not cleaned

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

[jira] [Updated] (FLINK-22611) add documentation about the semantics of timestamp for time window output

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

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

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

[jira] [Updated] (FLINK-12182) AggregateProjectMergeRule can not handle LogicalWindowAggregate

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

[jira] [Updated] (FLINK-12149) Support Proto for Streaming File Sink

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

[jira] [Updated] (FLINK-12252) Support not escaped table name for External Catalogs in INSERT SQL statement

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

[jira] [Updated] (FLINK-12256) Implement Confluent Schema Registry Catalog

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

[jira] [Updated] (FLINK-12210) Fix a bug in AbstractPagedInputView.readLine

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

[jira] [Updated] (FLINK-22857) Add possibility to call built-in functions in SpecializedFunction

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

[jira] [Updated] (FLINK-22844) Add doc to introduce ExplainDetails for EXPLAIN sytnax

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

[jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown

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

[jira] [Assigned] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-23003: - Assignee: Yanfei Lei > Resource leak in RocksIncrementalSnapshotStrategy >

[jira] [Commented] (FLINK-22886) Thread leak in RocksDBStateUploader

[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364376#comment-17364376 ] Yue Ma commented on FLINK-22886: [~roman_khachatryan]  Follow your suggestion, i merge t

[jira] [Updated] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23011: --- Issue Type: Bug (was: New Feature) > FLIP-27 sources are generating non-deterministic resul

[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 ] Guokuai Huang updated FLINK-22946: -- Labels: pull-request-available (was: stale-blocker) > Network buffer deadlock introduced by u

[jira] [Commented] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

[ https://issues.apache.org/jira/browse/FLINK-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364270#comment-17364270 ] Robert Metzger commented on FLINK-13703: it seems that we really can relax the c

[jira] [Assigned] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

[ https://issues.apache.org/jira/browse/FLINK-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13703: -- Assignee: Robert Metzger > AvroTypeInfo requires objects to be strict POJOs (mutable,

[jira] [Assigned] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

[ https://issues.apache.org/jira/browse/FLINK-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-13703: -- Assignee: (was: Robert Metzger) > AvroTypeInfo requires objects to be strict POJO

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363608#comment-17363608 ] Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:59 AM: ---

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363608#comment-17363608 ] Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:55 AM: ---

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363608#comment-17363608 ] Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:51 AM: ---

[jira] [Comment Edited] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364252#comment-17364252 ] Piotr Nowojski edited comment on FLINK-23011 at 6/16/21, 11:36 AM: ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17364253#comment-17364253 ] Dian Fu commented on FLINK-22984: - Thanks [~maver1ck] for reporting this issue. This is

[jira] [Commented] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364252#comment-17364252 ] Piotr Nowojski commented on FLINK-23011: [~AHeise] suggested that as a hotfix we

[jira] [Comment Edited] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364191#comment-17364191 ] Piotr Nowojski edited comment on FLINK-23011 at 6/16/21, 11:27 AM: ---

[jira] [Comment Edited] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364191#comment-17364191 ] Piotr Nowojski edited comment on FLINK-23011 at 6/16/21, 11:24 AM: ---

  1   2   >