[GitHub] [flink] flinkbot edited a comment on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

flinkbot edited a comment on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-552508742 ## CI report: * 7692a79b3c58f68ed1296c7a6f192528ef360a0f : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code

flinkbot edited a comment on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#issuecomment-559477264 ## CI report: * 0d3f9f0ad554418153570b7fd9cd9299d1958c5b : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[jira] [Updated] (FLINK-13634) Add Hadoop compression format for use with StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13634: - Summary: Add Hadoop compression format for use with StreamingFileSink (was:

[GitHub] [flink] rmetzger commented on issue #8444: [FLINK-10190] [Kinesis Connector] Allow AWS_REGION to be supplied along with custom Kinesis endpoint

rmetzger commented on issue #8444: [FLINK-10190] [Kinesis Connector] Allow AWS_REGION to be supplied along with custom Kinesis endpoint URL: https://github.com/apache/flink/pull/8444#issuecomment-559480279 Thanks. The change looks good from my point of view. I will wait for a final

[GitHub] [flink] flinkbot edited a comment on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

flinkbot edited a comment on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-552508742 ## CI report: * 7692a79b3c58f68ed1296c7a6f192528ef360a0f : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code

flinkbot commented on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#issuecomment-559477264 ## CI report: * 0d3f9f0ad554418153570b7fd9cd9299d1958c5b : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559445838 ## CI report: * 9d133e6ba91f6d688401f493cc39729b4b34feb6 : CANCELED

[GitHub] [flink] docete commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

docete commented on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-559476136 rebased master to resolve conflicts

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351750185 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351749833 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351749421 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351746791 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE

[jira] [Reopened] (FLINK-14955) Not able to write to swift via StreamingFileSink.forBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simya Jose reopened FLINK-14955: Please feel free to close if there is a plan to relax the condition on file schema check as well >

[GitHub] [flink] flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559445838 ## CI report: * 9d133e6ba91f6d688401f493cc39729b4b34feb6 : CANCELED

[GitHub] [flink] dmvk commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

dmvk commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-559465468 You're right that the disposal exception handling is reversed `ChainedReduceCombineDriver`. Fixed, thanks!

[GitHub] [flink] flinkbot commented on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code

flinkbot commented on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#issuecomment-559465102 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-14516) Remove non credit based network code

