[GitHub] [flink] flinkbot commented on issue #11147: [FLINK-15717] Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot commented on issue #11147: [FLINK-15717] Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11147#issuecomment-588710322 ## CI report: * 8127feb053c5d657b8453a7ef02c65da627d037c UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #11148: [FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId

2020-02-19 Thread GitBox
flinkbot commented on issue #11148: [FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId URL: https://github.com/apache/flink/pull/11148#issuecomment-588710480 ## CI report: * 9cf340d95807d82066316548ca6e503f8fd731e8 UNKNO

[GitHub] [flink-statefun] tzulitai opened a new pull request #28: [FLINK-16159] [tests, build] Add verification integration test + integrate with Maven build

2020-02-19 Thread GitBox
tzulitai opened a new pull request #28: [FLINK-16159] [tests, build] Add verification integration test + integrate with Maven build URL: https://github.com/apache/flink-statefun/pull/28 This PR achieves the following goals: - Adds a `statefun-integration-tests` module that is meant to ma

[jira] [Updated] (FLINK-16159) Add simple end-to-end test for Stateful Functions using testcontainers

2020-02-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16159: --- Labels: pull-request-available (was: ) > Add simple end-to-end test for Stateful Functions

[GitHub] [flink] flinkbot edited a comment on issue #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11146#issuecomment-588660647 ## CI report: * 6d0d8f47466cf61ec549d85627e0349550e2433d Travis: [PENDING](ht

[GitHub] [flink] flinkbot commented on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-19 Thread GitBox
flinkbot commented on issue #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#issuecomment-588705948 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-16128) Translate "Google Cloud PubSub" page into Chinese

2020-02-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16128: --- Labels: pull-request-available (was: ) > Translate "Google Cloud PubSub" page into Chinese

[GitHub] [flink] Sxnan opened a new pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-19 Thread GitBox
Sxnan opened a new pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151 ## What is the purpose of the change This pull request translates [Google Cloud PubSub](https://ci.apache.org/projects/flink/f

[GitHub] [flink] flinkbot commented on issue #11149: [hotfix][table-api] Fixed ExpressionResolver rules modifiers

2020-02-19 Thread GitBox
flinkbot commented on issue #11149: [hotfix][table-api] Fixed ExpressionResolver rules modifiers URL: https://github.com/apache/flink/pull/11149#issuecomment-588698826 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot commented on issue #11150: [FLINK-15721] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot commented on issue #11150: [FLINK-15721] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11150#issuecomment-588698772 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] yanghua opened a new pull request #11150: [FLINK-15721] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread GitBox
yanghua opened a new pull request #11150: [FLINK-15721] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11150 ## What is the purpose of the change * This pull request updates StatefulJobWBroadcastStateM

[jira] [Updated] (FLINK-15721) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15721: --- Labels: pull-request-available (was: ) > Update StatefulJobWBroadcastStateMigrationITCase t

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381826952 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] dawidwys opened a new pull request #11149: [hotfix][table-api] Fixed ExpressionResolver rules modifiers

2020-02-19 Thread GitBox
dawidwys opened a new pull request #11149: [hotfix][table-api] Fixed ExpressionResolver rules modifiers URL: https://github.com/apache/flink/pull/11149 It is a trivial hotfix. This is an automated message from the Apache Git

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381827789 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381827385 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381826952 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] HuangZhenQiu commented on issue #10980: [FLINK-12343][flink-yarn] add yarn file replication configuration

2020-02-19 Thread GitBox
HuangZhenQiu commented on issue #10980: [FLINK-12343][flink-yarn] add yarn file replication configuration URL: https://github.com/apache/flink/pull/10980#issuecomment-588680293 @TisonKun Would you please take one more round of look? -

[jira] [Updated] (FLINK-16180) Replacing vertexExecution in ScheduledUnit with executionVertexID

