[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20798: -- Description: 我这边 部署 flink 到 k8s 使用 PVC 作为 high avalibility storagedir ， 我看jobmanager 的日志，选举成功了。但是

[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20798: -- Description: 我这边 部署 flink 到 k8s 使用 PVC 作为 high avalibility storagedir ， 我看jobmanager 的日志，选举成功了。但是

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256365#comment-17256365 ] Yang Wang commented on FLINK-20798: --- [~hayden zhou] I do not find any suspicious logs in the attached

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 554e0a2c2ada42836d65397b163bad657806e8c2 Azure:

[GitHub] [flink] wuchong commented on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

wuchong commented on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-752361626 I helped to beautify the format. Will merge this once Azure is passed. This is an automated message from the

[jira] [Updated] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20816: - Description: [This

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 554e0a2c2ada42836d65397b163bad657806e8c2 Azure:

[jira] [Commented] (FLINK-20301) Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible

[ https://issues.apache.org/jira/browse/FLINK-20301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256349#comment-17256349 ] hehuiyuan commented on FLINK-20301: --- Array  & Array is not compatible. > Flink sql 1.10 : Legacy

[jira] [Created] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

Matthias created FLINK-20816: Summary: NotifyCheckpointAbortedITCase failed due to timeout Key: FLINK-20816 URL: https://issues.apache.org/jira/browse/FLINK-20816 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20814) The CEP code is not running properly

[ https://issues.apache.org/jira/browse/FLINK-20814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256346#comment-17256346 ] huqingwen commented on FLINK-20814: --- I have the same problem。 > The CEP code is not running properly

[jira] [Comment Edited] (FLINK-20815) Elasticsearch7DynamicSinkITCase failed caused by pulling docker image error

[ https://issues.apache.org/jira/browse/FLINK-20815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256344#comment-17256344 ] zlzhang0122 edited comment on FLINK-20815 at 12/30/20, 7:19 AM: This

[jira] [Commented] (FLINK-20815) Elasticsearch7DynamicSinkITCase failed caused by pulling docker image error

[ https://issues.apache.org/jira/browse/FLINK-20815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256344#comment-17256344 ] zlzhang0122 commented on FLINK-20815: - This problem maybe relate to

[jira] [Created] (FLINK-20815) Elasticsearch7DynamicSinkITCase failed caused by pulling docker image error

zlzhang0122 created FLINK-20815: --- Summary: Elasticsearch7DynamicSinkITCase failed caused by pulling docker image error Key: FLINK-20815 URL: https://issues.apache.org/jira/browse/FLINK-20815 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #14464: [FLINK-20385][canal][json] Allow to read metadata for canal-json format

flinkbot edited a comment on pull request #14464: URL: https://github.com/apache/flink/pull/14464#issuecomment-749543461 ## CI report: * e81abd70d44d6ce7221d4cd2f44d31deab78ea9a UNKNOWN * 554e0a2c2ada42836d65397b163bad657806e8c2 Azure:

[jira] [Commented] (FLINK-20814) The CEP code is not running properly

[ https://issues.apache.org/jira/browse/FLINK-20814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256341#comment-17256341 ] little-tomato commented on FLINK-20814: --- my pom file: org.apache.flink

[jira] [Updated] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19635: --- Fix Version/s: 1.13.0 > HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result

[jira] [Created] (FLINK-20814) The CEP code is not running properly

little-tomato created FLINK-20814: - Summary: The CEP code is not running properly Key: FLINK-20814 URL: https://issues.apache.org/jira/browse/FLINK-20814 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20026) Jdbc connector support regular expression

[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256337#comment-17256337 ] jiawen xiao commented on FLINK-20026: - SGTM，please a assign , I want to try > Jdbc connector

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256334#comment-17256334 ] jiawen xiao commented on FLINK-20777: - hi , [~renqs] , Maybe we need more people’s opinions hi

[jira] [Updated] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19635: --- Fix Version/s: (was: 1.12.0) 1.12.1 >

[jira] [Updated] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-19635: --- Fix Version/s: (was: 1.12.1) 1.12.0 >

[jira] [Reopened] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-19635: > HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result > mismatch >

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256332#comment-17256332 ] Leonard Xu commented on FLINK-19635: oops, let me reopen this >

[GitHub] [flink] xintongsong commented on a change in pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

xintongsong commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r549959072 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,93 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-20800) HadoopViewFileSystemTruncateTest failure caused by AssumptionViolatedException

[ https://issues.apache.org/jira/browse/FLINK-20800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256330#comment-17256330 ] zlzhang0122 commented on FLINK-20800: - [~chesnay] Thanks for your reply. You are right, the reason

[jira] [Created] (FLINK-20813) SQL Client should create modules with user class loader

Rui Li created FLINK-20813: -- Summary: SQL Client should create modules with user class loader Key: FLINK-20813 URL: https://issues.apache.org/jira/browse/FLINK-20813 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

flinkbot edited a comment on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693 ## CI report: * 655b2992fd97e20ef142287bfd435832c469261d Azure:

[jira] [Commented] (FLINK-20809) Limit push down with Hive table doesn't work when using with filter

[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256302#comment-17256302 ] Rui Li commented on FLINK-20809: Sure I'll take a look. > Limit push down with Hive table doesn't work

[jira] [Assigned] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20812: --- Assignee: WeiNan Zhao > flink connector hbase(1.4,2.2) too few control parameters provided >

[jira] [Commented] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256299#comment-17256299 ] Jark Wu commented on FLINK-20812: - Assigned this issue to you [~ZhaoWeiNan]. > flink connector

[jira] [Commented] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

[ https://issues.apache.org/jira/browse/FLINK-20348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256298#comment-17256298 ] zhuxiaoshang commented on FLINK-20348: -- [~jark]，I want to have a try. > Make

[GitHub] [flink] wuchong commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

wuchong commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-752336588 Hi @V1ncentzzZ , please avoid to use `git pull` or `git merge` in your dev branch. In order to have lastest master branch in your dev branch, a better way is to use `git

[jira] [Commented] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256297#comment-17256297 ] WeiNan Zhao commented on FLINK-20812: - I agree with your approach > flink connector hbase(1.4,2.2)

[jira] [Closed] (FLINK-20458) Translate page 'SQL-gettingStarted' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-20458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20458. --- Resolution: Fixed Fixed in master: bd403e2cd33490db7aa5dcde72ae53dc46d304a3 > Translate page

[GitHub] [flink] wuchong merged pull request #14437: [FLINK-20458][docs] translate gettingStarted.zh.md and correct spelling errors in gettingStarted.md

wuchong merged pull request #14437: URL: https://github.com/apache/flink/pull/14437 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

[GitHub] [flink] flinkbot edited a comment on pull request #14392: [FLINK-20606][connectors/hive, table sql] sql cli with hive catalog c…

flinkbot edited a comment on pull request #14392: URL: https://github.com/apache/flink/pull/14392#issuecomment-745400662 ## CI report: * a366565d2ef37c57eee2d17f5718b2f0e6f173a8 Azure:

[jira] [Updated] (FLINK-20809) Limit push down with Hive table doesn't work when using with filter

[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20809: Summary: Limit push down with Hive table doesn't work when using with filter (was: the limit push down

[jira] [Commented] (FLINK-20809) Limit push down with Hive table doesn't work when using with filter

[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256295#comment-17256295 ] Jark Wu commented on FLINK-20809: - cc [~lirui], could you help to check this? > Limit push down with

[jira] [Updated] (FLINK-20809) the limit push down invalid when use filter

[ https://issues.apache.org/jira/browse/FLINK-20809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20809: Component/s: (was: Table SQL / API) Connectors / Hive > the limit push down invalid

[jira] [Updated] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20812: Affects Version/s: (was: 1.13.0) (was: 1.11.3)

[jira] [Updated] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20812: Component/s: Table SQL / Ecosystem > flink connector hbase(1.4,2.2) too few control parameters provided >

[jira] [Commented] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256294#comment-17256294 ] Jark Wu commented on FLINK-20812: - I think we can do this like Kafka connector. Kafka connector provides

[jira] [Updated] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20812: Labels: (was: flink-connector) > flink connector hbase(1.4,2.2) too few control parameters provided >

[jira] [Comment Edited] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256293#comment-17256293 ] Yuan Mei edited comment on FLINK-20488 at 12/30/20, 5:37 AM: - A bit more

[jira] [Commented] (FLINK-20488) Show checkpoint type in the UI (AC/UC) for each subtask

[ https://issues.apache.org/jira/browse/FLINK-20488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256293#comment-17256293 ] Yuan Mei commented on FLINK-20488: -- A bit more details:   On the high-level, people want to

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256291#comment-17256291 ] Yuan Mei edited comment on FLINK-18983 at 12/30/20, 5:34 AM: - As [~liuyufei] 

[jira] [Commented] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256291#comment-17256291 ] Yuan Mei commented on FLINK-18983: -- As [~liuyufei] mentioned that they already have an internal

[jira] [Updated] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

[ https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] WeiNan Zhao updated FLINK-20812: Labels: flink-connector (was: ) > flink connector hbase(1.4,2.2) too few control parameters

[jira] [Created] (FLINK-20812) flink connector hbase(1.4,2.2) too few control parameters provided

WeiNan Zhao created FLINK-20812: --- Summary: flink connector hbase(1.4,2.2) too few control parameters provided Key: FLINK-20812 URL: https://issues.apache.org/jira/browse/FLINK-20812 Project: Flink

[GitHub] [flink] HuangZhenQiu commented on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

HuangZhenQiu commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-752331980 @xintongsong In the current implementation, I choose to use the class name TimestampBasedFailureRater rather than ThresholdMeter because there is a container failure

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

HuangZhenQiu commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r549938770 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,93 @@ +/* + * Licensed

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256288#comment-17256288 ] Jiangjie Qin commented on FLINK-20777: -- >From a Kafka user's perspective, I would expect the

[jira] [Comment Edited] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256282#comment-17256282 ] Huang Xingbo edited comment on FLINK-19635 at 12/30/20, 4:42 AM: -

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256282#comment-17256282 ] Huang Xingbo commented on FLINK-19635: --

[jira] [Comment Edited] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256280#comment-17256280 ] hayden zhou edited comment on FLINK-20798 at 12/30/20, 4:39 AM:

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256281#comment-17256281 ] hayden zhou commented on FLINK-20798: - can we chat on wechat？ my wechat account `zmfk2009` > Using

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256280#comment-17256280 ] hayden zhou commented on FLINK-20798: - [^flink.log] this is the log > Using PVC as

[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hayden zhou updated FLINK-20798: Attachment: flink.log > Using PVC as high-availability.storageDir could not work >

[jira] [Commented] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256279#comment-17256279 ] Jark Wu commented on FLINK-20321: - I assigned this issue to you [~xwang51]. Welcome contribution

[jira] [Assigned] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18654: --- Assignee: jiawen xiao > Correct missleading documentation in "Partitioned Scan" section of JDBC >

[jira] [Assigned] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20321: --- Assignee: Xue Wang (was: Sampad Kumar Saha) > Get NPE when using AvroDeserializationSchema to

[jira] [Updated] (FLINK-20026) Jdbc connector support regular expression

[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20026: Component/s: Table SQL / Ecosystem > Jdbc connector support regular expression >

[jira] [Commented] (FLINK-20026) Jdbc connector support regular expression

[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256278#comment-17256278 ] Jark Wu commented on FLINK-20026: - I'm fine with this feature. But we should make clear some

[jira] [Updated] (FLINK-20810) abstract JdbcSchema structure and derive it from JdbcDialect.

[ https://issues.apache.org/jira/browse/FLINK-20810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20810: Component/s: Table SQL / Ecosystem > abstract JdbcSchema structure and derive it from JdbcDialect. >

[jira] [Updated] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20386: Fix Version/s: 1.13.0 > ClassCastException when lookup join a JDBC table on INT UNSIGNED column >

[GitHub] [flink] xintongsong commented on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

xintongsong commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-752320806 On more thing, we need to update the PR w.r.t. the community's new formatting rules. Please check this

[GitHub] [flink] xintongsong commented on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

xintongsong commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-752320177 @HuangZhenQiu, Sorry for the late response. I don't think need to split the 100 LoC into `ThresholdMeter`, `TimestampBasedThresholdMeter`, and `FailureRater`. On the

[GitHub] [flink] xintongsong commented on a change in pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

xintongsong commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r549927391 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,93 @@ +/* + * Licensed to

[GitHub] [flink] xintongsong commented on a change in pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

xintongsong commented on a change in pull request #8952: URL: https://github.com/apache/flink/pull/8952#discussion_r549927391 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java ## @@ -0,0 +1,93 @@ +/* + * Licensed to

[GitHub] [flink] leonardBang commented on pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

leonardBang commented on pull request #14280: URL: https://github.com/apache/flink/pull/14280#issuecomment-752319197 Could you help rebase this PR? @wangxlong The master branch merged a big format PR which caused the conflict

[GitHub] [flink] zoucao closed pull request #14479: [FLINK-20505][yarn]let yarn descriptor support negative file length

zoucao closed pull request #14479: URL: https://github.com/apache/flink/pull/14479 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

[jira] [Assigned] (FLINK-17855) UDF with parameter Array(Row) can not work

[ https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17855: --- Assignee: Nicholas Jiang > UDF with parameter Array(Row) can not work >

[jira] [Comment Edited] (FLINK-20800) HadoopViewFileSystemTruncateTest failure caused by AssumptionViolatedException

[ https://issues.apache.org/jira/browse/FLINK-20800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255878#comment-17255878 ] zlzhang0122 edited comment on FLINK-20800 at 12/30/20, 3:35 AM: -I think

[jira] [Closed] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20505. Resolution: Won't Do As discussed, we will not support HTTP paths for the shared libs. Instead,

[jira] [Updated] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20798: -- Summary: Using PVC as high-availability.storageDir could not work (was: Service temporarily

[jira] [Created] (FLINK-20811) Support HTTP paths for yarn ship files/archives

Xintong Song created FLINK-20811: Summary: Support HTTP paths for yarn ship files/archives Key: FLINK-20811 URL: https://issues.apache.org/jira/browse/FLINK-20811 Project: Flink Issue Type:

[jira] [Closed] (FLINK-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir

[ https://issues.apache.org/jira/browse/FLINK-20797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-20797. - Resolution: Duplicate > can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir >

[jira] [Commented] (FLINK-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir

[ https://issues.apache.org/jira/browse/FLINK-20797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256256#comment-17256256 ] Yang Wang commented on FLINK-20797: --- I will close this ticket and let's keep the discussion under 

[jira] [Commented] (FLINK-20797) can flink on k8s use pv using NFS and pvc as the hight avalibility storagedir

[ https://issues.apache.org/jira/browse/FLINK-20797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256255#comment-17256255 ] Yang Wang commented on FLINK-20797: --- Mounting a PVC to replace the distributed storage in HA should

[jira] [Commented] (FLINK-20798) Service temporarily unavailable due to an ongoing leader election. Please refresh.

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256254#comment-17256254 ] Yang Wang commented on FLINK-20798: --- Could you share the complete logs for JobManager? From the pieces

[jira] [Commented] (FLINK-15656) Support user-specified pod templates

[ https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256252#comment-17256252 ] Yang Wang commented on FLINK-15656: --- [~lublinsky] I just give some examples here. Actually, these two

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256251#comment-17256251 ] Yang Wang commented on FLINK-17598: --- I notice that you have created some tickets FLINK-20798 and 

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256246#comment-17256246 ] hayden zhou commented on FLINK-17598: - [~fly_in_gis] I am trying to deploy Flink on k8s with HA

[jira] [Comment Edited] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256246#comment-17256246 ] hayden zhou edited comment on FLINK-17598 at 12/30/20, 3:07 AM:

[jira] [Updated] (FLINK-20810) abstract JdbcSchema structure and derive it from JdbcDialect.

[ https://issues.apache.org/jira/browse/FLINK-20810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiawen xiao updated FLINK-20810: Description: related  https://issues.apache.org/jira/browse/FLINK-20386?filter=12349963 >

[jira] [Updated] (FLINK-20810) abstract JdbcSchema structure and derive it from JdbcDialect.

[ https://issues.apache.org/jira/browse/FLINK-20810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiawen xiao updated FLINK-20810: Environment: (was: related  https://issues.apache.org/jira/browse/FLINK-20386?filter=12349963)

[jira] [Created] (FLINK-20810) abstract JdbcSchema structure and derive it from JdbcDialect.

jiawen xiao created FLINK-20810: --- Summary: abstract JdbcSchema structure and derive it from JdbcDialect. Key: FLINK-20810 URL: https://issues.apache.org/jira/browse/FLINK-20810 Project: Flink

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256244#comment-17256244 ] Huang Xingbo commented on FLINK-20329: --

[jira] [Commented] (FLINK-20026) Jdbc connector support regular expression

[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256243#comment-17256243 ] jiawen xiao commented on FLINK-20026: - cc,[~jark]. WDYT? > Jdbc connector support regular

[jira] [Commented] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

[ https://issues.apache.org/jira/browse/FLINK-20321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256240#comment-17256240 ] Xue Wang commented on FLINK-20321: -- Thank you, [~sampadsaha5]. I've worked with Avro Serdes and

[jira] [Commented] (FLINK-18654) Correct missleading documentation in "Partitioned Scan" section of JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256241#comment-17256241 ] jiawen xiao commented on FLINK-18654: - Hi,[~jark],I am happy to solve this problem .i will fix  it

[jira] [Created] (FLINK-20809) the limit push down invalid when use filter

Jun Zhang created FLINK-20809: - Summary: the limit push down invalid when use filter Key: FLINK-20809 URL: https://issues.apache.org/jira/browse/FLINK-20809 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256234#comment-17256234 ] jiawen xiao commented on FLINK-15352: - hi,[~phoenixjiangnan],I think this is a clear task and I am

[GitHub] [flink] flinkbot edited a comment on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

flinkbot edited a comment on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693 ## CI report: * ef398a6aca683bb22074d7a72abd6a328981610e Azure:

[jira] [Commented] (FLINK-20801) Using asynchronous methods in operators causes serialization problems

[ https://issues.apache.org/jira/browse/FLINK-20801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256230#comment-17256230 ] lafeier commented on FLINK-20801: - Well, I tried Async IO and it didn't meet my needs.This issue is a

[GitHub] [flink] V1ncentzzZ commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

V1ncentzzZ commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-752300734 Hi @fsk119, Would you help review this? This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

flinkbot edited a comment on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-751906693 ## CI report: * ef398a6aca683bb22074d7a72abd6a328981610e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14392: [FLINK-20606][connectors/hive, table sql] sql cli with hive catalog c…

flinkbot edited a comment on pull request #14392: URL: https://github.com/apache/flink/pull/14392#issuecomment-745400662 ## CI report: * Unknown: [CANCELED](TBD) * a366565d2ef37c57eee2d17f5718b2f0e6f173a8 Azure:

[jira] [Updated] (FLINK-20693) Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

[ https://issues.apache.org/jira/browse/FLINK-20693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20693: Component/s: API / Python > Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java >

[jira] [Closed] (FLINK-20693) Port BatchExecPythonCorrelate and StreamExecPythonCorrelate to Java

[ https://issues.apache.org/jira/browse/FLINK-20693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20693. --- Assignee: Huang Xingbo Resolution: Fixed Merged to master via 

  1   2   3   4   >