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

2021-05-21 Thread frank wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349599#comment-17349599 ] frank wang commented on FLINK-22443: can you give your table schema, maybe it can help me mock test

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2021-05-21 Thread frank wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349590#comment-17349590 ] frank wang commented on FLINK-8093: --- can we set clientId when user have not set the clientid,if so,

[jira] [Commented] (FLINK-17691) FlinkKafkaProducer transactional.id too long when using Semantic.EXACTLY_ONCE

2021-05-21 Thread freezhan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349586#comment-17349586 ] freezhan commented on FLINK-17691: -- [~nvolynets] https://issues.apache.org/jira/browse/FLINK-22452 >

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

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * af006de33d0d0e80b7a09c19ad812b8cd0d86e03 Azure:

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

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * af006de33d0d0e80b7a09c19ad812b8cd0d86e03 Azure:

[jira] [Commented] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'

2021-05-21 Thread Rion Williams (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349560#comment-17349560 ] Rion Williams commented on FLINK-20979: --- Hey all, I noticed the bot had tagged this so I thought

[jira] [Updated] (FLINK-20672) notifyCheckpointAborted RPC failure can fail JM

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

[jira] [Updated] (FLINK-20644) Check return type of ScalarFunction eval method shouldn't be void

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

[jira] [Updated] (FLINK-20538) sink.rolling-policy.file-size does not work in filesystem connector

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

[jira] [Updated] (FLINK-20979) Wrong description of 'sink.bulk-flush.max-actions'

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

[jira] [Updated] (FLINK-20670) Support query hints for Flink SQL

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

[jira] [Updated] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

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

[jira] [Updated] (FLINK-20633) test_configuration.test_add_all test failed in py35

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

[jira] [Updated] (FLINK-20572) HiveCatalog should be a standalone module

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

[jira] [Updated] (FLINK-22122) StreamingKafkaITCase Fail due to TestTimedOutException

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

[jira] [Updated] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

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

[jira] [Updated] (FLINK-20917) Support ALTER TABLE ... DROP PARTITION statement

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

[jira] [Updated] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer

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

[jira] [Closed] (FLINK-6986) Broken links to Photoshop images

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

[jira] [Closed] (FLINK-7605) JDBCOutputFormat autoCommit

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

[jira] [Updated] (FLINK-19425) Correct the usage of BulkWriter#flush and BulkWriter#finish

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

[jira] [Updated] (FLINK-19903) Allow to read metadata in filesystem connector

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

[jira] [Updated] (FLINK-19819) SourceReaderBase supports limit push down

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

[jira] [Updated] (FLINK-19955) Document cross-version compatibility

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

[jira] [Closed] (FLINK-7449) Improve and enhance documentation for incremental checkpoints

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

[jira] [Closed] (FLINK-7031) Document Gelly examples

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

[jira] [Closed] (FLINK-8157) Create a "Flink Resources" page on the Apache Flink project site

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

[jira] [Closed] (FLINK-7276) Gelly algorithm parameters

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

[jira] [Updated] (FLINK-19954) Move execution deployment tracking logic from legacy EG code to SchedulerNG

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

[jira] [Updated] (FLINK-19571) Port Transformation translation logic to TransformationTranslator framework

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

[jira] [Updated] (FLINK-19263) Enforce alphabetical order in configuration option docs

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

[jira] [Closed] (FLINK-7799) Improve performance of windowed joins

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

[jira] [Closed] (FLINK-6936) Add multiple targets support for custom partitioner

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

[jira] [Updated] (FLINK-19482) OrcRowInputFormat does not define serialVersionUID

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

[jira] [Updated] (FLINK-19432) Whether to capture the updates which don't change any monitored columns

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

[jira] [Updated] (FLINK-19670) Query on a view of temporal join throws ParseException

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

[jira] [Updated] (FLINK-19370) FileSourceTextLinesITCase.testContinuousTextFileSource failed as results mismatch

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

[jira] [Updated] (FLINK-19710) Fix performance regression to rebase FRocksDB with higher version RocksDB

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

[jira] [Updated] (FLINK-19929) Upgrade Kinesis dependencies to avoid protobuf 2.6.1

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

[jira] [Closed] (FLINK-7628) Add cookbooks to the documentation

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

[jira] [Updated] (FLINK-19613) Create flink-connector-files-test-utils for formats testing

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

[jira] [Updated] (FLINK-19896) Improve first-n-row fetching in the rank operator

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

[jira] [Updated] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent

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

[jira] [Updated] (FLINK-19524) Google Season of Docs - FLIP 60

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

[jira] [Closed] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

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

[jira] [Updated] (FLINK-22590) Add Scala implicit conversions for new API methods

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

[GitHub] [flink] flinkbot edited a comment on pull request #15950: [FLINK-22700] [api] Propagate watermarks to sink API

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-843682358 ## CI report: * 31a4ee9da09afc3e9d8f689c635fc314866c6f4b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15975: [FLINK-22725][coordination] SlotManagers unregister metrics in suspend()

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * c7293cdce7b7b106ec0db3f0bc41bf5cac79bf67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15989: [FLINK-22747] Upgrade to commons-io 2.8.0

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15989: URL: https://github.com/apache/flink/pull/15989#issuecomment-846005472 ## CI report: * 43eb3a2d7cd162057014781417f1240a0c16ad0c Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15950: [FLINK-22700] [api] Propagate watermarks to sink API

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-843682358 ## CI report: * 10e7ae7dcc1c335619f6415a39bbeae5fd1ac35d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15950: [FLINK-22700] [api] Propagate watermarks to sink API

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-843682358 ## CI report: * 10e7ae7dcc1c335619f6415a39bbeae5fd1ac35d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * 5a64f54467bca6bb7a5044bbcd2c654df5c978db Azure:

[jira] [Issue Comment Deleted] (FLINK-22753) Activate log-based Checkpoints for StateFun

2021-05-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22753: - Comment: was deleted (was: This is blocked on the implementation of [FLIP-158: Generalized

[jira] [Commented] (FLINK-22753) Activate log-based Checkpoints for StateFun

2021-05-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349382#comment-17349382 ] Stephan Ewen commented on FLINK-22753: -- This is blocked on the implementation of [FLIP-158:

[jira] [Updated] (FLINK-22753) Activate log-based Checkpoints for StateFun

2021-05-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22753: - Description: Once available, we should use log-based checkpointing in StateFun, to have

[jira] [Created] (FLINK-22753) Activate log-based Checkpoints for StateFun

2021-05-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22753: Summary: Activate log-based Checkpoints for StateFun Key: FLINK-22753 URL: https://issues.apache.org/jira/browse/FLINK-22753 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22752) Add robust default state configuration to StateFun

2021-05-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22752: - Description: We aim to reduce the state configuration complexity by applying a default

[jira] [Created] (FLINK-22752) Add robust default state configuration to StateFun

2021-05-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22752: Summary: Add robust default state configuration to StateFun Key: FLINK-22752 URL: https://issues.apache.org/jira/browse/FLINK-22752 Project: Flink Issue

[jira] [Created] (FLINK-22751) Reduce JVM Metaspace memory for StateFun

2021-05-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22751: Summary: Reduce JVM Metaspace memory for StateFun Key: FLINK-22751 URL: https://issues.apache.org/jira/browse/FLINK-22751 Project: Flink Issue Type:

[GitHub] [flink] NickBurkard commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-05-21 Thread GitBox
NickBurkard commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-846091998 I think the community is moving towards minimizing the usage of Scala in Flink: https://issues.apache.org/jira/browse/FLINK-13414 The current blocker for this

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15988: [FLINK-22745][zk] Trim starting slashes when creating a namespaced CuratorFramework facade

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15988: URL: https://github.com/apache/flink/pull/15988#issuecomment-845906000 ## CI report: * cc6da7ed3aae15aaeebaa67ada28d36f3fee0c70 Azure:

[jira] [Updated] (FLINK-22700) [FLIP-167] Propagate watermarks to Sink API

2021-05-21 Thread Eron Wright (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-22700: Description: Make it possible for sink functions / sink writers to propagate watermarks to

[jira] [Comment Edited] (FLINK-22700) [FLIP-167] Propagate watermarks to Sink API

2021-05-21 Thread Eron Wright (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347773#comment-17347773 ] Eron Wright edited comment on FLINK-22700 at 5/21/21, 4:15 PM: --- Update: am

[jira] [Updated] (FLINK-22700) [FLIP-167] Propagate watermarks to Sink API

2021-05-21 Thread Eron Wright (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-22700: Summary: [FLIP-167] Propagate watermarks to Sink API (was: Propagate watermarks to Sink API) >

[GitHub] [flink] virusdave commented on pull request #14544: [FLINK-20845] Drop Scala 2.11 support

2021-05-21 Thread GitBox
virusdave commented on pull request #14544: URL: https://github.com/apache/flink/pull/14544#issuecomment-846071503 Any updates on this? 2.11 isn't getting any newer, and lack of 2.13 support is really holding us back. If this is really a blocker to that, how can I help? -- This is an

[jira] [Commented] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349353#comment-17349353 ] Dawid Wysakowicz commented on FLINK-22686: -- That's what we want to do for 1.14. I'd prefer not

[GitHub] [flink] flinkbot edited a comment on pull request #15959: [FLINK-22684][runtime] Added ability to ignore in-flight data during …

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15959: URL: https://github.com/apache/flink/pull/15959#issuecomment-844265660 ## CI report: * a0b3af8f3d5503bbd3cb16c208521ce515ef6c67 Azure:

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

2021-05-21 Thread GitBox
AHeise commented on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-846056526 Sure I have assigned myself, so I receive updates. But realistically, it will be next week ;). -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-22686) Incompatible subtask mappings while resuming from unaligned checkpoints

2021-05-21 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349351#comment-17349351 ] Till Rohrmann commented on FLINK-22686: --- Would it make sense to disable UC for broadcast

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

2021-05-21 Thread GitBox
echauchot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-846050581 @AHeise can you also take a look at this PR once I have rebased on master -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] AHeise commented on a change in pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

2021-05-21 Thread GitBox
AHeise commented on a change in pull request #15771: URL: https://github.com/apache/flink/pull/15771#discussion_r637027020 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java ## @@ -243,6 +240,13 @@ public void

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

2021-05-21 Thread GitBox
echauchot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-846050581 @AHeise can you also take a look at this PR ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

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

2021-05-21 Thread GitBox
echauchot commented on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-846050581 @Arvid Heise can you also take a look at this PR ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-22750) Simplify Unit Testing of Remote Functions

2021-05-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349340#comment-17349340 ] Konstantin Knauf commented on FLINK-22750: -- I see two possible approaches: 1) A long the

[GitHub] [flink] flinkbot edited a comment on pull request #15975: [FLINK-22725][coordination] SlotManagers unregister metrics in suspend()

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * 0c86714da507bf568c23efbb3976b372b142dc79 Azure:

[jira] [Updated] (FLINK-22750) Simplify Unit Testing of Remote Functions

2021-05-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22750: - Description: Testing Remote Functions in isolation is currently more cumbersome than it

[jira] [Created] (FLINK-22750) Simplify Unit Testing of Remote Functions

2021-05-21 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22750: Summary: Simplify Unit Testing of Remote Functions Key: FLINK-22750 URL: https://issues.apache.org/jira/browse/FLINK-22750 Project: Flink Issue

[jira] [Updated] (FLINK-22750) Simplify Unit Testing of Remote Functions

2021-05-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22750: - Component/s: Build System / Stateful Functions > Simplify Unit Testing of Remote

[GitHub] [flink-docker] AHeise merged pull request #82: Dockerfile for 1.12.4

2021-05-21 Thread GitBox
AHeise merged pull request #82: URL: https://github.com/apache/flink-docker/pull/82 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink-docker] AHeise merged pull request #81: Update run_travis_tests.sh to test against 1.12.4

2021-05-21 Thread GitBox
AHeise merged pull request #81: URL: https://github.com/apache/flink-docker/pull/81 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink-web] AHeise merged pull request #447: Added release 1.12.4 blog post

2021-05-21 Thread GitBox
AHeise merged pull request #447: URL: https://github.com/apache/flink-web/pull/447 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink-docker] rmetzger closed pull request #63: Adjust dev-1.12 branch for building 1.12.0

2021-05-21 Thread GitBox
rmetzger closed pull request #63: URL: https://github.com/apache/flink-docker/pull/63 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink-web] rmetzger commented on a change in pull request #447: Added release 1.12.4 blog post

2021-05-21 Thread GitBox
rmetzger commented on a change in pull request #447: URL: https://github.com/apache/flink-web/pull/447#discussion_r636997157 ## File path: _posts/2021-05-14-release-1.12.4.md ## @@ -0,0 +1,94 @@ +--- +layout: post +title: "Apache Flink 1.12.4 Released" +date: 2021-05-14

[GitHub] [flink] flinkbot edited a comment on pull request #15975: [FLINK-22725][coordination] SlotManagers unregister metrics in suspend()

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * 0c86714da507bf568c23efbb3976b372b142dc79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15989: [FLINK-22747] Upgrade to commons-io 2.8.0

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #15989: URL: https://github.com/apache/flink/pull/15989#issuecomment-846005472 ## CI report: * 43eb3a2d7cd162057014781417f1240a0c16ad0c Azure:

[GitHub] [flink-web] AHeise commented on a change in pull request #447: Added release 1.12.4 blog post

2021-05-21 Thread GitBox
AHeise commented on a change in pull request #447: URL: https://github.com/apache/flink-web/pull/447#discussion_r636996490 ## File path: _posts/2021-05-14-release-1.12.4.md ## @@ -0,0 +1,94 @@ +--- +layout: post +title: "Apache Flink 1.12.4 Released" +date: 2021-05-14

[GitHub] [flink-web] rmetzger commented on a change in pull request #447: Added release 1.12.4 blog post

2021-05-21 Thread GitBox
rmetzger commented on a change in pull request #447: URL: https://github.com/apache/flink-web/pull/447#discussion_r636996120 ## File path: _posts/2021-05-14-release-1.12.4.md ## @@ -0,0 +1,94 @@ +--- +layout: post +title: "Apache Flink 1.12.4 Released" +date: 2021-05-14

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

2021-05-21 Thread GitBox
flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * af006de33d0d0e80b7a09c19ad812b8cd0d86e03 Azure:

[GitHub] [flink] sjwiesman commented on pull request #15985: [FLINK-22740][docs] Drop legacy planner references in docs

2021-05-21 Thread GitBox
sjwiesman commented on pull request #15985: URL: https://github.com/apache/flink/pull/15985#issuecomment-846017879 LGTM! Ship it! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Created] (FLINK-22749) Apply a robust default State Backend Configuration

2021-05-21 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-22749: Summary: Apply a robust default State Backend Configuration Key: FLINK-22749 URL: https://issues.apache.org/jira/browse/FLINK-22749 Project: Flink Issue

[GitHub] [flink-web] AHeise opened a new pull request #447: Added release 1.12.4 blog post

2021-05-21 Thread GitBox
AHeise opened a new pull request #447: URL: https://github.com/apache/flink-web/pull/447 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Updated] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

2021-05-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22748: - Summary: Allow dynamic target topic selection in SQL Kafka sinks (was: Allow dynamic target

[GitHub] [flink-web] AHeise merged pull request #446: Added release 1.12.4

2021-05-21 Thread GitBox
AHeise merged pull request #446: URL: https://github.com/apache/flink-web/pull/446 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] flinkbot commented on pull request #15989: [FLINK-22747] Upgrade to commons-io 2.8.0

2021-05-21 Thread GitBox
flinkbot commented on pull request #15989: URL: https://github.com/apache/flink/pull/15989#issuecomment-846005472 ## CI report: * 43eb3a2d7cd162057014781417f1240a0c16ad0c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-21 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-22698: - Assignee: Michał Ciesielczyk > RabbitMQ source does not stop unless

[jira] [Created] (FLINK-22748) Allow dynamic target topic selection in Kafka sinks

2021-05-21 Thread Timo Walther (Jira)
Timo Walther created FLINK-22748: Summary: Allow dynamic target topic selection in Kafka sinks Key: FLINK-22748 URL: https://issues.apache.org/jira/browse/FLINK-22748 Project: Flink Issue

[jira] [Updated] (FLINK-22748) Allow dynamic target topic selection in Kafka sinks

2021-05-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22748: - Component/s: Connectors / Kafka > Allow dynamic target topic selection in Kafka sinks >

[jira] [Updated] (FLINK-22746) Links to connectors in docs are broken

2021-05-21 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-22746: -- Priority: Critical (was: Major) > Links to connectors in docs are broken >

  1   2   3   4   >