[GitHub] [flink] carp84 merged pull request #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions

2020-01-12 Thread GitBox
carp84 merged pull request #10692: [FLINK-15387] Expose missing RocksDB properties out via RocksDBNativeMetricOptions URL: https://github.com/apache/flink/pull/10692 This is an automated message from the Apache Git Service.

[jira] [Reopened] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

2020-01-12 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reopened FLINK-15355: --- 'Shaded Hadoop S3A with credentials provider end-to-end test' still fails in latest release-1.10 nightly

[GitHub] [flink] carp84 commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
carp84 commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#discussion_r365564968 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
carp84 commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#discussion_r365226910 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
carp84 commented on a change in pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#discussion_r365565010 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#issuecomment-572715611 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

2020-01-12 Thread GitBox
flinkbot commented on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573413065 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#issuecomment-572715611 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820#issuecomment-572715611 ## CI report: *

[jira] [Created] (FLINK-15560) Timestamp literal support for startFromTimestamp in KafkaTableSource

2020-01-12 Thread Paul Lin (Jira)
Paul Lin created FLINK-15560: Summary: Timestamp literal support for startFromTimestamp in KafkaTableSource Key: FLINK-15560 URL: https://issues.apache.org/jira/browse/FLINK-15560 Project: Flink

[jira] [Closed] (FLINK-15387) Expose missing RocksDB properties out via RocksDBNativeMetricOptions

2020-01-12 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-15387. - Resolution: Implemented Merged in master via: 27c29f7656ded03ec57cdc485e4ec8ff6e3b9bef release-1.10 via:

[jira] [Updated] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

2020-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15533: --- Labels: pull-request-available (was: ) > Writing DataStream as text file fails due to

[GitHub] [flink] kl0u opened a new pull request #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

2020-01-12 Thread GitBox
kl0u opened a new pull request #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835 ## What is the purpose of the change Before the introduction of the executor (FLIP-73) and the consolidation of the

[GitHub] [flink] flinkbot commented on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation.

2020-01-12 Thread GitBox
flinkbot commented on issue #10835: [FLINK-15533] Fix parallelism setting propagation during graph instantiation. URL: https://github.com/apache/flink/pull/10835#issuecomment-573416112 ## CI report: * 0590888514ff79680992bf39f72235a4d90bb75b UNKNOWN Bot commands

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2020-01-12 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013767#comment-17013767 ] John Lonergan commented on FLINK-3929: -- This approach alone doesn't consider the impact of password

[GitHub] [flink] link3280 commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-12 Thread GitBox
link3280 commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573417670 Sounds good. I'll remove `connector.startup-timestamp` from this PR and file a new Jira ticket to

[jira] [Updated] (FLINK-15220) Add startFromTimestamp in KafkaTableSource

2020-01-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-15220: - Description: KafkaTableSource supports all startup modes in DataStream API except

[jira] [Updated] (FLINK-15560) Timestamp literal support for startFromTimestamp in KafkaTableSource

2020-01-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-15560: - Description: The follow-up work for FLINK-15220 which leaves timestamp literal support unimplemented,

[jira] [Updated] (FLINK-15560) Timestamp literal support for startFromTimestamp in KafkaTableSource

2020-01-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-15560: - Description: The follow-up work for FLINK-15220 which leaves timestamp literal support unimplemented,

[jira] [Updated] (FLINK-15560) Timestamp literal support for startFromTimestamp in KafkaTableSource

2020-01-12 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-15560: - Description: The follow-up work for FLINK-15220 which leaves timestamp literal support unimplemented,

[jira] [Comment Edited] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

2020-01-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013453#comment-17013453 ] godfrey he edited comment on FLINK-15556 at 1/12/20 11:00 AM: -- hi [~hailong

[GitHub] [flink] wuchong commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource

2020-01-12 Thread GitBox
wuchong commented on issue #10674: [FLINK-15220][Connector/Kafka][Table] Add startFromTimestamp in KafkaTableSource URL: https://github.com/apache/flink/pull/10674#issuecomment-573405777 I agree with @dawidwys , parsing from "2011-12-03 10:15:30" to a time second since epoch should

