[jira] [Closed] (FLINK-23006) issue in configuring History server

[ https://issues.apache.org/jira/browse/FLINK-23006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23006. - Resolution: Not A Problem > issue in configuring History server > -

[jira] [Updated] (FLINK-23006) issue in configuring History server

[ https://issues.apache.org/jira/browse/FLINK-23006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23006: -- Priority: Minor (was: Blocker) > issue in configuring History server > -

[jira] [Commented] (FLINK-23006) issue in configuring History server

[ https://issues.apache.org/jira/browse/FLINK-23006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364730#comment-17364730 ] Till Rohrmann commented on FLINK-23006: --- Are you sure that {{historyserver.web.add

[jira] [Assigned] (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:all-tabpanel ] Jark Wu reassigned FLINK-22970: --- Assignee: Wei-Che Wei > The documentation for `TO_TIMESTAMP` UDF has an incorrect description > ---

[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=17364733#comment-17364733 ] Till Rohrmann commented on FLINK-22483: --- Where else is {{CompletedCheckpointStore:

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364734#comment-17364734 ] Robert Metzger commented on FLINK-22257: I'm proposing to extend the {{ConfigOpt

[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=17364736#comment-17364736 ] Yangze Guo commented on FLINK-22891: I'll take another look into it. > FineGrainedS

[jira] [Updated] (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:all-tabpanel ] Wei-Che Wei updated FLINK-22970: Affects Version/s: 1.14.0 > The documentation for `TO_TIMESTAMP` UDF has an incorrect description

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

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364740#comment-17364740 ] Roman Khachatryan commented on FLINK-23003: --- Merged into master as 8be1058a605

[jira] [Assigned] (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 reassigned FLINK-22891: Assignee: Yangze Guo > FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fail

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364745#comment-17364745 ] Timo Walther commented on FLINK-22257: -- We should include [~AHeise] here as well. T

[jira] [Commented] (FLINK-22995) Failed to acquire lease 'ConfigMapLock: .... retrying...

[ https://issues.apache.org/jira/browse/FLINK-22995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364746#comment-17364746 ] Bhagi commented on FLINK-22995: --- Hi Till, I have 2 flink clusters in different namespace.

[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=17364747#comment-17364747 ] Eduardo Winpenny Tejedor commented on FLINK-22483: -- [~trohrmann] that's

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

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-22968: -- > Improve exception message when using toAppendStream[String] > --

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

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22968. Resolution: Won't Fix Let's not put more effort in deprecated APIs. > Improve exception message

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

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22968: - Comment: was deleted (was: Let's not put more effort in deprecated APIs. ) > Improve exception

[jira] [Commented] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364750#comment-17364750 ] Dawid Wysakowicz commented on FLINK-22326: -- I think updating the documentation

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

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22968. Resolution: Won't Fix Let's not put more effort into deprecated APIs. The 1.13 documentation clear

[jira] [Comment Edited] (FLINK-22326) Job contains Iterate Operator always fails on Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364750#comment-17364750 ] Dawid Wysakowicz edited comment on FLINK-22326 at 6/17/21, 7:39 AM: --

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364753#comment-17364753 ] Robert Metzger commented on FLINK-22257: Besides the {{pipeline.}} options, the

[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=17364755#comment-17364755 ] Xintong Song commented on FLINK-22662: -- [~fly_in_gis] and I have looked into this i

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364758#comment-17364758 ] Yuan Mei commented on FLINK-22420: -- The failure of this task is caused by "Recovery is

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

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364760#comment-17364760 ] Yanfei Lei commented on FLINK-23003: Sure, opened.  [https://github.com/apache/flink

[jira] [Comment Edited] (FLINK-22420) UnalignedCheckpointITCase failed

[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364758#comment-17364758 ] Yuan Mei edited comment on FLINK-22420 at 6/17/21, 7:52 AM:

[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=17364761#comment-17364761 ] Konstantin Knauf commented on FLINK-23013: -- I'd personally prefer to keep it se

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364762#comment-17364762 ] Timo Walther commented on FLINK-22257: -- Maybe but not always. We should think about

[jira] [Comment Edited] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364762#comment-17364762 ] Timo Walther edited comment on FLINK-22257 at 6/17/21, 7:55 AM: --

[jira] [Commented] (FLINK-22420) UnalignedCheckpointITCase failed

[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364765#comment-17364765 ] Yuan Mei commented on FLINK-22420: -- I did see in FLINK-21996 that a second option/solut

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364768#comment-17364768 ] Timo Walther commented on FLINK-22257: -- It might also be useful to look into FLIP-8

[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=17364771#comment-17364771 ] Jingsong Lee commented on FLINK-23013: -- Putting it under Flink will allow more peop

[jira] [Created] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

Daniel Lenz created FLINK-23017: --- Summary: HELP in sql-client still shows the removed SOURCE functionality Key: FLINK-23017 URL: https://issues.apache.org/jira/browse/FLINK-23017 Project: Flink

[jira] [Updated] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Lenz updated FLINK-23017: Description: The sql-client still shows the SOURCE command in HELP, even though the command itsel

[jira] [Updated] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Lenz updated FLINK-23017: Description: The sql-client still shows the SOURCE command in HELP, even though the command itsel

[jira] [Updated] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Lenz updated FLINK-23017: Description: The sql-client still shows the SOURCE command in HELP, even though the command itsel

[jira] [Updated] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Lenz updated FLINK-23017: Description: The sql-client still shows the SOURCE command in HELP, even though the command itsel

[jira] [Created] (FLINK-23018) TTL state factory should handle extended state descriptors

Yun Tang created FLINK-23018: Summary: TTL state factory should handle extended state descriptors Key: FLINK-23018 URL: https://issues.apache.org/jira/browse/FLINK-23018 Project: Flink Issue Type

[jira] [Updated] (FLINK-23018) TTL state factory should handle extended state descriptors

[ https://issues.apache.org/jira/browse/FLINK-23018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23018: - Description: Currently, {{TtlStateFactory}} can only handle fixed type of state descriptors. As {{Value

[jira] [Resolved] (FLINK-23004) Fix misleading log

[ https://issues.apache.org/jira/browse/FLINK-23004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23004. Fix Version/s: 1.14.0 Assignee: Junfan Zhang Resolution: Fixed Fixed in master: 9785ea4ee8

[jira] [Created] (FLINK-23019) Avoid errors when identifiers use reserved keywords

Timo Walther created FLINK-23019: Summary: Avoid errors when identifiers use reserved keywords Key: FLINK-23019 URL: https://issues.apache.org/jira/browse/FLINK-23019 Project: Flink Issue Typ

[jira] [Commented] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

[ https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364798#comment-17364798 ] Wenhao Ji commented on FLINK-22452: --- Hi, [~mdemierre]. I've just created the FLIP for

[jira] [Updated] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Lenz updated FLINK-23017: Environment: (was: This affects 1.13.0 and 1.13.1) > HELP in sql-client still shows the remove

[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=17364806#comment-17364806 ] Konstantin Knauf commented on FLINK-23013: -- It would be great if we can find a

[jira] [Commented] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364807#comment-17364807 ] JING ZHANG commented on FLINK-22955: Hi, [~gsavl], as we discussed in maillist, the

[jira] [Created] (FLINK-23020) NullPointerException when running collect from Python API

Maciej Bryński created FLINK-23020: -- Summary: NullPointerException when running collect from Python API Key: FLINK-23020 URL: https://issues.apache.org/jira/browse/FLINK-23020 Project: Flink

[jira] [Updated] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-23020: --- Summary: NullPointerException when running collect twice from Python API (was: NullPointerE

[jira] [Updated] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-23020: --- Description: Hi,  I'm trying to use PyFlink from Jupyter Notebook and I'm getting NPE in f

[jira] [Updated] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-23020: --- Description: Hi,  I'm trying to use PyFlink from Jupyter Notebook and I'm getting NPE in f

[jira] [Updated] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maciej Bryński updated FLINK-23020: --- Description: Hi,  I'm trying to use PyFlink from Jupyter Notebook and I'm getting NPE in 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=17364811#comment-17364811 ] Jingsong Lee commented on FLINK-23013: -- (y) Yes, we need a website or something els

[jira] [Comment Edited] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364156#comment-17364156 ] tinawenqiao edited comment on FLINK-22974 at 6/17/21, 9:51 AM: ---

[jira] [Created] (FLINK-23021) Check if the restarted job topology is consistent on restart

Yun Gao created FLINK-23021: --- Summary: Check if the restarted job topology is consistent on restart Key: FLINK-23021 URL: https://issues.apache.org/jira/browse/FLINK-23021 Project: Flink Issue Typ

[jira] [Updated] (FLINK-22998) Flink SQL does not support block comment before SET command

[ https://issues.apache.org/jira/browse/FLINK-22998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-22998: Component/s: (was: Table SQL / Planner) Table SQL / API > Flink SQL does not

[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=17364815#comment-17364815 ] Jark Wu commented on FLINK-23013: - Isn't it https://flink-packages.org/ ? > Introduce

[jira] [Closed] (FLINK-22703) SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed

[ https://issues.apache.org/jira/browse/FLINK-22703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-22703. - Resolution: Duplicate This test use the same codebase that will be fixed in  https://iss

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364826#comment-17364826 ] Anton Kalashnikov commented on FLINK-22625: --- [~gaoyunhaii], I think I found th

[jira] [Updated] (FLINK-11982) BatchTableSourceFactory support Json Format File

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

[jira] [Updated] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator

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

[jira] [Updated] (FLINK-12003) Revert the config option about mapreduce.output.basename in HadoopOutputFormatBase

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

[jira] [Updated] (FLINK-11848) Delete outdated kafka topics caused UNKNOWN_TOPIC_EXCEPTIION

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

[jira] [Updated] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

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

[jira] [Updated] (FLINK-11934) Remove the deprecate methods in TableEnvironment

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

[jira] [Updated] (FLINK-11909) Provide default failure/timeout/backoff handling strategy for AsyncIO functions

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

[jira] [Updated] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

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

[jira] [Updated] (FLINK-11893) Update ecosystem page and add it to the navigation bar

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

[jira] [Updated] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

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

[jira] [Updated] (FLINK-11737) Support org.apache.hadoop.mapreduce.lib.output.MultipleOutputs output

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

[jira] [Updated] (FLINK-11818) Provide pipe transformation function for DataSet API

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

[jira] [Updated] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

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

[jira] [Updated] (FLINK-4088) Add interface to save and load TableSources

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

[jira] [Updated] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector

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

[jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

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

[jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files

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

[jira] [Updated] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse)

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

[jira] [Updated] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

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

[jira] [Updated] (FLINK-3997) PRNG Skip-ahead

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

[jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink

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

[jira] [Updated] (FLINK-3857) Add reconnect attempt to Elasticsearch host

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

[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0

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

[jira] [Updated] (FLINK-3462) Add position and magic number checks to record (de)serializers

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

[jira] [Updated] (FLINK-2396) Review the datasets of dynamic path and static path in iteration.

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

[jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink

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

[jira] [Updated] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

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

[jira] [Updated] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

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

[jira] [Updated] (FLINK-11799) KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException

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

[jira] [Updated] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

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

[jira] [Updated] (FLINK-3769) RabbitMQ Sink ability to publish to a different exchange

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

[jira] [Closed] (FLINK-22737) Add support for CURRENT_WATERMARK to SQL

[ https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22737. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in 1.14.0: 8bd215dc28ae431120e5b1a114a94ddc6e

[jira] [Assigned] (FLINK-22948) Scala example for toDataStream does not compile

[ https://issues.apache.org/jira/browse/FLINK-22948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-22948: Assignee: Timo Walther > Scala example for toDataStream does not compile > --

[jira] [Created] (FLINK-23022) Plugin classloader settings do not work as described

Dawid Wysakowicz created FLINK-23022: Summary: Plugin classloader settings do not work as described Key: FLINK-23022 URL: https://issues.apache.org/jira/browse/FLINK-23022 Project: Flink

[jira] [Closed] (FLINK-22948) Scala example for toDataStream does not compile

[ https://issues.apache.org/jira/browse/FLINK-22948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22948. Fix Version/s: 1.13.2 1.14.0 Resolution: Fixed Fixed in 1.14.0: e23337aa

[jira] [Updated] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23020: Component/s: (was: API / Python) Table SQL / Planner > NullPointerException when runn

[jira] [Commented] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364896#comment-17364896 ] Dian Fu commented on FLINK-23020: - This is more like an issue of the underlying planner.

[jira] [Commented] (FLINK-22587) Support aggregations in batch mode with DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17364897#comment-17364897 ] Etienne Chauchot commented on FLINK-22587: -- [~sjwiesman] thanks for the pointer

[jira] [Closed] (FLINK-22682) Checkpoint interval too large for higher DOP

[ https://issues.apache.org/jira/browse/FLINK-22682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22682. -- Resolution: Not A Bug This is not a bug - better logging merged to master as described above.

[jira] [Comment Edited] (FLINK-22682) Checkpoint interval too large for higher DOP

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

[jira] [Updated] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21952: --- Priority: Minor (was: Major) > Make all the "Connection reset by peer" exception wrapped as

[jira] [Updated] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

[ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21952: --- Affects Version/s: 1.14.0 1.13.1 1.12.4 > Make

[jira] [Updated] (FLINK-22367) JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out

[ https://issues.apache.org/jira/browse/FLINK-22367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22367: --- Priority: Minor (was: Major) > JobMasterStopWithSavepointITCase.terminateWithSavepointWitho

[jira] [Reopened] (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 ] Piotr Nowojski reopened FLINK-19537: > Processed in-flight bytes metric is not accurate > -

[jira] [Reopened] (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 ] Piotr Nowojski reopened FLINK-17477: > resumeConsumption call should happen as quickly as possible to minimise > latency > ---

  1   2   >