[jira] [Commented] (FLINK-24477) Add MongoDB sink

2021-10-07 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426012#comment-17426012 ] Fabian Paul commented on FLINK-24477: - Hi [~nir.tsruya] I think having a MongoDB con

[jira] [Closed] (FLINK-24361) there are only two ways to define a processing time attribute but the time_attributes.md said has three

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24361. --- Fix Version/s: 1.15.0 Assignee: qingbo jiao Resolution: Fixed Fixed in master: 373b3840475c7

[GitHub] [flink] wuchong merged pull request #17339: [FLINK-24361][docs] there are only two ways to define a processing time attribute but the time_attributes.md said has three

2021-10-07 Thread GitBox
wuchong merged pull request #17339: URL: https://github.com/apache/flink/pull/17339 -- 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. To unsubscribe, e-mail: issues-unsubsc

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426004#comment-17426004 ] Xintong Song commented on FLINK-20928: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426003#comment-17426003 ] Xintong Song commented on FLINK-23493: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425988#comment-17425988 ] Xintong Song commented on FLINK-24480: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425987#comment-17425987 ] Xintong Song commented on FLINK-23391: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22096: - Fix Version/s: 1.14.1 1.15.0 1.13.3 > ServerTransportError

[jira] [Updated] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22096: - Labels: test-stability (was: auto-deprioritized-major test-stability) > ServerTransportErrorHan

[jira] [Updated] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22096: - Affects Version/s: 1.15.0 1.14.0 > ServerTransportErrorHandlingTest.testR

[jira] [Commented] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425984#comment-17425984 ] Xintong Song commented on FLINK-22096: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22096: - Priority: Major (was: Minor) > ServerTransportErrorHandlingTest.testRemoteClose fail > ---

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425983#comment-17425983 ] Xintong Song commented on FLINK-24390: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425982#comment-17425982 ] Xintong Song commented on FLINK-24480: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24480: - Affects Version/s: 1.12.5 > EqualiserCodeGeneratorTest fails on azure >

[jira] [Updated] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24480: - Component/s: (was: Table SQL / Legacy Planner) Table SQL / Planner > Equali

[GitHub] [flink] flinkbot commented on pull request #17434: [FLINK-24479][State Backends]Bug fix RocksIteratorWrapper#seekToLast method

2021-10-07 Thread GitBox
flinkbot commented on pull request #17434: URL: https://github.com/apache/flink/pull/17434#issuecomment-938378947 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 pro

[jira] [Updated] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24480: - Fix Version/s: 1.12.6 > EqualiserCodeGeneratorTest fails on azure >

[jira] [Updated] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

2021-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24479: --- Labels: pull-request-available (was: ) > Bug fix RocksIteratorWrapper#seekToLast method > -

[GitHub] [flink] xiangqiao123 opened a new pull request #17434: [FLINK-24479][State Backends]Bug fix RocksIteratorWrapper#seekToLast method

2021-10-07 Thread GitBox
xiangqiao123 opened a new pull request #17434: URL: https://github.com/apache/flink/pull/17434 ## What is the purpose of the change *Bug fix RocksIteratorWrapper#seekToLast method* ## Brief change log - *RocksIteratorWrapper#seekToLast method, calling Rock

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425981#comment-17425981 ] Xintong Song commented on FLINK-18634: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24476) Rename all ElasticSearch to Elasticsearch (without camel case)

2021-10-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425979#comment-17425979 ] Ingo Bürk commented on FLINK-24476: --- +1 to using proper naming, especially if it doesn

[jira] [Assigned] (FLINK-24476) Rename all ElasticSearch to Elasticsearch (without camel case)

2021-10-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk reassigned FLINK-24476: - Assignee: Ryan Skraba > Rename all ElasticSearch to Elasticsearch (without camel case) > --

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425978#comment-17425978 ] Xintong Song commented on FLINK-20928: -- Instance on 1.14: https://dev.azure.com/apa

[jira] [Created] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-07 Thread Xintong Song (Jira)
Xintong Song created FLINK-24480: Summary: EqualiserCodeGeneratorTest fails on azure Key: FLINK-24480 URL: https://issues.apache.org/jira/browse/FLINK-24480 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425977#comment-17425977 ] Xintong Song commented on FLINK-23493: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

2021-10-07 Thread xiangqiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangqiao updated FLINK-24479: -- Description: RocksIteratorWrapper#seekToLast method, calling RocksIterator#seekToFirst method incorre

[jira] [Created] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

