[GitHub] [flink] flinkbot commented on pull request #16209: [FLINK-23043][k8s] Get real master node address when kubernetes.rest-service.exposed.type is NodePort

flinkbot commented on pull request #16209: URL: https://github.com/apache/flink/pull/16209#issuecomment-864504251 ## CI report: * 9531ba3e5af22c944fe5812a4e414e145a973801 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort

[ https://issues.apache.org/jira/browse/FLINK-23043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shang Yuanchun updated FLINK-23043: --- Description: When running with Native Kubernetes in application mode, and Fabric8

[GitHub] [flink] flinkbot commented on pull request #16209: [FLINK-23043][k8s] Get real master node address when kubernetes.rest-service.exposed.type is NodePort

flinkbot commented on pull request #16209: URL: https://github.com/apache/flink/pull/16209#issuecomment-864502162 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort

[ https://issues.apache.org/jira/browse/FLINK-23043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366105#comment-17366105 ] Shang Yuanchun commented on FLINK-23043: I've provided a pull request: 

[jira] [Updated] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort

[ https://issues.apache.org/jira/browse/FLINK-23043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23043: --- Labels: pull-request-available (was: ) > Wrong master address displayed when run

[GitHub] [flink] ideal opened a new pull request #16209: [FLINK-23043][k8s] Get real master node address when kubernetes.rest-service.exposed.type is NodePort

ideal opened a new pull request #16209: URL: https://github.com/apache/flink/pull/16209 ## What is the purpose of the change When running with Native Kubernetes in application mode, and Fabric8 Kubernetes client is configured by Service account, if you specify

[jira] [Created] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort

Shang Yuanchun created FLINK-23043: -- Summary: Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort Key: FLINK-23043 URL:

[jira] [Commented] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

[ https://issues.apache.org/jira/browse/FLINK-23042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366104#comment-17366104 ] kevin commented on FLINK-23042: --- Can anyone assign this issue to me as my first Flink contribution? >

[jira] [Created] (FLINK-23042) Flink Chinese docs Fraud Detection with the DataStream API page picture display issue

kevin created FLINK-23042: - Summary: Flink Chinese docs Fraud Detection with the DataStream API page picture display issue Key: FLINK-23042 URL: https://issues.apache.org/jira/browse/FLINK-23042 Project:

[GitHub] [flink] Zakelly commented on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly commented on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-864496039 @rkhachatryan thanks for the review! I've addressed your comments. Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-20920) Document how to connect to kerberized HMS

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

[jira] [Updated] (FLINK-10667) Clean up Scala 2.10 remnants

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

[jira] [Updated] (FLINK-10568) Show correct time attributes when calling Table.getSchema()

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

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

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

[jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default

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

[jira] [Updated] (FLINK-19033) Cleanups of DataStream API

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

[jira] [Updated] (FLINK-18444) KafkaITCase failing with "Failed to send data to Kafka: This server does not host this topic-partition"

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

[jira] [Updated] (FLINK-23030) PartitionRequestClientFactory#createPartitionRequestClient should throw when network failure

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

[jira] [Updated] (FLINK-21065) Passing configuration from TableEnvironmentImpl to MiniCluster is not supported

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

[jira] [Updated] (FLINK-19230) Support Python UDAF on blink batch planner

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

[jira] [Updated] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

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

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

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

[jira] [Updated] (FLINK-22531) Improve the support for finite streaming jobs with async operations.

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

[jira] [Updated] (FLINK-20929) Add automated deployment of nightly docker images

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

[jira] [Updated] (FLINK-23001) flink-avro-glue-schema-registry lacks scala suffix

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

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

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

[jira] [Updated] (FLINK-21232) Introduce pluggable Hadoop delegation token providers

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

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

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

[jira] [Updated] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

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

[jira] [Updated] (FLINK-22723) multi-field-dynamic index is not supported by elasticsearch connector

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

[jira] [Updated] (FLINK-22729) Truncated Messages in Python workers

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

[jira] [Updated] (FLINK-22727) SerializableAvroSchema cannot handle large schema

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

[jira] [Updated] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic

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

[jira] [Updated] (FLINK-10684) Improve the CSV reading process

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

[jira] [Updated] (FLINK-10576) Introduce Machine/Node/TM health management

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

[jira] [Updated] (FLINK-10476) Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api

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

[jira] [Updated] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

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

[jira] [Updated] (FLINK-10834) TableAPI flatten() calculated value error

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

[jira] [Updated] (FLINK-10515) Improve tokenisation of program args passed as string

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

[jira] [Updated] (FLINK-12005) [State TTL] Event time support

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

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

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

[jira] [Updated] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction

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

[jira] [Updated] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

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

[jira] [Updated] (FLINK-10688) Remove flink-table dependencies from flink-connectors

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

[jira] [Updated] (FLINK-22871) Support to execute PyFlink jobs in YARN application mode

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

[jira] [Updated] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

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

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 50b2100f9a62e662d6cb4a7ec111d3e73b9cd843 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 9ab9c0e4f4ba349c78d57596621e6771564cd88d Azure:

[GitHub] [flink] dannycranmer merged pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

dannycranmer merged pull request #16206: URL: https://github.com/apache/flink/pull/16206 -- 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 #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * bd2ab46a5e8d4929110dc6360f53413b85e33b03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 2c78381d58d1e7e3ee3edd06afb03e7e6eb1f177 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 2c78381d58d1e7e3ee3edd06afb03e7e6eb1f177 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 2c78381d58d1e7e3ee3edd06afb03e7e6eb1f177 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot edited a comment on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861162068 ## CI report: * 2c78381d58d1e7e3ee3edd06afb03e7e6eb1f177 Azure:

[GitHub] [flink] Zakelly commented on a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654810546 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -607,6 +612,53 @@

[GitHub] [flink] Zakelly commented on a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654810136 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java ## @@ -58,7

[GitHub] [flink] Zakelly commented on a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654809920 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java ## @@ -384,6 +358,22 @@ public static boolean

[jira] [Commented] (FLINK-23028) Improve documentation for pages of SQL.

[ https://issues.apache.org/jira/browse/FLINK-23028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365953#comment-17365953 ] Roc Marshal commented on FLINK-23028: - Could someone kindly help me to advance this PR? Thank you.:)

[GitHub] [flink] Zakelly commented on a change in pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly commented on a change in pull request #16153: URL: https://github.com/apache/flink/pull/16153#discussion_r654809893 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLoader.java ## @@ -175,21 +174,16 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * 1ed7d814c13b56e109c9ef95ac5f350e36c3b863 Azure:

[jira] [Commented] (FLINK-21804) Create and wire changelog writer with backend

[ https://issues.apache.org/jira/browse/FLINK-21804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365937#comment-17365937 ] Zakelly Lan commented on FLINK-21804: - [~liyu], thanks! > Create and wire changelog writer with

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * 1ed7d814c13b56e109c9ef95ac5f350e36c3b863 Azure:

[GitHub] [flink] Aitozi commented on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

Aitozi commented on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864404875 @flinkbot run travis -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * 1ed7d814c13b56e109c9ef95ac5f350e36c3b863 Azure:

[jira] [Updated] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

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

[jira] [Updated] (FLINK-11250) fix thread leaked when StreamTask switched from DEPLOYING to CANCELING

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

[jira] [Updated] (FLINK-10882) Misleading job/task state for scheduled jobs

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

[jira] [Updated] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

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

[jira] [Updated] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous

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

[jira] [Updated] (FLINK-11070) Add stream-stream non-window cross join

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

[jira] [Updated] (FLINK-11157) Web UI should show timestamps relative to server time zone

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

[jira] [Updated] (FLINK-11172) Remove the max retention time in StreamQueryConfig

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

[jira] [Updated] (FLINK-11209) Provide more complete guidance for the log usage documentation

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

[jira] [Updated] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

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

[jira] [Updated] (FLINK-11221) Support delimited identifiers in TableAPI

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

[jira] [Updated] (FLINK-11150) Check exception messages in ValidationTest of flink-table

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

[jira] [Updated] (FLINK-11258) Add badge to the README

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

[jira] [Updated] (FLINK-11184) Rework TableSource and TableSink interfaces

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

[jira] [Updated] (FLINK-11276) Sliding Window Optimization

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

[GitHub] [flink] flinkbot edited a comment on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot edited a comment on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * 1ed7d814c13b56e109c9ef95ac5f350e36c3b863 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 773bfcf7c143eea72b1c5284d6dd3dfe19c90c85 Azure:

[jira] [Commented] (FLINK-23040) Consider ConfigOption fallback keys in FactoryUtil

[ https://issues.apache.org/jira/browse/FLINK-23040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365897#comment-17365897 ] Jark Wu commented on FLINK-23040: - +1 > Consider ConfigOption fallback keys in FactoryUtil >

[GitHub] [flink] Aitozi commented on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

Aitozi commented on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384700 @flinkbot run travis -- 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

[GitHub] [flink] flinkbot commented on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot commented on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864384053 ## CI report: * 1ed7d814c13b56e109c9ef95ac5f350e36c3b863 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

flinkbot commented on pull request #16208: URL: https://github.com/apache/flink/pull/16208#issuecomment-864382443 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-22594) Report oom killed pod in k8s resource manager

[ https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365892#comment-17365892 ] Aitozi commented on FLINK-22594: I have made an implementation for this issue, could you help review

[jira] [Updated] (FLINK-22594) Report oom killed pod in k8s resource manager

[ https://issues.apache.org/jira/browse/FLINK-22594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22594: --- Labels: pull-request-available (was: ) > Report oom killed pod in k8s resource manager >

[GitHub] [flink] Aitozi opened a new pull request #16208: [FLINK-22594][Kubernetes]Add handler to catch pod oomKilled message a…

Aitozi opened a new pull request #16208: URL: https://github.com/apache/flink/pull/16208 …nd report to resource manager metric ## What is the purpose of the change As described in issue, this pr is meant to report oom killed to metric in k8s mode. ## Brief change

[jira] [Resolved] (FLINK-22868) Update training exercises for 1.13

[ https://issues.apache.org/jira/browse/FLINK-22868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-22868. Fix Version/s: 1.13.1 Resolution: Fixed > Update training exercises for 1.13 >

[jira] [Commented] (FLINK-22868) Update training exercises for 1.13

[ https://issues.apache.org/jira/browse/FLINK-22868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365888#comment-17365888 ] David Anderson commented on FLINK-22868: Resolved via  dd7be31e084ac356813b2dcda5ec7408810af786

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * a4d3800c234d0cdc7af6125ee28ed1ae89e2ce32 Azure:

[jira] [Commented] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365881#comment-17365881 ] guxiang commented on FLINK-18464: - I'm going to fix this bug like this. The fix is currently only for

[GitHub] [flink] flinkbot edited a comment on pull request #16207: [FLINK-23031][table-planner-blink]Support to emit window result perio…

flinkbot edited a comment on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-864350218 ## CI report: * 41f6378376a0aecec273853b4aaeaf8d09ddeb59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 773bfcf7c143eea72b1c5284d6dd3dfe19c90c85 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

flinkbot edited a comment on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864189035 ## CI report: * 773bfcf7c143eea72b1c5284d6dd3dfe19c90c85 Azure:

[GitHub] [flink] dannycranmer commented on pull request #16206: [FLINK-18182][kinesis] Fixing bad shading of AWS SDK config file

dannycranmer commented on pull request #16206: URL: https://github.com/apache/flink/pull/16206#issuecomment-864364989 @flinkbot run azure -- 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

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

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365856#comment-17365856 ] Cooper Luan edited comment on FLINK-22955 at 6/19/21, 6:33 AM: --- it's ok to

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

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365856#comment-17365856 ] Cooper Luan edited comment on FLINK-22955 at 6/19/21, 6:31 AM: --- it's ok to

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

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365856#comment-17365856 ] Cooper Luan commented on FLINK-22955: - it's ok to implement LookupFunction like 

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

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365856#comment-17365856 ] Cooper Luan edited comment on FLINK-22955 at 6/19/21, 6:30 AM: --- it's ok to

  1   2   >