[jira] [Commented] (FLINK-22804) "CREATE VIEW" statement loses computed columns, metadata columns, watermark and table constraint

[ https://issues.apache.org/jira/browse/FLINK-22804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353682#comment-17353682 ] Jark Wu commented on FLINK-22804: - Hi [~yulei0824], computed columns, metadata columns,

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

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

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

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

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641891283 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,163 @@ +/*

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641890870 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumeratorState.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641889230 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitSerializer.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641889150 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,213

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r64182 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,214

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641887673 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SourceReaderFinishedEvent.java ## @@ -0,0

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641887433 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641887066 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641886803 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641886803 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641886186 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641885012 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[jira] [Commented] (FLINK-22804) "CREATE VIEW" statement loses computed columns, metadata columns, watermark and table constraint

[ https://issues.apache.org/jira/browse/FLINK-22804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353658#comment-17353658 ] tim yu commented on FLINK-22804: Hi [~jark],  Does this feature need to be supported by

[jira] [Created] (FLINK-22804) "CREATE VIEW" statement loses computed columns, metadata columns, watermark and table constraint

tim yu created FLINK-22804: -- Summary: "CREATE VIEW" statement loses computed columns, metadata columns, watermark and table constraint Key: FLINK-22804 URL: https://issues.apache.org/jira/browse/FLINK-22804

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641866362 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[jira] [Updated] (FLINK-21427) Recovering from savepoint key does not exist in S3

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

[jira] [Updated] (FLINK-21468) ParquetTableSource: where clause on integer does not work

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

[jira] [Updated] (FLINK-21415) JDBC connector should support to disable caching missing key

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

[jira] [Updated] (FLINK-21440) Translate Real Time Reporting with the Table API doc and correct a spelling mistake

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

[jira] [Updated] (FLINK-9896) Fix flink documentation error

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

[jira] [Updated] (FLINK-11381) JOIN LATERAL with a table was not support

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

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

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

[jira] [Updated] (FLINK-3431) Add retrying logic for RocksDB snapshots

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

[jira] [Updated] (FLINK-9667) Scala docs are only generated for flink-scala

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

[jira] [Updated] (FLINK-21367) Support objectReuse in JDBC sink

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

[jira] [Updated] (FLINK-21161) Investigate Datadog OOM on timeout

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

[jira] [Updated] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

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

[jira] [Updated] (FLINK-21555) HA does not work when using mesos scheduler

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

[jira] [Updated] (FLINK-3805) BloomFilter initialized with no memory available

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

[jira] [Updated] (FLINK-21450) Add local recovery support to adaptive scheduler

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

[jira] [Updated] (FLINK-21712) Extract interfaces for the Execution* (classes used by the DefaultExecutonGraph)

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

[jira] [Updated] (FLINK-21228) [Kinesis][Producer] Deadlock in KinesisProducer

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

[jira] [Updated] (FLINK-21830) [kinesis][auth] Add support for Session Token

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

[jira] [Updated] (FLINK-20432) SQLClientSchemaRegistryITCase hangs

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

[jira] [Updated] (FLINK-22380) Pub/Sub Lite Connector for Flink

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

[jira] [Updated] (FLINK-21501) Sync Chinese documentation with FLINK-21343

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-22452: --- Labels: stale-major (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-b

[jira] [Updated] (FLINK-22496) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed

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

[jira] [Updated] (FLINK-22513) Failed to upload compile artifacts

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

[jira] [Updated] (FLINK-22500) flink stop 命令找不到00000000000000000000000000000000

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

[jira] [Updated] (FLINK-21359) CompatibilityResult issues with Flink 1.9.0

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

[jira] [Updated] (FLINK-21286) Support BUCKET for flink sql CREATE TABLE

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

[jira] [Updated] (FLINK-21424) Lookup Hive partitioned table throws exception

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

[jira] [Updated] (FLINK-21447) Resuming Savepoint (file, async, scale up) end-to-end test Fail

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

[jira] [Updated] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

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

[jira] [Updated] (FLINK-21376) Failed state might not provide failureCause

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

[jira] [Updated] (FLINK-21607) Twitter table source connector

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

[jira] [Updated] (FLINK-21285) Support MERGE INTO for flink sql

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

[jira] [Updated] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

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

[jira] [Updated] (FLINK-21823) RocksDB on FreeBSD

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

[jira] [Updated] (FLINK-21797) Performance regression on 03/11/21

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

[jira] [Updated] (FLINK-22008) writing metadata is not an atomic operation, we should add a commit logic

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

[jira] [Updated] (FLINK-21695) Increase default value for number of KeyGroups

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

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641845906 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641846618 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641845906 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641845906 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641840416 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641840416 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641826626 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641825013 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@ -0,

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641822577 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641778102 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[jira] [Commented] (FLINK-22803) Running multiple CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-22803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353530#comment-17353530 ] Tejas Budukh commented on FLINK-22803: -- Thanks for the reply. I created a Jira thin

[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: * 4c1a9dbb3034eb0ac880db84954b2c40fed365c2 UNKNOWN * 9edf99c84c5bb5e664a658bdbcbb1a242882eb7f Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-22803) Running multiple CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-22803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22803. Resolution: Invalid > Running multiple CEP patterns > - > >

[jira] [Commented] (FLINK-22803) Running multiple CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-22803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353512#comment-17353512 ] Dawid Wysakowicz commented on FLINK-22803: -- I replied in the ML. Please do not

[jira] [Created] (FLINK-22803) Running multiple CEP patterns

Tejas Budukh created FLINK-22803: Summary: Running multiple CEP patterns Key: FLINK-22803 URL: https://issues.apache.org/jira/browse/FLINK-22803 Project: Flink Issue Type: Bug Compo

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

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

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641730936 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641730145 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java ## @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641729036 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,2

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r641726629 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0 +1,2

[GitHub] [flink] flinkbot edited a comment on pull request #16021: [FLINK-22798] [Connectors/Kafka] correct exception handling of KAFKA transactional producer

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

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

[ https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353485#comment-17353485 ] Ingo Bürk commented on FLINK-22737: --- I have to admit that I find it quite odd to retur

[GitHub] [flink-web] dawidwys closed pull request #448: Announce 1.13.1

dawidwys closed pull request #448: URL: https://github.com/apache/flink-web/pull/448 -- 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, pleas

[jira] [Commented] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg

[ https://issues.apache.org/jira/browse/FLINK-22701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353442#comment-17353442 ] Jinliang Guo commented on FLINK-22701: -- no problem, I did found that "-d" option is

[GitHub] [flink] flinkbot edited a comment on pull request #16022: [FLINK-21301][table-planner-blink] Decouple window aggregate allow lateness with state ttl configuration

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

[jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353428#comment-17353428 ] Matthias commented on FLINK-21439: -- The {{Executions}} could come from the {{ExecutionG

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

[ https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353427#comment-17353427 ] Jark Wu commented on FLINK-22737: - I have some concerns when returning NULL, because it

[GitHub] [flink-docker] dawidwys opened a new pull request #84: Update Dockerfiles for 1.13.1 release

dawidwys opened a new pull request #84: URL: https://github.com/apache/flink-docker/pull/84 -- 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-22802) Bump Fabric8 Kubernetes Client to >= 5.2.0

[ https://issues.apache.org/jira/browse/FLINK-22802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enrique Lacal updated FLINK-22802: -- Description: Hi All,  Currently, Flink is using version 4.9.2 of the Fabric8 Kubernetes Clien

[jira] [Updated] (FLINK-22802) Bump Fabric8 Kubernetes Client to 5.2.0

[ https://issues.apache.org/jira/browse/FLINK-22802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enrique Lacal updated FLINK-22802: -- Summary: Bump Fabric8 Kubernetes Client to 5.2.0 (was: Bump Fabric8 Kubernetes Client to ) >

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

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

[jira] [Created] (FLINK-22802) Bump Fabric8 Kubernetes Client to

Enrique Lacal created FLINK-22802: - Summary: Bump Fabric8 Kubernetes Client to Key: FLINK-22802 URL: https://issues.apache.org/jira/browse/FLINK-22802 Project: Flink Issue Type: Improvement

[GitHub] [flink-docker] dawidwys opened a new pull request #83: Release 1.13.1

dawidwys opened a new pull request #83: URL: https://github.com/apache/flink-docker/pull/83 -- 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] flinkbot edited a comment on pull request #16019: [FLINK-22686][checkpointing] Incompatible subtask mappings while resuming from unaligned checkpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

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

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

[ https://issues.apache.org/jira/browse/FLINK-22737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17353405#comment-17353405 ] David Anderson commented on FLINK-22737: Semantically, I would argue that return

[jira] [Updated] (FLINK-22589) There are quite a few Python classes doesn't appear in the Python docs

[ https://issues.apache.org/jira/browse/FLINK-22589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22589: - Fix Version/s: (was: 1.13.1) 1.13.2 > There are quite a few Pytho

[jira] [Updated] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22358: - Fix Version/s: (was: 1.13.1) 1.13.2 > Add missing stability annot

[jira] [Updated] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13856: - Fix Version/s: (was: 1.13.1) 1.13.2 > Reduce the delete file api

[jira] [Updated] (FLINK-22578) deployment configuration page miss content navigate menu

[ https://issues.apache.org/jira/browse/FLINK-22578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22578: - Fix Version/s: (was: 1.13.1) 1.13.2 > deployment configuration pa

[jira] [Updated] (FLINK-22701) "bin/flink savepoint -d :savepointpath" cannot locate savepointpath arg

[ https://issues.apache.org/jira/browse/FLINK-22701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22701: - Fix Version/s: (was: 1.13.1) 1.13.2 > "bin/flink savepoint -d :sa

[jira] [Updated] (FLINK-22759) Correct the applicability of RocksDB related options as per operator

[ https://issues.apache.org/jira/browse/FLINK-22759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22759: - Fix Version/s: (was: 1.13.1) 1.13.2 > Correct the applicability o

[jira] [Updated] (FLINK-22370) ParquetColumnarRowSplitReader#reachedEnd() returns false after it returns true

[ https://issues.apache.org/jira/browse/FLINK-22370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22370: - Fix Version/s: (was: 1.13.1) 1.13.2 > ParquetColumnarRowSplitRead

[jira] [Updated] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22766: - Fix Version/s: (was: 1.13.1) 1.13.2 > Report metrics of KafkaCons

  1   2   3   4   5   6   7   8   9   10   >