2021-10-07 Thread xiangqiao (Jira)
xiangqiao created FLINK-24479: - Summary: Bug fix RocksIteratorWrapper#seekToLast method Key: FLINK-24479 URL: https://issues.apache.org/jira/browse/FLINK-24479 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-23611) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425976#comment-17425976 ] Xintong Song commented on FLINK-23611: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425972#comment-17425972 ] Xintong Song commented on FLINK-24390: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

2021-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425971#comment-17425971 ] Xintong Song commented on FLINK-22702: -- Instance on 1.12: https://dev.azure.com/apa

[GitHub] [flink] zicat commented on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

2021-10-07 Thread GitBox
zicat commented on pull request #14916: URL: https://github.com/apache/flink/pull/14916#issuecomment-938367503 @flinkbot -- 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. T

[jira] [Commented] (FLINK-23271) RuntimeException: while resolving method 'booleanValue' in class class java.math.BigDecimal

2021-10-07 Thread xuyangzhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425946#comment-17425946 ] xuyangzhong commented on FLINK-23271: - Hi , [~matriv]. The result of the discussion

[GitHub] [flink-ml] zhipeng93 closed pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 closed pull request #15: URL: https://github.com/apache/flink-ml/pull/15 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 edited a comment on pull request #15: URL: https://github.com/apache/flink-ml/pull/15#issuecomment-938323217 I have rebased this PR on [Flink-10, iteration](https://github.com/apache/flink-ml/pull/17) and the new PR is [here](https://github.com/apache/flink-ml/pull/18). So closin

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 edited a comment on pull request #15: URL: https://github.com/apache/flink-ml/pull/15#issuecomment-938323217 I have rebased this PR on [Flink-10][iteration](https://github.com/apache/flink-ml/pull/17) and the new PR is [here](https://github.com/apache/flink-ml/pull/18). So closin

[GitHub] [flink-ml] zhipeng93 commented on pull request #15: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 commented on pull request #15: URL: https://github.com/apache/flink-ml/pull/15#issuecomment-938323217 I have rebased this PR on [Flink-10][iteration](https://github.com/apache/flink-ml/pull/17) and the new PR is [here](https://github.com/apache/flink-ml/pull/18) -- This is an

[GitHub] [flink-ml] zhipeng93 opened a new pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-07 Thread GitBox
zhipeng93 opened a new pull request #18: URL: https://github.com/apache/flink-ml/pull/18 This PR supports withBroadcast() function in DataStream by caching the broadcastInputs in static variables. Note that this PR is rebased on [[FLINK-10][iteration]](https://github.com/apache/flin

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

2021-10-07 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425936#comment-17425936 ] Roc Marshal commented on FLINK-15352: - Could someone help me to merge it if there ar

[jira] [Commented] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-07 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425935#comment-17425935 ] Roc Marshal commented on FLINK-10230: - Could someone help me to merge it if there ar

[GitHub] [flink] xintongsong commented on a change in pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

2021-10-07 Thread GitBox
xintongsong commented on a change in pull request #16821: URL: https://github.com/apache/flink/pull/16821#discussion_r724660924 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java ## @@ -127,9 +149,13 @@ +

[jira] [Assigned] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2021-10-07 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-24334: - Assignee: ouyangwulin > Configuration kubernetes.flink.log.dir not working > --

[jira] [Commented] (FLINK-24474) Standalone clusters should bind to localhost by default

2021-10-07 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425931#comment-17425931 ] Yang Wang commented on FLINK-24474: --- What will happen if the standalone cluster is sta

[jira] [Commented] (FLINK-24334) Configuration kubernetes.flink.log.dir not working

2021-10-07 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425930#comment-17425930 ] Yang Wang commented on FLINK-24334: --- [~ouyangwuli] I think your suggestion makes sense

[GitHub] [flink] zhuzhurk commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-10-07 Thread GitBox
zhuzhurk commented on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-938299821 @tillrohrmann I have an idea already and will do it this week. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Assigned] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-24390: --- Assignee: Dian Fu > Python 'build_wheels mac' fails on azure >

[GitHub] [flink] jjiey commented on pull request #15902: [FLINK-19028][docs] Translate the "application_parameters.md" into Chinese

2021-10-07 Thread GitBox
jjiey commented on pull request #15902: URL: https://github.com/apache/flink/pull/15902#issuecomment-938295045 Already translated and merged on 3 Sep. see [pr 16949](https://github.com/apache/flink/pull/16949) -- This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] jjiey closed pull request #15902: [FLINK-19028][docs] Translate the "application_parameters.md" into Chinese

2021-10-07 Thread GitBox
jjiey closed pull request #15902: URL: https://github.com/apache/flink/pull/15902 -- 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. To unsubscribe, e-mail: issues-unsubscr.

