[jira] [Assigned] (FLINK-13632) Update TypeSerializerUpgradeTestBase to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13632: - Assignee: vinoyang > Update TypeSerializerUpgradeTestBase to restore from 1.9 savepoint

[jira] [Assigned] (FLINK-13626) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13626: - Assignee: vinoyang > Update StatefulJobWBroadcastStateMigrationITCase.scala to restore

[jira] [Assigned] (FLINK-13631) Update FlinkKinesisConsumerMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13631: - Assignee: vinoyang > Update FlinkKinesisConsumerMigrationTest to restore from 1.9 savep

[jira] [Assigned] (FLINK-13629) Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13629: - Assignee: vinoyang > Update AbstractNonKeyedOperatorRestoreTestBase to restore from 1.9

[jira] [Assigned] (FLINK-13628) Update AbstractKeyedOperatorRestoreTestBase to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13628: - Assignee: vinoyang > Update AbstractKeyedOperatorRestoreTestBase to restore from 1.9 sa

[jira] [Assigned] (FLINK-13627) Update TypeSerializerSnapshotMigrationITCase to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13627: - Assignee: vinoyang > Update TypeSerializerSnapshotMigrationITCase to restore from 1.9 s

[jira] [Assigned] (FLINK-13625) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13625: - Assignee: vinoyang > Update StatefulJobSavepointMigrationITCase.scala to restore from 1

[jira] [Assigned] (FLINK-13622) Update WindowOperatorMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13622: - Assignee: vinoyang > Update WindowOperatorMigrationTest to restore from 1.9 savepoint >

[jira] [Assigned] (FLINK-13620) Update FlinkKafkaProducerMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13620: - Assignee: vinoyang > Update FlinkKafkaProducerMigrationTest to restore from 1.9 savepoi

[jira] [Assigned] (FLINK-13623) Update StatefulJobSavepointMigrationITCase to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13623: - Assignee: vinoyang > Update StatefulJobSavepointMigrationITCase to restore from 1.9 sav

[jira] [Assigned] (FLINK-13624) Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13624: - Assignee: vinoyang > Update StatefulJobWBroadcastStateMigrationITCase to restore from 1

[jira] [Assigned] (FLINK-13621) Update ContinuousFileProcessingMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13621: - Assignee: vinoyang > Update ContinuousFileProcessingMigrationTest to restore from 1.9 s

[jira] [Assigned] (FLINK-13618) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13618: - Assignee: vinoyang > Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 sav

[jira] [Assigned] (FLINK-13617) Update FlinkKafkaProducer011MigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13617: - Assignee: vinoyang > Update FlinkKafkaProducer011MigrationTest to restore from 1.9 save

[jira] [Assigned] (FLINK-13619) Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13619: - Assignee: vinoyang > Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.9

[jira] [Assigned] (FLINK-13616) Update BucketingSinkMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13616: - Assignee: vinoyang > Update BucketingSinkMigrationTest to restore from 1.9 savepoint >

[jira] [Assigned] (FLINK-13614) Add MigrationVersion.v1_9

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13614: - Assignee: vinoyang > Add MigrationVersion.v1_9 > - > >

[jira] [Assigned] (FLINK-13615) Update CEPMigrationTest to restore from 1.9 savepoint

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13615: - Assignee: vinoyang > Update CEPMigrationTest to restore from 1.9 savepoint > --

[GitHub] [flink] flinkbot edited a comment on issue #9401: [hotfix] Fix logger arguments in CatalogManager

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9401: [hotfix] Fix logger arguments in CatalogManager URL: https://github.com/apache/flink/pull/9401#issuecomment-519801400 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[jira] [Commented] (FLINK-13613) Update migration tests for Flink 1.9

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914325#comment-16914325 ] Till Rohrmann commented on FLINK-13613: --- Makes sense to start. I'll assign the iss

[jira] [Assigned] (FLINK-13613) Update migration tests for Flink 1.9

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13613: - Assignee: vinoyang > Update migration tests for Flink 1.9 > ---

[GitHub] [flink] StephanEwen commented on issue #9401: [hotfix] Fix logger arguments in CatalogManager

2019-08-23 Thread GitBox
StephanEwen commented on issue #9401: [hotfix] Fix logger arguments in CatalogManager URL: https://github.com/apache/flink/pull/9401#issuecomment-524346221 Thank you for fixing this! Merging... This is an automated mes

