[GitHub] [flink] flinkbot edited a comment on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

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

[jira] [Comment Edited] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151190#comment-17151190 ] Dian Fu edited comment on FLINK-18485 at 7/4/20, 6:20 AM: -- I tr

[jira] [Comment Edited] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151190#comment-17151190 ] Dian Fu edited comment on FLINK-18485 at 7/4/20, 6:09 AM: -- I tr

[jira] [Commented] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151190#comment-17151190 ] Dian Fu commented on FLINK-18485: - It should be a temporary technique issue of oracle we

[GitHub] [flink] wuchong commented on a change in pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

wuchong commented on a change in pull request #12802: URL: https://github.com/apache/flink/pull/12802#discussion_r449743192 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -1038,7 +1038,7 @@ use [time attributes](time_attributes.html). To select those there are

[GitHub] [flink] flinkbot edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * f284f503448e04e77c01d35b96a1130e52198f71 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

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

[jira] [Commented] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI

[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151182#comment-17151182 ] Dian Fu commented on FLINK-9992: master:  [https://dev.azure.com/apache-flink/apache-flin

[jira] [Commented] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151181#comment-17151181 ] Dian Fu commented on FLINK-18485: - Another instance on master branch:  [https://dev.azur

[jira] [Updated] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18485: Description: Instance on 1.11 branch:  [https://dev.azure.com/apache-flink/apache-flink/_build/results?bui

[GitHub] [flink] flinkbot edited a comment on pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

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

[jira] [Created] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

Dian Fu created FLINK-18485: --- Summary: Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip Key: FLINK-18485 URL: https://issues.apache.org/jira/browse/FLINK-18485 Project: Flink

[jira] [Updated] (FLINK-18485) Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.zip

[ https://issues.apache.org/jira/browse/FLINK-18485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18485: Labels: test-stability (was: ) > Kerberized YARN per-job on Docker test failed during unzip jce_policy-8.

[GitHub] [flink] flinkbot edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * 709566f740d1070ade3d82b193583c2b01dbd49f Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151166#comment-17151166 ] initsun edited comment on FLINK-18481 at 7/4/20, 4:29 AM: -- {quo

[jira] [Commented] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151166#comment-17151166 ] initsun commented on FLINK-18481: - {quote}StreamExecutionEnvironment bsEnv = StreamExec

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151165#comment-17151165 ] zhisheng edited comment on FLINK-18449 at 7/4/20, 4:23 AM: --- wh

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151165#comment-17151165 ] zhisheng edited comment on FLINK-18449 at 7/4/20, 4:23 AM: --- wh

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151165#comment-17151165 ] zhisheng edited comment on FLINK-18449 at 7/4/20, 4:22 AM: --- wh

[jira] [Commented] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151165#comment-17151165 ] zhisheng commented on FLINK-18449: -- what about this?[~jark] I had make change like belo

[GitHub] [flink] flinkbot edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

flinkbot edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-652303680 ## CI report: * ad5d5dcac846080e2e40255505dd35896a6c7a94 UNKNOWN * 709566f740d1070ade3d82b193583c2b01dbd49f Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] RocMarshal commented on a change in pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

RocMarshal commented on a change in pull request #12802: URL: https://github.com/apache/flink/pull/12802#discussion_r449736177 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -1038,7 +1038,7 @@ use [time attributes](time_attributes.html). To select those there

[jira] [Commented] (FLINK-18481) Kafka connector can't select data

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151164#comment-17151164 ] Jark Wu commented on FLINK-18481: - 1. Could you try to sleep a while after the first job

[GitHub] [flink] flinkbot edited a comment on pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

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

[GitHub] [flink] flinkbot edited a comment on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

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

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151151#comment-17151151 ] Jark Wu edited comment on FLINK-18449 at 7/4/20, 3:31 AM: -- I pr

[jira] [Comment Edited] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151151#comment-17151151 ] Jark Wu edited comment on FLINK-18449 at 7/4/20, 3:31 AM: -- I pr

[jira] [Commented] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151151#comment-17151151 ] Jark Wu commented on FLINK-18449: - {code:java} 'topic' = 'topic'

[GitHub] [flink] RocMarshal commented on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

RocMarshal commented on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-653711374 Hi, @libenchao , @klion26 , Could you help me to review this PR if you have free time? This review task is a bit huge for @XBaith and me to complete. Thank you.

[GitHub] [flink] RocMarshal edited a comment on pull request #12798: [FLINK-16087][docs-zh] Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

RocMarshal edited a comment on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-653711374 Hi, @libenchao , @klion26 , Could you help me to review this PR if you have free time? This `review` task is a bit huge for @XBaith and me to complete. T

[GitHub] [flink] wuchong commented on a change in pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

wuchong commented on a change in pull request #12802: URL: https://github.com/apache/flink/pull/12802#discussion_r449731700 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -1038,7 +1038,7 @@ use [time attributes](time_attributes.html). To select those there are

[GitHub] [flink] RocMarshal commented on pull request #12802: [FLINK-18457][docs] Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

RocMarshal commented on pull request #12802: URL: https://github.com/apache/flink/pull/12802#issuecomment-653709898 Hi, @wuchong . I have fixed the invalid links in `flink/docs/dev/table/streaming/match_recognize.md`. And I will fix the invalid links in `flink/docs/dev/tabl

[GitHub] [flink] flinkbot edited a comment on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

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

[GitHub] [flink] chaojianok commented on pull request #12797: [FLINK-18387] Translate "BlackHole SQL Connector" page into Chinese

chaojianok commented on pull request #12797: URL: https://github.com/apache/flink/pull/12797#issuecomment-653705322 Hi @klion26 , I've optimized this translation, please review again. This is an automated message from the Apa

[GitHub] [flink] flinkbot edited a comment on pull request #12822: [FLINK-18484][core] - Add length difference information to arity exception

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

[jira] [Updated] (FLINK-18482) Replace flink-training datasets with data generators

[ https://issues.apache.org/jira/browse/FLINK-18482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18482: --- Labels: pull-request-available (was: ) > Replace flink-training datasets with data generato

[jira] [Updated] (FLINK-16794) ClassNotFoundException caused by ClassLoader.getSystemClassLoader using impertinently

[ https://issues.apache.org/jira/browse/FLINK-16794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-16794: Affects Version/s: (was: 1.8.3) (was: 1.8.2)

[jira] [Closed] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs

[ https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10867. - Resolution: Duplicate > Add a DataSet-based CacheOperator to reuse results between jobs > --

[jira] [Commented] (FLINK-16867) Simplify default timeout configuration

[ https://issues.apache.org/jira/browse/FLINK-16867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150883#comment-17150883 ] Robert Metzger commented on FLINK-16867: I generally agree that this is a good i

[jira] [Assigned] (FLINK-18468) TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination fails with DuplicateJobSubmissionException

[ https://issues.apache.org/jira/browse/FLINK-18468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-18468: - Assignee: Till Rohrmann > TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermina

[jira] [Closed] (FLINK-17042) Jackson version conflict for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-17042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17042. Resolution: Cannot Reproduce > Jackson version conflict for Flink 1.9 > --

[jira] [Updated] (FLINK-18470) Tests RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorByte & RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorShort fail locally

[ https://issues.apache.org/jira/browse/FLINK-18470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18470: --- Labels: pull-request-available (was: ) > Tests RocksKeyGroupsRocksSingleStateIteratorTest#t

[jira] [Assigned] (FLINK-10643) Bubble execution: Resource aware job execution

[ https://issues.apache.org/jira/browse/FLINK-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10643: - Assignee: (was: ryantaocer) > Bubble execution: Resource aware job execution >

[jira] [Closed] (FLINK-18461) Changelog source can't be insert into upsert sink

[ https://issues.apache.org/jira/browse/FLINK-18461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18461. --- Resolution: Fixed - master (1.12.0): e08994588709b30e5d59d3c8302893a53c8a6baf - 1.11.1: 334f35cbd6da754d8b5b

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150791#comment-17150791 ] Piotr Nowojski commented on FLINK-17073: Hey [~echauchot], I'm OoO since last tw

[jira] [Updated] (FLINK-18461) Changelog source can't be insert into upsert sink

[ https://issues.apache.org/jira/browse/FLINK-18461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18461: Fix Version/s: 1.12.0 > Changelog source can't be insert into upsert sink > --

[jira] [Updated] (FLINK-18240) Correct modulus function usage in documentation or allow % operator

[ https://issues.apache.org/jira/browse/FLINK-18240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18240: --- Labels: pull-request-available (was: ) > Correct modulus function usage in documentation or

[jira] [Updated] (FLINK-18461) Changelog source can't be insert into upsert sink

[ https://issues.apache.org/jira/browse/FLINK-18461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18461: Fix Version/s: (was: 1.11.0) 1.11.1 > Changelog source can't be insert into upsert

[jira] [Closed] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10818. - Resolution: Abandoned The issue seems to be abandoned. > RestartStrategies.fixedDelayRestart Oc

[jira] [Closed] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10862. - Resolution: Won't Do Won't do because of feature creep. > REST API does not show program descri

[jira] [Commented] (FLINK-18479) can not commit partition when set partition time

[ https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150934#comment-17150934 ] Jun Zhang commented on FLINK-18479: --- hi,[~lzljs3620320] if I want to use partition pat

[jira] [Updated] (FLINK-16764) Allow custom Kafka topic discovery logic

[ https://issues.apache.org/jira/browse/FLINK-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16764: Fix Version/s: (was: 1.12.0) > Allow custom Kafka topic discovery logic >

[jira] [Commented] (FLINK-17024) Make AkkaRpcService#getExecutor return a custom thread pool

[ https://issues.apache.org/jira/browse/FLINK-17024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150871#comment-17150871 ] Chesnay Schepler commented on FLINK-17024: -- If the executor isn't running in th

[jira] [Commented] (FLINK-15843) Gracefully shutdown TaskManagers on Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-15843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150879#comment-17150879 ] Chesnay Schepler commented on FLINK-15843: -- [~fly_in_gis] ping > Gracefully sh

[jira] [Updated] (FLINK-18449) Make topic discovery and partition discovery configurable for FlinkKafkaConsumer in Table API

[ https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18449: Fix Version/s: 1.12.0 > Make topic discovery and partition discovery configurable for > FlinkKafkaConsume

[jira] [Updated] (FLINK-15221) supporting Exactly-once for kafka table APi

[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15221: Fix Version/s: 1.12.0 > supporting Exactly-once for kafka table APi >

[jira] [Updated] (FLINK-16764) Allow custom Kafka topic discovery logic

[ https://issues.apache.org/jira/browse/FLINK-16764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16764: Fix Version/s: 1.12.0 > Allow custom Kafka topic discovery logic > ---

[jira] [Commented] (FLINK-18468) TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination fails with DuplicateJobSubmissionException

[ https://issues.apache.org/jira/browse/FLINK-18468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151033#comment-17151033 ] Till Rohrmann commented on FLINK-18468: --- The problem of this test case is that we

[jira] [Assigned] (FLINK-15221) supporting Exactly-once for kafka table APi

[ https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15221: --- Assignee: Shengkai Fang (was: chaiyongqiang) > supporting Exactly-once for kafka table APi > -

[jira] [Commented] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150958#comment-17150958 ] Robert Metzger commented on FLINK-18013: [~zenfenan] FYI: I'm on vacation for 2

[jira] [Created] (FLINK-18480) JomManager suspend because of loss ZK connection

Zhang Jianguo created FLINK-18480: - Summary: JomManager suspend because of loss ZK connection Key: FLINK-18480 URL: https://issues.apache.org/jira/browse/FLINK-18480 Project: Flink Issue Type

[jira] [Commented] (FLINK-17090) Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU

[ https://issues.apache.org/jira/browse/FLINK-17090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150874#comment-17150874 ] Chesnay Schepler commented on FLINK-17090: -- [~felixzheng] Do you have a specifi

[jira] [Commented] (FLINK-18451) Flink HA on yarn may appear TaskManager double running when HA is restored

[ https://issues.apache.org/jira/browse/FLINK-18451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150766#comment-17150766 ] ming li commented on FLINK-18451: - Hi,[~trohrmann]. Thanks for your reply. We are curre

[jira] [Closed] (FLINK-10728) Unexpected items on ASF mirrors

[ https://issues.apache.org/jira/browse/FLINK-10728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10728. - Resolution: Fixed The issue should have been resolved by the linked PR. > Unexpected items on A

[jira] [Closed] (FLINK-18462) Improve the exception message when INSERT INTO mismatch types for empty char

[ https://issues.apache.org/jira/browse/FLINK-18462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18462. --- Fix Version/s: 1.12.0 Resolution: Fixed - master (1.12.0): 334f35cbd6da754d8b5b294032cd84c858b1f973

[jira] [Updated] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10656: -- Component/s: (was: Runtime / Coordination) Runtime / Network > Refactor o

[jira] [Commented] (FLINK-10643) Bubble execution: Resource aware job execution

[ https://issues.apache.org/jira/browse/FLINK-10643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150866#comment-17150866 ] Till Rohrmann commented on FLINK-10643: --- This could be a follow up step once we ha

[jira] [Updated] (FLINK-18480) JobManager lost zk connection, HA can not work

[ https://issues.apache.org/jira/browse/FLINK-18480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhang Jianguo updated FLINK-18480: -- Summary: JobManager lost zk connection, HA can not work (was: JomManager suspend because of l

[jira] [Closed] (FLINK-10654) AllowNonRestoredState should skip state that cannot be restored

[ https://issues.apache.org/jira/browse/FLINK-10654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10654. - Resolution: Abandoned Closing for inactivity. > AllowNonRestoredState should skip state that ca

[jira] [Updated] (FLINK-10664) Flink: Checkpointing fails with S3 exception - Please reduce your request rate

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

[jira] [Commented] (FLINK-17176) Slow down Pod re-creation in KubernetesResourceManager#PodCallbackHandler

[ https://issues.apache.org/jira/browse/FLINK-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150868#comment-17150868 ] Robert Metzger commented on FLINK-17176: [~fly_in_gis]It seems that this ticket

[jira] [Commented] (FLINK-17100) Improvements for Native Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-17100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150859#comment-17150859 ] Chesnay Schepler commented on FLINK-17100: -- What is the state here [~felixzheng

[jira] [Commented] (FLINK-17085) Remove FlinkKubeClient#handleException since it does not do anything

[ https://issues.apache.org/jira/browse/FLINK-17085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150864#comment-17150864 ] Chesnay Schepler commented on FLINK-17085: -- Sounds good [~fly_in_gis], will you

[jira] [Commented] (FLINK-18440) ROW_NUMBER function: ROW/RANGE not allowed with RANK, DENSE_RANK or ROW_NUMBER functions

[ https://issues.apache.org/jira/browse/FLINK-18440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150917#comment-17150917 ] JinxinTang commented on FLINK-18440: cc [~jark] Thank you for your test code and sug

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails locally

[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150777#comment-17150777 ] Dawid Wysakowicz commented on FLINK-18476: -- Yes, exactly you are right. The exc

[jira] [Closed] (FLINK-10640) Enable Slot Resource Profile for Resource Management

[ https://issues.apache.org/jira/browse/FLINK-10640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10640. - Resolution: Duplicate This ticket has been subsumed by FLINK-14187. > Enable Slot Resource Prof

[jira] [Commented] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150863#comment-17150863 ] Robert Metzger commented on FLINK-17177: Looking at the code, it seems that we a

[jira] [Comment Edited] (FLINK-18444) KafkaITCase.testMultipleSourcesOnePartition failed with "Failed to send data to Kafka: Failed to send data to Kafka: This server does not host this topic-partitio

[ https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150951#comment-17150951 ] Dian Fu edited comment on FLINK-18444 at 7/3/20, 11:46 AM: --- Ka

[jira] [Updated] (FLINK-18444) KafkaITCase.testMultipleSourcesOnePartition failed 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 ] Dian Fu updated FLINK-18444: Summary: KafkaITCase.testMultipleSourcesOnePartition failed with "Failed to send data to Kafka: This serve

[jira] [Updated] (FLINK-17070) Kubernetes session CLI ignores stop/help command in detached mode

[ https://issues.apache.org/jira/browse/FLINK-17070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17070: - Parent: FLINK-15856 Issue Type: Sub-task (was: Bug) > Kubernetes session CLI ig

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150857#comment-17150857 ] Robert Metzger commented on FLINK-17273: [~felixzheng] What's the status of this

[jira] [Closed] (FLINK-10573) Support task revocation

[ https://issues.apache.org/jira/browse/FLINK-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10573. - Resolution: Duplicate > Support task revocation > --- > > Ke

[jira] [Commented] (FLINK-18444) KafkaITCase.testMultipleSourcesOnePartition failed with "Failed to send data to Kafka: 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:comment-tabpanel&focusedCommentId=17150951#comment-17150951 ] Dian Fu commented on FLINK-18444: - KafkaITCase.testAllDeletes on the master branch faile

[jira] [Closed] (FLINK-6227) Introduce the abstract PartitionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6227. > Introduce the abstract PartitionException for downstream task failure > -

[jira] [Commented] (FLINK-17328) Expose network metric for job vertex in rest api

[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150858#comment-17150858 ] Chesnay Schepler commented on FLINK-17328: -- I'm not convinced this is necessary

[jira] [Comment Edited] (FLINK-18470) Tests RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorByte & RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorShort fail locally

[ https://issues.apache.org/jira/browse/FLINK-18470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151029#comment-17151029 ] Dawid Wysakowicz edited comment on FLINK-18470 at 7/3/20, 3:12 PM: ---

[jira] [Closed] (FLINK-10572) Enable Per-job level failover strategy.

[ https://issues.apache.org/jira/browse/FLINK-10572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10572. - Resolution: Abandoned Closing this ticket because the code base has diverged quite a bit due to

[jira] [Closed] (FLINK-18391) Translate "Avro Format" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18391. --- Fix Version/s: 1.11.1 1.12.0 Resolution: Fixed - master (1.12.0): be04062dbd853f6c

[jira] [Updated] (FLINK-18483) [EFO] Test coverage improvements for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-18483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-18483: -- Description: *Background* EFO will refactor the existing Polling implementation to use the pr

[jira] [Closed] (FLINK-18470) Tests RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorByte & RocksKeyGroupsRocksSingleStateIteratorTest#testMergeIteratorShort fail locally

[ https://issues.apache.org/jira/browse/FLINK-18470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18470. Fix Version/s: 1.11.1 1.12.0 Resolution: Fixed Fixed in: * maste

[jira] [Updated] (FLINK-18434) Can not select fields with JdbcCatalog

[ https://issues.apache.org/jira/browse/FLINK-18434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18434: --- Labels: pull-request-available (was: ) > Can not select fields with JdbcCatalog > -

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15728: Fix Version/s: 1.12.0 > JDBCUpsertOutputFormat does not set bind parameter keyFields in > updateStatement

[jira] [Updated] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15728: Priority: Critical (was: Major) > JDBCUpsertOutputFormat does not set bind parameter keyFields in > upda

[GitHub] [flink] flinkbot edited a comment on pull request #12822: [FLINK-18484][core] - Add length difference information to arity exception

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

[jira] [Updated] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel

[ https://issues.apache.org/jira/browse/FLINK-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15416: - Affects Version/s: 1.11.1 1.11.0 1.10.1 > Add Retry Mechan

[jira] [Commented] (FLINK-15728) JDBCUpsertOutputFormat does not set bind parameter keyFields in updateStatement

[ https://issues.apache.org/jira/browse/FLINK-15728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17150771#comment-17150771 ] Jark Wu commented on FLINK-15728: - Hi [~dasbh], are you still insterest in this issue? I

[jira] [Updated] (FLINK-18471) flink-runtime lists "org.uncommons.maths:uncommons-maths:1.2.2a" as a bundled dependency, but it isn't

[ https://issues.apache.org/jira/browse/FLINK-18471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18471: --- Labels: pull-request-available (was: ) > flink-runtime lists "org.uncommons.maths:uncommons

  1   2   3   >