[GitHub] [flink] KarmaGYZ commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-27 Thread GitBox
KarmaGYZ commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r565790739 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/PendingTaskManagerId.java ## @@ -0,0 +1,30 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #14783: [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-27 Thread GitBox
flinkbot commented on pull request #14783: URL: https://github.com/apache/flink/pull/14783#issuecomment-768765175 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-21169) Kafka flink-connector-base dependency should be scope compile

2021-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21169: --- Labels: pull-request-available (was: ) > Kafka flink-connector-base dependency should be

[GitHub] [flink] tweise opened a new pull request #14783: [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-27 Thread GitBox
tweise opened a new pull request #14783: URL: https://github.com/apache/flink/pull/14783 ## What is the purpose of the change Changes the scope of `flink-connector-base` dependency from `provided` to default so that the dependency becomes part of application classpath. Otherwise,

[jira] [Created] (FLINK-21169) Kafka flink-connector-base dependency should be scope compile

2021-01-27 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-21169: Summary: Kafka flink-connector-base dependency should be scope compile Key: FLINK-21169 URL: https://issues.apache.org/jira/browse/FLINK-21169 Project: Flink

[jira] [Comment Edited] (FLINK-21005) Introduce new provider for unified Sink API and implement in planner

2021-01-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272539#comment-17272539 ] Nicholas Jiang edited comment on FLINK-21005 at 1/28/21, 2:37 AM: --

[jira] [Created] (FLINK-21168) Add support for general python group window aggregate function in Physical Rule and Node

2021-01-27 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-21168: Summary: Add support for general python group window aggregate function in Physical Rule and Node Key: FLINK-21168 URL: https://issues.apache.org/jira/browse/FLINK-21168

[jira] [Closed] (FLINK-21154) Move the shared request-reply protobuf files to a separate artifact.

2021-01-27 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21154. --- Fix Version/s: statefun-3.0.0 Resolution: Fixed flink-statefun/master:

[GitHub] [flink-statefun] tzulitai closed pull request #194: [FLINK-21154] Move the shared request-reply Protobuf files to a separate artifact

2021-01-27 Thread GitBox
tzulitai closed pull request #194: URL: https://github.com/apache/flink-statefun/pull/194 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

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-27 Thread GitBox
KarmaGYZ commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r565777058 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedTaskManagerSlot.java ## @@ -0,0 +1,113 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #14774: [FLINK-21163][python] Fix the issue that Python dependencies specified via CLI override the dependencies specified in configuration

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538 ## CI report: * 25e36a813527d64dab09dde6c13cbdab78bf05ab Azure:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-27 Thread GitBox
KarmaGYZ commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r565769920 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedTaskManagerRegistration.java ## @@ -0,0

[GitHub] [flink] xintongsong commented on pull request #14779: [FLINK-21158][Runtime/Web Frontend] wrong jvm metaspace and overhead size show in taskmanager metric page

2021-01-27 Thread GitBox
xintongsong commented on pull request #14779: URL: https://github.com/apache/flink/pull/14779#issuecomment-768742573 @pengkangjing Please take a look at the CI report. There's a compiling failure due to code style violation. Please refer to the following guidelines on how to use

[GitHub] [flink] flinkbot edited a comment on pull request #14774: [FLINK-21163][python] Fix the issue that Python dependencies specified via CLI override the dependencies specified in configuration

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538 ## CI report: * 25e36a813527d64dab09dde6c13cbdab78bf05ab Azure:

[GitHub] [flink] dianfu commented on pull request #14774: [FLINK-21163][python] Fix the issue that Python dependencies specified via CLI override the dependencies specified in configuration

2021-01-27 Thread GitBox
dianfu commented on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768719211 @WeiZhong94 Thanks a lot for the view. Updated the PR. This is an automated message from the Apache Git Service.

