[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: * 4b06551a39ce8d9d6c5f19948e36d493e3d592e3 Azure:

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

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

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

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

[GitHub] [flink-web] rmetzger opened a new pull request #370: Add a blog post about the current state of Flink on Docker

rmetzger opened a new pull request #370: URL: https://github.com/apache/flink-web/pull/370 This blog post hasn't been proofread by anybody beforehand, so this is mostly for collecting early feedback. I'll cleanup the commit history and date in the blog post later.

[jira] [Created] (FLINK-18996) Avoid disorder for time interval join

Benchao Li created FLINK-18996: -- Summary: Avoid disorder for time interval join Key: FLINK-18996 URL: https://issues.apache.org/jira/browse/FLINK-18996 Project: Flink Issue Type: 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: * 4b06551a39ce8d9d6c5f19948e36d493e3d592e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

flinkbot edited a comment on pull request #13195: URL: https://github.com/apache/flink/pull/13195#issuecomment-675844035 ## CI report: * caa599bea8dc09145e62ca2edbbaa3238e5449f6 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

wuchong commented on a change in pull request #12908: URL: https://github.com/apache/flink/pull/12908#discussion_r472680410 ## File path: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka010DynamicSource.java ##

[GitHub] [flink] flinkbot commented on pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

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

[GitHub] [flink] flinkbot edited a comment on pull request #13177: [FLINK-18958] Lose column comment when create table

flinkbot edited a comment on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-674873978 ## CI report: * 1db995acea1f9f0f9a929dd59603b44b2786c325 Azure:

[GitHub] [flink] flinkbot commented on pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

flinkbot commented on pull request #13195: URL: https://github.com/apache/flink/pull/13195#issuecomment-675841189 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

[jira] [Updated] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18994: --- Labels: pull-request-available (was: ) > There is one typo in "Set up TaskManager Memory"

[GitHub] [flink] xintongsong commented on pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

xintongsong commented on pull request #13195: URL: https://github.com/apache/flink/pull/13195#issuecomment-675840306 cc @KarmaGYZ This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #13177: [FLINK-18958] Lose column comment when create table

flinkbot edited a comment on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-674873978 ## CI report: * Unknown: [CANCELED](TBD) * 1db995acea1f9f0f9a929dd59603b44b2786c325 Azure:

[GitHub] [flink] wuchong commented on pull request #13177: [FLINK-18958] Lose column comment when create table

wuchong commented on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-675840028 Thanks for the contribution @oikomi , after going through it roughly, I have some concern that we are making the `TableSchema` fatter and fatter. The community had some

[GitHub] [flink] xintongsong opened a new pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

xintongsong opened a new pull request #13195: URL: https://github.com/apache/flink/pull/13195 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] wuchong edited a comment on pull request #13177: [FLINK-18958] Lose column comment when create table

wuchong edited a comment on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-675840028 Thanks for the contribution @oikomi , after going through it roughly, I have some concern that we are making the `TableSchema` fatter and fatter. The community had some

[jira] [Updated] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18994: - Fix Version/s: 1.11.2 1.12.0 > There is one typo in "Set up TaskManager

[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=17180247#comment-17180247 ] Jark Wu commented on FLINK-17793: - Hi [~twalthr], are you still working on this? Do you think we should

[jira] [Updated] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18994: - Issue Type: Bug (was: Improvement) > There is one typo in "Set up TaskManager Memory" >

[jira] [Commented] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180246#comment-17180246 ] Xintong Song commented on FLINK-18994: -- Thanks for reporting this, [~wooplevip]. > There is one

[jira] [Assigned] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-18994: Assignee: Xintong Song > There is one typo in "Set up TaskManager Memory" >

[jira] [Closed] (FLINK-17427) Support SupportsPartitionPushDown in planner

[ https://issues.apache.org/jira/browse/FLINK-17427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17427. --- Fix Version/s: 1.12.0 Resolution: Fixed master (1.12.0): f5be4dfe77f02ce0459c3710fb82b319377a4329 >

[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-675836500 > Please refer to https://github.com/sparanoid/chinese-copywriting-guidelines/blob/master/README.zh-CN.md and typesetting the content. Ok, I will do typesetting

[GitHub] [flink] wuchong merged pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

wuchong merged pull request #12966: URL: https://github.com/apache/flink/pull/12966 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

[GitHub] [flink] flinkbot edited a comment on pull request #13177: [FLINK-18958] Lose column comment when create table

flinkbot edited a comment on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-674873978 ## CI report: * Unknown: [CANCELED](TBD) * 1db995acea1f9f0f9a929dd59603b44b2786c325 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] oikomi commented on pull request #13177: [FLINK-18958] Lose column comment when create table

oikomi commented on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-675836053 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

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

Rui Li created FLINK-18995: -- Summary: Some Hive functions fail because they need to access SessionState Key: FLINK-18995 URL: https://issues.apache.org/jira/browse/FLINK-18995 Project: Flink Issue

[GitHub] [flink] wuchong merged pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

wuchong merged pull request #13088: URL: https://github.com/apache/flink/pull/13088 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

[jira] [Closed] (FLINK-18814) Translate the 'Side Outputs' page of 'DataStream API' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18814. --- Fix Version/s: 1.12.0 Resolution: Fixed master (1.12.0): 060ca9909360dba8726042cdca0bf1f1b6942268 >

[jira] [Closed] (FLINK-18930) Translate "Hive Dialect" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18930. Resolution: Fixed master: 1cacf2efb7da6cfa9c63867ad4b4662088dfe67c > Translate "Hive Dialect"

[GitHub] [flink] JingsongLi merged pull request #13176: [FLINK-18930][docs-zh] Translate "Hive Dialect" page of "Hive Integration" into Chinese

JingsongLi merged pull request #13176: URL: https://github.com/apache/flink/pull/13176 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

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180234#comment-17180234 ] Jark Wu commented on FLINK-17826: - Assigned to you [~Leonard Xu] > Add missing custom query support on

[jira] [Assigned] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17826: --- Assignee: Leonard Xu (was: Flavio Pompermaier) > Add missing custom query support on new jdbc

[GitHub] [flink] flinkbot edited a comment on pull request #13177: [FLINK-18958] Lose column comment when create table

flinkbot edited a comment on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-674873978 ## CI report: * adce333a95ea3e35456433d343424300aedcb5f2 Azure:

[jira] [Assigned] (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:all-tabpanel ] Jark Wu reassigned FLINK-18988: --- Assignee: Danny Chen > Continuous query with LATERAL and LIMIT produces wrong 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=17180223#comment-17180223 ] Jark Wu commented on FLINK-18988: - We can translate this pattern into StreamExecRank which is already

[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=17180224#comment-17180224 ] Jark Wu commented on FLINK-18988: - Assigned to you [~danny0405] > Continuous query with LATERAL and

[jira] [Commented] (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:comment-tabpanel=17180221#comment-17180221 ] Matt Wang commented on FLINK-18983: --- You can add a test case in Description which has this problem. >

[jira] [Comment Edited] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180220#comment-17180220 ] Yao WANG edited comment on FLINK-17826 at 8/19/20, 2:35 AM: [~Leonard Xu],

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180220#comment-17180220 ] Yao WANG commented on FLINK-17826: -- [~Leonard Xu], ok, you can just refer to  FLINK-17361 > Add

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180216#comment-17180216 ] Leonard Xu commented on FLINK-17826: [~f.pompermaier] okay, I'll take this and open the pr soon. 

[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=17180215#comment-17180215 ] Echo Lee commented on FLINK-16408: -- [~trohrmann] I tested it with Wordcount.jar and submitted it to the

[GitHub] [flink] flinkbot edited a comment on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

flinkbot edited a comment on pull request #13186: URL: https://github.com/apache/flink/pull/13186#issuecomment-675299227 ## CI report: * bd4e2812d845277e7f4bc68e97f4759e11334ca3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13177: [FLINK-18958] Lose column comment when create table

flinkbot edited a comment on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-674873978 ## CI report: * adce333a95ea3e35456433d343424300aedcb5f2 Azure:

[jira] [Commented] (FLINK-16584) Whether to support the long type field in table planner when the source is kafka and event time field's type is long

[ https://issues.apache.org/jira/browse/FLINK-16584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180213#comment-17180213 ] Jark Wu commented on FLINK-16584: - Maybe TO_TIMESTAMP, see FLINK-16889 > Whether to support the long

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180211#comment-17180211 ] Yao WANG commented on FLINK-17826: -- Hi [~f.pompermaier] actually i met this problem and want to fix it,

[GitHub] [flink] oikomi commented on pull request #13177: [FLINK-18958] Lose column comment when create table

oikomi commented on pull request #13177: URL: https://github.com/apache/flink/pull/13177#issuecomment-675812346 @flinkbot run travis @flinkbot run azure This is an automated message from the Apache Git Service. To respond

[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

[jira] [Created] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

Peng created FLINK-18994: Summary: There is one typo in "Set up TaskManager Memory" Key: FLINK-18994 URL: https://issues.apache.org/jira/browse/FLINK-18994 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-18212) Init lookup join failed when use udf on lookup table

[ https://issues.apache.org/jira/browse/FLINK-18212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18212. --- Resolution: Fixed > Init lookup join failed when use udf on lookup table >

[jira] [Comment Edited] (FLINK-18212) Init lookup join failed when use udf on lookup table

[ https://issues.apache.org/jira/browse/FLINK-18212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179312#comment-17179312 ] Jark Wu edited comment on FLINK-18212 at 8/19/20, 2:11 AM: --- Fixed in - master

[jira] [Closed] (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 closed FLINK-18983. Resolution: Not A Bug > Job doesn't changed to failed if close function has blocked >

[jira] [Reopened] (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 reopened FLINK-18983: -- > Job doesn't changed to failed if close function has blocked >

[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=17180209#comment-17180209 ] Wenlong Lyu commented on FLINK-12351: - Hi, [~jark][~trohrmann] I think we may need to fix this issue

[GitHub] [flink] wuchong merged pull request #13182: [BP-1.11][FLINK-18212][table-planner-blink] Fix Lookup Join failed when there is a UDF equal condition on the column of temporal table

wuchong merged pull request #13182: URL: https://github.com/apache/flink/pull/13182 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

[GitHub] [flink] wuchong edited a comment on pull request #13182: [BP-1.11][FLINK-18212][table-planner-blink] Fix Lookup Join failed when there is a UDF equal condition on the column of temporal table

wuchong edited a comment on pull request #13182: URL: https://github.com/apache/flink/pull/13182#issuecomment-675809339 Build is passed: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5641=results Merging...

[GitHub] [flink] wuchong merged pull request #13183: [BP-1.10][FLINK-18212][table-planner-blink] Fix Lookup Join failed when there is a UDF equal condition on the column of temporal table

wuchong merged pull request #13183: URL: https://github.com/apache/flink/pull/13183 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

[GitHub] [flink] wuchong commented on pull request #13182: [BP-1.11][FLINK-18212][table-planner-blink] Fix Lookup Join failed when there is a UDF equal condition on the column of temporal table

wuchong commented on pull request #13182: URL: https://github.com/apache/flink/pull/13182#issuecomment-675809339 Build is passed: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5641=results This is

[GitHub] [flink] flinkbot edited a comment on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

flinkbot edited a comment on pull request #13186: URL: https://github.com/apache/flink/pull/13186#issuecomment-675299227 ## CI report: * bd4e2812d845277e7f4bc68e97f4759e11334ca3 Azure:

[GitHub] [flink] wuchong commented on pull request #13183: [BP-1.10][FLINK-18212][table-planner-blink] Fix Lookup Join failed when there is a UDF equal condition on the column of temporal table

wuchong commented on pull request #13183: URL: https://github.com/apache/flink/pull/13183#issuecomment-675809254 Travis is passed: https://travis-ci.com/github/flink-ci/flink/builds/180067046 This is an automated message

[GitHub] [flink] hequn8128 commented on a change in pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

hequn8128 commented on a change in pull request #13193: URL: https://github.com/apache/flink/pull/13193#discussion_r472592715 ## File path: docs/dev/python/user-guide/table/python_table_api_connectors.md ## @@ -0,0 +1,194 @@ +--- +title: "Connectors" +nav-parent_id:

[jira] [Assigned] (FLINK-15679) Improve Flink's ID system

[ https://issues.apache.org/jira/browse/FLINK-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-15679: Assignee: Yangze Guo > Improve Flink's ID system > - > >

[jira] [Closed] (FLINK-15679) Improve Flink's ID system

[ https://issues.apache.org/jira/browse/FLINK-15679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-15679. Resolution: Done > Improve Flink's ID system > - > > Key:

[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=17180207#comment-17180207 ] Danny Chen commented on FLINK-18988: Hi, [~fhueske], i would like to take this issue ~ I guess you

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

Peng created FLINK-18993: Summary: Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java Key: FLINK-18993 URL: https://issues.apache.org/jira/browse/FLINK-18993 Project:

[jira] [Closed] (FLINK-15448) Log host informations for TaskManager failures.

[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-15448. Resolution: Done Merged via: * master: b4705edc841a8cf380d9a12d71551a4d38ec9e31 > Log host

[GitHub] [flink] xintongsong closed pull request #13063: [FLINK-15448] Add Node information to the ResourceId of TaskExecutor …

xintongsong closed pull request #13063: URL: https://github.com/apache/flink/pull/13063 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

[GitHub] [flink] hequn8128 commented on a change in pull request #13192: [FLINK-18912][python][docs] Add Python api tutorial under Python GettingStart

hequn8128 commented on a change in pull request #13192: URL: https://github.com/apache/flink/pull/13192#discussion_r472587408 ## File path: docs/try-flink/python_table_api.md ## @@ -23,161 +23,9 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] RocMarshal edited a comment on pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

RocMarshal edited a comment on pull request #13089: URL: https://github.com/apache/flink/pull/13089#issuecomment-675246690 LGTM ping @wuchong @zentol @rmetzger This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-18985) Update the Sphinx doc for Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-18985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18985. --- Resolution: Resolved > Update the Sphinx doc for Python DataStream API. >

[GitHub] [flink] hequn8128 merged pull request #13191: [FLINK-18985][python] Update the Sphinx doc for Python DataStream API.

hequn8128 merged pull request #13191: URL: https://github.com/apache/flink/pull/13191 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

[jira] [Commented] (FLINK-18985) Update the Sphinx doc for Python DataStream API.

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

[jira] [Created] (FLINK-18992) Table API renameColumns method annotation error

tzxxh created FLINK-18992: - Summary: Table API renameColumns method annotation error Key: FLINK-18992 URL: https://issues.apache.org/jira/browse/FLINK-18992 Project: Flink Issue Type: Bug

[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-675794133 When will this pull request will be acceptted, or should I do some thing? This is an automated message from

[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-675793798 @flinkbot approve all This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180193#comment-17180193 ] Dian Fu commented on FLINK-17274: -

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180192#comment-17180192 ] Dian Fu commented on FLINK-17510: -

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

TisonKun commented on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-675783619 @zentol @rmetzger ci passed. PTAL. This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180051#comment-17180051 ] Chesnay Schepler commented on FLINK-18643: -- [~rmetzger] What about the 1.10/1.11 snapshots? >

[GitHub] [flink-web] morsapaes opened a new pull request #369: [blog] Monitoring and Controlling Networks of IoT Devices with Flink Stateful Functions

morsapaes opened a new pull request #369: URL: https://github.com/apache/flink-web/pull/369 Adding Igal's blogpost on StateFun to be published tomorrow (19/08). @sjwiesman This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

flinkbot edited a comment on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-601972922 ## CI report: * 14a49b71bdbf976fc27b0da2ef2065a357af7594 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

flinkbot edited a comment on pull request #13180: URL: https://github.com/apache/flink/pull/13180#issuecomment-674984135 ## CI report: * 4aea992b6d30869cc742525b56225e3bcead1439 Azure:

[jira] [Closed] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18643. -- Fix Version/s: 1.12.0 Resolution: Fixed Resolved in

[GitHub] [flink] rmetzger commented on pull request #13125: [FLINK-18643] Deploy Flink snapshot build with nightly CI job

rmetzger commented on pull request #13125: URL: https://github.com/apache/flink/pull/13125#issuecomment-675610845 Thanks a lot for your review! This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] rmetzger closed pull request #13125: [FLINK-18643] Deploy Flink snapshot build with nightly CI job

rmetzger closed pull request #13125: URL: https://github.com/apache/flink/pull/13125 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

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * d02272061d2264ee74d67da5d9f0e1524f1c7d52 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #13194: [FLINK-18987][WebUI] Sort user configuration entries

flinkbot edited a comment on pull request #13194: URL: https://github.com/apache/flink/pull/13194#issuecomment-675469238 ## CI report: * 2dba2784ba1d683e7a186ba4971dfaf38dc6b9ee Azure:

[jira] [Updated] (FLINK-18991) Optimize reading InputChannel state

[ https://issues.apache.org/jira/browse/FLINK-18991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18991: -- Description: Curently, channel state is read not sequentially. Inverting control

[jira] [Created] (FLINK-18991) Optimize reading InputChannel state

Roman Khachatryan created FLINK-18991: - Summary: Optimize reading InputChannel state Key: FLINK-18991 URL: https://issues.apache.org/jira/browse/FLINK-18991 Project: Flink Issue Type:

[jira] [Created] (FLINK-18990) Optimize reading ResultSubpartition state

Roman Khachatryan created FLINK-18990: - Summary: Optimize reading ResultSubpartition state Key: FLINK-18990 URL: https://issues.apache.org/jira/browse/FLINK-18990 Project: Flink Issue

[jira] [Updated] (FLINK-18990) Optimize reading ResultSubpartition state

[ https://issues.apache.org/jira/browse/FLINK-18990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-18990: -- Description: Curently, channel state is read not sequentially. Inverting control

[jira] [Created] (FLINK-18989) Write input and output channel state to separate files

Roman Khachatryan created FLINK-18989: - Summary: Write input and output channel state to separate files Key: FLINK-18989 URL: https://issues.apache.org/jira/browse/FLINK-18989 Project: Flink

[GitHub] [flink] sjwiesman commented on a change in pull request #13171: [FLINK-18927][python][doc] Add Debugging document in Python Table API

sjwiesman commented on a change in pull request #13171: URL: https://github.com/apache/flink/pull/13171#discussion_r472338737 ## File path: docs/dev/table/python/debugging.md ## @@ -0,0 +1,80 @@ +--- +title: "Debugging" +nav-parent_id: python_tableapi +nav-pos: 130 +--- + +

[GitHub] [flink] sjwiesman commented on a change in pull request #13193: [FLINK-18918][python][docs] Add dedicated connector documentation for Python Table API

sjwiesman commented on a change in pull request #13193: URL: https://github.com/apache/flink/pull/13193#discussion_r472299531 ## File path: docs/dev/python/user-guide/table/python_table_api_connectors.md ## @@ -0,0 +1,194 @@ +--- +title: "Connectors" +nav-parent_id:

[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:

[GitHub] [flink] flinkbot edited a comment on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

flinkbot edited a comment on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-601972922 ## CI report: * 47e6ef886af7cb5e2d43dfb6ce3e4f533457172d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13063: [FLINK-15448] Add Node information to the ResourceId of TaskExecutor …

flinkbot edited a comment on pull request #13063: URL: https://github.com/apache/flink/pull/13063#issuecomment-668948742 ## CI report: * b5846b825b766f68e81d0587bf933a61a3805776 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

flinkbot edited a comment on pull request #11469: URL: https://github.com/apache/flink/pull/11469#issuecomment-601972922 ## CI report: * 47e6ef886af7cb5e2d43dfb6ce3e4f533457172d Azure:

  1   2   3   4   >