[jira] [Commented] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348986#comment-17348986 ] Yun Gao commented on FLINK-22088: - Got that, I also agree with that it is not too urgent, I could first

[GitHub] [flink] flinkbot commented on pull request #15981: [FLINK-22733][python] DataStream.union should handle properly for KeyedStream in Python DataStream API

flinkbot commented on pull request #15981: URL: https://github.com/apache/flink/pull/15981#issuecomment-845675838 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] [Assigned] (FLINK-22733) Type mismatch thrown in KeyedStream.union in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-22733: --- Assignee: Dian Fu > Type mismatch thrown in KeyedStream.union in Python DataStream API >

[jira] [Updated] (FLINK-22733) Type mismatch thrown in KeyedStream.union in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22733: --- Labels: pull-request-available (was: ) > Type mismatch thrown in KeyedStream.union in

[GitHub] [flink] dianfu opened a new pull request #15981: [FLINK-22733][python] DataStream.union should handle properly for KeyedStream in Python DataStream API

dianfu opened a new pull request #15981: URL: https://github.com/apache/flink/pull/15981 ## What is the purpose of the change *This pull request fixes DataStream.union which should consider if the given DataStream is KeyedStream in Python DataStream API* ## Verifying

[GitHub] [flink] flinkbot commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

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

[GitHub] [flink] flinkbot edited a comment on pull request #15949: [FLINK-22319][table][sql-client] Support RESET table option for ALTER TABLE statement

flinkbot edited a comment on pull request #15949: URL: https://github.com/apache/flink/pull/15949#issuecomment-843638744 ## CI report: * f402c1cb1b6d6c1931bc1ed3778efa58e875fe89 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * c92770317d4c844d26f06a885b84fb6ab5c052d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 ## CI report: * e46df619d0b485fea75e9c36514be22887514314 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 459cbc691a8eaa5d823805debb1a9137ec048788 Azure:

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

[GitHub] [flink] flinkbot edited a comment on pull request #15936: [FLINK-22683][runtime] Fix the null or incorrect value of total Flink…

flinkbot edited a comment on pull request #15936: URL: https://github.com/apache/flink/pull/15936#issuecomment-842214419 ## CI report: * e46df619d0b485fea75e9c36514be22887514314 Azure:

[GitHub] [flink] flinkbot commented on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

flinkbot commented on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845663947 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

[GitHub] [flink] JasonLeeCoding opened a new pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

JasonLeeCoding opened a new pull request #15980: URL: https://github.com/apache/flink/pull/15980 ## What is the purpose of the change *this change is in order to use comments in the initialization script with '--' in the SQL Client* ## Brief change log *add

[jira] [Closed] (FLINK-22728) a problem of loading udf