2020-02-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16180: Description: {{ScheduledUnit#vertexExecution}} is nullable but {{ProgrammedSlotProvider}} requires it to

[jira] [Commented] (FLINK-16180) Replacing vertexExecution in ScheduledUnit with executionVertexID

2020-02-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040713#comment-17040713 ] Zhu Zhu commented on FLINK-16180: - cc [~gjy] [~trohrmann] > Replacing vertexExecution i

[GitHub] [flink] flinkbot commented on issue #11148: [FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId

2020-02-19 Thread GitBox
flinkbot commented on issue #11148: [FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId URL: https://github.com/apache/flink/pull/11148#issuecomment-588668558 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhuzhurk opened a new pull request #11148: [FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId

2020-02-19 Thread GitBox
zhuzhurk opened a new pull request #11148: [FLINK-16180][runtime] Replace the nullable vertexExecution in ScheduledUnit with a non-null executionVertexId URL: https://github.com/apache/flink/pull/11148 ## What is the purpose of the change ScheduledUnit#vertexExecution is nullable but

[jira] [Updated] (FLINK-16180) Replacing vertexExecution in ScheduledUnit with executionVertexID

2020-02-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16180: --- Labels: pull-request-available (was: ) > Replacing vertexExecution in ScheduledUnit with ex

[GitHub] [flink] flinkbot commented on issue #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot commented on issue #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11146#issuecomment-588660647 ## CI report: * 6d0d8f47466cf61ec549d85627e0349550e2433d UNKNOWN Bot comma

[GitHub] [flink] flinkbot commented on issue #11147: [FLINK-15717] Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot commented on issue #11147: [FLINK-15717] Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11147#issuecomment-588652456 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (FLINK-15717) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

2020-02-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15717: --- Labels: pull-request-available (was: ) > Update StatefulJobSavepointMigrationITCase.scala t

[GitHub] [flink] yanghua opened a new pull request #11147: [FLINK-15717] Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

2020-02-19 Thread GitBox
yanghua opened a new pull request #11147: [FLINK-15717] Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11147 ## What is the purpose of the change *This pull request updates StatefulJobSavepointMigratio

[jira] [Commented] (FLINK-16141) HiveTableSourceTest unstable

2020-02-19 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040690#comment-17040690 ] Rui Li commented on FLINK-16141: Hey [~sewen], yes the test is setup locally. It launche

[GitHub] [flink] flinkbot commented on issue #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot commented on issue #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11146#issuecomment-588634455 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[jira] [Updated] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15718: --- Labels: pull-request-available (was: ) > Update StatefulJobSavepointMigrationITCase to rest

[GitHub] [flink] yanghua opened a new pull request #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread GitBox
yanghua opened a new pull request #11146: [FLINK-15718] Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11146 ## What is the purpose of the change *This pull request updates StatefulJobSavepointMigrationITCas

[GitHub] [flink] flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11144#issuecomment-588270086 ## CI report: * bafa0b96be75a242a6465becc11e82a1afa1de61 Travis: [CANCELED]

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381780564 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381779124 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381779124 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381773812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381773376 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381771843 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381770789 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381770789 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] dianfu commented on a change in pull request #11118: [FLINK-16072][python] Optimize the performance of the write/read null mask

2020-02-19 Thread GitBox
dianfu commented on a change in pull request #8: [FLINK-16072][python] Optimize the performance of the write/read null mask URL: https://github.com/apache/flink/pull/8#discussion_r381725940 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@ -24,57

[GitHub] [flink] dianfu commented on a change in pull request #11118: [FLINK-16072][python] Optimize the performance of the write/read null mask

2020-02-19 Thread GitBox
dianfu commented on a change in pull request #8: [FLINK-16072][python] Optimize the performance of the write/read null mask URL: https://github.com/apache/flink/pull/8#discussion_r381766299 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@ -24,57

[GitHub] [flink] dianfu commented on a change in pull request #11118: [FLINK-16072][python] Optimize the performance of the write/read null mask

2020-02-19 Thread GitBox
dianfu commented on a change in pull request #8: [FLINK-16072][python] Optimize the performance of the write/read null mask URL: https://github.com/apache/flink/pull/8#discussion_r381768526 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@ -24,57

[GitHub] [flink] dianfu commented on a change in pull request #11118: [FLINK-16072][python] Optimize the performance of the write/read null mask

2020-02-19 Thread GitBox
dianfu commented on a change in pull request #8: [FLINK-16072][python] Optimize the performance of the write/read null mask URL: https://github.com/apache/flink/pull/8#discussion_r381769187 ## File path: flink-python/pyflink/fn_execution/coder_impl.py ## @@ -25,56

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * dbfc485ecea3aec8bc0054ca8bacb310b417c5dc Travis: [FAILURE](https://travis-ci.com/fli

[jira] [Comment Edited] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-19 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040625#comment-17040625 ] Yingjie Cao edited comment on FLINK-16142 at 2/20/20 5:11 AM:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-19 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040625#comment-17040625 ] Yingjie Cao commented on FLINK-16142: - Could you also print the contextClassLoader o

[GitHub] [flink] flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11144#issuecomment-588270086 ## CI report: * bafa0b96be75a242a6465becc11e82a1afa1de61 Travis: [CANCELED]

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381736600 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11144#issuecomment-588270086 ## CI report: * bafa0b96be75a242a6465becc11e82a1afa1de61 Travis: [CANCELED]

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * dbfc485ecea3aec8bc0054ca8bacb310b417c5dc Travis: [FAILURE](https://travis-ci.com/fli

[jira] [Commented] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

2020-02-19 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040607#comment-17040607 ] vinoyang commented on FLINK-15718: -- [~aljoscha] and [~chesnay] WDYT about {{LegacyStat

[GitHub] [flink] flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11144#issuecomment-588270086 ## CI report: * bafa0b96be75a242a6465becc11e82a1afa1de61 Travis: [PENDING](

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381714621 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * dbfc485ecea3aec8bc0054ca8bacb310b417c5dc Travis: [FAILURE](https://travis-ci.com/fli

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381704846 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink-statefun] tzulitai closed pull request #26: [FLINK-16176] Use PersistedAppendingBuffer

2020-02-19 Thread GitBox
tzulitai closed pull request #26: [FLINK-16176] Use PersistedAppendingBuffer URL: https://github.com/apache/flink-statefun/pull/26 This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381703666 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381703878 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11144#issuecomment-588270086 ## CI report: * bafa0b96be75a242a6465becc11e82a1afa1de61 Travis: [PENDING](

[jira] [Commented] (FLINK-16181) IfCallGen will throw NPE for primitive types in blink

2020-02-19 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040595#comment-17040595 ] Benchao Li commented on FLINK-16181: [~lzljs3620320] Thanks for your confirmation, I

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381696893 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[GitHub] [flink] godfreyhe commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-02-19 Thread GitBox
godfreyhe commented on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-588584960 Thanks for the suggestion @docete . Currently we can't get large result set based on `Accumulator`. so I think it'

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381696893 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo

[jira] [Commented] (FLINK-16181) IfCallGen will throw NPE for primitive types in blink

2020-02-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040593#comment-17040593 ] Jingsong Lee commented on FLINK-16181: -- Thanks [~libenchao] for reporting. You are

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

[jira] [Created] (FLINK-16181) IfCallGen will throw NPE for primitive types in blink

2020-02-19 Thread Benchao Li (Jira)
Benchao Li created FLINK-16181: -- Summary: IfCallGen will throw NPE for primitive types in blink Key: FLINK-16181 URL: https://issues.apache.org/jira/browse/FLINK-16181 Project: Flink Issue Type:

[GitHub] [flink] yanghua commented on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

2020-02-19 Thread GitBox
yanghua commented on issue #11144: [FLINK-15715] Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11144#issuecomment-588578559 @flinkbot run travis This is

[jira] [Updated] (FLINK-16180) Replacing vertexExecution in ScheduledUnit with executionVertexID

2020-02-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16180: Description: {{ScheduledUnit#vertexExecution}} is nullable but {{ProgrammedSlotProvider}} requires it to

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

2020-02-19 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040585#comment-17040585 ] godfrey he commented on FLINK-14807: Thanks for the propose, [~TsReaper]. About "Wha

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #26: [FLINK-16176] Use PersistedAppendingBuffer

2020-02-19 Thread GitBox
tzulitai commented on a change in pull request #26: [FLINK-16176] Use PersistedAppendingBuffer URL: https://github.com/apache/flink-statefun/pull/26#discussion_r381674329 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/Http

[jira] [Commented] (FLINK-16145) ScheduledUnit toString method throw NPE when Execution is null

2020-02-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040582#comment-17040582 ] Zhu Zhu commented on FLINK-16145: - Thanks for reporting this issue [~liuyufei]! This is

[jira] [Updated] (FLINK-16180) Replacing vertexExecution in ScheduledUnit with executionVertexID

2020-02-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16180: Parent: FLINK-15626 Issue Type: Sub-task (was: Improvement) > Replacing vertexExecution in Schedu

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #26: [FLINK-16176] Use PersistedAppendingBuffer

2020-02-19 Thread GitBox
tzulitai commented on a change in pull request #26: [FLINK-16176] Use PersistedAppendingBuffer URL: https://github.com/apache/flink-statefun/pull/26#discussion_r381674686 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/Http

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #26: [FLINK-16176] Use PersistedAppendingBuffer

2020-02-19 Thread GitBox
tzulitai commented on a change in pull request #26: [FLINK-16176] Use PersistedAppendingBuffer URL: https://github.com/apache/flink-statefun/pull/26#discussion_r381674329 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/Http

[jira] [Created] (FLINK-16180) Replacing vertexExecution in ScheduledUnit with executionVertexID

2020-02-19 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-16180: --- Summary: Replacing vertexExecution in ScheduledUnit with executionVertexID Key: FLINK-16180 URL: https://issues.apache.org/jira/browse/FLINK-16180 Project: Flink Issu

[GitHub] [flink] danny0405 commented on a change in pull request #11116: [FLINK-15349] add 'create catalog' DDL to blink planner

2020-02-19 Thread GitBox
danny0405 commented on a change in pull request #6: [FLINK-15349] add 'create catalog' DDL to blink planner URL: https://github.com/apache/flink/pull/6#discussion_r381670264 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserI

[jira] [Created] (FLINK-16179) Use configuration from TableFactory in hive connector

2020-02-19 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16179: Summary: Use configuration from TableFactory in hive connector Key: FLINK-16179 URL: https://issues.apache.org/jira/browse/FLINK-16179 Project: Flink Issue T

[GitHub] [flink] lirui-apache commented on a change in pull request #11116: [FLINK-15349] add 'create catalog' DDL to blink planner

2020-02-19 Thread GitBox
lirui-apache commented on a change in pull request #6: [FLINK-15349] add 'create catalog' DDL to blink planner URL: https://github.com/apache/flink/pull/6#discussion_r381654413 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ##

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis: [FAILURE](https://t

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381636671 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] flinkbot edited a comment on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files URL: https://github.com/apache/flink/pull/7702#issuecomment-572195960 ## CI report: * 72dd07f5f10a56adf6025e82083af21ada47c711 Travis: [SUCCESS](https://trav

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381636153 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381636064 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] KarmaGYZ commented on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh…

2020-02-19 Thread GitBox
KarmaGYZ commented on issue #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh… URL: https://github.com/apache/flink/pull/11100#issuecomment-588556496 Thanks for the review and information @zentol . If it is against ASF rules. I agree to not give that advic

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381633592 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381632755 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381624866 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381624725 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381624091 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381623946 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381623946 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-19 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r381623313 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/netw

[jira] [Commented] (FLINK-16005) Propagate yarn.application.classpath from client to TaskManager Classpath

2020-02-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040528#comment-17040528 ] Zhenqiu Huang commented on FLINK-16005: --- [~trohrmann] I feel specifying the yarn c

[GitHub] [flink] flinkbot edited a comment on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files URL: https://github.com/apache/flink/pull/7702#issuecomment-572195960 ## CI report: * 72dd07f5f10a56adf6025e82083af21ada47c711 Travis: [SUCCESS](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files URL: https://github.com/apache/flink/pull/7702#issuecomment-572195960 ## CI report: * 72dd07f5f10a56adf6025e82083af21ada47c711 Travis: [SUCCESS](https://trav

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 Travis: [FAILURE](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 Travis: [FAILURE](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2020-02-19 Thread GitBox
flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 Travis: [FAILURE](https://travis

  1   2   3   4   5   >