[GitHub] [flink] flinkbot edited a comment on issue #9395: [hotfix][streaming] Fix the wrong word used in the comments in class KeyedStream

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9395: [hotfix][streaming] Fix the wrong word used in the comments in class KeyedStream URL: https://github.com/apache/flink/pull/9395#issuecomment-519550324 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the com

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Commented] (FLINK-13292) NullPointerException when reading a string field in a nested struct from an Orc file.

2019-08-23 Thread Nithish (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914315#comment-16914315 ] Nithish commented on FLINK-13292: - [~alexsell] could you share a sanitized input set tha

[GitHub] [flink] StephanEwen commented on issue #9395: [hotfix][streaming] Fix the wrong word used in the comments in class KeyedStream

2019-08-23 Thread GitBox
StephanEwen commented on issue #9395: [hotfix][streaming] Fix the wrong word used in the comments in class KeyedStream URL: https://github.com/apache/flink/pull/9395#issuecomment-524345352 Thanks for spotting this. Merging... -

[jira] [Commented] (FLINK-13831) Free Slots / All Slots display error

2019-08-23 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914316#comment-16914316 ] TisonKun commented on FLINK-13831: -- Thanks for your contribution [~yuwang0...@gmail.com

[GitHub] [flink] StephanEwen commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

2019-08-23 Thread GitBox
StephanEwen commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-524345085 There is some extra Unsafe Helper logic in this PR. Could we consolidate this with the `Memor

[GitHub] [flink] flinkbot edited a comment on issue #9521: [FLINK-13831] Free Slots / All Slots display error

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9521: [FLINK-13831] Free Slots / All Slots display error URL: https://github.com/apache/flink/pull/9521#issuecomment-524270040 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Resolved] (FLINK-13831) Free Slots / All Slots display error

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13831. --- Resolution: Fixed Fixed via 1.10.0: 48e13852c70025a9f4e99a4de1350337ab33ebc7 1.9.1: 2d3179a

[jira] [Updated] (FLINK-13831) Free Slots / All Slots display error

2019-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13831: --- Labels: pull-request-available web-dashboard (was: web-dashboard) > Free Slots / All Slots

[GitHub] [flink] tillrohrmann closed pull request #9521: [FLINK-13831] Free Slots / All Slots display error

2019-08-23 Thread GitBox
tillrohrmann closed pull request #9521: [FLINK-13831] Free Slots / All Slots display error URL: https://github.com/apache/flink/pull/9521 This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] flinkbot edited a comment on issue #9521: [FLINK-13831] Free Slots / All Slots display error

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9521: [FLINK-13831] Free Slots / All Slots display error URL: https://github.com/apache/flink/pull/9521#issuecomment-524270040 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-13831) Free Slots / All Slots display error

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13831: -- Fix Version/s: 1.9.1 1.10.0 > Free Slots / All Slots display error > --

[jira] [Assigned] (FLINK-13831) Free Slots / All Slots display error

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13831: - Assignee: Yu Wang > Free Slots / All Slots display error >

[GitHub] [flink] flinkbot edited a comment on issue #9499: [FLINK-13809][python] Set more relaxed permission on "log" directory when installing Flink Python API via "sudo".

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9499: [FLINK-13809][python] Set more relaxed permission on "log" directory when installing Flink Python API via "sudo". URL: https://github.com/apache/flink/pull/9499#issuecomment-523385155 Thanks a lot for your contribution to the Apache Flink project.

[GitHub] [flink] StephanEwen edited a comment on issue #9499: [FLINK-13809][python] Set more relaxed permission on "log" directory when installing Flink Python API via "sudo".

2019-08-23 Thread GitBox
StephanEwen edited a comment on issue #9499: [FLINK-13809][python] Set more relaxed permission on "log" directory when installing Flink Python API via "sudo". URL: https://github.com/apache/flink/pull/9499#issuecomment-524341720 I think this fix would work, but I am wondering: Is that the

[GitHub] [flink] StephanEwen commented on issue #9499: [FLINK-13809][python] Set more relaxed permission on "log" directory when installing Flink Python API via "sudo".

2019-08-23 Thread GitBox
StephanEwen commented on issue #9499: [FLINK-13809][python] Set more relaxed permission on "log" directory when installing Flink Python API via "sudo". URL: https://github.com/apache/flink/pull/9499#issuecomment-524341720 I think this fix would work, but I am wondering: Is that the common w

[jira] [Updated] (FLINK-13840) Let StandaloneJobClusterEntrypoint use user code class loader

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13840: -- Summary: Let StandaloneJobClusterEntrypoint use user code class loader (was: Let JobClusterEn

[jira] [Updated] (FLINK-13840) Let JobClusterEntrypoint use user code class loader

2019-08-23 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13840: -- Summary: Let JobClusterEntrypoint use user code class loader (was: Let StandaloneJobClusterEn

[GitHub] [flink] flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring URL: https://github.com/apache/flink/pull/9507#issuecomment-523838542 ## CI report: * f95391f21b1fcad234145f13746822decc1bbe8c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[jira] [Created] (FLINK-13840) Let StandaloneJobClusterEntryPoint use user code class loader

2019-08-23 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-13840: - Summary: Let StandaloneJobClusterEntryPoint use user code class loader Key: FLINK-13840 URL: https://issues.apache.org/jira/browse/FLINK-13840 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example URL: https://github.com/apache/flink/pull/9520#issuecomment-524228220 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#issuecomment-524185771 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[GitHub] [flink] StephanEwen commented on issue #9520: [hotfix][docs] wrong method name in state-processor-api example

2019-08-23 Thread GitBox
StephanEwen commented on issue #9520: [hotfix][docs] wrong method name in state-processor-api example URL: https://github.com/apache/flink/pull/9520#issuecomment-524338008 Thank you for the fixing this! Looks good, merging... -

[GitHub] [flink] StephanEwen commented on a change in pull request #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey

2019-08-23 Thread GitBox
StephanEwen commented on a change in pull request #9517: [FLINK-13779][metrics] PrometheusPushGatewayReporter support push metrics with groupingKey URL: https://github.com/apache/flink/pull/9517#discussion_r317157818 ## File path: flink-metrics/flink-metrics-prometheus/src/test/jav

[GitHub] [flink] flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution URL: https://github.com/apache/flink/pull/9497#issuecomment-523364967 ## CI report: * b383982c0f9353b799ba85ca2635cd9b5f3e24a8 : FAILURE [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355867 ## CI report: * df58cd55f5ca284e412ebbfc35c336e4f012974c : FA

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution URL: https://github.com/apache/flink/pull/9497#issuecomment-523364967 ## CI report: * b383982c0f9353b799ba85ca2635cd9b5f3e24a8 : FAILURE [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355867 ## CI report: * df58cd55f5ca284e412ebbfc35c336e4f012974c : FA

[jira] [Updated] (FLINK-13824) Code duplication in tools/travis_watchdog.sh to launch watchdog process

2019-08-23 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13824: - Summary: Code duplication in tools/travis_watchdog.sh to launch watchdog process (was: Code duplication in tool

[jira] [Updated] (FLINK-13824) Code duplication in tools/trawis_watchdog.sh to launch watchdog process

2019-08-23 Thread Alex (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex updated FLINK-13824: - Description: {{travis_watchdog.sh}} scripts launches monitoring processes for Java processes (spawned by {{mvn

[GitHub] [flink] flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution URL: https://github.com/apache/flink/pull/9497#issuecomment-523361497 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-13833) Incorrect Maven dependencies for Flink-Hive connector

2019-08-23 Thread Qi Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914286#comment-16914286 ] Qi Kang commented on FLINK-13833: - [~Zentol] Sorry for the inconvenience, I will try to

[GitHub] [flink] flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525 ## CI report: * 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/bu

[GitHub] [flink] flinkbot edited a comment on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper.

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper. URL: https://github.com/apache/flink/pull/9522#issuecomment-524304491 ## CI report: * 299364c49caf5e7be1f3a2bd1ae57c066804f938 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[jira] [Updated] (FLINK-13836) Improve support of java.util.UUID for JDBCTypeUtil

2019-08-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-13836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] François Lacombe updated FLINK-13836: - Description: Currently, JDBCTypeUtil used by JDBCAppendTableSinkBuilder dones't support

[GitHub] [flink] flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355405 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhijiangW commented on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
zhijiangW commented on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-524313806 Thanks for the review @pnowojski ! I would rebase to merge after travis green

[GitHub] [flink] zhijiangW commented on a change in pull request #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
zhijiangW commented on a change in pull request #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#discussion_r317129016 ## File path: flink-streaming-java/src/main/java/o

[GitHub] [flink] flinkbot edited a comment on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader URL: https://github.com/apache/flink/pull/9262#issuecomment-515972928 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#issuecomment-522355405 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] zhijiangW commented on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader

2019-08-23 Thread GitBox
zhijiangW commented on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader URL: https://github.com/apache/flink/pull/9262#issuecomment-524312425 Thanks for review @pnowojski ! I would handle it later. ---

[GitHub] [flink] pnowojski commented on a change in pull request #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

2019-08-23 Thread GitBox
pnowojski commented on a change in pull request #9476: [FLINK-13764][task, metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor URL: https://github.com/apache/flink/pull/9476#discussion_r317126024 ## File path: flink-streaming-java/src/main/java/o

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/b

[GitHub] [flink] flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example URL: https://github.com/apache/flink/pull/9520#issuecomment-524232071 ## CI report: * b30983f20835f9f4aaddcdd974c9b9664f5ab142 : PENDING [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader URL: https://github.com/apache/flink/pull/9262#issuecomment-515976800 ## CI report: * bfc3f20979821e9648e5a03ef645998aa2f3587b : FAILURE [Build]

[GitHub] [flink] flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example URL: https://github.com/apache/flink/pull/9520#issuecomment-524228220 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Created] (FLINK-13839) Support to set yarn node label for flink jobmanager and taskmanager container

2019-08-23 Thread Yang Wang (Jira)
Yang Wang created FLINK-13839: - Summary: Support to set yarn node label for flink jobmanager and taskmanager container Key: FLINK-13839 URL: https://issues.apache.org/jira/browse/FLINK-13839 Project: Flin

[GitHub] [flink] flinkbot edited a comment on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9262: [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader URL: https://github.com/apache/flink/pull/9262#issuecomment-515972928 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] 1u0 commented on issue #9520: [hotfix][docs] wrong method name in state-processor-api example

2019-08-23 Thread GitBox
1u0 commented on issue #9520: [hotfix][docs] wrong method name in state-processor-api example URL: https://github.com/apache/flink/pull/9520#issuecomment-524310031 @flinkbot run travis This is an automated message from the Ap

[jira] [Created] (FLINK-13838) Support -yta(--yarnshipArchives) arguments in flink run command line

2019-08-23 Thread Yang Wang (Jira)
Yang Wang created FLINK-13838: - Summary: Support -yta(--yarnshipArchives) arguments in flink run command line Key: FLINK-13838 URL: https://issues.apache.org/jira/browse/FLINK-13838 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9520: [hotfix][docs] wrong method name in state-processor-api example URL: https://github.com/apache/flink/pull/9520#issuecomment-524228220 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Created] (FLINK-13837) Support --files and --libjars arguments in flink run command line

2019-08-23 Thread Yang Wang (Jira)
Yang Wang created FLINK-13837: - Summary: Support --files and --libjars arguments in flink run command line Key: FLINK-13837 URL: https://issues.apache.org/jira/browse/FLINK-13837 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525 ## CI report: * 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : PENDING [Build](https://travis-ci.com/flink-ci/flink/bu

[GitHub] [flink] flinkbot edited a comment on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper.

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper. URL: https://github.com/apache/flink/pull/9522#issuecomment-524304491 ## CI report: * 299364c49caf5e7be1f3a2bd1ae57c066804f938 : PENDING [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #9521: [FLINK-13831] Free Slots / All Slots display error

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9521: [FLINK-13831] Free Slots / All Slots display error URL: https://github.com/apache/flink/pull/9521#issuecomment-524273036 ## CI report: * 052af774d252f8899fb6c8f60ec51efd3a3be8a0 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/buil

[jira] [Closed] (FLINK-13762) Add the exception throwable in the interface methods of ValveOutputHandler

2019-08-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-13762. -- Fix Version/s: 1.10.0 Resolution: Fixed merged commit a30fd9a into apache:master > Add

[GitHub] [flink] flinkbot edited a comment on issue #9475: [FLINK-13762][task] Add the exception throwable in the interface methods of ValveOutputHandler

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9475: [FLINK-13762][task] Add the exception throwable in the interface methods of ValveOutputHandler URL: https://github.com/apache/flink/pull/9475#issuecomment-522352624 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] pnowojski merged pull request #9475: [FLINK-13762][task] Add the exception throwable in the interface methods of ValveOutputHandler

2019-08-23 Thread GitBox
pnowojski merged pull request #9475: [FLINK-13762][task] Add the exception throwable in the interface methods of ValveOutputHandler URL: https://github.com/apache/flink/pull/9475 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/b

[GitHub] [flink] flinkbot commented on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-08-23 Thread GitBox
flinkbot commented on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525 ## CI report: * 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : UNKNOWN --

[GitHub] [flink] flinkbot commented on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper.

2019-08-23 Thread GitBox
flinkbot commented on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper. URL: https://github.com/apache/flink/pull/9522#issuecomment-524304491 ## CI report: * 299364c49caf5e7be1f3a2bd1ae57c066804f938 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring URL: https://github.com/apache/flink/pull/9507#issuecomment-523838542 ## CI report: * f95391f21b1fcad234145f13746822decc1bbe8c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9507: [FLINK-13824][travis] Travis scripts refactoring URL: https://github.com/apache/flink/pull/9507#issuecomment-523837860 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] [flink] zentol commented on issue #9507: [FLINK-13824][travis] Travis scripts refactoring

2019-08-23 Thread GitBox
zentol commented on issue #9507: [FLINK-13824][travis] Travis scripts refactoring URL: https://github.com/apache/flink/pull/9507#issuecomment-524302724 @flinkbot run travis This is an automated message from the Apache Git Ser

[GitHub] [flink] flinkbot commented on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-08-23 Thread GitBox
flinkbot commented on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523#issuecomment-524302269 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reque

[GitHub] [flink] flinkbot commented on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper.

2019-08-23 Thread GitBox
flinkbot commented on issue #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper. URL: https://github.com/apache/flink/pull/9522#issuecomment-524301705 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/b

[jira] [Updated] (FLINK-13835) Add class for FeatureHasherMapper.

2019-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13835: --- Labels: pull-request-available (was: ) > Add class for FeatureHasherMapper. > -

[GitHub] [flink] xuyang1706 opened a new pull request #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-08-23 Thread GitBox
xuyang1706 opened a new pull request #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523 ## What is the purpose of the change FeatureHasherMapper is a transformer to project a number of categorical or numerical features

[jira] [Updated] (FLINK-13834) Add class for PolynomialExpansionMapper

2019-08-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13834: --- Labels: pull-request-available (was: ) > Add class for PolynomialExpansionMapper >

[GitHub] [flink] xuyang1706 opened a new pull request #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper.

2019-08-23 Thread GitBox
xuyang1706 opened a new pull request #9522: [FLINK-13834][ml] Add class for PolynomialExpansionMapper. URL: https://github.com/apache/flink/pull/9522 ## What is the purpose of the change Polynomial expansion is the process of expanding your features into a polynomial space,

[GitHub] [flink] flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9497: [FLINK-13794][client] Remove unused logic of printStatusDuringExecution URL: https://github.com/apache/flink/pull/9497#issuecomment-523364967 ## CI report: * b383982c0f9353b799ba85ca2635cd9b5f3e24a8 : FAILURE [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-23 Thread GitBox
flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522623760 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communit

[jira] [Created] (FLINK-13836) Improve support of java.util.UUID for JDBCTypeUtil

2019-08-23 Thread Jira
François Lacombe created FLINK-13836: Summary: Improve support of java.util.UUID for JDBCTypeUtil Key: FLINK-13836 URL: https://issues.apache.org/jira/browse/FLINK-13836 Project: Flink Is

[GitHub] [flink] JingsongLi edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

2019-08-23 Thread GitBox
JingsongLi edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-524248709 @wuchong Thanks for your review, comments addressed. Due to the large changes, rewrite 4a4c28b --

<    1   2   3   4   5   6   >