[ https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22728. --- Resolution: Not A Problem > a problem of loading udf > > > Key:

[jira] [Commented] (FLINK-22728) a problem of loading udf

[ https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348975#comment-17348975 ] Dian Fu commented on FLINK-22728: - [~JYXL_1] Great to hear! Then I'm closing this ticket~ > a problem

[jira] [Commented] (FLINK-22728) a problem of loading udf

[ https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348974#comment-17348974 ] JYXL commented on FLINK-22728: -- Hi Dian, ok that works when I transfor`Target.TRUE` to

[jira] [Commented] (FLINK-22728) a problem of loading udf

[ https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348967#comment-17348967 ] JYXL commented on FLINK-22728: -- hi Dian: I have used the method that note in the url, and create a

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * a566bb9a4714ea61156295a3a8617edba8ca53cb Azure:

[jira] [Closed] (FLINK-22203) KafkaChangelogTableITCase.testKafkaCanalChangelogSource fail due to ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-22203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22203. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: 17d5643235d486be7f6a27fd5042311b6a95bcf7 >

[GitHub] [flink] wuchong merged pull request #15978: [FLINK-22203][table-runtime-blink] Fix ConcurrentModificationException for testing values sink functions

wuchong merged pull request #15978: URL: https://github.com/apache/flink/pull/15978 -- 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] fhan688 commented on pull request #15965: [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

fhan688 commented on pull request #15965: URL: https://github.com/apache/flink/pull/15965#issuecomment-845638735 @sjwiesman please help review, thanks! -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 3340cf6344fef506c4f57952537a60540870f54c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 3340cf6344fef506c4f57952537a60540870f54c Azure:

[GitHub] [flink] yittg commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-845629668 If the issue is the potential risk of introducing a complex dependency, i think it may be a way by adding a feature gate and refactoring the original adhoc watching like the

[GitHub] [flink] xintongsong commented on pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

xintongsong commented on pull request #15524: URL: https://github.com/apache/flink/pull/15524#issuecomment-845627262 Thanks for the review, @wangyang0918. Concerning re-registering AM on Yarn, I think it is indeed a problem. It looks like Yarn differentiate AMs by their attempt ids,

[GitHub] [flink] yittg commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

yittg commented on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-845625212 @tillrohrmann Would you help to make this PR continue? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348952#comment-17348952 ] Yi Tang commented on FLINK-21921: - [~trohrmann] You can assign it to me, i will provide a little change

[jira] [Created] (FLINK-22733) Type mismatch thrown in KeyedStream.union in Python DataStream API

Dian Fu created FLINK-22733: --- Summary: Type mismatch thrown in KeyedStream.union in Python DataStream API Key: FLINK-22733 URL: https://issues.apache.org/jira/browse/FLINK-22733 Project: Flink

[jira] [Updated] (FLINK-22733) Type mismatch thrown in KeyedStream.union in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22733: Issue Type: Bug (was: Improvement) > Type mismatch thrown in KeyedStream.union in Python DataStream API

[GitHub] [flink] xintongsong commented on a change in pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

xintongsong commented on a change in pull request #15524: URL: https://github.com/apache/flink/pull/15524#discussion_r636608218 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerServiceImpl.java ## @@ -0,0 +1,347 @@ +/* + *

[jira] [Commented] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

[ https://issues.apache.org/jira/browse/FLINK-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348947#comment-17348947 ] Wenlong Lyu commented on FLINK-7271: hi, [~twalthr] [~xueyu] I investigate a bit on the case, the

[GitHub] [flink] xintongsong commented on a change in pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

xintongsong commented on a change in pull request #15524: URL: https://github.com/apache/flink/pull/15524#discussion_r636603827 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerServiceImpl.java ## @@ -143,25 +147,16 @@ public

[jira] [Updated] (FLINK-15024) System classloader memory leak after loading too many codegen classes.

[ https://issues.apache.org/jira/browse/FLINK-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-15024: Priority: Major (was: Minor) > System classloader memory leak after loading too many codegen

[jira] [Updated] (FLINK-15024) System classloader memory leak after loading too many codegen classes.

[ https://issues.apache.org/jira/browse/FLINK-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-15024: Labels: (was: auto-deprioritized-major) > System classloader memory leak after loading too many

[GitHub] [flink] xintongsong commented on a change in pull request #15524: [FLINK-21667][runtime] Defer starting ResourceManager to after obtaining leadership.

xintongsong commented on a change in pull request #15524: URL: https://github.com/apache/flink/pull/15524#discussion_r636600545 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerServiceImpl.java ## @@ -18,63 +18,101 @@

[GitHub] [flink] LadyForest commented on a change in pull request #15949: [FLINK-22319][table][sql-client] Support RESET table option for ALTER TABLE statement

LadyForest commented on a change in pull request #15949: URL: https://github.com/apache/flink/pull/15949#discussion_r636599668 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java ## @@

[jira] [Created] (FLINK-22732) Restrict ALTER TABLE from setting empty table options

Jane Chan created FLINK-22732: - Summary: Restrict ALTER TABLE from setting empty table options Key: FLINK-22732 URL: https://issues.apache.org/jira/browse/FLINK-22732 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #15679: [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources.

flinkbot edited a comment on pull request #15679: URL: https://github.com/apache/flink/pull/15679#issuecomment-822619295 ## CI report: * 52666aec138a4d90021047b344010a1946925417 Azure:

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15977: [FLINK-22725] Resolved SlotManagers should unregister metrics at the …

flinkbot edited a comment on pull request #15977: URL: https://github.com/apache/flink/pull/15977#issuecomment-845223929 ## CI report: * 3fa8a67f5fb94c32cc0bfe2160598029ebbfe073 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/226470521) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 5237b1460bc7089cef03814417a9f6e511c85f57 Azure:

[jira] [Assigned] (FLINK-21375) Refactor HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21375: Assignee: (was: Xintong Song) > Refactor HybridMemorySegment >

[jira] [Commented] (FLINK-21375) Refactor HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348933#comment-17348933 ] Xintong Song commented on FLINK-21375: -- I've been distracted by other works. Unassigned myself for

[jira] [Updated] (FLINK-21375) Refactor HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21375: - Labels: (was: stale-assigned) > Refactor HybridMemorySegment > >

[jira] [Updated] (FLINK-20988) Various resource allocation improvements for active resource managers

[ https://issues.apache.org/jira/browse/FLINK-20988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20988: - Labels: Umbrella (was: Umbrella stale-assigned) > Various resource allocation improvements for

[jira] [Commented] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348932#comment-17348932 ] Xintong Song commented on FLINK-21799: -- I've been distracted by other works. Unassigned myself for

[jira] [Assigned] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21799: Assignee: (was: Xintong Song) > Detect and fail explicitly on managed memory leaking

[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21799: - Component/s: (was: Runtime / Checkpointing) Runtime / Coordination >

[jira] [Updated] (FLINK-21799) Detect and fail explicitly on managed memory leaking

[ https://issues.apache.org/jira/browse/FLINK-21799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21799: - Labels: (was: stale-assigned) > Detect and fail explicitly on managed memory leaking >

[GitHub] [flink] flinkbot edited a comment on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * ce1bf535ffd28ea2b7fc10264a184f05e8980aed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 5237b1460bc7089cef03814417a9f6e511c85f57 Azure:

[jira] [Commented] (FLINK-22728) a problem of loading udf

[ https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348924#comment-17348924 ] Dian Fu commented on FLINK-22728: - [~JYXL_1] You could take a look at the following:

[GitHub] [flink] paul8263 commented on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

paul8263 commented on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-845588698 @zentol I think there might not be necessary to ensure that the classloader is closed so I kept it the same as other test cases. Also I noticed the method

[GitHub] [flink] flinkbot edited a comment on pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin…

flinkbot edited a comment on pull request #15927: URL: https://github.com/apache/flink/pull/15927#issuecomment-842054909 ## CI report: * ce1bf535ffd28ea2b7fc10264a184f05e8980aed Azure:

[jira] [Updated] (FLINK-22728) a problem of loading udf

[ https://issues.apache.org/jira/browse/FLINK-22728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22728: Priority: Major (was: Blocker) > a problem of loading udf > > >

[jira] [Commented] (FLINK-22724) NoSuchMethodError PackagedProgramUtils.isPython (Application mode in native kubernetes)

[ https://issues.apache.org/jira/browse/FLINK-22724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348921#comment-17348921 ] Dian Fu commented on FLINK-22724: - Agree with [~chesnay]. Have checked that this method should exist in

[GitHub] [flink] flinkbot edited a comment on pull request #15679: [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources.

flinkbot edited a comment on pull request #15679: URL: https://github.com/apache/flink/pull/15679#issuecomment-822619295 ## CI report: * 52666aec138a4d90021047b344010a1946925417 Azure:

[jira] [Updated] (FLINK-20569) testKafkaSourceSinkWithMetadata hangs

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

[jira] [Closed] (FLINK-10871) ExecutionEnvironment & TableEnvironment should be singleton

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

[jira] [Closed] (FLINK-9837) Display the job description in the Flink web UI

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

[jira] [Updated] (FLINK-20559) history-server: don't add caching headers for /jobs/overview.json

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

[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-unassigned stale-critical (was: auto-unassigned) I am the [Flink Jira

[GitHub] [flink] weizheng92 commented on pull request #15957: [FLINK-22713][docs] Correct document syntax errors

weizheng92 commented on pull request #15957: URL: https://github.com/apache/flink/pull/15957#issuecomment-845577215 @Jark Wu could plz have a review? -- 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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- Labels: stale-blocker stale-critical (was: stale-critical) I am the [Flink Jira

[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-unassigned stale-critical (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-8093: -- Labels: auto-unassigned stale-critical usability (was: auto-unassigned usability) I am the

[jira] [Updated] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

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

[jira] [Updated] (FLINK-20560) history-server: update archives while they're being loaded

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

[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: stale-major test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical (was: ) I am the [Flink Jira

[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: stale-major (was: ) I am the [Flink Jira

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[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: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

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

[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 ] Flink Jira Bot updated FLINK-22370: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-20825) Upsert-kafka should throw a better exception when the key of the record is NULL

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

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

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

[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-unassigned stale-critical (was: auto-unassigned) I am the [Flink Jira

[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-unassigned stale-critical (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

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

[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: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-20641) flink-connector-elasticsearch6 will deadlock

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

[jira] [Updated] (FLINK-20474) flink cep results of doc is not right

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

[jira] [Updated] (FLINK-20448) Obsolete generated avro classes

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

[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: stale-major (was: ) I am the [Flink Jira

[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-unassigned stale-critical (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-20785) MapRelDataType for legacy planner has wrong digest

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

[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: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-20643) flink-connector-elasticsearch7 causes Direct buffer memory OOM

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

[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: stale-major (was: ) I am the [Flink Jira

[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: stale-major test-stability (was: test-stability) I am the [Flink Jira

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[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: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

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

[jira] [Updated] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

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

[jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

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

[jira] [Updated] (FLINK-20518) WebUI should escape characters in metric names

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

[jira] [Updated] (FLINK-21032) JsonFileCompactionITCase fails on azure

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

  1   2   3   4   5   6   >