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

flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * ff58123cc85c7b14cce996b8d04a4c1cfee9e167 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17349599#comment-17349599 ] frank wang commented on FLINK-22443: can you give your table schema, maybe it can he

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

[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349590#comment-17349590 ] frank wang commented on FLINK-8093: --- can we set clientId when user have not set the cli

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

[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349586#comment-17349586 ] freezhan commented on FLINK-17691: -- [~nvolynets] https://issues.apache.org/jira/browse/

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

flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * af006de33d0d0e80b7a09c19ad812b8cd0d86e03 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * af006de33d0d0e80b7a09c19ad812b8cd0d86e03 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-20979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349560#comment-17349560 ] Rion Williams commented on FLINK-20979: --- Hey all, I noticed the bot had tagged th

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

[ 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 Bot|https://github.com/apache/flink-jira-b

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

[ 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 Bot|https://github.com/apac

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

[ 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 Bot|https://github.com/apache/flink-jira-b

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

[ 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) I

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

[ 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 Bot|https://github.com/apache/flink-jira-b

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

[ 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 Bot|https:

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

[ 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 Bot|https://g

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

[ 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 Bot|https://github.com/apache/flink-jira-b

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

[ 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 Bot|https://g

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

[ 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 Ji

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

[ 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 Bot|https://github.com/apache/flink-jira-b

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

[ 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) Pri

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

[ 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 updat

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

[ 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 updat

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

[ 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) Thi

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

[ 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 stal

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

[ 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) Thi

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

[ 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 updat

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

[ 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 updat

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

[ 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) Thi

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

[ 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 updat

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

[ 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 updat

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

[ 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) Thi

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

[ 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 [Flink

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

[ 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) Thi

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

[ 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 updat

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

[ 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 updat

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

[ 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 stal

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

[ 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) Thi

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

[ 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) Thi

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

[ 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) Pri

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

[ 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 Bot|https://github.com/apache/flink-jir

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

[ 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) Thi

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

[ 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 updat

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

[ 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) Thi

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

[ 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 stal

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

[ 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

[ 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 Bot|https://github.com/apache/flink-jir

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

[ 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 updat

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

[ 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 Bot|https://github.com/apache/flink-jir

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

flinkbot edited a comment on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-843682358 ## CI report: * 31a4ee9da09afc3e9d8f689c635fc314866c6f4b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * c7293cdce7b7b106ec0db3f0bc41bf5cac79bf67 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15989: URL: https://github.com/apache/flink/pull/15989#issuecomment-846005472 ## CI report: * 43eb3a2d7cd162057014781417f1240a0c16ad0c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15771: URL: https://github.com/apache/flink/pull/15771#issuecomment-826939649 ## CI report: * d55f8912d2aea880925f4aa631467e8f9679d501 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-843682358 ## CI report: * 10e7ae7dcc1c335619f6415a39bbeae5fd1ac35d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15950: URL: https://github.com/apache/flink/pull/15950#issuecomment-843682358 ## CI report: * 10e7ae7dcc1c335619f6415a39bbeae5fd1ac35d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * 5a64f54467bca6bb7a5044bbcd2c654df5c978db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ 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 incr

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

[ https://issues.apache.org/jira/browse/FLINK-22753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349382#comment-17349382 ] Stephan Ewen commented on FLINK-22753: -- This is blocked on the implementation of [F

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

[ 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 predict

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

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: Sub-t

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

[ 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 configur

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

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 Type

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

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: Sub-task

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

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 parti

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

flinkbot edited a comment on pull request #15987: URL: https://github.com/apache/flink/pull/15987#issuecomment-845883196 ## CI report: * d47f5f72fafd68587477c49fbe2b365a511a0cc3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15988: URL: https://github.com/apache/flink/pull/15988#issuecomment-845906000 ## CI report: * cc6da7ed3aae15aaeebaa67ada28d36f3fee0c70 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ 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 extern

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

[ https://issues.apache.org/jira/browse/FLINK-22700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17347773#comment-17347773 ] Eron Wright edited comment on FLINK-22700 at 5/21/21, 4:15 PM: ---

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

[ 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

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 a

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

[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349353#comment-17349353 ] Dawid Wysakowicz commented on FLINK-22686: -- That's what we want to do for 1.14.

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

flinkbot edited a comment on pull request #15959: URL: https://github.com/apache/flink/pull/15959#issuecomment-844265660 ## CI report: * a0b3af8f3d5503bbd3cb16c208521ce515ef6c67 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 me

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

[ https://issues.apache.org/jira/browse/FLINK-22686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349351#comment-17349351 ] Till Rohrmann commented on FLINK-22686: --- Would it make sense to disable UC for bro

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

echauchot edited a comment on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-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, pleas

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

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

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 t

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

echauchot commented on pull request #15725: URL: https://github.com/apache/flink/pull/15725#issuecomment-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 the

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

[ https://issues.apache.org/jira/browse/FLINK-22750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17349340#comment-17349340 ] Konstantin Knauf commented on FLINK-22750: -- I see two possible approaches: 1)

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

flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * 0c86714da507bf568c23efbb3976b372b142dc79 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ 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

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 Type:

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

[ 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 Functio

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

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, please

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

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, please

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

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

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, plea

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

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 00:0

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

flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * 0c86714da507bf568c23efbb3976b372b142dc79 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15989: URL: https://github.com/apache/flink/pull/15989#issuecomment-846005472 ## CI report: * 43eb3a2d7cd162057014781417f1240a0c16ad0c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 00:00:

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

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 00:0

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

flinkbot edited a comment on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-776614443 ## CI report: * af006de33d0d0e80b7a09c19ad812b8cd0d86e03 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 com

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

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 Type

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

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, p

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

[ 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 top

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

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

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 r

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

[ 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 mes

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

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 Typ

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

[ 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 >

  1   2   3   4   >