[GitHub] [flink] GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly

2020-01-12 Thread GitBox
GJL commented on a change in pull request #10804: [FLINK-15488] Obtain the JVM and TM param correctly URL: https://github.com/apache/flink/pull/10804#discussion_r365588580 ## File path: flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java ## @@ -34,21

[GitHub] [flink] zentol commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

2020-01-12 Thread GitBox
zentol commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365613821 ## File path:

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013963#comment-17013963 ] Kurt Young commented on FLINK-15527: [~chenchencc] can you use yarn session mode to achieve what you

[jira] [Comment Edited] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013961#comment-17013961 ] Yangze Guo edited comment on FLINK-15562 at 1/13/20 2:11 AM: - _With

[jira] [Comment Edited] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013959#comment-17013959 ] Jingsong Lee edited comment on FLINK-15527 at 1/13/20 3:01 AM: --- Hi

[GitHub] [flink] wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365635974 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-568440738 ## CI report: * 5a0d5d3d499347ca216e19175ff5f066a6d9b458 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-568440738 ## CI report: * 5a0d5d3d499347ca216e19175ff5f066a6d9b458 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-12 Thread GitBox
zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r365663503 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client URL: https://github.com/apache/flink/pull/10787#issuecomment-571493639 ## CI report: * a1b145997f6ba4834eca41304b3c9aeaf968442a Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-12 Thread GitBox
zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r365663234 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client URL: https://github.com/apache/flink/pull/10787#issuecomment-571493639 ## CI report: * a1b145997f6ba4834eca41304b3c9aeaf968442a Travis:

[GitHub] [flink] zhuzhurk commented on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-12 Thread GitBox
zhuzhurk commented on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-573517594 Thanks @tillrohrmann. Will try to backport the fix to release-1.9.

[GitHub] [flink] KarmaGYZ commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

2020-01-12 Thread GitBox
KarmaGYZ commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-573521081 Kindly ping @GJL This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10787: [FLINK-15495][sql-cli] Set default planner to Blink planner for SQL Client URL: https://github.com/apache/flink/pull/10787#issuecomment-571493639 ## CI report: * a1b145997f6ba4834eca41304b3c9aeaf968442a Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-12 Thread GitBox
zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r365662444 ## File path:

[jira] [Assigned] (FLINK-14313) Add Gojek to Chinese Powered By page

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14313: --- Assignee: Jiawei Wu > Add Gojek to Chinese Powered By page >

[jira] [Commented] (FLINK-14684) Add Pinterest to Chinese Powered By page

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014074#comment-17014074 ] Jark Wu commented on FLINK-14684: - Hi [~Jiawei Wu], would be better to separate them in different PRs. I

[GitHub] [flink] flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#issuecomment-568850864 ## CI report: * a7411a5d1a86381078670898c1f20be4fe3a88f4

[jira] [Commented] (FLINK-15563) When using ParquetTableSource, The program hangs until OOM

2020-01-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013990#comment-17013990 ] Kurt Young commented on FLINK-15563: cc [~godfreyhe] > When using ParquetTableSource, The program

[GitHub] [flink] flinkbot edited a comment on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#issuecomment-571963932 ## CI report: * e904ab518c4d3b26bf27a89c61b9df30af54b6ed Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis:

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014002#comment-17014002 ] Jingsong Lee commented on FLINK-15527: -- > Hive setting too high job parallelism It is not a

[jira] [Comment Edited] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014002#comment-17014002 ] Jingsong Lee edited comment on FLINK-15527 at 1/13/20 3:43 AM: --- Thanks

[GitHub] [flink] flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#issuecomment-568440738 ## CI report: * 5a0d5d3d499347ca216e19175ff5f066a6d9b458 Travis:

[jira] [Assigned] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15548: --- Assignee: wangsan > Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator

[jira] [Commented] (FLINK-15553) Create table ddl support comment after computed column

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014077#comment-17014077 ] Jark Wu commented on FLINK-15553: - cc [~danny0405] > Create table ddl support comment after computed

[GitHub] [flink] zentol commented on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