[GitHub] [flink] xintongsong commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-27 Thread GitBox
xintongsong commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r565154346 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedTaskManagerTrackerTest.java ## @@ -0,0

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-01-27 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273247#comment-17273247 ] Kurt Young commented on FLINK-20663: IIRC in the past, users of managed memory (operators, data

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-27 Thread GitBox
KarmaGYZ commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r565757084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/PendingTaskManagerId.java ## @@ -0,0 +1,30 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14782: [FLINK-21167] Make StateTable snapshots iterable

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14782: URL: https://github.com/apache/flink/pull/14782#issuecomment-768559542 ## CI report: * d3fa4291770bf08966eafb0ca2e4d7f3ffe0912a Azure:

[jira] [Comment Edited] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-27 Thread Xiaoguang Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273212#comment-17273212 ] Xiaoguang Sun edited comment on FLINK-21108 at 1/28/21, 12:24 AM: --

[jira] [Commented] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-27 Thread Xiaoguang Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273212#comment-17273212 ] Xiaoguang Sun commented on FLINK-21108: --- Cluster IP can be accessed by anybody running within the

[GitHub] [flink] sjwiesman closed pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
sjwiesman closed pull request #13912: URL: https://github.com/apache/flink/pull/13912 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

[jira] [Commented] (FLINK-21059) KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273170#comment-17273170 ] Thomas Weise commented on FLINK-21059: -- 1.12: 

[jira] [Resolved] (FLINK-21059) KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-21059. -- Resolution: Fixed > KafkaSourceEnumerator does not honor consumer properties >

[jira] [Updated] (FLINK-21059) KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-21059: - Fix Version/s: 1.12.2 1.13.0 > KafkaSourceEnumerator does not honor consumer

[GitHub] [flink] tweise merged pull request #14781: [release-1.12][FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
tweise merged pull request #14781: URL: https://github.com/apache/flink/pull/14781 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 #14781: [release-1.12][FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14781: URL: https://github.com/apache/flink/pull/14781#issuecomment-768462281 ## CI report: * c5896f26c6106ab25c7c9c24bf9867dabca83e98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14782: [FLINK-21167] Make StateTable snapshots iterable

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14782: URL: https://github.com/apache/flink/pull/14782#issuecomment-768559542 ## CI report: * d3fa4291770bf08966eafb0ca2e4d7f3ffe0912a Azure:

[GitHub] [flink] flinkbot commented on pull request #14782: [FLINK-21167] Make StateTable snapshots iterable

2021-01-27 Thread GitBox
flinkbot commented on pull request #14782: URL: https://github.com/apache/flink/pull/14782#issuecomment-768559542 ## CI report: * d3fa4291770bf08966eafb0ca2e4d7f3ffe0912a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 3885663038156d52aec21062a9743009fb875cc3 Azure:

[GitHub] [flink] flinkbot commented on pull request #14782: [FLINK-21167] Make StateTable snapshots iterable

2021-01-27 Thread GitBox
flinkbot commented on pull request #14782: URL: https://github.com/apache/flink/pull/14782#issuecomment-768547756 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-21167) Make StateTable snapshots iterable

2021-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21167: --- Labels: pull-request-available (was: ) > Make StateTable snapshots iterable >

[GitHub] [flink] dawidwys opened a new pull request #14782: [FLINK-21167] Make StateTable snapshots iterable

2021-01-27 Thread GitBox
dawidwys opened a new pull request #14782: URL: https://github.com/apache/flink/pull/14782 ## What is the purpose of the change In order to implement an iterator required by a binary unified savepoint we need a way to iterate a snapshot. ## Verifying this change

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 3885663038156d52aec21062a9743009fb875cc3 Azure:

[jira] [Created] (FLINK-21167) Make StateTable snapshots iterable

2021-01-27 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-21167: Summary: Make StateTable snapshots iterable Key: FLINK-21167 URL: https://issues.apache.org/jira/browse/FLINK-21167 Project: Flink Issue Type:

[GitHub] [flink] sjwiesman commented on a change in pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
sjwiesman commented on a change in pull request #14780: URL: https://github.com/apache/flink/pull/14780#discussion_r565575632 ## File path: docs/flinkDev/building.md ## @@ -132,7 +132,7 @@ Since version 1.7 Flink builds with Scala version 2.11 (default) and 2.12. To build

