[jira] [Closed] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-17572. Fix Version/s: (was: 1.13.0) Resolution: Fixed The alignmentBuffered metric

[jira] [Updated] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-18662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18662: - Component/s: Runtime / Web Frontend > Provide more detailed metrics why unaligned

[GitHub] [flink] flinkbot edited a comment on pull request #14776: [FLINK-21072][hotfix] Clear resources in HeapSnapshotStrategy

flinkbot edited a comment on pull request #14776: URL: https://github.com/apache/flink/pull/14776#issuecomment-768243876 ## CI report: * 17d8c09735c5dd36d23d2db1d690283acbbc509a Azure:

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

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

[jira] [Updated] (FLINK-21158) wrong jvm metaspace and overhead size show in taskmanager metric page

[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21158: --- Labels: pull-request-available (was: ) > wrong jvm metaspace and overhead size show in

[GitHub] [flink] pengkangjing opened a new pull request #14778: [FLINK-21158]wrong jvm metaspace and overhead size show in taskmanager metric page

pengkangjing opened a new pull request #14778: URL: https://github.com/apache/flink/pull/14778 ## What is the purpose of the change the size of jvm metaspace and jvm overhead on taskmanager metrics page not the derived value from flink-conf.yaml but always be the

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565315896 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBrief.java ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #14770: [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x

flinkbot edited a comment on pull request #14770: URL: https://github.com/apache/flink/pull/14770#issuecomment-768105021 ## CI report: * f515dd11a8c7bda0fd1386c9287edacec51492d2 Azure:

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

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

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

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

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

[ 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

[ 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

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

[ 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-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272825#comment-17272825 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~yunta] Any updates on the metafile

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272824#comment-17272824 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~AHeise] Any updates on the above issue?

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

xintongsong commented on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-768265430 @zentol, I think the core differences are 1) as you said tracking resources per task executor and decide the TM to allocate slot accordingly, and 2) the abstraction of

[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

flinkbot edited a comment on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538 ## CI report: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #14766: [FLINK-20254][hive] Make PartitionMonitor fetching partitions with same create time properly

flinkbot edited a comment on pull request #14766: URL: https://github.com/apache/flink/pull/14766#issuecomment-767662801 ## CI report: * 1275e312138642ea6a6d00f4ff8bd225723ec903 Azure:

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

flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * Unknown: [CANCELED](TBD) * 4d9ace4ee4a4650ea186f806b0379995fee65873 UNKNOWN Bot commands The @flinkbot bot supports the

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

flinkbot edited a comment on pull request #14760: URL: https://github.com/apache/flink/pull/14760#issuecomment-767543514 ## CI report: * a2dbd928da387b47c4e7daf1b2bd7dc3c0bf032f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14776: [FLINK-21072][hotfix] Clear resources in HeapSnapshotStrategy

flinkbot edited a comment on pull request #14776: URL: https://github.com/apache/flink/pull/14776#issuecomment-768243876 ## CI report: * 17d8c09735c5dd36d23d2db1d690283acbbc509a Azure:

[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

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

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

rmetzger edited a comment on pull request #14770: URL: https://github.com/apache/flink/pull/14770#issuecomment-768300909 > What test failure are you investigating @rmetzger? The ORC test was failing in the Hadoop 3 profile. Most likely the failure is unrelated to my change and has

[GitHub] [flink] tillrohrmann commented on pull request #14686: [FLINK-6042][runtime] Adds exception history

tillrohrmann commented on pull request #14686: URL: https://github.com/apache/flink/pull/14686#issuecomment-768301088 Matthias and me talked offline and we concluded that we might not need to change the `Executions` to also set a `failureInfo` if `processFail` is called when they are in

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-20701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272816#comment-17272816 ] zoucao commented on FLINK-20701: maybe you are right, it is not a good motivation, after considering

[jira] [Updated] (FLINK-21165) Timestamps/Watermarks chained erroneously with previous operator

[ https://issues.apache.org/jira/browse/FLINK-21165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-21165: Description: When using assignTimestampAndWatermarks function separately, if it can satisfied

[GitHub] [flink] WeiZhong94 commented on pull request #14760: [FLINK-20994][python] Add public method to create TableEnvironment in PyFlink.

WeiZhong94 commented on pull request #14760: URL: https://github.com/apache/flink/pull/14760#issuecomment-768268884 @HuangXingBo Thanks for your review. I have updated this PR. This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on pull request #14778: [FLINK-21158]wrong jvm metaspace and overhead size show in taskmanager metric page

flinkbot commented on pull request #14778: URL: https://github.com/apache/flink/pull/14778#issuecomment-768288718 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-docker] rmetzger commented on a change in pull request #63: Adjust dev-1.12 branch for building 1.12.0

rmetzger commented on a change in pull request #63: URL: https://github.com/apache/flink-docker/pull/63#discussion_r565311288 ## File path: add-version.sh ## @@ -112,9 +112,9 @@ for source_variant in "${SOURCE_VARIANTS[@]}"; do

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

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272878#comment-17272878 ] Timo Walther commented on FLINK-21045: -- Thanks for discussing this topic again. I quickly scanned

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

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,

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

[ 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] [Closed] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ 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

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

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

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

[ 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] flinkbot commented on pull request #14777: [FLINK-21164][rest] Delete temporary jars

flinkbot commented on pull request #14777: URL: https://github.com/apache/flink/pull/14777#issuecomment-768249538 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] shouweikun removed a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

shouweikun removed a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-766614104 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] XComp edited a comment on pull request #14686: [FLINK-6042][runtime] Adds exception history

XComp edited a comment on pull request #14686: URL: https://github.com/apache/flink/pull/14686#issuecomment-768170545 After talking to @chesnay about the exception history, I had to reiterate over the implementation as I realized that I tried to solve it using wrong assumptions. I try to

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565321454 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1924,7 +1918,8 @@ private void

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

[ 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 edited a comment on pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

flinkbot edited a comment on pull request #14767: URL: https://github.com/apache/flink/pull/14767#issuecomment-767740322 ## CI report: * 7b5d7b37c9a10af67665068053bed59ecb2fccc8 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

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 edited a comment on pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

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

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

[ 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

[jira] [Created] (FLINK-21165) Timestamps/Watermarks chained erroneously with previous operator

zlzhang0122 created FLINK-21165: --- Summary: Timestamps/Watermarks chained erroneously with previous operator Key: FLINK-21165 URL: https://issues.apache.org/jira/browse/FLINK-21165 Project: Flink

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565277280 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBriefComputer.java ## @@ -0,0 +1,120 @@ +/* + * Licensed to the

[GitHub] [flink] shouweikun commented on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

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

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565315896 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBrief.java ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-21158) wrong jvm metaspace and overhead size show in taskmanager metric page

[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272862#comment-17272862 ] pengkangjing commented on FLINK-21158: -- [~xintongsong] Thanks for assigned this work to me，and

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

echauchot commented on pull request #14558: URL: https://github.com/apache/flink/pull/14558#issuecomment-768297169 @rmetzger don't worry, I know what it is :) This is an automated message from the Apache Git Service. To

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565321454 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1924,7 +1918,8 @@ private void

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

rmetzger commented on a change in pull request #14767: URL: https://github.com/apache/flink/pull/14767#discussion_r565331523 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java ## @@ -751,6 +760,8 @@ public

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

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] [Commented] (FLINK-21132) BoundedOneInput.endInput is called when taking synchronous savepoint

[ 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] flinkbot edited a comment on pull request #14765: [FLINK-21151] Extract common full-snapshot writer from RocksDB full-snapshot strategy

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

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

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 #14774: [FLINK-21163][python] Fix the issue that Python dependencies specified via CLI override the dependencies specified in configuration

flinkbot edited a comment on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538 ## CI report: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 Azure:

[GitHub] [flink] flinkbot commented on pull request #14776: [FLINK-21072][hotfix] Clear resources in HeapSnapshotStrategy

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

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

zentol commented on a change in pull request #14767: URL: https://github.com/apache/flink/pull/14767#discussion_r565269327 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorBatchExecutionTest.java ## @@ -105,6 +107,7 @@

[jira] [Commented] (FLINK-18129) Unhandled exception stack trace from DispatcherRestEndpoint when deploying Kubernetes session cluster

[ https://issues.apache.org/jira/browse/FLINK-18129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272832#comment-17272832 ] Robert Metzger commented on FLINK-18129: +1 to Till's proposal of only logging the exception

[jira] [Commented] (FLINK-19158) Revisit java e2e download timeouts

[ https://issues.apache.org/jira/browse/FLINK-19158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272847#comment-17272847 ] Robert Metzger commented on FLINK-19158: Another case in PR:

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

flinkbot commented on pull request #14779: URL: https://github.com/apache/flink/pull/14779#issuecomment-768289736 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-docker] rmetzger merged pull request #24: [hotfix] Add readme with simple instructions

rmetzger merged pull request #24: URL: https://github.com/apache/flink-docker/pull/24 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] [Comment Edited] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

[ 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

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

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 #14770: [FLINK-21066] Fix hbase 1.4 tests on Hadoop 3.x

flinkbot edited a comment on pull request #14770: URL: https://github.com/apache/flink/pull/14770#issuecomment-768105021 ## CI report: * f515dd11a8c7bda0fd1386c9287edacec51492d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

flinkbot edited a comment on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768234436 ## CI report: * 0da2330259082ab890d671077cca17cbae4c5db5 Azure:

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565277280 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBriefComputer.java ## @@ -0,0 +1,120 @@ +/* + * Licensed to the

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565277280 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBriefComputer.java ## @@ -0,0 +1,120 @@ +/* + * Licensed to the

[GitHub] [flink] pengkangjing closed pull request #14778: [FLINK-21158]wrong jvm metaspace and overhead size show in taskmanager metric page

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

[jira] [Commented] (FLINK-21153) yarn-per-job deployment target ignores yarn options

[ https://issues.apache.org/jira/browse/FLINK-21153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272858#comment-17272858 ] Till Rohrmann commented on FLINK-21153: --- How are we implementing features which only work for a

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565315896 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBrief.java ## @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache

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

rmetzger commented on a change in pull request #14767: URL: https://github.com/apache/flink/pull/14767#discussion_r565327342 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorBatchExecutionTest.java ## @@ -105,6 +107,7

[GitHub] [flink] flinkbot edited a comment on pull request #14770: [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x

flinkbot edited a comment on pull request #14770: URL: https://github.com/apache/flink/pull/14770#issuecomment-768105021 ## CI report: * f515dd11a8c7bda0fd1386c9287edacec51492d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14779: [Flink-21158][Runtime/Web Frontend] wrong jvm metaspace and overhead size show in taskmanager metric page

flinkbot edited a comment on pull request #14779: URL: https://github.com/apache/flink/pull/14779#issuecomment-768302027 ## CI report: * 87fab35cbddf22b2479969188eca5a9a3767c098 Azure:

[GitHub] [flink] aljoscha opened a new pull request #14780: [FLINK-12461] Document Scala 2.12.x situation

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

[jira] [Updated] (FLINK-12461) Flink 1.8 not working with Scala 2.12.8

[ https://issues.apache.org/jira/browse/FLINK-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12461: --- Labels: pull-request-available (was: ) > Flink 1.8 not working with Scala 2.12.8 >

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

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] zentol opened a new pull request #14777: [FLINK-21164][rest] Delete temporary jars

zentol opened a new pull request #14777: URL: https://github.com/apache/flink/pull/14777 Modifies the Jar(Run|Plan)Handler to call `PackagedProgram#deleteExtractedLibraries` once we are done with the job submission / plan generation. This is not **covered** by tests; I don't see a

[jira] [Updated] (FLINK-21164) Jar handlers don't cleanup temporarily extracted jars

[ https://issues.apache.org/jira/browse/FLINK-21164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21164: --- Labels: pull-request-available (was: ) > Jar handlers don't cleanup temporarily extracted

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

HuangXingBo commented on a change in pull request #14760: URL: https://github.com/apache/flink/pull/14760#discussion_r565280413 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -1045,7 +1059,8 @@ def register_java_function(self, name: str,

[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

flinkbot edited a comment on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538 ## CI report: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 Azure:

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

flinkbot edited a comment on pull request #14760: URL: https://github.com/apache/flink/pull/14760#issuecomment-767543514 ## CI report: * a2dbd928da387b47c4e7daf1b2bd7dc3c0bf032f Azure:

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

flinkbot edited a comment on pull request #14727: URL: https://github.com/apache/flink/pull/14727#issuecomment-765189922 ## CI report: * Unknown: [CANCELED](TBD) * 4d9ace4ee4a4650ea186f806b0379995fee65873 Azure:

[GitHub] [flink] pengkangjing commented on pull request #14778: [FLINK-21158]wrong jvm metaspace and overhead size show in taskmanager metric page

pengkangjing commented on pull request #14778: URL: https://github.com/apache/flink/pull/14778#issuecomment-768281934 used wrong branch This is an automated message from the Apache Git Service. To respond to the message,

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

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

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

rmetzger commented on pull request #14770: URL: https://github.com/apache/flink/pull/14770#issuecomment-768300909 > What test failure are you investigating @rmetzger? The ORC test was failing in the Hadoop 3 profile. Most likely the failure is unrelated to my change and has been

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

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

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

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

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565260718 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java ## @@ -197,22 +197,13 @@ public static

[jira] [Closed] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

[ https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18347. Fix Version/s: (was: 1.10.4) (was: 1.11.4)

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565270255 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -448,14 +441,24 @@ public void

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r565270255 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -448,14 +441,24 @@ public void

[jira] [Updated] (FLINK-21165) Timestamps/Watermarks chained erroneously with previous operator

[ https://issues.apache.org/jira/browse/FLINK-21165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-21165: - Component/s: (was: Client / Job Submission) API / DataStream >

[GitHub] [flink] pengkangjing opened a new pull request #14779: [Flink-21158][Runtime/Web Frontend] wrong jvm metaspace and overhead size show in taskmanager metric page

pengkangjing opened a new pull request #14779: URL: https://github.com/apache/flink/pull/14779 ## What is the purpose of the change the size of jvm metaspace and jvm overhead on taskmanager metrics page not the derived value from flink-conf.yaml but always be the

[jira] [Commented] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

[ https://issues.apache.org/jira/browse/FLINK-20942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272883#comment-17272883 ] Timo Walther commented on FLINK-20942: -- Thanks for investigating this [~danny0405]. Once the fix

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

rmetzger commented on a change in pull request #14767: URL: https://github.com/apache/flink/pull/14767#discussion_r565337043 ## File path: flink-tests/src/test/java/org/apache/flink/test/runtime/BlockingShuffleITCase.java ## @@ -94,6 +95,7 @@ private JobGraph

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

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

  1   2   3   4   5   >