[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=17425946#comment-17425946 ] xuyangzhong commented on FLINK-23271: - Hi , [~matriv]. The result of the discussion in calcite is

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

[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

[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

[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

[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=17425936#comment-17425936 ] Roc Marshal commented on FLINK-15352: - Could someone help me to merge it if there are nothing

[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=17425935#comment-17425935 ] Roc Marshal commented on FLINK-10230: - Could someone help me to merge it if there are nothing

[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=17425931#comment-17425931 ] Yang Wang commented on FLINK-24474: --- What will happen if the standalone cluster is started across

[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=17425930#comment-17425930 ] Yang Wang commented on FLINK-24334: --- [~ouyangwuli] I think your suggestion makes sense and I have

[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

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

[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

[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

[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=17425921#comment-17425921 ] Dian Fu commented on FLINK-24390: - It should be caused that the latest grpcio (1.41.0 which was released

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

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

[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

[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=17425908#comment-17425908 ] liwei li commented on FLINK-24351: -- [~monster#12], Sorry, I don't have permission. Maybe we can ask

[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=17425894#comment-17425894 ] shengkui leng edited comment on FLINK-24408 at 10/8/21, 1:08 AM: - The

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

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

[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

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

[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

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

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

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

[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

[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

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

[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

[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

[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

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

[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

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

[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

[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

[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 ## @@

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

[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

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

[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

[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

[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

[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

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

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

[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

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

[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

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

[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

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

[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

[GitHub] [flink] flinkbot commented on pull request #17432: [BP-1.14][FLINK-24437][HA]Remove unhandled exception handler from CuratorFramework before closing it

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

[GitHub] [flink] flinkbot commented on pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

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

[GitHub] [flink] slinkydeveloper commented on pull request #17423: [FLINK-24443][table-runtime] Reenable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs

2021-10-07 Thread GitBox
slinkydeveloper commented on pull request #17423: URL: https://github.com/apache/flink/pull/17423#issuecomment-937820171 @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

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

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

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

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

[GitHub] [flink] tisonkun closed pull request #16763: [hotfix][state_processor_api][union_state][doc] Updated variable name to match method invocation

2021-10-07 Thread GitBox
tisonkun closed pull request #16763: URL: https://github.com/apache/flink/pull/16763 -- 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:

[GitHub] [flink] flinkbot commented on pull request #17424: [FLINK-24455][tests]FallbackAkkaRpcSystemLoader should check for mave…

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

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

2021-10-07 Thread GitBox
AHeise commented on pull request #17358: URL: https://github.com/apache/flink/pull/17358#issuecomment-937485519 -- 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-shaded] zentol merged pull request #100: [FLINK-24447][zk] Bundle netty

2021-10-07 Thread GitBox
zentol merged pull request #100: URL: https://github.com/apache/flink-shaded/pull/100 -- 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:

[GitHub] [flink] pnowojski merged pull request #17425: [hotfix][datastream] Add missing Internal annotations for OperatorCoordinator class

2021-10-07 Thread GitBox
pnowojski merged pull request #17425: URL: https://github.com/apache/flink/pull/17425 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17235: [FLINK-24246][connector/pulsar] Bump pulsar client to latest 2.8.1 release

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17235: URL: https://github.com/apache/flink/pull/17235#issuecomment-916768949 ## CI report: * 6fba18288bfbfb1f83a6ec568be35ef749c974bc Azure:

[GitHub] [flink] flinkbot commented on pull request #17428: [hotfix]Refactor the registerJobManager to registerJobMaster

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

[GitHub] [flink] AHeise merged pull request #17420: [BP-1.14][FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat…

2021-10-07 Thread GitBox
AHeise merged pull request #17420: URL: https://github.com/apache/flink/pull/17420 -- 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:

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

2021-10-07 Thread GitBox
snuyanzin closed pull request #6614: URL: https://github.com/apache/flink/pull/6614 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17417: FLINK-24431 [flink-connector-kinesis] Stop consumer deregistration when EAGER EFO configured.

2021-10-07 Thread GitBox
flinkbot edited a comment on pull request #17417: URL: https://github.com/apache/flink/pull/17417#issuecomment-935782208 -- 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-benchmarks] dawidwys commented on a change in pull request #34: [hotfix] Increase warmup iterations and iterations in CheckpointingTimeBenchmark

2021-10-07 Thread GitBox
dawidwys commented on a change in pull request #34: URL: https://github.com/apache/flink-benchmarks/pull/34#discussion_r724221931 ## File path: src/main/java/org/apache/flink/benchmark/CheckpointingTimeBenchmark.java ## @@ -65,37 +61,20 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

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

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

2021-10-07 Thread Nir Tsruya (Jira)
Nir Tsruya created FLINK-24477: -- Summary: Add MongoDB sink Key: FLINK-24477 URL: https://issues.apache.org/jira/browse/FLINK-24477 Project: Flink Issue Type: New Feature Components:

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

[jira] [Closed] (FLINK-24472) DispatcherTest is unstable

2021-10-07 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24472. Resolution: Fixed master: e38cd1be718a207125e8116667d3e2675258d2b9 > DispatcherTest is

[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] flinkbot commented on pull request #17432: [BP-1.14][FLINK-24437][HA]Remove unhandled exception handler from CuratorFramework before closing it

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

[GitHub] [flink] tillrohrmann opened a new pull request #17432: [BP-1.14][FLINK-24437][HA]Remove unhandled exception handler from CuratorFramework before closing it

2021-10-07 Thread GitBox
tillrohrmann opened a new pull request #17432: URL: https://github.com/apache/flink/pull/17432 Backport of #17409 to `release-1.14`. -- 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

[jira] [Comment Edited] (FLINK-24473) getString value from any datatype columns

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425647#comment-17425647 ] Jark Wu edited comment on FLINK-24473 at 10/7/21, 3:52 PM: --- >From the

[jira] [Comment Edited] (FLINK-24473) getString value from any datatype columns

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425647#comment-17425647 ] Jark Wu edited comment on FLINK-24473 at 10/7/21, 3:51 PM: --- >From the

[jira] [Commented] (FLINK-24473) getString value from any datatype columns

2021-10-07 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425647#comment-17425647 ] Jark Wu commented on FLINK-24473: - >From the exception message, the field type is int type, so you can't

[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-937922730 @dmvk it would also be good to understand where a dependency conflict arises with the unrelocated `io.fabric8.*` dependencies. -- This is an automated message from the

[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 I've tried bumping the `maven-shade-plugin` version to `3.2.4` but it suffered from the same problem. -- This is an automated message from the Apache Git Service. To

[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

[GitHub] [flink] rudikershaw opened a new pull request #17431: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.12.x

2021-10-07 Thread GitBox
rudikershaw opened a new pull request #17431: URL: https://github.com/apache/flink/pull/17431 ## What is the purpose of the change This is a fix being pulled back into 1.12, please see #17417 for the original PR. The following is just the original text from the previous pull

[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

[GitHub] [flink] rudikershaw opened a new pull request #17430: [FLINK-24431][kinesis][efo] Stop consumer deregistration when EAGER EFO configured into 1.13.x

2021-10-07 Thread GitBox
rudikershaw opened a new pull request #17430: URL: https://github.com/apache/flink/pull/17430 ## What is the purpose of the change This is a fix being pulled back into 1.13, please see #17417 for the original PR. The following is just the original text from the previous pull

  1   2   3   >