2020-01-12 Thread GitBox
zentol commented on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573458471 We have no tests that actually use the azure-fs jar; while there is an e2e _test_ we have no azure credentials. I did however look

[GitHub] [flink] flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#issuecomment-571963932 ## CI report: * e904ab518c4d3b26bf27a89c61b9df30af54b6ed Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: *

[jira] [Commented] (FLINK-15509) Use sql cilents create view occur Unexpected exception

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014059#comment-17014059 ] Jark Wu commented on FLINK-15509: - Hi [~lzljs3620320], +1 that's the point I mentioned above. If the

[GitHub] [flink] wuchong merged pull request #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOpe

2020-01-12 Thread GitBox
wuchong merged pull request #10827: [FLINK-15548] [table-runtime-blink] Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator URL: https://github.com/apache/flink/pull/10827

[jira] [Resolved] (FLINK-15548) Make KeyedCoProcessOperatorWithWatermarkDelay extends KeyedCoProcessOperator instead of LegacyKeyedCoProcessOperator

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-15548. - Fix Version/s: (was: 1.10.0) 1.11.0 Resolution: Fixed 1.11.0:

[GitHub] [flink] zentol commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

2020-01-12 Thread GitBox
zentol commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365612987 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

2020-01-12 Thread GitBox
zentol commented on a change in pull request #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#discussion_r365612875 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#issuecomment-568850864 ## CI report: * a7411a5d1a86381078670898c1f20be4fe3a88f4

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013997#comment-17013997 ] Xintong Song commented on FLINK-15527: -- Thanks for involving me, [~lzljs3620320]. If I understand

[GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-12 Thread GitBox
zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r365642499 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10825: [FLINK-15522][runtime] JobResult takes ExecutionGraph failure cause as its failure cause only if job is FAILED URL: https://github.com/apache/flink/pull/10825#issuecomment-572937976 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis:

[jira] [Created] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-15562: -- Summary: Unable to create walk through project Key: FLINK-15562 URL: https://issues.apache.org/jira/browse/FLINK-15562 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15562: --- Component/s: Documentation > Unable to create walk through project >

[jira] [Commented] (FLINK-14684) Add Pinterest to Chinese Powered By page

2020-01-12 Thread Jiawei Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013977#comment-17013977 ] Jiawei Wu commented on FLINK-14684: --- [~fhueske] Thanks! I will try to finish it in the next 3 days.

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013989#comment-17013989 ] Kurt Young commented on FLINK-15527: IIRC yarn session mode is just a standalone cluster but

[jira] [Commented] (FLINK-15318) RocksDBWriteBatchPerformanceTest.benchMark fails on ppc64le

2020-01-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013995#comment-17013995 ] Yun Tang commented on FLINK-15318: -- [~redmark-ibm] you can try this

[GitHub] [flink] wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365636347 ## File path: flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh

[jira] [Commented] (FLINK-15565) sql planner Incompatible

2020-01-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014056#comment-17014056 ] Kurt Young commented on FLINK-15565: cc [~lzljs3620320] > sql planner Incompatible >

[jira] [Commented] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014069#comment-17014069 ] Jark Wu commented on FLINK-15552: - Hi [~Terry1897], are you sure there is kafka sql jar under

[GitHub] [flink] yanghua commented on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation

2020-01-12 Thread GitBox
yanghua commented on issue #10833: [FLINK-15535][documentation] Add usage of ProcessFunctionTestHarnesses for testing documentation URL: https://github.com/apache/flink/pull/10833#issuecomment-573534012 cc @aljoscha This is

[GitHub] [flink] jiasheng55 commented on issue #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o…

2020-01-12 Thread GitBox
jiasheng55 commented on issue #8400: [FLINK-12472][yarn] Support setting attemptFailuresValidityInterval o… URL: https://github.com/apache/flink/pull/8400#issuecomment-573483344 @langdangjushi 请平息一下情绪……你可以看一下这个“File

[jira] [Comment Edited] (FLINK-15562) Unable to create walk through project

2020-01-12 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013961#comment-17013961 ] Yangze Guo edited comment on FLINK-15562 at 1/13/20 2:09 AM: - _With

[GitHub] [flink] JingsongLi commented on a change in pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-01-12 Thread GitBox
JingsongLi commented on a change in pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#discussion_r365632450 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365635088 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh

[jira] [Updated] (FLINK-15563) When using ParquetTableSource, The program hangs until OOM

2020-01-12 Thread sujun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sujun updated FLINK-15563: -- Description: This is my code: {code:java} def main(args: Array[String]): Unit = { val env =

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013986#comment-17013986 ] Jingsong Lee commented on FLINK-15527: -- CC: [~xintongsong] > can not control the number of

[GitHub] [flink] carp84 merged pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s)

2020-01-12 Thread GitBox
carp84 merged pull request #10820: [FLINK-15512][statebackend] Refactor the mechanism to calculate the cache capacity shared among RocksDB instance(s) URL: https://github.com/apache/flink/pull/10820 This is an automated

[GitHub] [flink] wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365635600 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014009#comment-17014009 ] Jingsong Lee commented on FLINK-15527: -- Hi [~xintongsong] You are right about using yarn queue

[jira] [Updated] (FLINK-15565) sql planner Incompatible

2020-01-12 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15565: --- Description: *The sql is:* CREATE TABLE `over10k` ( t tinyint, si smallint, i int, b bigint,

[jira] [Updated] (FLINK-15565) Incompatible types of expression and result type thrown in codegen

2020-01-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15565: --- Summary: Incompatible types of expression and result type thrown in codegen (was: sql planner

[jira] [Commented] (FLINK-15559) Missing {{site.baseurl}} in some docs

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014071#comment-17014071 ] Jark Wu commented on FLINK-15559: - Hi [~libenchao], do you mean these links are broken because of

[GitHub] [flink] flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10762: [FLINK-15115][kafka] Drop Kafka 0.8/0.9 URL: https://github.com/apache/flink/pull/10762#issuecomment-570591280 ## CI report: * 6bfb6d18af5fdfbddadf6da53adab78567d64aa9 Travis:

[jira] [Created] (FLINK-15564) YarnClusterDescriptorTest failed to validate the original intended behavior

2020-01-12 Thread Xintong Song (Jira)
Xintong Song created FLINK-15564: Summary: YarnClusterDescriptorTest failed to validate the original intended behavior Key: FLINK-15564 URL: https://issues.apache.org/jira/browse/FLINK-15564 Project:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests

2020-01-12 Thread GitBox
wangyang0918 commented on a change in pull request #10665: [FLINK-15354] Start and stop minikube only in kubernetes related e2e tests URL: https://github.com/apache/flink/pull/10665#discussion_r365636347 ## File path: flink-end-to-end-tests/test-scripts/test_kubernetes_session.sh

[jira] [Comment Edited] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014006#comment-17014006 ] Xintong Song edited comment on FLINK-15527 at 1/13/20 3:58 AM: --- {quote}> 

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014006#comment-17014006 ] Xintong Song commented on FLINK-15527: -- {quote}> Hive setting too high job parallelism It is not a

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#issuecomment-571963932 ## CI report: * e904ab518c4d3b26bf27a89c61b9df30af54b6ed Travis:

[jira] [Commented] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

2020-01-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014073#comment-17014073 ] Jark Wu commented on FLINK-15556: - I think in most cases reusing sources will save more resources than

[GitHub] [flink] flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-573052596 ## CI report: * 8aba8ccd54ff402b95b302453317d534febb5df9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping

2020-01-12 Thread GitBox
flinkbot edited a comment on issue #10682: [FLINK-15247][Runtime] Wait for all slots to be free before task executor services shutdown upon stopping URL: https://github.com/apache/flink/pull/10682#issuecomment-568850864 ## CI report: * a7411a5d1a86381078670898c1f20be4fe3a88f4

[jira] [Commented] (FLINK-15527) can not control the number of container on yarn single job module

2020-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013959#comment-17013959 ] Jingsong Lee commented on FLINK-15527: -- Hi [~trohrmann], thanks for your involving. I have provided

  1   2   >