[GitHub] [flink] flinkbot commented on pull request #17433: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5

2021-10-07 Thread GitBox
flinkbot commented on pull request #17433: URL: https://github.com/apache/flink/pull/17433#issuecomment-938293481 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 pro

[jira] [Updated] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24390: --- Labels: pull-request-available (was: ) > Python 'build_wheels mac' fails on azure > ---

[GitHub] [flink] dianfu opened a new pull request #17433: [FLINK-24390][python] Limit the grpcio version <= 1.40.0 for Python 3.5

2021-10-07 Thread GitBox
dianfu opened a new pull request #17433: URL: https://github.com/apache/flink/pull/17433 ## What is the purpose of the change *This pull request limits the grpcio version <= 1.40.0 for Python 3.5 as the latest grpcio (1.41.0 which was released in 9.28) has dropped the support for Py

[jira] [Commented] (FLINK-24390) Python 'build_wheels mac' fails on azure

2021-10-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425921#comment-17425921 ] Dian Fu commented on FLINK-24390: - It should be caused that the latest grpcio (1.41.0 wh

[jira] [Closed] (FLINK-24442) Flink Queries Docs markup does not show escape ticks

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24442. --- Fix Version/s: 1.15.0 Assignee: Mans Singh Resolution: Fixed Fixed in - master: 21582b1a92

[GitHub] [flink] wuchong merged pull request #17408: [FLINK-24442][table][docs] - Corrected markup to show back ticks

2021-10-07 Thread GitBox
wuchong merged pull request #17408: URL: https://github.com/apache/flink/pull/17408 -- 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. To unsubscribe, e-mail: issues-unsubsc

[jira] [Assigned] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24351: --- Assignee: ZhuoYu Chen > translate "JSON Function" pages into Chinese > ---

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-10-07 Thread GitBox
xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-938283249 @galenwarren Great to hear from you. It would be nice to see this in the next release. -- This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

2021-10-07 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425908#comment-17425908 ] liwei li commented on FLINK-24351: -- [~monster#12], Sorry, I don't have permission. Mayb

[jira] [Comment Edited] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "Strea

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425894#comment-17425894 ] shengkui leng edited comment on FLINK-24408 at 10/8/21, 1:08 AM: -

[jira] [Commented] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExec

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425894#comment-17425894 ] shengkui leng commented on FLINK-24408: --- [^sql.txt]   I built it with this code:

[jira] [Updated] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecVa

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengkui leng updated FLINK-24408: -- Attachment: HudiBenchS3.java > org.codehaus.janino.InternalCompilerException: Compiling > "St

[jira] [Updated] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecVa

2021-10-07 Thread shengkui leng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shengkui leng updated FLINK-24408: -- Attachment: sql.txt > org.codehaus.janino.InternalCompilerException: Compiling > "StreamExecV

[jira] [Created] (FLINK-24478) gradle quickstart is out-of-date

2021-10-07 Thread David Anderson (Jira)
David Anderson created FLINK-24478: -- Summary: gradle quickstart is out-of-date Key: FLINK-24478 URL: https://issues.apache.org/jira/browse/FLINK-24478 Project: Flink Issue Type: Improvement

[GitHub] [flink] mans2singh commented on pull request #17408: [FLINK-24442][table][docs] - Corrected markup to show back ticks

2021-10-07 Thread GitBox
mans2singh commented on pull request #17408: URL: https://github.com/apache/flink/pull/17408#issuecomment-938235770 @leonardBang @wuchong - Can you please review this PR ? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [flink] zentol merged pull request #17427: [FLINK-24472][tests] Wait for cancellation future to complete

2021-10-07 Thread GitBox
zentol merged pull request #17427: URL: https://github.com/apache/flink/pull/17427 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] hililiwei commented on a change in pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-07 Thread GitBox
hililiwei commented on a change in pull request #17106: URL: https://github.com/apache/flink/pull/17106#discussion_r723857343 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java ## @@ -74,6 +74

[GitHub] [flink] AHeise merged pull request #17358: [hotfix] Fix typo,'Kakfa' corrected to 'Kafka'

2021-10-07 Thread GitBox
AHeise merged pull request #17358: URL: https://github.com/apache/flink/pull/17358 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] AHeise merged pull request #17421: [FLINK-24405][tests] Introduce util to reliably drain all messages from a kafka topic

