[
https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187499#comment-17187499
]
Till Rohrmann commented on FLINK-19022:
---
[~tartarus] this is what the underlying {
flinkbot edited a comment on pull request #13283:
URL: https://github.com/apache/flink/pull/13283#issuecomment-683593514
## CI report:
* 8637f1ba5ea426d9f20777bc03b6d15cd78f8d06 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
WeiZhong94 commented on a change in pull request #13273:
URL: https://github.com/apache/flink/pull/13273#discussion_r479937040
##
File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.zh.md
##
@@ -0,0 +1,719 @@
+---
+title: "10分钟入门Table API"
+nav-parent_id: python
MarkSfik commented on a change in pull request #373:
URL: https://github.com/apache/flink-web/pull/373#discussion_r479937420
##
File path: _posts/2020-09-01-flink-1.11-memory-management-improvements.md
##
@@ -0,0 +1,66 @@
+---
+layout: post
+title: "Memory Management improvemen
Shuiqiang Chen created FLINK-19097:
--
Summary: Support add_jar() for Python DataStream API
Key: FLINK-19097
URL: https://issues.apache.org/jira/browse/FLINK-19097
Project: Flink
Issue Type: I
MarkSfik commented on a change in pull request #373:
URL: https://github.com/apache/flink-web/pull/373#discussion_r479939254
##
File path: _posts/2020-09-01-flink-1.11-memory-management-improvements.md
##
@@ -0,0 +1,66 @@
+---
+layout: post
+title: "Memory Management improvemen
MarkSfik commented on a change in pull request #373:
URL: https://github.com/apache/flink-web/pull/373#discussion_r479940171
##
File path: _posts/2020-09-01-flink-1.11-memory-management-improvements.md
##
@@ -0,0 +1,66 @@
+---
+layout: post
+title: "Memory Management improvemen
carp84 commented on pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-683607502
Thanks for sharing the thoughts @billyrrr , and sure let's discuss more
about it (and sorry for the late response, busy preparing for this year's
Singles' Day recently).
MarkSfik commented on a change in pull request #373:
URL: https://github.com/apache/flink-web/pull/373#discussion_r479940629
##
File path: _posts/2020-09-01-flink-1.11-memory-management-improvements.md
##
@@ -0,0 +1,66 @@
+---
+layout: post
+title: "Memory Management improvemen
dianfu commented on a change in pull request #13273:
URL: https://github.com/apache/flink/pull/13273#discussion_r479714609
##
File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.md
##
@@ -0,0 +1,719 @@
+---
+title: "10 Minutes to Table API"
+nav-parent_id: pytho
[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187510#comment-17187510
]
Jark Wu commented on FLINK-19064:
-
>From the definition of {{configure()}}, it dosn't op
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187511#comment-17187511
]
Timo Walther commented on FLINK-19076:
--
[~Leonard Xu] could you add a description t
MarkSfik commented on a change in pull request #373:
URL: https://github.com/apache/flink-web/pull/373#discussion_r479944151
##
File path: _posts/2020-09-01-flink-1.11-memory-management-improvements.md
##
@@ -0,0 +1,66 @@
+---
+layout: post
+title: "Memory Management improvemen
[
https://issues.apache.org/jira/browse/FLINK-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19097:
---
Component/s: (was: API / DataStream)
API / Python
> Support add_jar() f
[
https://issues.apache.org/jira/browse/FLINK-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19097:
---
Summary: Support add_jar() for Python StreamExecutionEnvironment (was:
Support add_jar() fo
[
https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-19093:
-
Assignee: Roman Khachatryan
> "Elasticsearch (v6.3.1) sink end-to-end test" fai
Brian Zhou created FLINK-19098:
--
Summary: Make Rowdata converters public
Key: FLINK-19098
URL: https://issues.apache.org/jira/browse/FLINK-19098
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187518#comment-17187518
]
Brian Zhou commented on FLINK-19098:
Notify the author of FLINK-16048 [~danny0405] t
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187533#comment-17187533
]
Leonard Xu commented on FLINK-19076:
[~twalthr] Sure, I'll add description for all s
azagrebin closed pull request #13265:
URL: https://github.com/apache/flink/pull/13265
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
zouwenlong created FLINK-19099:
--
Summary: consumer kafka message repeat
Key: FLINK-19099
URL: https://issues.apache.org/jira/browse/FLINK-19099
Project: Flink
Issue Type: Bug
Component
twalthr commented on pull request #13144:
URL: https://github.com/apache/flink/pull/13144#issuecomment-683629016
Sorry, for the late response. I was on vacation. I will leave some final
feedback that we can address in FLINK-15854. Are you also taking care of this
issue @lirui-apache?
---
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19076:
---
Description:
Temporal join is a correlate, the right of correlate is a *Snapshot*, the
*period* of
[
https://issues.apache.org/jira/browse/FLINK-19055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin closed FLINK-19055.
---
Resolution: Fixed
merged into master by 6a80de22185ed8de291b766e24739ead8a94175e
merged into
[
https://issues.apache.org/jira/browse/FLINK-14964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187540#comment-17187540
]
Till Rohrmann commented on FLINK-14964:
---
It looks as if FLINK-13938 already solves
twalthr commented on a change in pull request #13144:
URL: https://github.com/apache/flink/pull/13144#discussion_r479965411
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveScalarFunction.java
##
@@ -104,4 +114,66 @@ p
flinkbot edited a comment on pull request #13122:
URL: https://github.com/apache/flink/pull/13122#issuecomment-672466736
## CI report:
* 1c448cfcac75bd818b6d8e1609f891418d892b7c Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
tzulitai opened a new pull request #136:
URL: https://github.com/apache/flink-statefun/pull/136
This reworks the `registerValue` / `registerTable` etc. methods on
`PersistedStateRegistry` to directly accept a constructed `PersistedValue` /
`PersistedTable` instance. This allows us to avoid
[
https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187547#comment-17187547
]
Leonard Xu edited comment on FLINK-18548 at 8/31/20, 8:11 AM:
[
https://issues.apache.org/jira/browse/FLINK-19096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19096:
---
Labels: pull-request-available (was: )
> Simplify PersistedStateRegistry state registration
[
https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187547#comment-17187547
]
Leonard Xu commented on FLINK-18548:
Calcite has limitation with Snapshot node, the
[
https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187547#comment-17187547
]
Leonard Xu edited comment on FLINK-18548 at 8/31/20, 8:12 AM:
[
https://issues.apache.org/jira/browse/FLINK-10211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-10211:
Assignee: (was: Timo Walther)
> Time indicators are not correctly materialized for Lo
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187548#comment-17187548
]
Timo Walther commented on FLINK-19076:
--
Thanks. I'm wondering if we will also solve
[
https://issues.apache.org/jira/browse/FLINK-18363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-18363:
Assignee: Dawid Wysakowicz
> Add user classloader to context in DeSerializationSc
tillrohrmann closed pull request #13251:
URL: https://github.com/apache/flink/pull/13251
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 g
[
https://issues.apache.org/jira/browse/FLINK-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14435.
-
Fix Version/s: 1.12.0
Resolution: Fixed
Fixed via 1e89ade01610cd76a71441f7b0cd6f17f40bc67
[
https://issues.apache.org/jira/browse/FLINK-7681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-7681.
---
Resolution: Won't Fix
Closing this because TypeInformation is not used in the Blink planner anymore.
[
https://issues.apache.org/jira/browse/FLINK-19072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19072:
---
Description:
The initial temporal table join (FOR SYSTEM_TIME AS OF) is a Correlate, we need
rewrit
tzulitai commented on pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-683638078
A similar translation specification for StateFun is indeed nice, especially
if we want to move along with this, it would be best to have consensus on what
not to translate
[
https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19073:
---
Description:
Rule that matches a temporal join node and converts it to
[[StreamExecTemporalJoin]],
[
https://issues.apache.org/jira/browse/FLINK-19073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19073:
---
Description:
Improve streamExecTemporalJoinRule that matches a temporal join node and
converts it t
[
https://issues.apache.org/jira/browse/FLINK-19077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19077:
---
Summary: Import process time temporal join operator (was: Improve process
time temporal join operat
[
https://issues.apache.org/jira/browse/FLINK-19077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19077:
---
Description: import *TemporalProcessTimeJoinOperator* for Processing-Time
temporal join.
> Import p
[
https://issues.apache.org/jira/browse/FLINK-19078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19078:
---
Description: import *TemporalRowTimeJoinOperator* for EventTime-Time
temporal join.
> Import rowtim
[
https://issues.apache.org/jira/browse/FLINK-19100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-19100:
-
Summary: Fix note about hadoop dependency in flink-avro (was: Fix note
about hadoop dep
Dawid Wysakowicz created FLINK-19100:
Summary: Fix note about hadoop dependency from flink-avro
Key: FLINK-19100
URL: https://issues.apache.org/jira/browse/FLINK-19100
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187556#comment-17187556
]
Jark Wu commented on FLINK-19076:
-
Hi [~twalthr], we also have another issue FLINK-18651
alpinegizmo commented on a change in pull request #13273:
URL: https://github.com/apache/flink/pull/13273#discussion_r479977187
##
File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.zh.md
##
@@ -0,0 +1,719 @@
+---
+title: "10分钟入门Table API"
+nav-parent_id: pytho
[
https://issues.apache.org/jira/browse/FLINK-19076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187556#comment-17187556
]
Jark Wu edited comment on FLINK-19076 at 8/31/20, 8:30 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19080:
---
Summary: Materialize TimeIndicatorRelDataType in the right input of
temporal join (was: Materialize
[
https://issues.apache.org/jira/browse/FLINK-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19080:
---
Description: The output of temporal join should follow left stream's time
attribute, we should mate
[
https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187558#comment-17187558
]
Jark Wu commented on FLINK-19098:
-
I'm fine with that. But please mark them as {{@Intern
rmetzger commented on a change in pull request #13217:
URL: https://github.com/apache/flink/pull/13217#discussion_r479980792
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/LeaderChangeClusterComponentsTest.java
##
@@ -135,6 +138,8 @@ public v
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187559#comment-17187559
]
Till Rohrmann commented on FLINK-18959:
---
In theory I agree that it would be great
dawidwys commented on pull request #13072:
URL: https://github.com/apache/flink/pull/13072#issuecomment-683647507
Hey @PatrickRen,
I think it would be fine upgrading the avro version for the sql jar. We
could even think of upgrading it straight to the 1.10 version. Again I very
much agr
fa zheng created FLINK-19101:
Summary: The SelectivityEstimator throw an NullPointerException
when convertValueInterval with string type
Key: FLINK-19101
URL: https://issues.apache.org/jira/browse/FLINK-19101
[
https://issues.apache.org/jira/browse/FLINK-19079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-19079:
---
Description:
To convert a insert-only table to versioned table, the recommended way is use
deduplic
[
https://issues.apache.org/jira/browse/FLINK-19101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fa zheng updated FLINK-19101:
-
Description:
For a SQL :
{code:sql}
select t1.a, t2.b from t1 join t2 on t1.b=t2.b and t1.b<'2'
{cod
JingsongLi commented on a change in pull request #13144:
URL: https://github.com/apache/flink/pull/13144#discussion_r479982832
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveScalarFunction.java
##
@@ -104,4 +114,66 @
[
https://issues.apache.org/jira/browse/FLINK-14870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187560#comment-17187560
]
Till Rohrmann commented on FLINK-14870:
---
Sounds like good improvement to me which
[
https://issues.apache.org/jira/browse/FLINK-19101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fa zheng updated FLINK-19101:
-
Description:
For a SQL :
{code:sql}
select t1.a, t2.b from t1 join t2 on t1.b=t2.b and t1.b<'2'
{cod
flinkbot edited a comment on pull request #13209:
URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672
## CI report:
* a343c2c3bf36c97dca7045c65eccbcccfbbef5bf UNKNOWN
* 0ae129370bd5135099c3d195cc36e656f656e35d Azure:
[CANCELED](https://dev.azure.com/apache-f
dianfu commented on a change in pull request #13273:
URL: https://github.com/apache/flink/pull/13273#discussion_r479984221
##
File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.zh.md
##
@@ -0,0 +1,719 @@
+---
+title: "10分钟入门Table API"
+nav-parent_id: python_tab
JingsongLi commented on a change in pull request #13144:
URL: https://github.com/apache/flink/pull/13144#discussion_r479986398
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveScalarFunction.java
##
@@ -104,4 +114,66 @
[
https://issues.apache.org/jira/browse/FLINK-14042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-14042.
Resolution: Won't Fix
All type related issues are fixed by FLIP-65. Since the provided example is
JingsongLi commented on pull request #13144:
URL: https://github.com/apache/flink/pull/13144#issuecomment-683653045
> Sorry, for the late response. I was on vacation. I will leave some final
feedback that we can address in
[FLINK-15854](https://issues.apache.org/jira/browse/FLINK-15854). A
[
https://issues.apache.org/jira/browse/FLINK-15854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-15854:
Assignee: Rui Li
> Use the new type inference for hive udtf
> ---
alpinegizmo commented on a change in pull request #13273:
URL: https://github.com/apache/flink/pull/13273#discussion_r479992426
##
File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.zh.md
##
@@ -0,0 +1,719 @@
+---
+title: "10分钟入门Table API"
+nav-parent_id: pytho
alpinegizmo commented on a change in pull request #13273:
URL: https://github.com/apache/flink/pull/13273#discussion_r479992426
##
File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.zh.md
##
@@ -0,0 +1,719 @@
+---
+title: "10分钟入门Table API"
+nav-parent_id: pytho
rmetzger edited a comment on pull request #12962:
URL: https://github.com/apache/flink/pull/12962#issuecomment-683658725
Thanks for merging this @zhijiangW. I personally believe we should not
backport this to 1.11, as this is not a bugfix, rather a small improvement (but
I understand that
Tzu-Li (Gordon) Tai created FLINK-19102:
---
Summary: Make StateBinder a per-FunctionType entity
Key: FLINK-19102
URL: https://issues.apache.org/jira/browse/FLINK-19102
Project: Flink
Issu
rmetzger commented on pull request #12962:
URL: https://github.com/apache/flink/pull/12962#issuecomment-683658725
Thanks for merging this @zhijiangW. I personally believe we should not
backport this to 1.11, as this is not a bugfix, rather a small improvement.
[
https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187584#comment-17187584
]
Timo Walther commented on FLINK-19038:
--
[~nicholasjiang] yes, we can allow multiple
tzulitai opened a new pull request #137:
URL: https://github.com/apache/flink-statefun/pull/137
This PR is based on top of #136 because it touches a few overlapping classes.
Only last 2 commits are relevant.
---
Prior to this PR, a single `StateBinder` instance handles bindi
[
https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187585#comment-17187585
]
Danny Chen commented on FLINK-19098:
Abstract some common part of the code to reuse
[
https://issues.apache.org/jira/browse/FLINK-19102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19102:
---
Labels: pull-request-available (was: )
> Make StateBinder a per-FunctionType entity
> -
[
https://issues.apache.org/jira/browse/FLINK-19101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187586#comment-17187586
]
Danny Chen commented on FLINK-19101:
You may need to provide the data set of the tab
tillrohrmann commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r479998734
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java
##
@@ -98,14 +101,15 @@ public SchedulerImp
fa zheng created FLINK-19103:
Summary: The PushPartitionIntoTableSourceScanRule will lead a
performance problem when there are still many partitions after pruning
Key: FLINK-19103
URL: https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/FLINK-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fa zheng updated FLINK-19103:
-
Description:
The PushPartitionIntoTableSourceScanRule will obtain new statistic after
pruning, however,
twalthr closed pull request #13257:
URL: https://github.com/apache/flink/pull/13257
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
[
https://issues.apache.org/jira/browse/FLINK-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-18992:
Assignee: Fin-chan
> Table API renameColumns method annotation error
> --
[
https://issues.apache.org/jira/browse/FLINK-18992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-18992.
Fix Version/s: 1.11.2
1.12.0
Resolution: Fixed
Fixed in 1.12.0: 3d290c89
[
https://issues.apache.org/jira/browse/FLINK-18782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187593#comment-17187593
]
Timo Walther commented on FLINK-18782:
--
[~ykt836] is right, FLIP-136 would also sol
[
https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187592#comment-17187592
]
Danny Chen edited comment on FLINK-19099 at 8/31/20, 9:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187592#comment-17187592
]
Danny Chen commented on FLINK-19099:
Before Flink-15221, the SQL Kafka connector onl
[
https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187596#comment-17187596
]
Shuiqiang Chen commented on FLINK-17480:
Hi [~felixzheng], I have managed to run
[
https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187596#comment-17187596
]
Shuiqiang Chen edited comment on FLINK-17480 at 8/31/20, 9:30 AM:
[
https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187596#comment-17187596
]
Shuiqiang Chen edited comment on FLINK-17480 at 8/31/20, 9:31 AM:
zhuzhurk opened a new pull request #13284:
URL: https://github.com/apache/flink/pull/13284
## What is the purpose of the change
This PR is to change blink planner batch jobs to run with pipelined region
scheduling.
Blink planner batch jobs currently corresponds to
ScheduleMode.LA
[
https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187596#comment-17187596
]
Shuiqiang Chen edited comment on FLINK-17480 at 8/31/20, 9:33 AM:
[
https://issues.apache.org/jira/browse/FLINK-19049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187598#comment-17187598
]
Timo Walther commented on FLINK-19049:
--
The test should use {{execInsertSqlAndWaitR
flinkbot commented on pull request #13284:
URL: https://github.com/apache/flink/pull/13284#issuecomment-683674269
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
[
https://issues.apache.org/jira/browse/FLINK-19049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-19049:
Assignee: Timo Walther
> TableEnvironmentImpl.executeInternal() does not wait for the fin
zhuzhurk closed pull request #12540:
URL: https://github.com/apache/flink/pull/12540
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
zhuzhurk commented on pull request #12540:
URL: https://github.com/apache/flink/pull/12540#issuecomment-683675904
Closing it because it is outdated and the underlying slot allocation was
reworked.
A new PR #13284 superseded this one.
[
https://issues.apache.org/jira/browse/FLINK-17480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187596#comment-17187596
]
Shuiqiang Chen edited comment on FLINK-17480 at 8/31/20, 9:45 AM:
[
https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187607#comment-17187607
]
Brian Zhou commented on FLINK-19098:
Thanks Jark and Danny, I can pick up this chang
[
https://issues.apache.org/jira/browse/FLINK-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187608#comment-17187608
]
fa zheng commented on FLINK-19103:
--
It’s not necessary to get statistics of partitions
1 - 100 of 328 matches
Mail list logo
