[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Description: *The background* I found SQL Kafka connector can not consume avro data that was

[jira] [Updated] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-16048: --- Description: *The background* I found SQL Kafka connector can not consume avro data that was

[GitHub] [flink] godfreyhe commented on a change in pull request #12873: [FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better

godfreyhe commented on a change in pull request #12873: URL: https://github.com/apache/flink/pull/12873#discussion_r456232970 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkCalcMergeRule.scala ## @@

[GitHub] [flink] godfreyhe commented on a change in pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

godfreyhe commented on a change in pull request #12866: URL: https://github.com/apache/flink/pull/12866#discussion_r456231454 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -565,14

[jira] [Comment Edited] (FLINK-18612) WordCount example failure when setting relative output path

[ https://issues.apache.org/jira/browse/FLINK-18612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159691#comment-17159691 ] Yun Gao edited comment on FLINK-18612 at 7/17/20, 5:47 AM: --- The issue is

[jira] [Comment Edited] (FLINK-18612) WordCount example failure when setting relative output path

[ https://issues.apache.org/jira/browse/FLINK-18612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159691#comment-17159691 ] Yun Gao edited comment on FLINK-18612 at 7/17/20, 5:45 AM: --- The issue is

[jira] [Commented] (FLINK-18612) WordCount example failure when setting relative output path

[ https://issues.apache.org/jira/browse/FLINK-18612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159691#comment-17159691 ] Yun Gao commented on FLINK-18612: - The issue is caused by when we create a file under the current user

[GitHub] [flink] godfreyhe commented on a change in pull request #12873: [FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better

godfreyhe commented on a change in pull request #12873: URL: https://github.com/apache/flink/pull/12873#discussion_r456230725 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/FlinkCalcMergeRule.scala ## @@

[GitHub] [flink] liuyongvs commented on a change in pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

liuyongvs commented on a change in pull request #12866: URL: https://github.com/apache/flink/pull/12866#discussion_r456229609 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -565,14

[jira] [Comment Edited] (FLINK-18618) Docker e2e tests are failing on CI

[ https://issues.apache.org/jira/browse/FLINK-18618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159683#comment-17159683 ] Dian Fu edited comment on FLINK-18618 at 7/17/20, 5:39 AM: --- I have observed

[GitHub] [flink] liuyongvs closed pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

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

[GitHub] [flink] liuyongvs commented on pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

liuyongvs commented on pull request #12851: URL: https://github.com/apache/flink/pull/12851#issuecomment-659867535 @KurtYoung ,ok. And i opened a new PR, which @godfreyhe is reviewing now This is an automated message from

[jira] [Comment Edited] (FLINK-18618) Docker e2e tests are failing on CI

[ https://issues.apache.org/jira/browse/FLINK-18618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159683#comment-17159683 ] Dian Fu edited comment on FLINK-18618 at 7/17/20, 5:38 AM: --- I have observed

[GitHub] [flink] godfreyhe commented on a change in pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

godfreyhe commented on a change in pull request #12866: URL: https://github.com/apache/flink/pull/12866#discussion_r456228726 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -565,14

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * 64fb19f04de68c5592bc28fd01c8ea8569fa238b Azure:

[jira] [Assigned] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16048: --- Assignee: Danny Chen > Support read/write confluent schema registry avro data from Kafka >

[GitHub] [flink] godfreyhe commented on a change in pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault toler

godfreyhe commented on a change in pull request #12867: URL: https://github.com/apache/flink/pull/12867#discussion_r456225483 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java ## @@ -132,10 +132,22 @@ * }

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159687#comment-17159687 ] Danny Chen commented on FLINK-16048: [~anshul.bansal] [~lingyaKK] I'm working on this now, as part

[jira] [Commented] (FLINK-18620) Unify behaviors of active resource managers

[ https://issues.apache.org/jira/browse/FLINK-18620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159684#comment-17159684 ] Xintong Song commented on FLINK-18620: -- cc [~trohrmann] > Unify behaviors of active resource

[GitHub] [flink] wtog commented on pull request #12888: [FLINK-18588] hive ddl create table support 'if not exists'

wtog commented on pull request #12888: URL: https://github.com/apache/flink/pull/12888#issuecomment-659861262 hi @lirui-apache , please help to review this pr, it will be better to be merged before 1.11.1 released. This is

[jira] [Created] (FLINK-18620) Unify behaviors of active resource managers

Xintong Song created FLINK-18620: Summary: Unify behaviors of active resource managers Key: FLINK-18620 URL: https://issues.apache.org/jira/browse/FLINK-18620 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18618) Docker e2e tests are failing on CI

[ https://issues.apache.org/jira/browse/FLINK-18618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159683#comment-17159683 ] Dian Fu commented on FLINK-18618: - I have observed similar log in the [personal

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * 64fb19f04de68c5592bc28fd01c8ea8569fa238b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance

flinkbot edited a comment on pull request #12867: URL: https://github.com/apache/flink/pull/12867#issuecomment-656590407 ## CI report: * aa18ae06c64ff88beba4bfe780f7de03d0dc77f1 UNKNOWN * a64ca67c2e50380c4b6aca1748fb71a3c620377a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * a78a2f7e1d75e0409fedff1c32cddb41d6e8121c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

flinkbot edited a comment on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-648131818 ## CI report: * 64fb19f04de68c5592bc28fd01c8ea8569fa238b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance

flinkbot edited a comment on pull request #12867: URL: https://github.com/apache/flink/pull/12867#issuecomment-656590407 ## CI report: * aa18ae06c64ff88beba4bfe780f7de03d0dc77f1 UNKNOWN * 577a355b33c5bdd7176f207201dc1b33d98c665a Azure:

[GitHub] [flink] fsk119 commented on pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

fsk119 commented on pull request #12756: URL: https://github.com/apache/flink/pull/12756#issuecomment-659836892 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wuchong commented on a change in pull request #12756: [FLINK-18296][json] add support for TIMESTAMP_WITH_LOCAL_ZONE and fix…

wuchong commented on a change in pull request #12756: URL: https://github.com/apache/flink/pull/12756#discussion_r456208012 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java ## @@ -526,7 +541,7 @@ private void

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

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159653#comment-17159653 ] Jark Wu edited comment on FLINK-18481 at 7/17/20, 4:03 AM: --- You need to enable

[jira] [Closed] (FLINK-16087) Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

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

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

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159653#comment-17159653 ] Jark Wu commented on FLINK-18481: - You need to enable checkpoint to see the results of

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

RocMarshal commented on pull request #12798: URL: https://github.com/apache/flink/pull/12798#issuecomment-659831480 @klion26 @XBaith @wuchong Thank you so much for your patience and help, guys. This is an

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

wuchong merged pull request #12798: URL: https://github.com/apache/flink/pull/12798 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] wuchong merged pull request #12895: [hotfix][docs-zh] Fix invalid links in the page 'dev/table/streaming/match_recognize.zh.md'

wuchong merged pull request #12895: URL: https://github.com/apache/flink/pull/12895 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 #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 77a024153709102d91ba165e15dcb0d8cb9d0925 Azure:

[GitHub] [flink] Thesharing closed pull request #12917: [TEST] Try to remove the SchedulerImpl in testAllocateSimpleSlot

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

[GitHub] [flink] Thesharing opened a new pull request #12917: [TEST] Try to remove the SchedulerImpl in testAllocateSimpleSlot

Thesharing opened a new pull request #12917: URL: https://github.com/apache/flink/pull/12917 （仅用于预览，不会提交） 思路：用`slotPoolImpl.requestNewAllocatedSlot()`来代替`schedulerImpl.allocateSlot()`，在该test

[GitHub] [flink] flinkbot edited a comment on pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance

flinkbot edited a comment on pull request #12867: URL: https://github.com/apache/flink/pull/12867#issuecomment-656590407 ## CI report: * aa18ae06c64ff88beba4bfe780f7de03d0dc77f1 UNKNOWN * 577a355b33c5bdd7176f207201dc1b33d98c665a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 77a024153709102d91ba165e15dcb0d8cb9d0925 Azure:

[GitHub] [flink] leonardBang commented on pull request #12873: [FLINK-18548][table-planner] Improve FlinkCalcMergeRule to merge calc nodes better

leonardBang commented on pull request #12873: URL: https://github.com/apache/flink/pull/12873#issuecomment-659813009 @godfreyhe Could you have a more look? This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] tweise commented on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

tweise commented on pull request #12916: URL: https://github.com/apache/flink/pull/12916#issuecomment-659811130 @flinkbot approve all This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-11547) JsonMappingException in DynamoDBStreamsSchema

[ https://issues.apache.org/jira/browse/FLINK-11547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159631#comment-17159631 ] Thomas Weise commented on FLINK-11547: -- [~tinder-dthomson] thanks! I will take a look at the PR. >

[jira] [Commented] (FLINK-17627) Add support for writing _SUCCESS file with StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159628#comment-17159628 ] Lu Niu commented on FLINK-17627: hmm... It seems not because I don't have DataStream to operate on. All

[jira] [Commented] (FLINK-16827) StreamExecTemporalSort should require a distribution trait in StreamExecTemporalSortRule

[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159627#comment-17159627 ] Benchao Li commented on FLINK-16827: [~docete] Thanks for the reminder, I'll raise another pr

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 3acf20bd7d812b4d54ae7b87aa2499cacef30651 Azure:

[jira] [Commented] (FLINK-17627) Add support for writing _SUCCESS file with StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159602#comment-17159602 ] Jingsong Lee commented on FLINK-17627: -- Looks like you should do something like

[GitHub] [flink] flinkbot edited a comment on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

flinkbot edited a comment on pull request #12916: URL: https://github.com/apache/flink/pull/12916#issuecomment-659762134 ## CI report: * f5c161b9cbf0df4cbf0e9f9efd08d1b5b3edb47e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

flinkbot edited a comment on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-656576219 ## CI report: * 3acf20bd7d812b4d54ae7b87aa2499cacef30651 Azure:

[GitHub] [flink] KurtYoung commented on pull request #12851: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

KurtYoung commented on pull request #12851: URL: https://github.com/apache/flink/pull/12851#issuecomment-659785168 @liuyongvs could you close this then? This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-16827) StreamExecTemporalSort should require a distribution trait in StreamExecTemporalSortRule

[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159601#comment-17159601 ] Zhenghua Gao commented on FLINK-16827: -- [~jark] [~libenchao] I think this bugfix should port to

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

[ https://issues.apache.org/jira/browse/FLINK-18481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159596#comment-17159596 ] gaoling ma commented on FLINK-18481: StreamExecutionEnvironment bsEnv =

[GitHub] [flink] DashShen edited a comment on pull request #12911: [hotfix][k8s] fix checkstyle problem

DashShen edited a comment on pull request #12911: URL: https://github.com/apache/flink/pull/12911#issuecomment-659776124 @zentol There is trully a rule constrains file that should be end with a new line. ```xml ... ```

[GitHub] [flink] DashShen edited a comment on pull request #12911: [hotfix][k8s] fix checkstyle problem

DashShen edited a comment on pull request #12911: URL: https://github.com/apache/flink/pull/12911#issuecomment-659776124 @zentol There is trully a rule constrains file should be end with a new line. ```xml ... ```

[GitHub] [flink] godfreyhe commented on pull request #12866: [FLINK-17425][blink-planner] supportsFilterPushDown rule in DynamicSource.

godfreyhe commented on pull request #12866: URL: https://github.com/apache/flink/pull/12866#issuecomment-659778821 thanks for the update. LGTM overall, last comment: please remove the import: `import static org.apache.flink.runtime.state.CheckpointStreamWithResultProvider.LOG;` in

[GitHub] [flink] DashShen commented on pull request #12911: [hotfix][k8s] fix checkstyle problem

DashShen commented on pull request #12911: URL: https://github.com/apache/flink/pull/12911#issuecomment-659776124 @zentol There is trully a rule constrains that file should be end with a new line. ```xml ... ```

[GitHub] [flink] flinkbot edited a comment on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

flinkbot edited a comment on pull request #12916: URL: https://github.com/apache/flink/pull/12916#issuecomment-659762134 ## CI report: * f5c161b9cbf0df4cbf0e9f9efd08d1b5b3edb47e Azure:

[jira] [Commented] (FLINK-18615) run flink with openjdk11 get java.lang.UnsupportedOperationException: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

[ https://issues.apache.org/jira/browse/FLINK-18615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159585#comment-17159585 ] dongjie.shi commented on FLINK-18615: - Thanks [~chesnay] and [~dian.fu]. In this case, I need 

[GitHub] [flink] flinkbot commented on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

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

[jira] [Commented] (FLINK-11547) JsonMappingException in DynamoDBStreamsSchema

[ https://issues.apache.org/jira/browse/FLINK-11547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159579#comment-17159579 ] Devin Thomson commented on FLINK-11547: --- I have (finally!) submitted a PR here: 

[GitHub] [flink] flinkbot commented on pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

flinkbot commented on pull request #12916: URL: https://github.com/apache/flink/pull/12916#issuecomment-659755881 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-11547) JsonMappingException in DynamoDBStreamsSchema

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

[GitHub] [flink] tinder-dthomson opened a new pull request #12916: [FLINK-11547][flink-connector-kinesis] Fix JsonMappingException in DynamoDBStreamsSchema

tinder-dthomson opened a new pull request #12916: URL: https://github.com/apache/flink/pull/12916 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Commented] (FLINK-17627) Add support for writing _SUCCESS file with StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-17627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159544#comment-17159544 ] Lu Niu commented on FLINK-17627: Hi, [~lzljs3620320]. thanks for replying. I took a look at 

[jira] [Closed] (FLINK-18163) Should be volatile: network.api.writer.RecordWriter.flusherException

[ https://issues.apache.org/jira/browse/FLINK-18163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18163. -- Resolution: Fixed merged commit 9fa0a99 into master > Should be volatile:

[GitHub] [flink] pnowojski merged pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

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

[GitHub] [flink] zentol closed pull request #12914: Release 1.11

zentol closed pull request #12914: URL: https://github.com/apache/flink/pull/12914 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] [Commented] (FLINK-18619) Update training to use WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-18619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159321#comment-17159321 ] Seth Wiesman commented on FLINK-18619: -- master: d34d36c235c20bf6c648a3af961919dd29fd7332

[jira] [Closed] (FLINK-18619) Update training to use WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-18619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18619. Resolution: Fixed > Update training to use WatermarkStrategy >

[GitHub] [flink] sjwiesman closed pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

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

[GitHub] [flink] sjwiesman commented on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

sjwiesman commented on pull request #12915: URL: https://github.com/apache/flink/pull/12915#issuecomment-659506563 Awesome, thank you both. Merging . . . This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

flinkbot edited a comment on pull request #12915: URL: https://github.com/apache/flink/pull/12915#issuecomment-659492442 ## CI report: * 43f49b9259890aea61c9d5f44f68c104c352ee3f Azure:

[GitHub] [flink] alpinegizmo commented on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

alpinegizmo commented on pull request #12915: URL: https://github.com/apache/flink/pull/12915#issuecomment-659496434 Good catch! I'm happy with this. +1 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] aljoscha commented on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

aljoscha commented on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-659493329  If Jiangjie doesn't respond after a while, ping me on the issue and I can assign you. This is an automated

[GitHub] [flink] flinkbot commented on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

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

[GitHub] [flink] aljoscha commented on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

aljoscha commented on pull request #12915: URL: https://github.com/apache/flink/pull/12915#issuecomment-659492138 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot commented on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

flinkbot commented on pull request #12915: URL: https://github.com/apache/flink/pull/12915#issuecomment-659485164 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-18619) Update training to use WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-18619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18619: --- Labels: pull-request-available (was: ) > Update training to use WatermarkStrategy >

[GitHub] [flink] sjwiesman opened a new pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

sjwiesman opened a new pull request #12915: URL: https://github.com/apache/flink/pull/12915 ## What is the purpose of the change Update the training to use the modern `WatermarkStrategy` class in its examples. I will backport this to 1.11.

[GitHub] [flink] sjwiesman commented on pull request #12915: [FLINK-18619][docs] Update training to use WatermarkStrategy

sjwiesman commented on pull request #12915: URL: https://github.com/apache/flink/pull/12915#issuecomment-659483561 cc @alpinegizmo This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Created] (FLINK-18619) Update training to use WatermarkStrategy

Seth Wiesman created FLINK-18619: Summary: Update training to use WatermarkStrategy Key: FLINK-18619 URL: https://issues.apache.org/jira/browse/FLINK-18619 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18614) Performance regression 2020.07.13 (most benchmarks)

[ https://issues.apache.org/jira/browse/FLINK-18614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159279#comment-17159279 ] Roman Khachatryan commented on FLINK-18614: --- Brought the node offline. > Performance

[jira] [Comment Edited] (FLINK-18614) Performance regression 2020.07.13 (most benchmarks)

[ https://issues.apache.org/jira/browse/FLINK-18614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159266#comment-17159266 ] Roman Khachatryan edited comment on FLINK-18614 at 7/16/20, 3:01 PM: -

[jira] [Commented] (FLINK-18614) Performance regression 2020.07.13 (most benchmarks)

[ https://issues.apache.org/jira/browse/FLINK-18614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159266#comment-17159266 ] Roman Khachatryan commented on FLINK-18614: --- Starting from Jul 13 (1st problematic build),

[GitHub] [flink] flinkbot edited a comment on pull request #12914: Release 1.11

flinkbot edited a comment on pull request #12914: URL: https://github.com/apache/flink/pull/12914#issuecomment-659453586 ## CI report: * 71fa2c1402497013c8c1d24093edaf6962e5c66a Azure:

[GitHub] [flink] flinkbot commented on pull request #12914: Release 1.11

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

[GitHub] [flink] dawidwys commented on pull request #12913: [FLINK-18600] Upgrade kerberized yarn docker image to use openjdk

dawidwys commented on pull request #12913: URL: https://github.com/apache/flink/pull/12913#issuecomment-659445067 Yes, that's why I haven't even rebased it on master yet. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #12914: Release 1.11

flinkbot commented on pull request #12914: URL: https://github.com/apache/flink/pull/12914#issuecomment-659434210 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] whalefall541 opened a new pull request #12914: Release 1.11

whalefall541 opened a new pull request #12914: URL: https://github.com/apache/flink/pull/12914 111 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] whalefall541 commented on pull request #12914: Release 1.11

whalefall541 commented on pull request #12914: URL: https://github.com/apache/flink/pull/12914#issuecomment-659432743 > add flink 1.1.10 branch This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

flinkbot edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643957887 ## CI report: * 93f58e49ad79331331d4d85bbe7720ecfe39f968 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance

flinkbot edited a comment on pull request #12867: URL: https://github.com/apache/flink/pull/12867#issuecomment-656590407 ## CI report: * aa18ae06c64ff88beba4bfe780f7de03d0dc77f1 UNKNOWN * 577a355b33c5bdd7176f207201dc1b33d98c665a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12913: [FLINK-18600] Upgrade kerberized yarn docker image to use openjdk

flinkbot edited a comment on pull request #12913: URL: https://github.com/apache/flink/pull/12913#issuecomment-659374157 ## CI report: * 286279cae3ca0bb11c2e8476285114e3685f1329 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

flinkbot edited a comment on pull request #12903: URL: https://github.com/apache/flink/pull/12903#issuecomment-658519879 ## CI report: * de4e633b56dd675a6f3ddd1af5c5bd1721892815 Azure:

[GitHub] [flink] zentol commented on pull request #12913: [FLINK-18600] Upgrade kerberized yarn docker image to use openjdk

zentol commented on pull request #12913: URL: https://github.com/apache/flink/pull/12913#issuecomment-659409321 I'd suggest to wait with this PR while the docker tests are broken. This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #12867: [FLINK-18558][streaming] Introduce collect iterator with at least once semantics and exactly once semantics without fault tolerance

flinkbot edited a comment on pull request #12867: URL: https://github.com/apache/flink/pull/12867#issuecomment-656590407 ## CI report: * aa18ae06c64ff88beba4bfe780f7de03d0dc77f1 UNKNOWN * c39f4a57e2cf4383ce76795f118096a1fffcbd6d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12649: [FLINK-18286] Implement type inference for GET/FLATTEN

flinkbot edited a comment on pull request #12649: URL: https://github.com/apache/flink/pull/12649#issuecomment-643957887 ## CI report: * 43596996d023eb47c9589f95d8baf8a3cee83016 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12903: [FLINK-18492][python] Extract the implementation logic of Beam in Operations

flinkbot edited a comment on pull request #12903: URL: https://github.com/apache/flink/pull/12903#issuecomment-658519879 ## CI report: * 08494953cea4e986cc165c77d7f933f45aff7b41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12913: [FLINK-18600] Upgrade kerberized yarn docker image to use openjdk

flinkbot edited a comment on pull request #12913: URL: https://github.com/apache/flink/pull/12913#issuecomment-659374157 ## CI report: * 286279cae3ca0bb11c2e8476285114e3685f1329 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12827: [FLINK-18163][task] Add RecordWriter.volatileFlusherException

flinkbot edited a comment on pull request #12827: URL: https://github.com/apache/flink/pull/12827#issuecomment-654120002 ## CI report: * 43390e73c380909dd7538ada962c565532512c5f Azure:

  1   2   3   >