[GitHub] [flink] sjwiesman commented on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
sjwiesman commented on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-768537882 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] sjwiesman removed a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
sjwiesman removed a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-768343868 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] sjwiesman commented on a change in pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
sjwiesman commented on a change in pull request #14780: URL: https://github.com/apache/flink/pull/14780#discussion_r565575632 ## File path: docs/flinkDev/building.md ## @@ -132,7 +132,7 @@ Since version 1.7 Flink builds with Scala version 2.11 (default) and 2.12. To build

[jira] [Updated] (FLINK-21166) IllegalStateException in CheckpointMetricsBuilder surfacing in "Resuming Savepoint" e2e

2021-01-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21166: --- Summary: IllegalStateException in CheckpointMetricsBuilder surfacing in "Resuming

[GitHub] [flink] sjwiesman edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
sjwiesman edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-768343868 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-01-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273080#comment-17273080 ] Till Rohrmann commented on FLINK-20663: --- Thanks for reporting this issue. Which Java version are

[jira] [Updated] (FLINK-21166) NullPointer in CheckpointMetricsBuilder surfacing in "Resuming Savepoint" e2e

2021-01-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21166: --- Fix Version/s: 1.13.0 > NullPointer in CheckpointMetricsBuilder surfacing in "Resuming

[GitHub] [flink] rmetzger commented on pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
rmetzger commented on pull request #14767: URL: https://github.com/apache/flink/pull/14767#issuecomment-768488566 Reported e2e test instability here: https://issues.apache.org/jira/browse/FLINK-21166 Otherwise, I've addressed all your comments!

[jira] [Created] (FLINK-21166) NullPointer in CheckpointMetricsBuilder surfacing in "Resuming Savepoint" e2e

2021-01-27 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-21166: -- Summary: NullPointer in CheckpointMetricsBuilder surfacing in "Resuming Savepoint" e2e Key: FLINK-21166 URL: https://issues.apache.org/jira/browse/FLINK-21166

[GitHub] [flink] aljoscha commented on a change in pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14780: URL: https://github.com/apache/flink/pull/14780#discussion_r565528105 ## File path: docs/flinkDev/building.md ## @@ -132,7 +132,7 @@ Since version 1.7 Flink builds with Scala version 2.11 (default) and 2.12. To build

[GitHub] [flink] flinkbot edited a comment on pull request #14781: [release-1.12][FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14781: URL: https://github.com/apache/flink/pull/14781#issuecomment-768462281 ## CI report: * c5896f26c6106ab25c7c9c24bf9867dabca83e98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14765: URL: https://github.com/apache/flink/pull/14765#issuecomment-767648687 ## CI report: * 31d80dfb565af80b87945d5b717c6ea3d2b8d0ec Azure:

[GitHub] [flink] flinkbot commented on pull request #14781: [release-1.12][FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
flinkbot commented on pull request #14781: URL: https://github.com/apache/flink/pull/14781#issuecomment-768462281 ## CI report: * c5896f26c6106ab25c7c9c24bf9867dabca83e98 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-01-27 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273052#comment-17273052 ] Kezhu Wang commented on FLINK-21132: I did not find an easy/viable way to distinguish truly end of

[GitHub] [flink] flinkbot edited a comment on pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14765: URL: https://github.com/apache/flink/pull/14765#issuecomment-767648687 ## CI report: * 08c35397ba79eab9e80cfcb2b4d58b7df5da1f1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14760: [FLINK-20994][python] Add public method to create TableEnvironment in PyFlink.

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14760: URL: https://github.com/apache/flink/pull/14760#issuecomment-767543514 ## CI report: * 7ab4b72ce52f1bf451df45ca43814b221025ebbd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * 4d9ace4ee4a4650ea186f806b0379995fee65873 Azure:

[GitHub] [flink] flinkbot commented on pull request #14781: [release-1.12][FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
flinkbot commented on pull request #14781: URL: https://github.com/apache/flink/pull/14781#issuecomment-768444750 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-21138) KvStateServerHandler is not invoked with user code classloader

2021-01-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273026#comment-17273026 ] Till Rohrmann commented on FLINK-21138: --- Thanks for posting this example. I am wondering whether