2021-10-07 Thread GitBox
AHeise merged pull request #17421: URL: https://github.com/apache/flink/pull/17421 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #17422: [FLINK-9432][table] Enable EXTRACT for DECADE, ISODOW, ISOYEAR

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17422: URL: https://github.com/apache/flink/pull/17422#issuecomment-937776577 ## CI report: * cb2bcd6ec000f84f73bfa38fb5c00ec33b9030de Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] AHeise commented on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2021-10-07 Thread GitBox
AHeise commented on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-937503443 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[GitHub] [flink] StephanEwen commented on pull request #17425: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

2021-10-07 Thread GitBox
StephanEwen commented on pull request #17425: URL: https://github.com/apache/flink/pull/17425#issuecomment-937676627 +1 to merge -- 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 comm

[GitHub] [flink] twalthr closed pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-07 Thread GitBox
twalthr closed pull request #17350: URL: https://github.com/apache/flink/pull/17350 -- 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. To unsubscribe, e-mail: issues-unsubsc

[GitHub] [flink] snuyanzin commented on pull request #6614: [FLINK-9432] [table] Support extract timeunit: DECADE, EPOCH, ISODOW, ISOYEAR…

2021-10-07 Thread GitBox
snuyanzin commented on pull request #6614: URL: https://github.com/apache/flink/pull/6614#issuecomment-937270898 I will close this PR and create a new one as there are from one side to many merge conflicts and from another calcite was updated to 1.2x since the time the PR was created. --

[GitHub] [flink] tillrohrmann commented on pull request #17262: [FLINK-24273][kubernetes] Relocate io.fabric8 dependency.

2021-10-07 Thread GitBox
tillrohrmann commented on pull request #17262: URL: https://github.com/apache/flink/pull/17262#issuecomment-937919332 -- 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. To uns

[GitHub] [flink-shaded] XComp commented on a change in pull request #100: [FLINK-24447][zk] Bundle netty

2021-10-07 Thread GitBox
XComp commented on a change in pull request #100: URL: https://github.com/apache/flink-shaded/pull/100#discussion_r724055043 ## File path: flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35/src/main/resources/META-INF/NOTICE ## @@ -7,6 +7,14 @@ The Apache Software Foundat

[GitHub] [flink] flinkbot commented on pull request #17426: [FLINK-24167][Runtime]Add default HeartbeatReceiver and HeartbeatSend…

2021-10-07 Thread GitBox
flinkbot commented on pull request #17426: URL: https://github.com/apache/flink/pull/17426#issuecomment-937651834 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 0a0cd972b9e8406a06ead5f7e9c8fd161340a625 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] sjwiesman commented on pull request #273: [FLINK-24464][core] Metrics sometimes report negative backlog

2021-10-07 Thread GitBox
sjwiesman commented on pull request #273: URL: https://github.com/apache/flink-statefun/pull/273#issuecomment-937327204 I'll fix the header while merging, grazi! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17427: [FLINK-24472][tests] Wait for cancellation future to complete

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17427: URL: https://github.com/apache/flink/pull/17427#issuecomment-937776797 ## CI report: * 1741d035b576d508032d7e963376238ffaeef39b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Aitozi commented on pull request #17410: [FLINK-24445][build] Copy rpc-akka jar in package phase

2021-10-07 Thread GitBox
Aitozi commented on pull request #17410: URL: https://github.com/apache/flink/pull/17410#issuecomment-937564663 Hi @zentol, I still have some doubts that after changing to the `package` phase , the `mvn clean test` will fail when executing in `flink-rpc-akka-loader` folder. Because the fat

[GitHub] [flink] flinkbot commented on pull request #17422: [FLINK-9432] Enable EXTRACT for DECADE, ISODOW, ISOYEAR

2021-10-07 Thread GitBox
flinkbot commented on pull request #17422: URL: https://github.com/apache/flink/pull/17422#issuecomment-937329360 -- 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. To unsubsc

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #273: [FLINK-24464][core] Metrics sometimes report negative backlog

2021-10-07 Thread GitBox
igalshilman commented on a change in pull request #273: URL: https://github.com/apache/flink-statefun/pull/273#discussion_r723750424 ## File path: statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/metrics/NonNegativeCounterTest.java ## @@ -0

[GitHub] [flink] alpreu commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-07 Thread GitBox
alpreu commented on a change in pull request #17374: URL: https://github.com/apache/flink/pull/17374#discussion_r724221489 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7Configuration.

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 -- 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. To

[GitHub] [flink] twalthr commented on a change in pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-07 Thread GitBox
twalthr commented on a change in pull request #17350: URL: https://github.com/apache/flink/pull/17350#discussion_r724214646 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java ## @@ -331,7 +338,7 @@ private Row

[GitHub] [flink-statefun] sjwiesman closed pull request #273: [FLINK-24464][core] Metrics sometimes report negative backlog

