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

2021-01-27 Thread ASF GitHub Bot (Jira)
[ 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] flinkbot edited a comment 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
flinkbot edited a comment on pull request #14779: URL: https://github.com/apache/flink/pull/14779#issuecomment-768302027 ## CI report: * 87fab35cbddf22b2479969188eca5a9a3767c098 Azure:

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

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

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

2021-01-27 Thread Timo Walther (Jira)
[ 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

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread Timo Walther (Jira)
[ 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] rmetzger commented on a change in pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
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 a change in pull request #14767: [FLINK-21099] Introduce JobType to distinguish between batch and streaming jobs

2021-01-27 Thread GitBox
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 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
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 edited a comment on pull request #14770: [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x

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

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

2021-01-27 Thread GitBox
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] rmetzger edited a comment on pull request #14770: [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x

2021-01-27 Thread GitBox
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] rmetzger commented on pull request #14770: [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x

2021-01-27 Thread GitBox
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] 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_r565295292 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/FullSnapshotUtil.java ## @@ -16,13 +16,13 @@ * limitations under 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

2021-01-27 Thread GitBox
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] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-27 Thread GitBox
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] echauchot commented on pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

2021-01-27 Thread GitBox
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

2021-01-27 Thread GitBox
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] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-27 Thread GitBox
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

2021-01-27 Thread pengkangjing (Jira)
[ 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] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-27 Thread GitBox
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 #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] flinkbot edited a comment on pull request #14776: [FLINK-21072][hotfix] Clear resources in HeapSnapshotStrategy

2021-01-27 Thread GitBox
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 #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: * a2dbd928da387b47c4e7daf1b2bd7dc3c0bf032f Azure:

[GitHub] [flink-docker] rmetzger merged pull request #24: [hotfix] Add readme with simple instructions

2021-01-27 Thread GitBox
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

[GitHub] [flink] flinkbot 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
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 commented on a change in pull request #63: Adjust dev-1.12 branch for building 1.12.0

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread Till Rohrmann (Jira)
[ 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] pengkangjing opened a new pull request #14779: [Flink-21158][Runtime/Web Frontend] wrong jvm metaspace and overhead size show in taskmanager metric page

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread GitBox
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] pengkangjing closed pull request #14778: [FLINK-21158]wrong jvm metaspace and overhead size show in taskmanager metric page

2021-01-27 Thread GitBox
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] [Updated] (FLINK-21158) wrong jvm metaspace and overhead size show in taskmanager metric page

2021-01-27 Thread ASF GitHub Bot (Jira)
[ 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

2021-01-27 Thread GitBox
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] 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: * a2dbd928da387b47c4e7daf1b2bd7dc3c0bf032f 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

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: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 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: * Unknown: [CANCELED](TBD) * 4d9ace4ee4a4650ea186f806b0379995fee65873 Azure:

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

2021-01-27 Thread Robert Metzger (Jira)
[ 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] WeiZhong94 commented on pull request #14760: [FLINK-20994][python] Add public method to create TableEnvironment in PyFlink.

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread Chesnay Schepler (Jira)
[ 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] 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:

[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: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 Azure:

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

2021-01-27 Thread GitBox
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…

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: * Unknown: [CANCELED](TBD) * 4d9ace4ee4a4650ea186f806b0379995fee65873 UNKNOWN Bot commands The @flinkbot bot supports the

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

2021-01-27 Thread GitBox
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] HuangXingBo commented on a change in pull request #14760: [FLINK-20994][python] Add public method to create TableEnvironment in PyFlink.

2021-01-27 Thread GitBox
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] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread Robert Metzger (Jira)
[ 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] [Updated] (FLINK-21165) Timestamps/Watermarks chained erroneously with previous operator

2021-01-27 Thread zlzhang0122 (Jira)
[ 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] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread zlzhang0122 (Jira)
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] shouweikun commented on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

2021-01-27 Thread GitBox
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] XComp edited a comment on pull request #14686: [FLINK-6042][runtime] Adds exception history

2021-01-27 Thread GitBox
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] shouweikun removed a comment on pull request #14727: [FLINK-19945][Connectors / FileSystem]Support sink parallelism config…

2021-01-27 Thread GitBox
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] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-27 Thread GitBox
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] 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_r565269327 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorBatchExecutionTest.java ## @@ -105,6 +107,7 @@

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

2021-01-27 Thread GitBox
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

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

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

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