[GitHub] [flink] tweise opened a new pull request #14781: [release-1.12][FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
tweise opened a new pull request #14781: URL: https://github.com/apache/flink/pull/14781 1.12 backport of https://github.com/apache/flink/pull/14711 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] raghavgautam commented on pull request #14724: [FLINK-19360] Fink startup fails when $JAVA_HOME have space

2021-01-27 Thread GitBox
raghavgautam commented on pull request #14724: URL: https://github.com/apache/flink/pull/14724#issuecomment-768434524 @zentol I have addressed your review comment. Please take another look. This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #14777: [FLINK-21164][rest] Delete temporary jars

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14777: URL: https://github.com/apache/flink/pull/14777#issuecomment-768256830 ## CI report: * 8eded2f333e80f7d9ef5adaada7a3323774b8869 Azure:

[jira] [Commented] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-27 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273006#comment-17273006 ] Till Rohrmann commented on FLINK-21108: --- One way to limit the access to real servers is to not

[GitHub] [flink] sjwiesman commented on a change in pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
sjwiesman commented on a change in pull request #14780: URL: https://github.com/apache/flink/pull/14780#discussion_r565478156 ## File path: docs/dev/project-configuration.md ## @@ -146,6 +146,23 @@ pick the Scala version that matches their application's Scala version. Please

[GitHub] [flink] tweise commented on pull request #14711: [FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
tweise commented on pull request #14711: URL: https://github.com/apache/flink/pull/14711#issuecomment-768422261 @becketqin thanks for the review. In this case `WhiteBox` is needed to check that the settings are reflected in the Kafka client objects. Should there be ideas how to

[GitHub] [flink] tweise merged pull request #14711: [FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

2021-01-27 Thread GitBox
tweise merged pull request #14711: URL: https://github.com/apache/flink/pull/14711 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] zentol commented on a change in pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
zentol commented on a change in pull request #14780: URL: https://github.com/apache/flink/pull/14780#discussion_r565470148 ## File path: docs/flinkDev/building.md ## @@ -132,7 +132,7 @@ Since version 1.7 Flink builds with Scala version 2.11 (default) and 2.12. To build

[GitHub] [flink] flinkbot edited a comment on pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14765: URL: https://github.com/apache/flink/pull/14765#issuecomment-767648687 ## CI report: * 08c35397ba79eab9e80cfcb2b4d58b7df5da1f1f Azure:

[GitHub] [flink] zentol commented on a change in pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
zentol commented on a change in pull request #14767: URL: https://github.com/apache/flink/pull/14767#discussion_r565469068 ## File path: flink-tests/src/test/java/org/apache/flink/test/runtime/BlockingShuffleITCase.java ## @@ -94,6 +95,7 @@ private JobGraph createJobGraph(int

[GitHub] [flink] dawidwys commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
dawidwys commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565462300 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/iterator/RocksSingleStateIterator.java

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2021-01-27 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272982#comment-17272982 ] Etienne Chauchot commented on FLINK-18685: -- [~rmetzger] my pleasure ! thanks for

[GitHub] [flink] aljoscha commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565458656 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBFullSnapshotResources.java

[GitHub] [flink] aljoscha commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565457375 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565455652 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565454972 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/iterator/RocksSingleStateIterator.java

[GitHub] [flink] aljoscha commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565454247 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyValueStateIterator.java ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14765: URL: https://github.com/apache/flink/pull/14765#issuecomment-767648687 ## CI report: * 08c35397ba79eab9e80cfcb2b4d58b7df5da1f1f Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-27 Thread GitBox
rmetzger commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r565363984 ## File path: flink-end-to-end-tests/flink-glue-schema-registry-test/src/main/java/org.apache.flink.glue.schema.registry.test/GSRKinesisPubsubClient.java

[GitHub] [flink] aljoscha commented on a change in pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
aljoscha commented on a change in pull request #14765: URL: https://github.com/apache/flink/pull/14765#discussion_r565449964 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/FullSnapshotUtil.java ## @@ -16,13 +16,13 @@ * limitations under the

[GitHub] [flink] flinkbot edited a comment on pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14775: URL: https://github.com/apache/flink/pull/14775#issuecomment-768234660 ## CI report: * 7df0cb198efffa5c5dd7d6cbe98e4db63f8e4269 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14765: URL: https://github.com/apache/flink/pull/14765#issuecomment-767648687 ## CI report: * 52588009ab10795ee7c7e576ad11879760350871 Azure:

