swuferhong opened a new pull request, #20994:
URL: https://github.com/apache/flink/pull/20994
## What is the purpose of the change
This pr is aims to let FileSystemTableSource implements
LookupTableSource。This pr designs FileSystemRowDataLookupFunction which extends
the new Looku
[
https://issues.apache.org/jira/browse/FLINK-18436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18436:
---
Labels: pull-request-available (was: )
> how to implement the class `MyTupleReducer`in flin
flinkbot commented on PR #20994:
URL: https://github.com/apache/flink/pull/20994#issuecomment-1272475083
## CI report:
* 61fe1ed555220c3dd1c866eadda1995f8914701f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-29552:
---
Assignee: zhangjingcun
> Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and DAYOFFEEK
[
https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614637#comment-17614637
]
lincoln lee commented on FLINK-29498:
-
[~eric.xiao] the retry feature is implemented
masteryhx commented on code in PR #20965:
URL: https://github.com/apache/flink/pull/20965#discussion_r990748412
##
flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java:
##
@@ -251,6 +254,8 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29244:
---
Labels: pull-request-available (was: )
> Add metric lastMaterializationDuration to Changel
[
https://issues.apache.org/jira/browse/FLINK-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614639#comment-17614639
]
Hangxiang Yu commented on FLINK-29244:
--
Sure, Thanks for your pr!
I have linked yo
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614642#comment-17614642
]
Hangxiang Yu commented on FLINK-29545:
--
Hi, Could you provide more information abou
liuyongvs commented on PR #20992:
URL: https://github.com/apache/flink/pull/20992#issuecomment-1272481474
fix compile error of master branch
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_apis/build/builds/41754/logs/16
--
This is an automated message from the Ap
[
https://issues.apache.org/jira/browse/FLINK-29539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-29539:
-
Assignee: Carlos Castro
> dnsPolicy in FlinkPod is not overridable
> -
masteryhx commented on code in PR #20975:
URL: https://github.com/apache/flink/pull/20975#discussion_r990751814
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/SequenceNumberRange.java:
##
@@ -29,7 +29,7 @@ public interface SequenceNumberRange {
long
hehuiyuan opened a new pull request, #20995:
URL: https://github.com/apache/flink/pull/20995
## What is the purpose of the change
Support unix_timestamp built-in function in Table API.
## Brief change log
Support unix_timestamp built-in functions in Table API.
Support unix_t
hehuiyuan created FLINK-29553:
-
Summary: Support UNIX_TIMESTAMP in Table API
Key: FLINK-29553
URL: https://issues.apache.org/jira/browse/FLINK-29553
Project: Flink
Issue Type: Improvement
flinkbot commented on PR #20995:
URL: https://github.com/apache/flink/pull/20995#issuecomment-1272486919
## CI report:
* 6c27f147467e8e5fa8af27359e92545315e919e9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29553:
---
Labels: pull-request-available (was: )
> Support UNIX_TIMESTAMP in Table API
> ---
[ https://issues.apache.org/jira/browse/FLINK-29050 ]
Nagaraj Tantri deleted comment on FLINK-29050:
was (Author: nagarajtantri):
Hi, can I work on this?
> [JUnit5 Migration] Module: flink-hadoop-compatibility
>
dianfu closed pull request #20993: [FLINK-29552][doc]Fix documentation usage
examples for DAYOFYEAR, DAYOFMONTH, and DAYOFFEEK functions
URL: https://github.com/apache/flink/pull/20993
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-29552.
---
Fix Version/s: 1.17.0
1.16.1
Resolution: Fixed
Merged to
- master via c0df986333ab
[
https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-29552:
Summary: Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and
DAYOFWEEK functions (was: Fix do
Jingsong Lee created FLINK-29554:
Summary: Add partial-update.ignore-delete option to avoid
exception after join
Key: FLINK-29554
URL: https://issues.apache.org/jira/browse/FLINK-29554
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29554:
Assignee: Jingsong Lee
> Add partial-update.ignore-delete option to avoid exception after
JingsongLi opened a new pull request, #311:
URL: https://github.com/apache/flink-table-store/pull/311
When the partial update input is a normal database cdc input, it can work
normally as long as there is no delete data.
However, if a join is performed previously, the join node in fli
[
https://issues.apache.org/jira/browse/FLINK-29554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29554:
---
Labels: pull-request-available (was: )
> Add partial-update.ignore-delete option to avoid e
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou commented on FLINK-29545:
---
1， yes, I have debug this task to many ti
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:11 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:22 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/9/22 9:27 AM:
--
qingwei91 commented on PR #20140:
URL: https://github.com/apache/flink/pull/20140#issuecomment-1272509188
@flinkbot run azure
--
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 the specific comment.
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614698#comment-17614698
]
xiaogang zhou commented on FLINK-29545:
---
I tried to get some info when block happ
liwei li created FLINK-29555:
Summary: GlobalStreamingCommitterHandler not call
notifyCheckpointCompleted after endOfInput
Key: FLINK-29555
URL: https://issues.apache.org/jira/browse/FLINK-29555
Project:
[
https://issues.apache.org/jira/browse/FLINK-29555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
liwei li updated FLINK-29555:
-
Description:
env:
Flink 1.14.3
{code:java}
EnvironmentSettings.Builder settingsBuilder = Environment
lsyldliu opened a new pull request, #20996:
URL: https://github.com/apache/flink/pull/20996
## What is the purpose of the change
Improving adaptive hash join by using sort-merge join strategy per partition
instead of all partitions
## Brief change log
- *Improving
[
https://issues.apache.org/jira/browse/FLINK-29551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29551:
---
Labels: pull-request-available (was: )
> Improving adaptive hash join by using sort merge j
flinkbot commented on PR #20996:
URL: https://github.com/apache/flink/pull/20996#issuecomment-1272523220
## CI report:
* 45246b4fa4b05a55cbff2c29a0233ab9790b4780 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990791541
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date: 2022-10-
godfreyhe commented on PR #574:
URL: https://github.com/apache/flink-web/pull/574#issuecomment-1272547331
> Some nits on links
Thanks for the review~
--
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
gyfora commented on code in PR #394:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r990795976
##
docs/content/docs/custom-resource/reference.md:
##
@@ -251,6 +261,7 @@ This page serves as a full reference for FlinkDeployment
custom resource defin
godfreyhe commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990798648
##
_posts/2022-10-10-1.16-announcement.md:
##
@@ -0,0 +1,401 @@
+---
+layout: post
+title: "Announcing the Release of Apache Flink 1.16"
+subtitle: ""
+date: 2022-10-
flinkbot commented on PR #20997:
URL: https://github.com/apache/flink/pull/20997#issuecomment-1272559812
## CI report:
* ab8ea0b88dcaf06f8249d20945c7f57b904c5c78 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora merged PR #377:
URL: https://github.com/apache/flink-kubernetes-operator/pull/377
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr
gyfora merged PR #393:
URL: https://github.com/apache/flink-kubernetes-operator/pull/393
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614724#comment-17614724
]
Eugene Koblov commented on FLINK-27344:
---
Paul, do you have more details on exact s
[
https://issues.apache.org/jira/browse/FLINK-29507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29507:
---
Labels: pull-request-available (was: )
> Make e2e tests independent of the current director
[
https://issues.apache.org/jira/browse/FLINK-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-28979.
--
Resolution: Fixed
merged to main 62eb68c812713378f7f66fde01cf14370a2252e4
> Add another owner into th
[
https://issues.apache.org/jira/browse/FLINK-29507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-29507.
--
Resolution: Fixed
merged to main 39a275f4f4c306061d37991644f81e4625737e93
> Make e2e tests independen
[
https://issues.apache.org/jira/browse/FLINK-28979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28979:
---
Fix Version/s: kubernetes-operator-1.3.0
> Add another owner into the JM deployment's owner referenc
tweise merged PR #20215:
URL: https://github.com/apache/flink/pull/20215
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-27479.
--
Resolution: Fixed
> HybridSource refreshes availability future
> -
[
https://issues.apache.org/jira/browse/FLINK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-27479:
-
Fix Version/s: (was: 1.15.3)
> HybridSource refreshes availability future
>
Luochg created FLINK-29556:
--
Summary: flink sql 执行过程报java.lang.NullPointerException异常
Key: FLINK-29556
URL: https://issues.apache.org/jira/browse/FLINK-29556
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: flink sql 执行过程报implicit type conversion between BIGINT and
VARCHAR(2147483647) is not supported on
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: implicit type conversion between BIGINT and VARCHAR(2147483647) is
not supported on join's conditio
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Summary: Flink Sql: implicit type conversion between BIGINT and
VARCHAR(2147483647) is not supported on join
[
https://issues.apache.org/jira/browse/FLINK-29497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614743#comment-17614743
]
Thomas Weise commented on FLINK-29497:
--
Hi [~chesnay] , at the moment we are using
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614744#comment-17614744
]
Luochg commented on FLINK-29556:
!image-2022-10-10-00-40-03-422.png!
> Flink Sql: impli
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: image-2022-10-10-00-40-03-422.png
> Flink Sql: implicit type conversion between BIGINT and VARCH
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614744#comment-17614744
]
Luochg edited comment on FLINK-29556 at 10/9/22 4:42 PM:
-
*table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin 中脚本如下
首先创建一些临时表：
%flink
val table = btenv.sqlQuery("""
select a.agentcode,b.upage
[ https://issues.apache.org/jira/browse/FLINK-29556 ]
Luochg deleted comment on FLINK-29556:
was (Author: JIRAUSER296715):
*table b_186_P2:*
!image-2022-10-10-00-42-29-986.png!
*table b_186_P2_1:*
!image-2022-10-10-00-41-18-313.png!
*Error In
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin 中脚本如下
首先创建一些临时表：
%flink
val table = btenv.sqlQuery("""
select a.agentcode,b.upage
tweise opened a new pull request, #20998:
URL: https://github.com/apache/flink/pull/20998
## What is the purpose of the change
Adds a maven property to control publishing of the flink-dist jar. By
default the jar file isn't published, retaining the existing behavior.
Publishing can b
[
https://issues.apache.org/jira/browse/FLINK-29497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29497:
---
Labels: pull-request-available (was: )
> Provide an option to publish the flink-dist jar fi
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: image-2022-10-10-00-47-58-672.png
image-2022-10-10-00-47-38-627.png
Descrip
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary view first：
%flink
val table = btenv.sqlQu
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
flinkbot commented on PR #20998:
URL: https://github.com/apache/flink/pull/20998#issuecomment-1272582996
## CI report:
* e0846a7213873e458e898e710d53f4519d97b27f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Environment: Flink 1.13.6, Apache Zeppelin, Mysql
> Flink Sql: implicit type conversion between BIGINT and V
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
[样式|https://issues.apache.org/jira/projects/FLINK/issues/FLINK-29556?filter=allopenissues#]Zepp
darenwkt opened a new pull request, #8:
URL: https://github.com/apache/flink-connector-dynamodb/pull/8
Added license check as maven plugin to be used in ci workflow for license
check.
Added Download Flink Binary to ci workflow to use flink-ci-tools package.
--
This is an automa
MartijnVisser commented on code in PR #20997:
URL: https://github.com/apache/flink/pull/20997#discussion_r990828362
##
flink-connectors/flink-sql-connector-hive-2.3.9/pom.xml:
##
@@ -48,7 +45,7 @@ under the License.
org.apache.hive
MartijnVisser commented on PR #20994:
URL: https://github.com/apache/flink/pull/20994#issuecomment-1272611408
Does this really make sense for the filesource? I can envision that having a
scanned index access for a filesystem isn't exactly the most resource or
solution friendly solution.
MartijnVisser commented on PR #20170:
URL: https://github.com/apache/flink/pull/20170#issuecomment-1272611849
@flinkbot run azure
--
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 the specific comm
MartijnVisser commented on PR #20980:
URL: https://github.com/apache/flink/pull/20980#issuecomment-1272613196
@syhily Thanks, I've made the changes. Please check again, I'll wait for CI
to pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please
snuyanzin commented on PR #20410:
URL: https://github.com/apache/flink/pull/20410#issuecomment-1272641859
rebased to solve conflicts
--
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 the specific c
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
%flink
val table = btenv.sqlQ
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val tabl
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Attachment: screenshot-1.png
> Flink Sql: implicit type conversion between BIGINT and VARCHAR(2147483647) is
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interprete
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first：
{code:java}
%flink
val table
[
https://issues.apache.org/jira/browse/FLINK-29556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luochg updated FLINK-29556:
---
Description:
Zeppelin Flink Interpreter
Create some temporary views first：
{code:java}
%flink
val table
RocMarshal commented on PR #20989:
URL: https://github.com/apache/flink/pull/20989#issuecomment-1272681554
@gaoyunhaii Could you help to check it ? thx~
--
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
luoyuxia opened a new pull request, #20999:
URL: https://github.com/apache/flink/pull/20999
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them o
[
https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29408:
---
Labels: pull-request-available test-stability (was: test-stability)
> HiveCatalogITCase fai
flinkbot commented on PR #20999:
URL: https://github.com/apache/flink/pull/20999#issuecomment-1272697175
## CI report:
* cfe704b280ba4978c70a6f7df1a192c5d04d0b8d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
klion26 commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r990876505
##
_config.yml:
##
@@ -73,6 +73,22 @@ FLINK_TABLE_STORE_GITHUB_REPO_NAME: flink-table-store
# md1_url:
https://repo.maven.apache.org/maven2/org/apache/flink/f
yunfengzhou-hub commented on code in PR #156:
URL: https://github.com/apache/flink-ml/pull/156#discussion_r990872536
##
docs/content/docs/operators/feature/vectorassembler.md:
##
@@ -156,12 +160,13 @@ input_data_table = t_env.from_data_stream(
[DenseVectorTypeInfo()
[
https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614666#comment-17614666
]
xiaogang zhou edited comment on FLINK-29545 at 10/10/22 2:01 AM:
-
zhipeng93 commented on PR #161:
URL: https://github.com/apache/flink-ml/pull/161#issuecomment-1272706717
Thanks for the update. Merging
--
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 the specifi
zhipeng93 merged PR #161:
URL: https://github.com/apache/flink-ml/pull/161
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
tsreaper merged PR #310:
URL: https://github.com/apache/flink-table-store/pull/310
--
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 the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@fl
[
https://issues.apache.org/jira/browse/FLINK-29297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29297.
---
> Group Table Store file writers into SingleFileWriter and RollingFileWriter
> -
[
https://issues.apache.org/jira/browse/FLINK-29293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29293:
---
Assignee: Caizhi Weng
> Introduce a MergeFunction for full compaction
> ---
tsreaper opened a new pull request, #312:
URL: https://github.com/apache/flink-table-store/pull/312
We need to introduce a special `MergeFunction` to produce changelogs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
1 - 100 of 123 matches
Mail list logo
