[jira] [Commented] (FLINK-24035) Fix the deadlock issue caused by buffer listeners may not be notified

2021-08-31 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407312#comment-17407312 ] Yingjie Cao commented on FLINK-24035: - Thanks [~pnowojski]. I opened a refactor PR for this: 

[jira] [Comment Edited] (FLINK-24080) FileCache can leak user code classloader

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407308#comment-17407308 ] Chesnay Schepler edited comment on FLINK-24080 at 8/31/21, 12:44 PM: -

[jira] [Commented] (FLINK-24080) FileCache can leak user code classloader

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407310#comment-17407310 ] Chesnay Schepler commented on FLINK-24080: -- [~leishuiyu] Upgrading to 1.12 should resolve the

[jira] [Updated] (FLINK-24080) FileCache can leak user code classloader

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24080: - Affects Version/s: (was: 1.14.0) (was: 1.13.0)

[GitHub] [flink] flinkbot commented on pull request #17074: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

2021-08-31 Thread GitBox
flinkbot commented on pull request #17074: URL: https://github.com/apache/flink/pull/17074#issuecomment-909201603 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-24082) Python UDTF throws exception when the result type is generator of Row

2021-08-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24082: Description: For job: {code}

[GitHub] [flink] wsry opened a new pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to SingleInpu

2021-08-31 Thread GitBox
wsry opened a new pull request #17075: URL: https://github.com/apache/flink/pull/17075 ## What is the purpose of the change Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to SingleInputGate#setupChannels(). This makes the code

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24080: - Affects Version/s: 1.14.0 1.12.0 1.13.0 >

