[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180311#comment-17180311 ] Echo Lee commented on FLINK-16408: -- [~trohrmann]  Yes, The problem I currently encounte

[GitHub] [flink] wbgentleman commented on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

wbgentleman commented on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675890942 @TisonKun I have do the typesetting according the materials you offered. Please check. Thank you. This is a

[jira] [Updated] (FLINK-18997) Rename type_info to result_type to make it more clear

[ https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18997: --- Labels: pull-request-available (was: ) > Rename type_info to result_type to make it more cl

[GitHub] [flink] flinkbot commented on pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

flinkbot commented on pull request #13196: URL: https://github.com/apache/flink/pull/13196#issuecomment-675891549 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472783027 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String

[GitHub] [flink] flinkbot edited a comment on pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

flinkbot edited a comment on pull request #12770: URL: https://github.com/apache/flink/pull/12770#issuecomment-649764859 ## CI report: * 14838ccc8ac1e759449b5c392e05e2deeb0e005c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 1f213639e4e38e9e25506c20d7eff660cadbb6b1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 664986884e6e9e1930d48568a4e33b2f36cefe6c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

flinkbot commented on pull request #13196: URL: https://github.com/apache/flink/pull/13196#issuecomment-675895709 ## CI report: * ef1e3aff4509d7dbabed7cb333b1d75851b3e502 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] wbgentleman edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

wbgentleman edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675890942 @TisonKun I have done the typesetting according the materials you offered. Please check. Thank you.

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180322#comment-17180322 ] Jark Wu commented on FLINK-17793: - Maybe. Not sure. The {{Schema}} descriptor will hold

[GitHub] [flink] flinkbot edited a comment on pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

flinkbot edited a comment on pull request #12770: URL: https://github.com/apache/flink/pull/12770#issuecomment-649764859 ## CI report: * 14838ccc8ac1e759449b5c392e05e2deeb0e005c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 1f213639e4e38e9e25506c20d7eff660cadbb6b1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

flinkbot edited a comment on pull request #13196: URL: https://github.com/apache/flink/pull/13196#issuecomment-675895709 ## CI report: * ef1e3aff4509d7dbabed7cb333b1d75851b3e502 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 664986884e6e9e1930d48568a4e33b2f36cefe6c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result

[ https://issues.apache.org/jira/browse/FLINK-18988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180331#comment-17180331 ] Fabian Hueske commented on FLINK-18988: --- [~danny0405] Yes, I used the Blink planne

[jira] [Created] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

Jun Qin created FLINK-18998: --- Summary: No watermark is shown on Flink UI when ProcessingTime is used Key: FLINK-18998 URL: https://issues.apache.org/jira/browse/FLINK-18998 Project: Flink Issue Ty

[GitHub] [flink] dawidwys commented on a change in pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

dawidwys commented on a change in pull request #13050: URL: https://github.com/apache/flink/pull/13050#discussion_r472815116 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/Expander.java ## @@ -0,0 +1,126 @@ +/* + * Licens

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472817962 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[] arg

[GitHub] [flink] rkhachatryan commented on a change in pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

rkhachatryan commented on a change in pull request #13180: URL: https://github.com/apache/flink/pull/13180#discussion_r472818246 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -129,12 +129,10 @@ publ

[GitHub] [flink] wuchong commented on a change in pull request #13122: [FLINK-18824][format][canal] Support serialization for canal-json format

wuchong commented on a change in pull request #13122: URL: https://github.com/apache/flink/pull/13122#discussion_r472805841 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonFormatFactory.java ## @@ -56,16 +57,16 @@ @Supp

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180345#comment-17180345 ] Piotr Nowojski commented on FLINK-12351: I think this is a valid concern. I'm no

[jira] [Updated] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-18983: - Description: If a operator throw a exception, it will break process loop and dispose all operator. But

[GitHub] [flink] zentol commented on a change in pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

zentol commented on a change in pull request #11469: URL: https://github.com/apache/flink/pull/11469#discussion_r472826235 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java ## @@ -306,94 +257,6 @@ private TestJobCancellat

[jira] [Updated] (FLINK-15299) Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

[ https://issues.apache.org/jira/browse/FLINK-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15299: - Fix Version/s: 1.12.0 > Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResu

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-18998: Description: As stated in the subject, no watermark is shown on Flink UI when ProcessingTime is used, see

[GitHub] [flink] lirui-apache opened a new pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

lirui-apache opened a new pull request #13197: URL: https://github.com/apache/flink/pull/13197 …ess SessionState ## What is the purpose of the change Fix/ban some hive functions that need to access SessionState. ## Brief change log - Ban `current_dat

[jira] [Updated] (FLINK-18995) Some Hive functions fail because they need to access SessionState

[ https://issues.apache.org/jira/browse/FLINK-18995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18995: --- Labels: pull-request-available (was: ) > Some Hive functions fail because they need to acce

[GitHub] [flink] flinkbot commented on pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

flinkbot commented on pull request #13197: URL: https://github.com/apache/flink/pull/13197#issuecomment-675933780 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180352#comment-17180352 ] Rui Li commented on FLINK-18931: [~lzljs3620320] Could you help assign this ticket? > T

[jira] [Assigned] (FLINK-18995) Some Hive functions fail because they need to access SessionState

[ https://issues.apache.org/jira/browse/FLINK-18995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18995: Assignee: Rui Li > Some Hive functions fail because they need to access SessionState > --

[jira] [Assigned] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18931: Assignee: Xu Ronghao > Translate "Hive Streaming" page of "Hive Integration" into Chinese

[GitHub] [flink] TisonKun commented on a change in pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

TisonKun commented on a change in pull request #11469: URL: https://github.com/apache/flink/pull/11469#discussion_r472859214 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java ## @@ -595,35 +458,6 @@ public void testRetri

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180359#comment-17180359 ] Timo Walther commented on FLINK-17793: -- I'm also not sure yet. But it would be good

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 94e8eb39032665f77e897cb572cd4320b66635f9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

flinkbot commented on pull request #13197: URL: https://github.com/apache/flink/pull/13197#issuecomment-675953571 ## CI report: * 66f8b6582b131697cccebbf4e2ef9f90a7f43825 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472863712 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180363#comment-17180363 ] Till Rohrmann commented on FLINK-16408: --- How many concurrent {{WordCount}} jobs do

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472866577 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Component/s: Runtime / Web Frontend Runtime / Task > No watermark is shown on

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Fix Version/s: 1.12.0 > No watermark is shown on Flink UI when ProcessingTime is used > --

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Affects Version/s: 1.12.0 1.11.1 > No watermark is shown on Flink UI wh

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180366#comment-17180366 ] Robert Metzger commented on FLINK-18998: I agree, this is a good improvement. >

[GitHub] [flink] flinkbot edited a comment on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

flinkbot edited a comment on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658771971 ## CI report: * 2769a8edbd4a4e28ca6b75f39e69d95007b5c4b2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Issue Type: Improvement (was: Bug) > No watermark is shown on Flink UI when ProcessingTime is

[GitHub] [flink] flinkbot edited a comment on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

flinkbot edited a comment on pull request #13157: URL: https://github.com/apache/flink/pull/13157#issuecomment-674410767 ## CI report: * b64a33a3e57e4af2522aeaf274c4711ddb2b00ef Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

flinkbot edited a comment on pull request #13197: URL: https://github.com/apache/flink/pull/13197#issuecomment-675953571 ## CI report: * 66f8b6582b131697cccebbf4e2ef9f90a7f43825 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Labels: starter usability (was: usability) > No watermark is shown on Flink UI when Processin

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Component/s: (was: Runtime / Task) > No watermark is shown on Flink UI when ProcessingTime

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 5c37469ec372c4660283677e4984a8c87f5254a9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180374#comment-17180374 ] Chesnay Schepler commented on FLINK-18998: -- [~trohrmann] How is this related to

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180380#comment-17180380 ] Nico Kruber commented on FLINK-18998: - Maybe also add a line how to enable EventTime

[jira] [Commented] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180377#comment-17180377 ] CaoZhen commented on FLINK-16258: - Hi  [~twalthr] ,Can this task be assigned to me? > U

[jira] [Assigned] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-16258: Assignee: Timo Walther > Update test utilities to FLIP-65 > -

[jira] [Commented] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180381#comment-17180381 ] Timo Walther commented on FLINK-16258: -- This issue is not as straight forward as it

[jira] [Assigned] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-16258: Assignee: CaoZhen (was: Timo Walther) > Update test utilities to FLIP-65 > -

[GitHub] [flink] flinkbot edited a comment on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

flinkbot edited a comment on pull request #13157: URL: https://github.com/apache/flink/pull/13157#issuecomment-674410767 ## CI report: * b64a33a3e57e4af2522aeaf274c4711ddb2b00ef Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180388#comment-17180388 ] Yun Gao commented on FLINK-18695: - Hi, I have finished the tests with the current master

[GitHub] [flink] wooplevip opened a new pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

wooplevip opened a new pull request #13198: URL: https://github.com/apache/flink/pull/13198 ## What is the purpose of the change This pull request fixes checking jobmanager off-heap memory size incorrectly when off-heap memory is explicitly set by user. ## Brief change log

[jira] [Updated] (FLINK-18993) Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

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

[GitHub] [flink] flinkbot commented on pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

flinkbot commented on pull request #13198: URL: https://github.com/apache/flink/pull/13198#issuecomment-676015059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot commented on pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

flinkbot commented on pull request #13198: URL: https://github.com/apache/flink/pull/13198#issuecomment-676027592 ## CI report: * f7e89b9ebadf0c8373c09817f327558363fe2751 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18999: --- Description: Suppose current catalog is a {{HiveCatalog}}. If user creates a temporary generic table, this

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180405#comment-17180405 ] Chesnay Schepler commented on FLINK-18695: -- [~gaoyunhaii] Thanks for keeping us

[jira] [Created] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog

Rui Li created FLINK-18999: -- Summary: Temporary generic table doesn't work with HiveCatalog Key: FLINK-18999 URL: https://issues.apache.org/jira/browse/FLINK-18999 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18998: - Labels: usability (was: starter usability) > No watermark is shown on Flink UI when Pro

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180411#comment-17180411 ] Chesnay Schepler commented on FLINK-18998: -- Do we display anywhere in the UI wh

[jira] [Assigned] (FLINK-18553) Update Table API set operations to the new type system

[ https://issues.apache.org/jira/browse/FLINK-18553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-18553: Assignee: Timo Walther > Update Table API set operations to the new type system > ---

[GitHub] [flink] flinkbot edited a comment on pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

flinkbot edited a comment on pull request #13198: URL: https://github.com/apache/flink/pull/13198#issuecomment-676027592 ## CI report: * f7e89b9ebadf0c8373c09817f327558363fe2751 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18982) InputFormat should remove unnecessary override methods

[ https://issues.apache.org/jira/browse/FLINK-18982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180414#comment-17180414 ] Benchao Li commented on FLINK-18982: Hi [~lemonjing], thanks for your contribution.

[GitHub] [flink] TisonKun commented on a change in pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

TisonKun commented on a change in pull request #13188: URL: https://github.com/apache/flink/pull/13188#discussion_r472898345 ## File path: docs/flinkDev/building.zh.md ## @@ -22,62 +22,63 @@ specific language governing permissions and limitations under the License. --> -Thi

[jira] [Commented] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180416#comment-17180416 ] Jingsong Lee commented on FLINK-18999: -- Maybe reading a temporary table should neve

[jira] [Comment Edited] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180416#comment-17180416 ] Jingsong Lee edited comment on FLINK-18999 at 8/19/20, 9:51 AM: --

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472914149 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180424#comment-17180424 ] Till Rohrmann commented on FLINK-18998: --- FLINK-8949 introduced the handler which i

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472915726 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[] arg

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472916183 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[] arg

[GitHub] [flink] hequn8128 merged pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

hequn8128 merged pull request #13196: URL: https://github.com/apache/flink/pull/13196 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[jira] [Commented] (FLINK-18997) Rename type_info to result_type to make it more clear

[ https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180427#comment-17180427 ] Hequn Cheng commented on FLINK-18997: - Resolved in 1.12.0 via 0522827b27eb6a1351f9a2

[jira] [Closed] (FLINK-18997) Rename type_info to result_type to make it more clear

[ https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18997. --- Resolution: Resolved > Rename type_info to result_type to make it more clear > -

[jira] [Created] (FLINK-19000) Forward JobStatus.INITIALIZING timestamp to ExecutionGraph

Robert Metzger created FLINK-19000: -- Summary: Forward JobStatus.INITIALIZING timestamp to ExecutionGraph Key: FLINK-19000 URL: https://issues.apache.org/jira/browse/FLINK-19000 Project: Flink

[jira] [Created] (FLINK-19001) Add data-stream integration for stateful functions

Igal Shilman created FLINK-19001: Summary: Add data-stream integration for stateful functions Key: FLINK-19001 URL: https://issues.apache.org/jira/browse/FLINK-19001 Project: Flink Issue Typ

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472933647 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[] arg

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472936802 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[] arg

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472941009 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[] arg

[GitHub] [flink] wangyang0918 commented on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

wangyang0918 commented on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-676142615 @rmetzger Thanks for your suggestions. I have added two more commits to address your comments. * de1e3d29fe97e5daecddebf4c8c705aba41f10db to update the documentation to

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472942385 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,42 @@ private int run(String[] arg

[GitHub] [flink-statefun] igalshilman opened a new pull request #133: [FLINK-19001] Add data stream api interoperability

igalshilman opened a new pull request #133: URL: https://github.com/apache/flink-statefun/pull/133 # Add DataStream API interoperability This PR adds an extension the stateful function SDK that allows embedding stateful function applications into a data stream program. This i

[jira] [Updated] (FLINK-19001) Add data-stream integration for stateful functions

[ https://issues.apache.org/jira/browse/FLINK-19001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19001: --- Labels: pull-request-available (was: ) > Add data-stream integration for stateful functions

[GitHub] [flink] zentol commented on a change in pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

zentol commented on a change in pull request #11469: URL: https://github.com/apache/flink/pull/11469#discussion_r472947504 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java ## @@ -306,94 +257,6 @@ private TestJobCancellat

[GitHub] [flink] zentol commented on a change in pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

zentol commented on a change in pull request #11469: URL: https://github.com/apache/flink/pull/11469#discussion_r472948766 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java ## @@ -595,35 +458,6 @@ public void testRetriab

[GitHub] [flink] flinkbot edited a comment on pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

flinkbot edited a comment on pull request #12770: URL: https://github.com/apache/flink/pull/12770#issuecomment-649764859 ## CI report: * 57c89e51ecb4276461a136b3b3e4bae7f7d71799 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * a572964939815f96ee78d0ff1939bf444812b7da Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

flinkbot edited a comment on pull request #13190: URL: https://github.com/apache/flink/pull/13190#issuecomment-675384858 ## CI report: * 3d0ec8202d20e69a2e0f76598566378a28152dd6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dianfu closed pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

dianfu closed pull request #12770: URL: https://github.com/apache/flink/pull/12770 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Closed] (FLINK-18200) Replace the deprecated interfaces with the new interfaces in the tests and examples

[ https://issues.apache.org/jira/browse/FLINK-18200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18200. --- Resolution: Fixed master: b6592fc10f18f8a5057e44794a843c84359c220f > Replace the deprecated interfaces with

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * a572964939815f96ee78d0ff1939bf444812b7da Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

flinkbot edited a comment on pull request #13190: URL: https://github.com/apache/flink/pull/13190#issuecomment-675384858 ## CI report: * 3d0ec8202d20e69a2e0f76598566378a28152dd6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger commented on a change in pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

rmetzger commented on a change in pull request #13121: URL: https://github.com/apache/flink/pull/13121#discussion_r472956028 ## File path: docs/ops/deployment/native_kubernetes.md ## @@ -195,6 +188,28 @@ As always, Jobs may stop when manually canceled or, in the case of bounde

[jira] [Created] (FLINK-19002) Support to only read changelogs of specific database and table for canal-json format

Jark Wu created FLINK-19002: --- Summary: Support to only read changelogs of specific database and table for canal-json format Key: FLINK-19002 URL: https://issues.apache.org/jira/browse/FLINK-19002 Project: F

  1   2   3   >