2021-01-27 Thread Partha Pradeep Mishra (Jira)
[ 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?

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

2021-01-27 Thread Partha Pradeep Mishra (Jira)
[ 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] [Closed] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

2021-01-27 Thread Chesnay Schepler (Jira)
[ 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

2021-01-27 Thread GitBox
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

2021-01-27 Thread GitBox
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-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

2021-01-27 Thread Chesnay Schepler (Jira)
[ 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

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

2021-01-27 Thread Chesnay Schepler (Jira)
[ 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

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

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread ASF GitHub Bot (Jira)
[ 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] zentol opened a new pull request #14777: [FLINK-21164][rest] Delete temporary jars

2021-01-27 Thread GitBox
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] [Commented] (FLINK-20701) print connector supports outputting seriailzed record

2021-01-27 Thread zoucao (Jira)
[ 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

[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

2021-01-27 Thread GitBox
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

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

2021-01-27 Thread GitBox
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] 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: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 Azure:

[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 #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

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

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

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

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

2021-01-27 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-21164: Summary: Jar handlers don't cleanup temporarily extracted jars Key: FLINK-21164 URL: https://issues.apache.org/jira/browse/FLINK-21164 Project: Flink

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

2021-01-27 Thread GitBox
flinkbot commented on pull request #14776: URL: https://github.com/apache/flink/pull/14776#issuecomment-768236188 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] dawidwys opened a new pull request #14776: [FLINK-21072][hotfix] Clear resources in HeapSnapshotStrategy

2021-01-27 Thread GitBox
dawidwys opened a new pull request #14776: URL: https://github.com/apache/flink/pull/14776 ## What is the purpose of the change A fix for a bug introduced in #14719. The resources in HeapSnapshotStrategy are not being closed properly. ## Does this pull request

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

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

[GitHub] [flink] flinkbot 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
flinkbot commented on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768234538 ## CI report: * 1e2a1f5b555fad9fc28440c37f695a610ed30f31 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

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

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

2021-01-27 Thread GitBox
flinkbot commented on pull request #14775: URL: https://github.com/apache/flink/pull/14775#issuecomment-768230921 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] rmetzger commented on pull request #14558: [FLINK-18685] [runtime] Make MiniClusterJobClient#getAccumulators non-blocking in Streaming mode

2021-01-27 Thread GitBox
rmetzger commented on pull request #14558: URL: https://github.com/apache/flink/pull/14558#issuecomment-768230246 @echauchot I'm really sorry for the delay. I'll take a look at this PR today! This is an automated message

[jira] [Updated] (FLINK-20964) Introduce PythonStreamGroupWindowAggregateOperator

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

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

2021-01-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272796#comment-17272796 ] Chesnay Schepler commented on FLINK-17572: -- We can remove it from the WebUI, yes. > Remove

[GitHub] [flink] HuangXingBo opened a new pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

2021-01-27 Thread GitBox
HuangXingBo opened a new pull request #14775: URL: https://github.com/apache/flink/pull/14775 ## What is the purpose of the change *This pull request will Introduce `PythonStreamGroupWindowAggregateOperator` for supporting Python Stream Group Window agg* ## Brief change

[jira] [Reopened] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

2021-01-27 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-20309: --

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

2021-01-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21158: - Fix Version/s: 1.12.2 1.13.0 > wrong jvm metaspace and overhead size show in

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

2021-01-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21158: - Priority: Major (was: Minor) > wrong jvm metaspace and overhead size show in taskmanager

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

2021-01-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21158: - Affects Version/s: (was: 1.12.0) > wrong jvm metaspace and overhead size show in

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

2021-01-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21158: Assignee: pengkangjing > wrong jvm metaspace and overhead size show in taskmanager

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

2021-01-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272790#comment-17272790 ] Xintong Song commented on FLINK-21158: -- Thanks [~pengkangjing] for reporting this, and thanks

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

2021-01-27 Thread GitBox
echauchot commented on pull request #14558: URL: https://github.com/apache/flink/pull/14558#issuecomment-768224928 @tillrohrmann can you please take a look at this PR as I saw you in the git history of this part of code ? Thanks

[jira] [Closed] (FLINK-21145) Flink Temporal Join Hive optimization

2021-01-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21145. --- Resolution: Duplicate > Flink Temporal Join Hive optimization > - > >

[jira] [Commented] (FLINK-21145) Flink Temporal Join Hive optimization

2021-01-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272789#comment-17272789 ] Jark Wu commented on FLINK-21145: - [~HideOnBush], the pushed down optimization is not supported yet. >

[GitHub] [flink] flinkbot 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
flinkbot commented on pull request #14774: URL: https://github.com/apache/flink/pull/14774#issuecomment-768224175 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 #14773: [FLINK-16153] Translate "Operator/windows" into Chinese

2021-01-27 Thread GitBox
flinkbot commented on pull request #14773: URL: https://github.com/apache/flink/pull/14773#issuecomment-768224190 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-20416) Need a cached catalog for HiveCatalog

2021-01-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272787#comment-17272787 ] Jark Wu commented on FLINK-20416: - Sounds good to me. I think we don't need the {{Wrapper}} postfix for

[jira] [Updated] (FLINK-21163) Python dependencies specified via CLI should not override the dependencies specified in configuration

2021-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21163: --- Labels: pull-request-available (was: ) > Python dependencies specified via CLI should not

[jira] [Assigned] (FLINK-20416) Need a cached catalog for HiveCatalog

2021-01-27 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20416: --- Assignee: Sebastian Liu > Need a cached catalog for HiveCatalog >

<    1   2   3   4   5   >