2021-10-07 Thread GitBox
sjwiesman closed pull request #273: URL: https://github.com/apache/flink-statefun/pull/273 -- 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. To unsubscribe, e-mail: issues-

[GitHub] [flink] flinkbot commented on pull request #17430: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.13.x

2021-10-07 Thread GitBox
flinkbot commented on pull request #17430: URL: https://github.com/apache/flink/pull/17430#issuecomment-937889110 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 pro

[GitHub] [flink] flinkbot commented on pull request #17427: [FLINK-24472][tests] Wait for cancellation future to complete

2021-10-07 Thread GitBox
flinkbot commented on pull request #17427: URL: https://github.com/apache/flink/pull/17427#issuecomment-937723783 -- 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. To unsubsc

[GitHub] [flink] dawidwys commented on a change in pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

2021-10-07 Thread GitBox
dawidwys commented on a change in pull request #17253: URL: https://github.com/apache/flink/pull/17253#discussion_r723934098 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java ## @@ -324,16 +324,19 @@ public voi

[GitHub] [flink] AHeise commented on pull request #17401: [FLINK-24409][connectors] Fix metrics errors with topics names with periods

2021-10-07 Thread GitBox
AHeise commented on pull request #17401: URL: https://github.com/apache/flink/pull/17401#issuecomment-937502238 @PatrickRen could you PTAL? I think we should have a test case for record lag metric as well. -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] tisonkun closed pull request #16790: [hotfix][connector][serialization][docs] Fix some typos in readme.md , kafka.md , schema_evolution.md docs

2021-10-07 Thread GitBox
tisonkun closed pull request #16790: URL: https://github.com/apache/flink/pull/16790 -- 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. To unsubscribe, e-mail: issues-unsubs

[GitHub] [flink] AHeise merged pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on the unified sink (FLIP-143)

2021-10-07 Thread GitBox
AHeise merged pull request #17363: URL: https://github.com/apache/flink/pull/17363 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] snuyanzin commented on pull request #17422: [FLINK-9432][table] Enable EXTRACT for DECADE, ISODOW, ISOYEAR

2021-10-07 Thread GitBox
snuyanzin commented on pull request #17422: URL: https://github.com/apache/flink/pull/17422#issuecomment-937735175 yes, sure, just added -- 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 speci

[GitHub] [flink] dannycranmer commented on pull request #17417: FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured.

2021-10-07 Thread GitBox
dannycranmer commented on pull request #17417: URL: https://github.com/apache/flink/pull/17417#issuecomment-937674900 @rudikershaw thanks for the contribution, can you also update the `cn` documentation? It is still in English but eventually someone will translate it: https://github.com/ap

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-929172201 -- 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. To

[GitHub] [flink] flinkbot commented on pull request #17425: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

2021-10-07 Thread GitBox
flinkbot commented on pull request #17425: URL: https://github.com/apache/flink/pull/17425#issuecomment-937642490 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 pro

[GitHub] [flink] dannycranmer merged pull request #17417: FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured.

2021-10-07 Thread GitBox
dannycranmer merged pull request #17417: URL: https://github.com/apache/flink/pull/17417 -- 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. To unsubscribe, e-mail: issues-un

[GitHub] [flink] flinkbot commented on pull request #17431: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.12.x

2021-10-07 Thread GitBox
flinkbot commented on pull request #17431: URL: https://github.com/apache/flink/pull/17431#issuecomment-937896727 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 pro

[GitHub] [flink] twalthr closed pull request #17418: [FLINK-24421][table-runtime] Fix conversion of strings to TIME

2021-10-07 Thread GitBox
twalthr closed pull request #17418: URL: https://github.com/apache/flink/pull/17418 -- 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. To unsubscribe, e-mail: issues-unsubsc

[GitHub] [flink] tillrohrmann commented on a change in pull request #17414: [FLINK-24451][HA]Replace the scattered objects with encapsulated LeaderIn…

2021-10-07 Thread GitBox
tillrohrmann commented on a change in pull request #17414: URL: https://github.com/apache/flink/pull/17414#discussion_r724319224 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionService.java ## @@ -263,13 +257,11 @@ public

[GitHub] [flink-shaded] zentol commented on a change in pull request #100: [FLINK-24447][zk] Bundle netty

2021-10-07 Thread GitBox
zentol commented on a change in pull request #100: URL: https://github.com/apache/flink-shaded/pull/100#discussion_r724110204 ## File path: flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35/src/main/resources/META-INF/NOTICE ## @@ -7,6 +7,14 @@ The Apache Software Founda

  1   2   3   >