[jira] [Updated] (FLINK-24080) FileCache can leak user code classloader

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24080: - Summary: FileCache can leak user code classloader (was: taskmanagers leak suspect

[jira] [Commented] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

2021-08-31 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407307#comment-17407307 ] Leonard Xu commented on FLINK-24081: [~dianfu] Could you help assign this to me? Appreciate if you

[jira] [Commented] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances

2021-08-31 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407308#comment-17407308 ] Chesnay Schepler commented on FLINK-24080: -- Close related to FLINK-23147. Task#doRun sets the

[jira] [Updated] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

2021-08-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24081: --- Labels: pull-request-available (was: ) > OVER window throws exception when the rowtime is

[GitHub] [flink] leonardBang opened a new pull request #17074: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

2021-08-31 Thread GitBox
leonardBang opened a new pull request #17074: URL: https://github.com/apache/flink/pull/17074 ## What is the purpose of the change * Fix `StreamExecOverAggregate` and `StreamExecTemporalSort` operators didn't support LocalZonedTimestampType ## Brief change log - Use

[jira] [Updated] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

2021-08-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24081: Affects Version/s: 1.13.0 > OVER window throws exception when the rowtime is timestamp_ltz type >

[GitHub] [flink] flinkbot commented on pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

2021-08-31 Thread GitBox
flinkbot commented on pull request #17073: URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473 ## CI report: * 64652a612587229163e00d740031f8b303308c86 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17071: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot commented on pull request #17071: URL: https://github.com/apache/flink/pull/17071#issuecomment-909190390 ## CI report: * 5f6b9cba775dee77385bdd4506aaae9660801ba4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17070: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot commented on pull request #17070: URL: https://github.com/apache/flink/pull/17070#issuecomment-909190301 ## CI report: * 3700dfa72cd72d384bf6d69376321fb7ef9eaab9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17069: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17069: URL: https://github.com/apache/flink/pull/17069#issuecomment-909162379 ## CI report: * aed06a7ed1fb587d27ca6b1e86bebdbfc7a887da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17058: URL: https://github.com/apache/flink/pull/17058#issuecomment-908449514 ## CI report: * 28bf74c268622468560e20f5edcfdc728c1fef18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087 ## CI report: * dd573c4bb1475210822d64e5df8b659f7ecc3546 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 60655804ce59530d485c1ae939f9b005b1ef5ede Azure:

[jira] [Comment Edited] (FLINK-24049) TupleTypeInfo doesn't handle correctly for data types need conversion

2021-08-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407020#comment-17407020 ] Dian Fu edited comment on FLINK-24049 at 8/31/21, 12:24 PM: Merged to -

[jira] [Created] (FLINK-24083) The result isn't as expected when the result type is generator of string for Python UDTF

2021-08-31 Thread Dian Fu (Jira)
Dian Fu created FLINK-24083: --- Summary: The result isn't as expected when the result type is generator of string for Python UDTF Key: FLINK-24083 URL: https://issues.apache.org/jira/browse/FLINK-24083

[jira] [Updated] (FLINK-24082) Python UDTF throws exception when the result type is generator of Row

2021-08-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24082: Component/s: API / Python > Python UDTF throws exception when the result type is generator of Row >

[jira] [Created] (FLINK-24082) Python UDTF throws exception when the result type is generator of Row

2021-08-31 Thread Dian Fu (Jira)
Dian Fu created FLINK-24082: --- Summary: Python UDTF throws exception when the result type is generator of Row Key: FLINK-24082 URL: https://issues.apache.org/jira/browse/FLINK-24082 Project: Flink

[jira] [Updated] (FLINK-24064) HybridSource recovery from savepoint fails

2021-08-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-24064: - Fix Version/s: 1.14.0 > HybridSource recovery from savepoint fails >

[jira] [Created] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

2021-08-31 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-24081: -- Summary: OVER window throws exception when the rowtime is timestamp_ltz type Key: FLINK-24081 URL: https://issues.apache.org/jira/browse/FLINK-24081 Project: Flink

[jira] [Commented] (FLINK-24064) HybridSource recovery from savepoint fails

2021-08-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407288#comment-17407288 ] Thomas Weise commented on FLINK-24064: -- [~xtsong] [~arvid] fyi I'm testing the fix for this

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Attachment: class add.png > taskmanagers leak suspect ChildFirstClassLoader Biggest instances >

[jira] [Comment Edited] (FLINK-24070) Support different over window aggregates in streaming queries

2021-08-31 Thread zl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407286#comment-17407286 ] zl edited comment on FLINK-24070 at 8/31/21, 12:13 PM: --- Hi [~lzljs3620320],f2 is a

[GitHub] [flink] AHeise commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r699262279 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java ## @@ -141,13 +138,15 @@

[jira] [Assigned] (FLINK-23468) Benchmarks networkThroughput for OpenSSL do not run

2021-08-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23468: -- Assignee: Piotr Nowojski > Benchmarks networkThroughput for OpenSSL do not run >

[jira] [Commented] (FLINK-24064) HybridSource recovery from savepoint fails

2021-08-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407287#comment-17407287 ] Thomas Weise commented on FLINK-24064: -- Exception restoring task/operator: {code:java}

[jira] [Commented] (FLINK-24070) Support different over window aggregates in streaming queries

2021-08-31 Thread zl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407286#comment-17407286 ] zl commented on FLINK-24070: Hi [~lzljs3620320],f2 is a time field. and the code above is just to show two

[jira] [Commented] (FLINK-24064) HybridSource recovery from savepoint fails

2021-08-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407284#comment-17407284 ] Thomas Weise commented on FLINK-24064: -- Exception restoring coordinator: {code:java} ERROR

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Summary: taskmanagers leak suspect ChildFirstClassLoader Biggest instances (was: taskmanagers

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Description: * Symptom After submitting a batch task for several times, the task is abnormal ,Caused

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Description: * Symptom After submitting a batch task for several times, the task is abnormal ,Caused

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Description: * Symptom After submitting a batch task for several times, the task is abnormal ,Caused

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Description: * Symptom After submitting a batch task for several times, the task is abnormal ,Caused

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Description: * submit batch job ,Caused by: java.lang.OutOfMemoryError: Direct buffer memory >

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Attachment: GC root.png > taskmanagers leak suspect ChildFirstClassLoader Biggest instances: >

[jira] [Updated] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated FLINK-24080: -- Attachment: screenshot-1.png > taskmanagers leak suspect ChildFirstClassLoader Biggest instances: >

[jira] [Created] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

2021-08-31 Thread leishuiyu (Jira)
leishuiyu created FLINK-24080: - Summary: taskmanagers leak suspect ChildFirstClassLoader Biggest instances: Key: FLINK-24080 URL: https://issues.apache.org/jira/browse/FLINK-24080 Project: Flink

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

2021-08-31 Thread lixu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407279#comment-17407279 ] lixu commented on FLINK-23857: -- insert overwrite table t1 partition(f2=1) select * from t2 where 1 != 1 I

[GitHub] [flink] AHeise commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r699253994 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java ## @@ -226,11 +236,12 @@

[jira] [Closed] (FLINK-24079) BufferedUpsertSinkFunction can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-24079. --- Resolution: Invalid > BufferedUpsertSinkFunction can loose records during failover >

[jira] [Commented] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407277#comment-17407277 ] Fabian Paul commented on FLINK-23875: - [~jark] Thanks for your fast reply you are right we missed

[GitHub] [flink] AHeise commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r699250923 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitRetrier.java ## @@ -0,0 +1,84 @@ +/* + *

[GitHub] [flink] fapaul closed pull request #17072: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpsertWriter

2021-08-31 Thread GitBox
fapaul closed pull request #17072: URL: https://github.com/apache/flink/pull/17072 -- 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] zentol commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699249459 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[jira] [Commented] (FLINK-24070) Support different over window aggregates in streaming queries

2021-08-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407273#comment-17407273 ] Jingsong Lee commented on FLINK-24070: -- Is it because f2 is not a time field? > Support different

[GitHub] [flink] flinkbot commented on pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

2021-08-31 Thread GitBox
flinkbot commented on pull request #17073: URL: https://github.com/apache/flink/pull/17073#issuecomment-909164286 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] zentol commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
zentol commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699245678 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[GitHub] [flink] flinkbot commented on pull request #17072: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpsertWriter

2021-08-31 Thread GitBox
flinkbot commented on pull request #17072: URL: https://github.com/apache/flink/pull/17072#issuecomment-909162735 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-24058) TaskSlotTableImplTest.testMarkSlotActiveDeactivatesSlotTimeout fails on azure

2021-08-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24058: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] flinkbot edited a comment on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-909101643 ## CI report: * 28513efba235e7f4b923bcfd4a111eb3cf241d43 Azure:

[GitHub] [flink] flinkbot commented on pull request #17069: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot commented on pull request #17069: URL: https://github.com/apache/flink/pull/17069#issuecomment-909162379 ## CI report: * aed06a7ed1fb587d27ca6b1e86bebdbfc7a887da UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol opened a new pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

2021-08-31 Thread GitBox
zentol opened a new pull request #17073: URL: https://github.com/apache/flink/pull/17073 `TaskSlotTableImplTest#runDeactivateSlotTimeoutTest` checks that the timeout is cancelled by asserting that a future is _not_ canceled in a given time-frame. These kind of assertions (of something

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * ac9ad3d39442f0479d1f74d4664c3351fc311a41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316 ## CI report: * a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN * 7c20e7910b5f15eb88d6d2b25733c50a8c214f14 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087 ## CI report: * dd573c4bb1475210822d64e5df8b659f7ecc3546 Azure:

[jira] [Closed] (FLINK-24076) Implement Table API walkthrough in flink-playground

2021-08-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-24076. Resolution: Won't Fix My mistake - the walkthrough is supposed to be implemented by the user. Initially,

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 680f8172bea8a9b7396604e8f0c5dcaf4efff5f9 Azure:

[jira] [Commented] (FLINK-24079) BufferedUpsertSinkFunction can loose records during failover

2021-08-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407269#comment-17407269 ] Jark Wu commented on FLINK-24079: - [~fabian.paul] I commented in FLINK-23875. >

[GitHub] [flink] AHeise commented on a change in pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17050: URL: https://github.com/apache/flink/pull/17050#discussion_r699242679 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/api/FileReadingWatermarkITCase.java ## @@ -17,130 +17,109 @@ package

[jira] [Commented] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407268#comment-17407268 ] Jark Wu commented on FLINK-23875: - Sorry [~fabian.paul] and [~fabian.paul], but I don't understand why

[GitHub] [flink] fapaul opened a new pull request #17072: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpsertWriter

2021-08-31 Thread GitBox
fapaul opened a new pull request #17072: URL: https://github.com/apache/flink/pull/17072 Unchanged backport of #16966 -- 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 #17070: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot commented on pull request #17070: URL: https://github.com/apache/flink/pull/17070#issuecomment-909159673 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 #17071: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot commented on pull request #17071: URL: https://github.com/apache/flink/pull/17071#issuecomment-909159653 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] [Commented] (FLINK-23768) Test StreamTableEnvironment batch mode in Python

2021-08-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407266#comment-17407266 ] Dian Fu commented on FLINK-23768: - Sure. I will test this. > Test StreamTableEnvironment batch mode in

[GitHub] [flink] fapaul opened a new pull request #17071: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
fapaul opened a new pull request #17071: URL: https://github.com/apache/flink/pull/17071 Unchanged backport of #17052 -- 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] [Comment Edited] (FLINK-24055) Deprecate FlinkKafkaConsumer

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407263#comment-17407263 ] Arvid Heise edited comment on FLINK-24055 at 8/31/21, 11:40 AM: Merged

[jira] [Resolved] (FLINK-24055) Deprecate FlinkKafkaConsumer

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-24055. - Fix Version/s: 1.14.0 Release Note: FlinkKafkaConsumer has been deprecated in favor of

[GitHub] [flink] fapaul opened a new pull request #17070: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
fapaul opened a new pull request #17070: URL: https://github.com/apache/flink/pull/17070 Unchanged backport of #17052 -- 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] [Commented] (FLINK-23768) Test StreamTableEnvironment batch mode in Python

2021-08-31 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407265#comment-17407265 ] Martijn Visser commented on FLINK-23768: [~dianfu] Can someone on your end test this?  > Test

[GitHub] [flink] flinkbot commented on pull request #17069: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
flinkbot commented on pull request #17069: URL: https://github.com/apache/flink/pull/17069#issuecomment-909153802 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] [Commented] (FLINK-24055) Deprecate FlinkKafkaConsumer

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407263#comment-17407263 ] Arvid Heise commented on FLINK-24055: - Merged into master as

[GitHub] [flink] fapaul opened a new pull request #17069: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

2021-08-31 Thread GitBox
fapaul opened a new pull request #17069: URL: https://github.com/apache/flink/pull/17069 Unchanged backport of #17052 -- 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] AHeise merged pull request #17054: [FLINK-24055][connectors/kafka] Deprecate FlinkKafkaConsumer

2021-08-31 Thread GitBox
AHeise merged pull request #17054: URL: https://github.com/apache/flink/pull/17054 -- 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] [Commented] (FLINK-23544) Window TVF Supports session window

2021-08-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407262#comment-17407262 ] Jark Wu commented on FLINK-23544: - I'm fine with not exposing the SESSION WINDOW TVF feature in this

[jira] [Commented] (FLINK-24079) BufferedUpsertSinkFunction can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407261#comment-17407261 ] Fabian Paul commented on FLINK-24079: - [~jark] do you have time to pick it up or know someone who

[jira] [Updated] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-23875: Fix Version/s: 1.14.0 > ReducingUpsertSink can loose records during failover >

[jira] [Resolved] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-23875. - Resolution: Fixed > ReducingUpsertSink can loose records during failover >

[jira] [Updated] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-23875: Affects Version/s: (was: 1.13.2) > ReducingUpsertSink can loose records during failover >

[jira] [Commented] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407260#comment-17407260 ] Fabian Paul commented on FLINK-23875: - I created a separate ticket to fix it for Flink 1.13 

[jira] [Created] (FLINK-24079) BufferedUpsertSinkFunction can loose records during failover

2021-08-31 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24079: --- Summary: BufferedUpsertSinkFunction can loose records during failover Key: FLINK-24079 URL: https://issues.apache.org/jira/browse/FLINK-24079 Project: Flink

[GitHub] [flink] AHeise commented on a change in pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source and File sink.

2021-08-31 Thread GitBox
AHeise commented on a change in pull request #17067: URL: https://github.com/apache/flink/pull/17067#discussion_r699231139 ## File path: docs/content/docs/connectors/datastream/kafka.md ## @@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed offsets

[jira] [Commented] (FLINK-23875) ReducingUpsertSink can loose records during failover

2021-08-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407259#comment-17407259 ] Arvid Heise commented on FLINK-23875: - Merged into master as

[GitHub] [flink] AHeise merged pull request #16966: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpse…

2021-08-31 Thread GitBox
AHeise merged pull request #16966: URL: https://github.com/apache/flink/pull/16966 -- 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 commented on pull request #16966: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpse…

2021-08-31 Thread GitBox
AHeise commented on pull request #16966: URL: https://github.com/apache/flink/pull/16966#issuecomment-909147805 Failure completely unrelated (FLINK-15451). Merging. -- 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] fapaul commented on a change in pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

2021-08-31 Thread GitBox
fapaul commented on a change in pull request #17050: URL: https://github.com/apache/flink/pull/17050#discussion_r699229651 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/api/FileReadingWatermarkITCase.java ## @@ -17,130 +17,109 @@ package

[GitHub] [flink] flinkbot edited a comment on pull request #17068: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17068: URL: https://github.com/apache/flink/pull/17068#issuecomment-909101643 ## CI report: * 28513efba235e7f4b923bcfd4a111eb3cf241d43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17066: FLINK-24066

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17066: URL: https://github.com/apache/flink/pull/17066#issuecomment-908973411 ## CI report: * c4c3e02c2c2122c90f71548caebfac6602592a1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17040: [FLINK-24041][connectors] Flip 171 - Abstract Async Sink Base

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17040: URL: https://github.com/apache/flink/pull/17040#issuecomment-907834154 ## CI report: * 752c9db951f0ba3f26695b873b1f81dc6e830cab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16966: [FLINK-23875][connectors/kafka] Snapshot reduceBuffer of ReducingUpse…

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #16966: URL: https://github.com/apache/flink/pull/16966#issuecomment-904741081 ## CI report: * 0b725628d29c9cab3dd35929bc3e10e0231920fd Azure:

[GitHub] [flink] gaborgsomogyi commented on pull request #17022: [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data

2021-08-31 Thread GitBox
gaborgsomogyi commented on pull request #17022: URL: https://github.com/apache/flink/pull/17022#issuecomment-909129087 @zentol thanks for the guidance, just did it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-23850) Test Kafka table connector with new runtime provider

2021-08-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407245#comment-17407245 ] Timo Walther commented on FLINK-23850: -- [~mapohl] I have observed the similar issues. The result

[GitHub] [flink] flinkbot edited a comment on pull request #17000: [FLINK-23946][clients] Application mode should shutdown gracefully on…

2021-08-31 Thread GitBox
flinkbot edited a comment on pull request #17000: URL: https://github.com/apache/flink/pull/17000#issuecomment-906394364 ## CI report: * 371e8744569d180669b538e27bcdd355914571a6 Azure:

<    1   2   3   4   5   6   7   8   >