flinkbot commented on pull request #11984:
URL: https://github.com/apache/flink/pull/11984#issuecomment-623392125
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 pro
[
https://issues.apache.org/jira/browse/FLINK-16034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-16034.
Resolution: Fixed
Implemented in 51f373e296904ac77ff3701edbce9f76cb77a770
> Update the st
flinkbot edited a comment on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-623338745
## CI report:
* dd93ed53068426549218864c3b4f278bab0929a5 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163638645) Azure:
[PENDING](http
[
https://issues.apache.org/jira/browse/FLINK-17501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17501:
---
Labels: pull-request-available (was: )
> Improve logging in AbstractServerHandler#channelRe
GJL opened a new pull request #11984:
URL: https://github.com/apache/flink/pull/11984
## What is the purpose of the change
*Improve logging in
`AbstractServerHandler#channelRead(ChannelHandlerContext, Object)`. If an Error
is thrown, it should be logged as early as possible. Current
flinkbot edited a comment on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542
## CI report:
* 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN
* d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN
* cba096ae3d8eba4a0d39c64659f76ad10a62
Gary Yao created FLINK-17501:
Summary: Improve logging in
AbstractServerHandler#channelRead(ChannelHandlerContext, Object)
Key: FLINK-17501
URL: https://issues.apache.org/jira/browse/FLINK-17501
Project:
[
https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098812#comment-17098812
]
Stephan Ewen edited comment on FLINK-17192 at 5/4/20, 10:20 AM:
--
azagrebin commented on pull request #11934:
URL: https://github.com/apache/flink/pull/11934#issuecomment-623380047
Thanks for working on this @xintongsong @link3280
LGTM, merging this
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14816.
-
Release Note: It is now possible to create and view the thread dump of a
`TaskExecutor` through
leonardBang commented on pull request #11951:
URL: https://github.com/apache/flink/pull/11951#issuecomment-623373132
> Can not tell for sure as this code is quite old (It was ported in 1.9 from
`TableEnvironment.scala`). It worked as you are describing that you could/can
not use the `rowti
[
https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-14816:
---
> Add thread dump feature for taskmanager
> ---
>
>
dawidwys commented on pull request #11951:
URL: https://github.com/apache/flink/pull/11951#issuecomment-623366784
Can not tell for sure as this code is quite old (It was ported in 1.9 from
`TableEnvironment.scala`). It worked as you are describing that you could/can
not use the `rowtime` i
[
https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098812#comment-17098812
]
Stephan Ewen edited comment on FLINK-17192 at 5/4/20, 9:41 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098812#comment-17098812
]
Stephan Ewen commented on FLINK-17192:
--
There is a hidden/experimental feature in t
[
https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-17500:
-
Summary: Deploy JobGraph from file in StandaloneClusterEntrypoint (was:
Deploy JobGraph
[
https://issues.apache.org/jira/browse/FLINK-17192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098801#comment-17098801
]
Aljoscha Krettek commented on FLINK-17192:
--
Did you try setting {{taskmanager.r
Ufuk Celebi created FLINK-17500:
---
Summary: Deploy JobGraph form file in StandaloneClusterEntrypoint
Key: FLINK-17500
URL: https://issues.apache.org/jira/browse/FLINK-17500
Project: Flink
Issue
flinkbot edited a comment on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-623338745
## CI report:
* dd93ed53068426549218864c3b4f278bab0929a5 Travis:
[PENDING](https://travis-ci.com/github/flink-ci/flink/builds/163638645) Azure:
[PENDING](http
flinkbot edited a comment on pull request #11983:
URL: https://github.com/apache/flink/pull/11983#issuecomment-623338857
## CI report:
* d63d8eb14a296134b7eb60366b0067af38cc8e97 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #11951:
URL: https://github.com/apache/flink/pull/11951#issuecomment-621585351
## CI report:
* 38b17d3e6bb0dff3d2a383ed066f23bc3c2dce4f Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862304) Azure:
[SUCCESS](http
KarmaGYZ commented on a change in pull request #11920:
URL: https://github.com/apache/flink/pull/11920#discussion_r419303769
##
File path:
flink-external-resource/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUDriver.java
##
@@ -0,0 +1,134 @
KarmaGYZ commented on a change in pull request #11920:
URL: https://github.com/apache/flink/pull/11920#discussion_r419303241
##
File path:
flink-external-resource/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUDriver.java
##
@@ -0,0 +1,134 @
KarmaGYZ commented on a change in pull request #11920:
URL: https://github.com/apache/flink/pull/11920#discussion_r419301850
##
File path:
flink-external-resource/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUDriver.java
##
@@ -0,0 +1,134 @
leonardBang commented on a change in pull request #11897:
URL: https://github.com/apache/flink/pull/11897#discussion_r419283115
##
File path: docs/dev/table/tuning/streaming_aggregation_optimization.zh.md
##
@@ -22,33 +23,32 @@ specific language governing permissions and limita
flinkbot commented on pull request #11983:
URL: https://github.com/apache/flink/pull/11983#issuecomment-623338857
## CI report:
* d63d8eb14a296134b7eb60366b0067af38cc8e97 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-623338745
## CI report:
* dd93ed53068426549218864c3b4f278bab0929a5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #11951:
URL: https://github.com/apache/flink/pull/11951#issuecomment-621585351
## CI report:
* 38b17d3e6bb0dff3d2a383ed066f23bc3c2dce4f Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162862304) Azure:
[SUCCESS](http
flinkbot edited a comment on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824
## CI report:
* 56a3c01587e6e87d3a9d82fbe14c3c72724bb547 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161906304) Azure:
[CANCELED](htt
flinkbot edited a comment on pull request #11914:
URL: https://github.com/apache/flink/pull/11914#issuecomment-619541487
## CI report:
* 5246f29f20f57b6805dcac293f9024344edf5160 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162067327) Azure:
[SUCCESS](http
flinkbot edited a comment on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542
## CI report:
* 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN
* d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN
* cba096ae3d8eba4a0d39c64659f76ad10a62
KarmaGYZ commented on a change in pull request #11920:
URL: https://github.com/apache/flink/pull/11920#discussion_r419289302
##
File path:
flink-external-resource/flink-external-resource-gpu/src/main/resources/gpu-discovery.sh
##
@@ -0,0 +1,121 @@
+#!/usr/bin/env bash
+###
[
https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-11086:
---
Fix Version/s: 1.11.0
> Add support for Hadoop 3
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-11086:
---
Comment: was deleted
(was: Implementation plan:
- wait for decision on the dev@ ml
- replace
flinkbot commented on pull request #11983:
URL: https://github.com/apache/flink/pull/11983#issuecomment-623334690
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 pro
[
https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11086:
---
Labels: pull-request-available (was: )
> Add support for Hadoop 3
> ---
rmetzger opened a new pull request #11983:
URL: https://github.com/apache/flink/pull/11983
## What is the purpose of the change
- Replace flink-shaded-hadoop dependencies by vanilla Hadoop dependencies
Why?
- in principle it is better for users to use exactly the same client-ha
KarmaGYZ commented on a change in pull request #11920:
URL: https://github.com/apache/flink/pull/11920#discussion_r419285029
##
File path:
flink-external-resource/flink-external-resource-gpu/src/main/resources/gpu-discovery.sh
##
@@ -0,0 +1,121 @@
+#!/usr/bin/env bash
+###
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15178:
---
Fix Version/s: (was: 1.10.2)
> TaskExecutor crashes due to mmap allocation failure for B
[
https://issues.apache.org/jira/browse/FLINK-17165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-17165:
Assignee: Chesnay Schepler
> Remove flink-container/docker
>
[
https://issues.apache.org/jira/browse/FLINK-17163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-17163:
Assignee: Chesnay Schepler
> Remove flink-contrib/docker-flink
>
[
https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-17486:
---
Summary: ClassCastException when checkpointing AVRO SpecificRecord with
decimal fields (was
[
https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098770#comment-17098770
]
Piotr Nowojski commented on FLINK-17073:
As it's a rare issue that in this parti
[
https://issues.apache.org/jira/browse/FLINK-17287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098769#comment-17098769
]
Chesnay Schepler commented on FLINK-17287:
--
Turns out it's not a problem in Fli
[
https://issues.apache.org/jira/browse/FLINK-17421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-17421.
--
Resolution: Duplicate
After some offline discussions we decided to treat it as a bug FLINK-170
[
https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17073:
---
Priority: Major (was: Critical)
> Slow checkpoint cleanup causing OOMs
> --
[
https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17073:
---
Fix Version/s: (was: 1.9.4)
(was: 1.10.2)
> Slow checkpoint clean
[
https://issues.apache.org/jira/browse/FLINK-17287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098764#comment-17098764
]
Chesnay Schepler commented on FLINK-17287:
--
[~fabian.paul] thanks, I fixed it f
[
https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098763#comment-17098763
]
Li Ying commented on FLINK-17289:
-
I've finished it. Please refer to the
[PR11982|https
flinkbot edited a comment on pull request #11981:
URL: https://github.com/apache/flink/pull/11981#issuecomment-623312081
## CI report:
* b4a3be33dec4a270015f863fc2963c0eedd148eb Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 3c3f0a78079da08bfae6b2704e619a39a4f8e47f Azure:
[SUCCESS](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11914:
URL: https://github.com/apache/flink/pull/11914#issuecomment-619541487
## CI report:
* 174b4dbf50719f2a8a215be245bbd469acc3b3d5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824
## CI report:
* 6d068905bd0bcdcdc6074ec657ee5b87b5377e2c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
leonardBang commented on pull request #11951:
URL: https://github.com/apache/flink/pull/11951#issuecomment-623321491
Thanks @dawidwys , I add `$("aa"), $("bb"), $("cc"),
$("cc").proctime().as("proctime")` test, and I found rowtime expression does
not support alias from
https://github.com/
flinkbot commented on pull request #11982:
URL: https://github.com/apache/flink/pull/11982#issuecomment-623321333
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 pro
flinkbot edited a comment on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542
## CI report:
* 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN
* d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN
* cba096ae3d8eba4a0d39c64659f76ad10a62
liying919 opened a new pull request #11982:
URL: https://github.com/apache/flink/pull/11982
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17289:
---
Labels: pull-request-available (was: )
> Translate tutorials/etl.md to chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11186.
Resolution: Duplicate
> Event-time balancing for multiple Kafka partitions
> -
flinkbot commented on pull request #11981:
URL: https://github.com/apache/flink/pull/11981#issuecomment-623312081
## CI report:
* b4a3be33dec4a270015f863fc2963c0eedd148eb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 3c3f0a78079da08bfae6b2704e619a39a4f8e47f Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-17494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-17494.
Resolution: Duplicate
> Possible direct memory leak in cassandra sink
> --
[
https://issues.apache.org/jira/browse/FLINK-17473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-17473.
Resolution: Fixed
master: d385f20f607875a625df8b95917f7a8eaacea4a6
> Remove unused classes ArchivedExecut
[
https://issues.apache.org/jira/browse/FLINK-17498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-17498:
-
Component/s: (was: API / DataStream)
Runtime / Task
[
https://issues.apache.org/jira/browse/FLINK-17498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-17498:
-
Labels: test-stability (was: )
> MapCancelingITCase.testMapCancelling fails with timeou
fpompermaier commented on pull request #11900:
URL: https://github.com/apache/flink/pull/11900#issuecomment-623310522
@flinkbot run travis
@flinkbot run azure
This is an automated message from the Apache Git Service.
To re
fpompermaier commented on pull request #11914:
URL: https://github.com/apache/flink/pull/11914#issuecomment-623310124
@flinkbot run travis
@flinkbot run azure
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-16408:
--
Fix Version/s: (was: 1.10.2)
> Bind user code class loader to lifetime of a slot
> ---
[
https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-17487:
-
Component/s: Client / Job Submission
> Do not delete old checkpoints when stop the job.
[
https://issues.apache.org/jira/browse/FLINK-17393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098515#comment-17098515
]
Etienne Chauchot edited comment on FLINK-17393 at 5/4/20, 7:44 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-10934:
---
Affects Version/s: 1.11.0
> Support application mode in kubernetes
> ---
dawidwys commented on pull request #11981:
URL: https://github.com/apache/flink/pull/11981#issuecomment-623308581
cc @aljoscha @twalthr
This is an automated message from the Apache Git Service.
To respond to the message, ple
[
https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-10934:
---
Component/s: Client / Job Submission
> Support application mode in kubernetes
>
[
https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-16521:
Assignee: Guru Prasad
> Remove unused FileUtils#isClassFile
> ---
[
https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098748#comment-17098748
]
Aljoscha Krettek commented on FLINK-16521:
--
[~guruprasad146], please go ahead.
flinkbot commented on pull request #11981:
URL: https://github.com/apache/flink/pull/11981#issuecomment-623308245
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 pro
[
https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-16521:
-
Fix Version/s: (was: 1.10.2)
> Remove unused FileUtils#isClassFile
> ---
dawidwys opened a new pull request #11981:
URL: https://github.com/apache/flink/pull/11981
## What is the purpose of the change
This PR implements the logic behind `CREATE TABLE ... LIKE` clause. It does
not add a specific option/parameters to the `Operation` stack. The clause is
ev
[
https://issues.apache.org/jira/browse/FLINK-17002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17002:
---
Labels: pull-request-available (was: )
> Support creating tables using other tables definit
[
https://issues.apache.org/jira/browse/FLINK-17473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-17473:
-
Description: Remove unused test classes {{ArchivedExecutionBuilder}},
{{ArchivedExecutionVertexBuilder}}
[
https://issues.apache.org/jira/browse/FLINK-17473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-17473:
-
Summary: Remove unused classes ArchivedExecutionBuilder,
ArchivedExecutionVertexBuilder, and ArchivedExe
[
https://issues.apache.org/jira/browse/FLINK-17473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-17473:
-
Summary: Remove unused classes ArchivedExecutionBuilder,
ArchivedExecutionVertexBuilder and ArchivedExec
dawidwys commented on a change in pull request #11969:
URL: https://github.com/apache/flink/pull/11969#discussion_r419242981
##
File path: flink-core/src/test/java/org/apache/flink/util/StringUtilsTest.java
##
@@ -39,21 +40,26 @@ public void testControlCharacters() {
}
201 - 283 of 283 matches
Mail list logo