[ https://issues.apache.org/jira/browse/FLINK-14516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14516: --- Labels: pull-request-available (was: ) > Remove non credit based network code >

[GitHub] [flink] pnowojski opened a new pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code

pnowojski opened a new pull request #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347 This PR removes non credit-based flow control code ## Verifying this change *(Please pick either of the following

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351738365 ## File path:

[jira] [Updated] (FLINK-14985) FLNIK YARN per job with ehcache Exception

[ https://issues.apache.org/jira/browse/FLINK-14985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14985: --- Description: I used ehcache in my project,I get the following exception when using per job mode：

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351737446 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351714937 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351736589 ## File path:

[jira] [Created] (FLINK-14985) FLNIK YARN per job with ehcache Exception

Rockey Cui created FLINK-14985: -- Summary: FLNIK YARN per job with ehcache Exception Key: FLINK-14985 URL: https://issues.apache.org/jira/browse/FLINK-14985 Project: Flink Issue Type: Bug

[GitHub] [flink] eskabetxe commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

eskabetxe commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-559461704 @aljoscha updated the PR with the changes we talk

[GitHub] [flink] flinkbot edited a comment on issue #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions

flinkbot edited a comment on issue #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10086#issuecomment-549735265 ## CI report: * 27464531f28c38944b85020bd6adee9cedaf42d8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

flinkbot edited a comment on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559445838 ## CI report: * 9d133e6ba91f6d688401f493cc39729b4b34feb6 : PENDING

[jira] [Commented] (FLINK-14955) Not able to write to swift via StreamingFileSink.forBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984339#comment-16984339 ] Simya Jose commented on FLINK-14955:  FLINK-14170 is related to hadoop version. My issue is with the

[jira] [Commented] (FLINK-14968) Kerberized YARN on Docker test (custom fs plugin) fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984335#comment-16984335 ] Aljoscha Krettek commented on FLINK-14968: -- It's very strange, I'm running this on my machine

[jira] [Updated] (FLINK-14927) Remove LegacyTimestampTypeInfo and LegacyLocalDateTimeTypeInfo when the conversion is not needed

[ https://issues.apache.org/jira/browse/FLINK-14927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-14927: - Description: 1) PhysicalTableSourceScan.getSourceTransformation use 

[GitHub] [flink] kl0u commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

kl0u commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559450678 @aljoscha I integrated your comments. This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions

flinkbot edited a comment on issue #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10086#issuecomment-549735265 ## CI report: * 27464531f28c38944b85020bd6adee9cedaf42d8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] kl0u commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

kl0u commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#discussion_r351718421 ## File path: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java ##

[GitHub] [flink] aljoscha commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

aljoscha commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#discussion_r351714358 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

aljoscha commented on a change in pull request #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#discussion_r351715242 ## File path: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java

[GitHub] [flink] flinkbot commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors.

flinkbot commented on issue #10346: [FLINK-14972] Make Remote(Stream)Environment use Executors. URL: https://github.com/apache/flink/pull/10346#issuecomment-559445838 ## CI report: * 9d133e6ba91f6d688401f493cc39729b4b34feb6 : UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351714937 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351712514 ## File path:

[GitHub] [flink] kl0u commented on issue #10346: Remote env

kl0u commented on issue #10346: Remote env URL: https://github.com/apache/flink/pull/10346#issuecomment-559441508 @tweise this PR removes some unused methods from the `RemoteStreamEnvironment` that were introduced in the context of

[GitHub] [flink] flinkbot commented on issue #10346: Remote env

flinkbot commented on issue #10346: Remote env URL: https://github.com/apache/flink/pull/10346#issuecomment-559441124 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

[GitHub] [flink] aljoscha commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

aljoscha commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559440391 @klion26 It's a bit harder to find but there is this:

[GitHub] [flink] kl0u opened a new pull request #10346: Remote env

kl0u opened a new pull request #10346: Remote env URL: https://github.com/apache/flink/pull/10346 ## What is the purpose of the change This PR makes the `RemoteEnvironment` (batch) and the `RemoteStreamEnvironment` use the newly introduced `Executors`. ## Verifying this

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351701206 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351698119 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351699757 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351700970 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351703565 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351702892 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351698785 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351702127 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351701625 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

AHeise commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351705345 ## File path:

[jira] [Closed] (FLINK-14969) Refactor CliFrontendRunWithYarnTest reflect to new execution codepath

[ https://issues.apache.org/jira/browse/FLINK-14969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-14969. -- Fix Version/s: 1.10.0 Resolution: Fixed Merged with 

[GitHub] [flink] kl0u merged pull request #10331: [FLINK-14969][tests] Refactor CliFrontendRunWithYarnTest reflect to new execution codepath

kl0u merged pull request #10331: [FLINK-14969][tests] Refactor CliFrontendRunWithYarnTest reflect to new execution codepath URL: https://github.com/apache/flink/pull/10331 This is an automated message from the Apache Git

[GitHub] [flink] rkhachatryan commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

rkhachatryan commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351704472 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions

flinkbot edited a comment on issue #10086: [FLINK-14584][python] Support complex data types in Python user-defined functions URL: https://github.com/apache/flink/pull/10086#issuecomment-549735265 ## CI report: * 27464531f28c38944b85020bd6adee9cedaf42d8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[jira] [Commented] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984305#comment-16984305 ] John Lonergan commented on FLINK-14170: --- Will do > Support hadoop < 2.7 with

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE

[GitHub] [flink] AHeise commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

AHeise commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351694683 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

AHeise commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351694957 ## File path: flink-core/src/main/java/org/apache/flink/util/function/FunctionUtils.java

[GitHub] [flink] AHeise commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

AHeise commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351693326 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

AHeise commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351693696 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351690850 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java

[jira] [Commented] (FLINK-14955) Not able to write to swift via StreamingFileSink.forBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984291#comment-16984291 ] Kostas Kloudas commented on FLINK-14955: This is related to 

[GitHub] [flink] WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-559427101 @dianfu Thanks for your review! I have addressed your comments in the

[GitHub] [flink] aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351685865 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java

[GitHub] [flink] aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351686887 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java

[GitHub] [flink] aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

aljoscha commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351685568 ## File path: flink-core/src/main/java/org/apache/flink/api/common/JobStatus.java ## @@ -0,0 +1,77 @@

[jira] [Commented] (FLINK-8949) Rest API failure with long URL

[ https://issues.apache.org/jira/browse/FLINK-8949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984281#comment-16984281 ] lining commented on FLINK-8949: --- This solution could solve the problem of watermarks. However, if users

[GitHub] [flink] kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351680463 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java

[GitHub] [flink] kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351669357 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/AbstractJobClusterExecutor.java

[GitHub] [flink] kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351668932 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/AbstractJobClusterExecutor.java

[GitHub] [flink] kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351674172 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java

[GitHub] [flink] kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API

kl0u commented on a change in pull request #10311: [FLINK-14762][client] Enrich JobClient API URL: https://github.com/apache/flink/pull/10311#discussion_r351679227 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobStatus.java ## @@ -97,6

[GitHub] [flink] flinkbot commented on issue #10345: Flink 12484 synchronize all mailbox actions

flinkbot commented on issue #10345: Flink 12484 synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] mchro commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

mchro commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#discussion_r351679763 ## File path:

[GitHub] [flink] aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-559420365 By the way, I'm on the ASF slack workspace: https://s.apache.org/slack-invite. You can ping me there so that we can resolve reviews quicker.

[GitHub] [flink] aljoscha commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

aljoscha commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-559418757 @lukess So what's the outcome for this PR, should we close it and the Jira issue?

[GitHub] [flink] aljoscha commented on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

aljoscha commented on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398#issuecomment-559418196 I'm closing this for now, please re-open if you want to pick it up again.

[GitHub] [flink] aljoscha closed pull request #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

aljoscha closed pull request #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398 This is an automated message from the Apache

[GitHub] [flink] aljoscha commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

aljoscha commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-559418445 @Rishi55 Any updates on this?

[GitHub] [flink] aljoscha commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

aljoscha commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-559417975 By the way, I'm on the ASF slack workspace: https://s.apache.org/slack-invite. You can ping me there so that we

[jira] [Commented] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984274#comment-16984274 ] Aljoscha Krettek commented on FLINK-14170: -- This was mentioned again (FLINK-14955) so I think

[jira] [Closed] (FLINK-14955) Not able to write to swift via StreamingFileSink.forBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14955. Resolution: Duplicate > Not able to write to swift via StreamingFileSink.forBulkFormat >

[jira] [Commented] (FLINK-14955) Not able to write to swift via StreamingFileSink.forBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984272#comment-16984272 ] Aljoscha Krettek commented on FLINK-14955: -- This is essentially a duplicate of FLINK-14170, I'd

[GitHub] [flink] flinkbot commented on issue #10345: Flink 12484 synchronize all mailbox actions

flinkbot commented on issue #10345: Flink 12484 synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559416107 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

[jira] [Updated] (FLINK-14955) Not able to write to swift via StreamingFileSink.forBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-14955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14955: - Component/s: Connectors / FileSystem > Not able to write to swift via

[jira] [Closed] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11301. Resolution: Fixed > Travis failed: No output has been received in the last 10m0s >

[GitHub] [flink] rkhachatryan opened a new pull request #10345: Flink 12484 synchronize all mailbox actions

rkhachatryan opened a new pull request #10345: Flink 12484 synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345 ## What is the purpose of the change * Synchronize all mailbox actions, so there is no need to acquire checkpoint lock in any code that is

[jira] [Closed] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml

[ https://issues.apache.org/jira/browse/FLINK-10836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10836. Resolution: Won't Fix Following the conclusion surrounding flink-shaded that additional

[jira] [Closed] (FLINK-10824) Compile Flink unit test failed with 1.6.0 branch

[ https://issues.apache.org/jira/browse/FLINK-10824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10824. Resolution: Cannot Reproduce > Compile Flink unit test failed with 1.6.0 branch >

<    1   2   3   4   5   >