[jira] [Comment Edited] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-27 Thread Xiaoguang Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272950#comment-17272950 ] Xiaoguang Sun edited comment on FLINK-21108 at 1/27/21, 3:53 PM: - At

[jira] [Comment Edited] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-27 Thread Xiaoguang Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272950#comment-17272950 ] Xiaoguang Sun edited comment on FLINK-21108 at 1/27/21, 3:52 PM: - At

[jira] [Commented] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

2021-01-27 Thread Xiaoguang Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272950#comment-17272950 ] Xiaoguang Sun commented on FLINK-21108: --- At this time, anybody who knows the endpoint of a running

[GitHub] [flink] flinkbot edited a comment on pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14767: URL: https://github.com/apache/flink/pull/14767#issuecomment-767740322 ## CI report: * 12db140bd9ec875810a27e88b840f2969d34fb63 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 3885663038156d52aec21062a9743009fb875cc3 Azure:

[jira] [Closed] (FLINK-21006) HBaseTablePlanTest tests failed in haoop 3.1.3 with "java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;

2021-01-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21006. -- Resolution: Fixed Resolved in

[GitHub] [flink] rmetzger closed pull request #14770: [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x

2021-01-27 Thread GitBox
rmetzger closed pull request #14770: URL: https://github.com/apache/flink/pull/14770 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] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * 3885663038156d52aec21062a9743009fb875cc3 Azure:

[jira] [Closed] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2021-01-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18685. -- Fix Version/s: 1.13.0 Resolution: Fixed > JobClient.getAccumulators() blocks until

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

2021-01-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272922#comment-17272922 ] Robert Metzger commented on FLINK-18685: Resolved in

[jira] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

2021-01-27 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272921#comment-17272921 ] Aljoscha Krettek commented on FLINK-21132: -- It seems to me we just need to make sure that 

[GitHub] [flink] rmetzger closed pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

2021-01-27 Thread GitBox
rmetzger closed pull request #14558: URL: https://github.com/apache/flink/pull/14558 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 #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-27 Thread GitBox
sjwiesman commented on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-768343868 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14780: URL: https://github.com/apache/flink/pull/14780#issuecomment-768329420 ## CI report: * 8251a890daad47333167e3998fc697ffd45eca8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14767: URL: https://github.com/apache/flink/pull/14767#issuecomment-767740322 ## CI report: * 7b5d7b37c9a10af67665068053bed59ecb2fccc8 Azure:

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-01-27 Thread GitBox
rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-768331002 Thanks a lot for the clarification This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-20701) print connector supports outputting seriailzed record

2021-01-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20701. --- Resolution: Invalid Thanks [~zoucao], I will close this issue then. > print connector supports outputting

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272898#comment-17272898 ] Jark Wu commented on FLINK-21045: - Thanks for your reply [~twalthr]. I don't have strong opinion on

[GitHub] [flink] flinkbot commented on pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
flinkbot commented on pull request #14780: URL: https://github.com/apache/flink/pull/14780#issuecomment-768329420 ## CI report: * 8251a890daad47333167e3998fc697ffd45eca8f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
flinkbot edited a comment on pull request #14767: URL: https://github.com/apache/flink/pull/14767#issuecomment-767740322 ## CI report: * 7b5d7b37c9a10af67665068053bed59ecb2fccc8 Azure:

[jira] [Commented] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2021-01-27 Thread Jude Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272893#comment-17272893 ] Jude Zhu commented on FLINK-20951: -- I' alread set 

[GitHub] [flink] flinkbot commented on pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
flinkbot commented on pull request #14780: URL: https://github.com/apache/flink/pull/14780#issuecomment-768319433 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] aljoscha opened a new pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

2021-01-27 Thread GitBox
aljoscha opened a new pull request #14780: URL: https://github.com/apache/flink/pull/14780 ## What is the purpose of the change Scala versions after 2.12.8 are not binary compatible with previous versions, we link to the relevant release notes and point users towards building their

<    1   2   3   4   5   >