[jira] [Updated] (FLINK-13502) CatalogTableStatisticsConverter & TreeNode should be in correct package

[ https://issues.apache.org/jira/browse/FLINK-13502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-13502: --- Description: currently, {{CatalogTableStatisticsConverter}} is in {{org.apache.flink.table.util}}, i

[jira] [Updated] (FLINK-13502) CatalogTableStatisticsConverter & TreeNode should be in correct package

[ https://issues.apache.org/jira/browse/FLINK-13502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-13502: --- Summary: CatalogTableStatisticsConverter & TreeNode should be in correct package (was: CatalogTable

[jira] [Created] (FLINK-13502) CatalogTableStatisticsConverter should be in planner.utils package

godfrey he created FLINK-13502: -- Summary: CatalogTableStatisticsConverter should be in planner.utils package Key: FLINK-13502 URL: https://issues.apache.org/jira/browse/FLINK-13502 Project: Flink

[GitHub] [flink] TsReaper commented on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

TsReaper commented on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#issuecomment-516658071 Travis passed: https://travis-ci.com/TsReaper/flink/builds/121249787 --

[GitHub] [flink] flinkbot commented on issue #9283: [FLINK-13487][tests] Fix unstable partition lifecycle tests by ensuring TM has registered to JM before submitting task

flinkbot commented on issue #9283: [FLINK-13487][tests] Fix unstable partition lifecycle tests by ensuring TM has registered to JM before submitting task URL: https://github.com/apache/flink/pull/9283#issuecomment-516656866 ## CI report: * afd7ba4663e2298776c0e02a4fe56cc1d3cf63a3 : P

[GitHub] [flink] flinkbot commented on issue #9283: [FLINK-13487][tests] Fix unstable partition lifecycle tests by ensuring TM has registered to JM before submitting task

flinkbot commented on issue #9283: [FLINK-13487][tests] Fix unstable partition lifecycle tests by ensuring TM has registered to JM before submitting task URL: https://github.com/apache/flink/pull/9283#issuecomment-516655514 Thanks a lot for your contribution to the Apache Flink project. I'm

[jira] [Updated] (FLINK-13487) TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13487: --- Labels: pull-request-available (was: ) > TaskExecutorPartitionLifecycleTest.testPartitionRe

[GitHub] [flink] gaoyunhaii opened a new pull request #9283: [FLINK-13487][tests] Fix unstable partition lifecycle tests by ensuring TM has registered to JM before submitting task

gaoyunhaii opened a new pull request #9283: [FLINK-13487][tests] Fix unstable partition lifecycle tests by ensuring TM has registered to JM before submitting task URL: https://github.com/apache/flink/pull/9283 ## What is the purpose of the change This pull request targets at

[jira] [Updated] (FLINK-13501) Fixes a few issues in documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-13501: Attachment: Screen Shot 2019-07-30 at 3.25.13 PM.png Screen Shot 2019-07-30 at 3.21

[jira] [Commented] (FLINK-13501) Fixes a few issues in documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896589#comment-16896589 ] Xuefu Zhang commented on FLINK-13501: - cc: [~tiwalter], [~Terry1897] > Fixes a few

[jira] [Created] (FLINK-13501) Fixes a few issues in documentation for Hive integration

Xuefu Zhang created FLINK-13501: --- Summary: Fixes a few issues in documentation for Hive integration Key: FLINK-13501 URL: https://issues.apache.org/jira/browse/FLINK-13501 Project: Flink Issue

[GitHub] [flink] xintongsong closed pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

xintongsong closed pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105 This is an automat

[GitHub] [flink] xintongsong commented on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

xintongsong commented on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#issuecomment-516602332 close in 86491b6b4ccc8c9ef5fa15e4755e2e5c252c29ad

[GitHub] [flink] flinkbot edited a comment on issue #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client

flinkbot edited a comment on issue #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client URL: https://github.com/apache/flink/pull/9266#issuecomment-516047670 ## CI report: * ac53ced5cd134af11f453f00fc3aaaea611654f7 : FAILURE [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.com/fli

[jira] [Commented] (FLINK-13472) taskmanager.jvm-exit-on-oom doesn't work reliably with YARN

[ https://issues.apache.org/jira/browse/FLINK-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896510#comment-16896510 ] Ken Krugler commented on FLINK-13472: - Hi [~pawelbartoszek] - In my experience, when

[GitHub] [flink] flinkbot edited a comment on issue #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository

flinkbot edited a comment on issue #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository URL: https://github.com/apache/flink/pull/9282#issuecomment-516489105 ## CI report: * d48067bb1882c3515cfbcd6c0b2d502ebd22dbd3 : FAILURE [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support decimal precision to table source

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support decimal precision to table source URL: https://github.com/apache/flink/pull/9274#issuecomment-516352701 ## CI report: * 6e259d68552bf14b3c0f593706d2c879d32b294e : FAILURE [Build

[GitHub] [flink] flinkbot edited a comment on issue #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

flinkbot edited a comment on issue #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224#issuecomment-514889442 ## CI report: * 78b445e8a5fb88c8c7f7080f1e6d9fdf89a5a594 : FAILURE [Build](htt

[GitHub] [flink] flinkbot edited a comment on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver

flinkbot edited a comment on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver URL: https://github.com/apache/flink/pull/9281#issuecomment-516443976 ## CI report: * d1d56e2c854c5d1324877e14edd4fb887278e090 : SUCCESS [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job

flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job URL: https://github.com/apache/flink/pull/9277#issuecomment-516388088 ## CI report: * 7bebdd65247ac172a23f9b0a91873b01b554cd71 : FAILURE [Build](https://travis-ci.com/fl

[jira] [Commented] (FLINK-13499) Remove dependency on MapR artifact repository

[ https://issues.apache.org/jira/browse/FLINK-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896395#comment-16896395 ] Till Rohrmann commented on FLINK-13499: --- Please move the issue to "In Progress" [~

[jira] [Commented] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896392#comment-16896392 ] Till Rohrmann commented on FLINK-13446: --- If this issue is not a blocker, then plea

[jira] [Commented] (FLINK-13497) Checkpoints can complete after CheckpointFailureManager fails job

[ https://issues.apache.org/jira/browse/FLINK-13497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896390#comment-16896390 ] Yun Tang commented on FLINK-13497: -- One quick fix to this problem is to let {{Checkpoin

[GitHub] [flink] tillrohrmann closed pull request #9242: [FLINK-13408][runtime] Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired

tillrohrmann closed pull request #9242: [FLINK-13408][runtime] Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired URL: https://github.com/apache/flink/pull/9242 This is an aut

[jira] [Resolved] (FLINK-13242) StandaloneResourceManagerTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13242. --- Resolution: Fixed Fix Version/s: (was: 1.10.0) (was: 1.9.0)

[jira] [Resolved] (FLINK-13408) Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired

[ https://issues.apache.org/jira/browse/FLINK-13408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13408. --- Resolution: Fixed Fix Version/s: (was: 1.10.0) Fixed via 1.10.0: 0f9d0952cd89a98

[GitHub] [flink] tillrohrmann commented on issue #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase

tillrohrmann commented on issue #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9269#issuecomment-516536280 I think it is definitely good enough as a bandaid because we see the test failing quite often. Maybe we merge it as

[GitHub] [flink] xuefuz commented on a change in pull request #9264: [FLINK-13192][hive] Add tests for different Hive table formats

xuefuz commented on a change in pull request #9264: [FLINK-13192][hive] Add tests for different Hive table formats URL: https://github.com/apache/flink/pull/9264#discussion_r308872595 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/h

[jira] [Commented] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896376#comment-16896376 ] Till Rohrmann commented on FLINK-9900: -- Another instance: https://api.travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese

flinkbot edited a comment on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9280#issuecomment-516431274 ## CI report: * 3c6dadbc58f9f1d0f44efbc63ae5e6444dfb : SUCCESS [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] xuefuz commented on a change in pull request #9264: [FLINK-13192][hive] Add tests for different Hive table formats

xuefuz commented on a change in pull request #9264: [FLINK-13192][hive] Add tests for different Hive table formats URL: https://github.com/apache/flink/pull/9264#discussion_r308867419 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/batch/connector

[jira] [Commented] (FLINK-13452) Pipelined region failover strategy does not recover Job if checkpoint cannot be read

[ https://issues.apache.org/jira/browse/FLINK-13452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896372#comment-16896372 ] Yun Tang commented on FLINK-13452: -- Before FLINK-13060, the process to restart tasks wi

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

flinkbot edited a comment on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#issuecomment-515390325 ## CI report: * 1135cc72f00606c7a230714838c938068887ce23 :

[GitHub] [flink] flinkbot edited a comment on issue #9242: [FLINK-13408][runtime] Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired

flinkbot edited a comment on issue #9242: [FLINK-13408][runtime] Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired URL: https://github.com/apache/flink/pull/9242#issuecomment-515479114 ## CI report: * bc4bc3a00e1692381368af36b87d23367

[jira] [Comment Edited] (FLINK-13487) TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896346#comment-16896346 ] Yun Gao edited comment on FLINK-13487 at 7/30/19 5:26 PM: -- Very

[jira] [Commented] (FLINK-13487) TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896346#comment-16896346 ] Yun Gao commented on FLINK-13487: - Very thanks [~SleePy] and [~zjwang] for the help at t

[GitHub] [flink] flinkbot edited a comment on issue #9278: [FLINK-13488][Python] remove python 3.3/3.4 support

flinkbot edited a comment on issue #9278: [FLINK-13488][Python] remove python 3.3/3.4 support URL: https://github.com/apache/flink/pull/9278#issuecomment-516392430 ## CI report: * 6629e045eead82db608617dd46b81718d84fb031 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[jira] [Created] (FLINK-13500) RestClusterClient requires S3 access when HA is configured

David Judd created FLINK-13500: -- Summary: RestClusterClient requires S3 access when HA is configured Key: FLINK-13500 URL: https://issues.apache.org/jira/browse/FLINK-13500 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on issue #9279: [FLINK-13423][hive] Unable to find function in hive 1

flinkbot edited a comment on issue #9279: [FLINK-13423][hive] Unable to find function in hive 1 URL: https://github.com/apache/flink/pull/9279#issuecomment-516401194 ## CI report: * ce30c4da05c4c788bbeb86a812e26f6d89ca35a2 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/build

[GitHub] [flink] xuefuz commented on a change in pull request #9279: [FLINK-13423][hive] Unable to find function in hive 1

xuefuz commented on a change in pull request #9279: [FLINK-13423][hive] Unable to find function in hive 1 URL: https://github.com/apache/flink/pull/9279#discussion_r308827372 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/clien

[GitHub] [flink] flinkbot edited a comment on issue #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client

flinkbot edited a comment on issue #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client URL: https://github.com/apache/flink/pull/9266#issuecomment-516047670 ## CI report: * ac53ced5cd134af11f453f00fc3aaaea611654f7 : FAILURE [Build](https://travis-ci.com/flink-ci

[GitHub] [flink] twalthr commented on issue #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client

twalthr commented on issue #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client URL: https://github.com/apache/flink/pull/9266#issuecomment-516496213 Thanks for the feedback @dawidwys and @docete. I updated the PR. It was also possible to make the SQL Client work withou

[GitHub] [flink] flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job

flinkbot edited a comment on issue #9277: [FLINK-13494][table-planner-blink] Only use env parallelism for sql job URL: https://github.com/apache/flink/pull/9277#issuecomment-516388088 ## CI report: * 7bebdd65247ac172a23f9b0a91873b01b554cd71 : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9278: [FLINK-13488][Python] remove python 3.3/3.4 support

flinkbot edited a comment on issue #9278: [FLINK-13488][Python] remove python 3.3/3.4 support URL: https://github.com/apache/flink/pull/9278#issuecomment-516392430 ## CI report: * 6629e045eead82db608617dd46b81718d84fb031 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot commented on issue #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository

flinkbot commented on issue #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository URL: https://github.com/apache/flink/pull/9282#issuecomment-516489105 ## CI report: * d48067bb1882c3515cfbcd6c0b2d502ebd22dbd3 : PENDING [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.com/fli

[jira] [Closed] (FLINK-13466) Rename Batch/StreamTableSourceFactory methods for avoiding name clashes

[ https://issues.apache.org/jira/browse/FLINK-13466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13466. Resolution: Won't Fix It seems that the clashes are acceptable given that both context are equival

[GitHub] [flink] flinkbot commented on issue #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository

flinkbot commented on issue #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository URL: https://github.com/apache/flink/pull/9282#issuecomment-516487122 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] twalthr closed pull request #9263: [FLINK-13466][table-common] Uncouple batch factories from new source/sink stack

twalthr closed pull request #9263: [FLINK-13466][table-common] Uncouple batch factories from new source/sink stack URL: https://github.com/apache/flink/pull/9263 This is an automated message from the Apache Git Service. To r

[GitHub] [flink] twalthr commented on issue #9263: [FLINK-13466][table-common] Uncouple batch factories from new source/sink stack

twalthr commented on issue #9263: [FLINK-13466][table-common] Uncouple batch factories from new source/sink stack URL: https://github.com/apache/flink/pull/9263#issuecomment-516486093 This PR does not meet the requirements of unified table sources and would require special cases at a coupl

[jira] [Updated] (FLINK-13499) Remove dependency on MapR artifact repository

[ https://issues.apache.org/jira/browse/FLINK-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13499: --- Labels: pull-request-available (was: ) > Remove dependency on MapR artifact repository > --

[GitHub] [flink] StephanEwen opened a new pull request #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository

StephanEwen opened a new pull request #9282: [FLINK-13499][maprfs] Remove dependency on MapR artifact repository URL: https://github.com/apache/flink/pull/9282 ## What is the purpose of the change This change removes the MapR FS connector to work based on reflection and avoid a hard

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE [Build](https://travis-ci.com/fli

[GitHub] [flink] ifndef-SleePy commented on issue #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase

ifndef-SleePy commented on issue #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9269#issuecomment-516479435 Hi @tillrohrmann , thanks for reviewing. Actually I implemented the solution at first as same as your suggest

[GitHub] [flink] GJL commented on a change in pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

GJL commented on a change in pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r308800773 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/AbstractInv

[GitHub] [flink] GJL commented on a change in pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

GJL commented on a change in pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r308800730 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/AbstractInv

[GitHub] [flink] GJL commented on a change in pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

GJL commented on a change in pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r308800470 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java

[GitHub] [flink] flinkbot edited a comment on issue #9276: [FLINK-13439] Run Streaming SQL e2e test with blink planner

flinkbot edited a comment on issue #9276: [FLINK-13439] Run Streaming SQL e2e test with blink planner URL: https://github.com/apache/flink/pull/9276#issuecomment-516382130 ## CI report: * 60432f857803273b0e8779f0948b318e764d86f0 : FAILURE [Build](https://travis-ci.com/flink-ci/flink

[jira] [Updated] (FLINK-13499) Remove dependency on MapR artifact repository

[ https://issues.apache.org/jira/browse/FLINK-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13499: - Issue Type: Bug (was: Improvement) > Remove dependency on MapR artifact repository > --

[GitHub] [flink] flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT cas

flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-516364194 ## CI report: * 821ab87a6c7e

[jira] [Created] (FLINK-13499) Remove dependency on MapR artifact repository

Stephan Ewen created FLINK-13499: Summary: Remove dependency on MapR artifact repository Key: FLINK-13499 URL: https://issues.apache.org/jira/browse/FLINK-13499 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-13475) Reduce dependency on third-party maven repositories

[ https://issues.apache.org/jira/browse/FLINK-13475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896226#comment-16896226 ] Stephan Ewen commented on FLINK-13475: -- Hadoop dependencies are generally super mes

[GitHub] [flink] flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support decimal precision to table source

flinkbot edited a comment on issue #9274: [FLINK-13495][table-planner-blink] blink-planner should support decimal precision to table source URL: https://github.com/apache/flink/pull/9274#issuecomment-516352701 ## CI report: * 6e259d68552bf14b3c0f593706d2c879d32b294e : FAILURE [Build

[jira] [Commented] (FLINK-12164) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable

[ https://issues.apache.org/jira/browse/FLINK-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896216#comment-16896216 ] Biao Liu commented on FLINK-12164: -- It seems that the PR does not be linked here someho

[GitHub] [flink] ifndef-SleePy commented on issue #9253: [Flink-12164][tests] Harden JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout

ifndef-SleePy commented on issue #9253: [Flink-12164][tests] Harden JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout URL: https://github.com/apache/flink/pull/9253#issuecomment-516461833 Bad luck. Travis building fails due to another unstable case, see https://issues.apache.org

[jira] [Closed] (FLINK-13399) Create two separate uber jars for each planner

[ https://issues.apache.org/jira/browse/FLINK-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13399. Resolution: Fixed [FLINK-13399][legal] Update NOTICE-binary for new table uber jars Fixed in 1.10.

[jira] [Updated] (FLINK-13487) TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-13487: Attachment: error_log.png > TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall > fai

[GitHub] [flink] twalthr commented on a change in pull request #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client

twalthr commented on a change in pull request #9266: [FLINK-13273][sql-client] Allow switching planners in SQL Client URL: https://github.com/apache/flink/pull/9266#discussion_r308770560 ## File path: flink-end-to-end-tests/run-nightly-tests.sh ## @@ -143,7 +143,8 @@ run_

[jira] [Created] (FLINK-13498) Reduce Kafka producer startup time by aborting transactions in parallel

Nico Kruber created FLINK-13498: --- Summary: Reduce Kafka producer startup time by aborting transactions in parallel Key: FLINK-13498 URL: https://issues.apache.org/jira/browse/FLINK-13498 Project: Flink

[GitHub] [flink] kl0u commented on issue #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

kl0u commented on issue #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#issuecomment-516452053 OK I will merge. This is an automated mess

[GitHub] [flink] hequn8128 commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver

hequn8128 commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver URL: https://github.com/apache/flink/pull/9281#issuecomment-516450735 @sunjincheng121 Thanks a lot for improving the class name. I agree with you. LGTM and +1 to merge.

[GitHub] [flink] flinkbot edited a comment on issue #9050: [FLINK-13181][Table]Add Builder to build CsvTableSink instances

flinkbot edited a comment on issue #9050: [FLINK-13181][Table]Add Builder to build CsvTableSink instances URL: https://github.com/apache/flink/pull/9050#issuecomment-516422309 ## CI report: * 96ff341529c250d6eb8d002c36eed57101b72e92 : FAILURE [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] asfgit closed pull request #9261: [FLINK-13399][table] Create two separate table uber jars for old and blink planners

asfgit closed pull request #9261: [FLINK-13399][table] Create two separate table uber jars for old and blink planners URL: https://github.com/apache/flink/pull/9261 This is an automated message from the Apache Git Service.

[GitHub] [flink] YngwieWang closed pull request #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese

YngwieWang closed pull request #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9280 This is an automated message from the Apache Git Service. To respond to the me

[GitHub] [flink] YngwieWang commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese

YngwieWang commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9280#issuecomment-516447837 Thank you very much. This is an automated message from th

[jira] [Updated] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13488: - Fix Version/s: (was: 1.10.0) > flink-python fails to build on Travis due to Packages

[jira] [Updated] (FLINK-13497) Checkpoints can complete after CheckpointFailureManager fails job

[ https://issues.apache.org/jira/browse/FLINK-13497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13497: -- Fix Version/s: 1.9.0 > Checkpoints can complete after CheckpointFailureManager fails job > ---

[GitHub] [flink] flinkbot edited a comment on issue #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

flinkbot edited a comment on issue #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224#issuecomment-514889442 ## CI report: * 78b445e8a5fb88c8c7f7080f1e6d9fdf89a5a594 : FAILURE [Build](htt

[GitHub] [flink] klion26 commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese

klion26 commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9280#issuecomment-516447015 You can make a clean history and force push to this branch. If this is not easy, then close and create a new pr is fine. -

[jira] [Created] (FLINK-13497) Checkpoints can complete after CheckpointFailureManager fails job

Till Rohrmann created FLINK-13497: - Summary: Checkpoints can complete after CheckpointFailureManager fails job Key: FLINK-13497 URL: https://issues.apache.org/jira/browse/FLINK-13497 Project: Flink

[jira] [Commented] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896182#comment-16896182 ] Till Rohrmann commented on FLINK-9900: -- I think this test instability actually point

[GitHub] [flink] zhijiangW commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#issuecomment-516446006 @azagrebin I have finished the whole review and left some nit comments besides t

[GitHub] [flink] YngwieWang commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese

YngwieWang commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9280#issuecomment-516445776 Sorry, should I close this pr and open a new one? This is

[GitHub] [flink] tillrohrmann commented on a change in pull request #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase

tillrohrmann commented on a change in pull request #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9269#discussion_r308755028 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighA

[GitHub] [flink] tillrohrmann commented on a change in pull request #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase

tillrohrmann commented on a change in pull request #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9269#discussion_r308755854 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighA

[GitHub] [flink] tillrohrmann commented on issue #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase

tillrohrmann commented on issue #9269: [FLINK-9900][tests] Fix unstable ZooKeeperHighAvailabilityITCase URL: https://github.com/apache/flink/pull/9269#issuecomment-516444371 Thanks for opening this fix @ifndef-SleePy. I actually think that you uncovered a true inconsistency which has been

[GitHub] [flink] flinkbot edited a comment on issue #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

flinkbot edited a comment on issue #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224#issuecomment-514889442 ## CI report: * 78b445e8a5fb88c8c7f7080f1e6d9fdf89a5a594 : FAILURE [Build](htt

[GitHub] [flink] flinkbot edited a comment on issue #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

flinkbot edited a comment on issue #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#issuecomment-514645431 ## CI report: * 05fe281c79ab4bd2646ec949dcbbf0c2af9fec6e : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver

flinkbot commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver URL: https://github.com/apache/flink/pull/9281#issuecomment-516443976 ## CI report: * d1d56e2c854c5d1324877e14edd4fb887278e090 : PENDING [Build](https://travis-ci.com

[GitHub] [flink] klion26 commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese

klion26 commented on issue #9280: Flink-13405 Translate "Basic API Concepts" page into Chinese URL: https://github.com/apache/flink/pull/9280#issuecomment-516442916 Please avoid using `git merge` in the git history This is an

[GitHub] [flink] zhijiangW commented on a change in pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW commented on a change in pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#discussion_r308752205 ## File path: flink-runtime/src/main/java/org/apache/f

[GitHub] [flink] zhijiangW commented on a change in pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW commented on a change in pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#discussion_r308751389 ## File path: flink-runtime/src/main/java/org/apache/f

[GitHub] [flink] flinkbot commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver

flinkbot commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver URL: https://github.com/apache/flink/pull/9281#issuecomment-516440424 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896175#comment-16896175 ] Seth Wiesman commented on FLINK-13415: -- I think that is more approriate, document h

[GitHub] [flink] sunjincheng121 commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver

sunjincheng121 commented on issue #9281: [hotfix][table]Rename TableAggFunctionCallVisitor to TableAggFunctionCallResolver URL: https://github.com/apache/flink/pull/9281#issuecomment-516439425 @hequn8128 I appreciate if you can have look at this changes :)

[GitHub] [flink] zhijiangW commented on a change in pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW commented on a change in pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#discussion_r308748565 ## File path: flink-runtime/src/main/java/org/apache/f

<    1   2   3   4   5   6   >