zhuzhurk commented on issue #10264: [FLINK-14811][runtime] Replace Java Streams
in input check methods with for-loops
URL: https://github.com/apache/flink/pull/10264#issuecomment-557080911
Thanks a lot for merging the changes! @zentol
flinkbot edited a comment on issue #10278: [FLINK-14735][scheduler] Improve
scheduling of all-to-all partitions with ALL input constraint for legacy
scheduler
URL: https://github.com/apache/flink/pull/10278#issuecomment-557049375
## CI report:
*
flinkbot commented on issue #10280: [FLINK-14891][python] Set the default
chaining strategy to ALWAYS for Python operators
URL: https://github.com/apache/flink/pull/10280#issuecomment-557080349
## CI report:
* 87d9b9c26d73f9ea20dabdd88c73e802c0c9c7fc : UNKNOWN
Bot
flinkbot edited a comment on issue #10279: [FLINK-14888][python] Move the
Python SqlDialect to module table
URL: https://github.com/apache/flink/pull/10279#issuecomment-557069220
## CI report:
* d2cf3979637d5cccb190c5ceff376aee262359ad : PENDING
flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support
for managing environment and dependencies of Python UDF in Flink Python API
URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394
## CI report:
*
zhuzhurk commented on issue #10278: [FLINK-14735][scheduler] Improve scheduling
of all-to-all partitions with ALL input constraint for legacy scheduler
URL: https://github.com/apache/flink/pull/10278#issuecomment-557079589
Thanks for addressing the comments.
The change looks good to me.
[
https://issues.apache.org/jira/browse/FLINK-14811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-14811.
Fix Version/s: 1.10.0
Resolution: Fixed
master:
zentol merged pull request #10264: [FLINK-14811][runtime] Replace Java Streams
in input check methods with for-loops
URL: https://github.com/apache/flink/pull/10264
This is an automated message from the Apache Git Service.
zentol commented on issue #10264: [FLINK-14811][runtime] Replace Java Streams
in input check methods with for-loops
URL: https://github.com/apache/flink/pull/10264#issuecomment-557077402
Will merge this excluding the checkstyle changes as they are covered in
#10278
StephanEwen commented on issue #10278: [FLINK-14735][scheduler] Improve
scheduling of all-to-all partitions with ALL input constraint for legacy
scheduler
URL: https://github.com/apache/flink/pull/10278#issuecomment-557077221
@zhuzhurk I addressed your suggestion in the latest commit.
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349066710
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349073315
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349056397
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349069913
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349069315
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349062555
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349071321
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349071375
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349062062
##
File path:
zentol commented on a change in pull request #10236: [FLINK-14703][e2e] Port
the Kafka SQL related tests.
URL: https://github.com/apache/flink/pull/10236#discussion_r349068796
##
File path:
Michel Davit created FLINK-14896:
Summary: Kinesis connector doesn't shade jackson dependency
Key: FLINK-14896
URL: https://issues.apache.org/jira/browse/FLINK-14896
Project: Flink
Issue
kl0u closed pull request #10251: [FLINK-14851][FLINK-14850] Implement Executors
and wire them to the ContextEnvironment
URL: https://github.com/apache/flink/pull/10251
This is an automated message from the Apache Git
kl0u commented on issue #10251: [FLINK-14851][FLINK-14850] Implement Executors
and wire them to the ContextEnvironment
URL: https://github.com/apache/flink/pull/10251#issuecomment-557074142
Merged! Thanks for the reviews!
[
https://issues.apache.org/jira/browse/FLINK-14850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979254#comment-16979254
]
Kostas Kloudas commented on FLINK-14850:
All yours [~tison]! :)
> Refactor Executor interface
[
https://issues.apache.org/jira/browse/FLINK-14850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-14850.
--
Fix Version/s: 1.10.0
Resolution: Fixed
Merged with
[
https://issues.apache.org/jira/browse/FLINK-14851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-14851.
--
Fix Version/s: 1.10.0
Resolution: Fixed
Merged with
Leonard Xu created FLINK-14895:
--
Summary: same rank in rollup row with group row that all group key
are null
Key: FLINK-14895
URL: https://issues.apache.org/jira/browse/FLINK-14895
Project: Flink
flinkbot edited a comment on issue #10221: [1.9][FLINK-14104][build] Add opt-in
jackson 2.10.1 profile
URL: https://github.com/apache/flink/pull/10221#issuecomment-554361057
## CI report:
* cfdc60b82dc0521d36f743bebb03427566cb45da : SUCCESS
Gary Yao created FLINK-14894:
Summary: HybridOffHeapUnsafeMemorySegmentTest#testByteBufferWrap
failed on Travis
Key: FLINK-14894
URL: https://issues.apache.org/jira/browse/FLINK-14894
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979249#comment-16979249
]
Piotr Nowojski commented on FLINK-14845:
[~kevin.cyj], I think I would prefer the 3rd option,
WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for
managing environment and dependencies of Python UDF in Flink Python API
URL: https://github.com/apache/flink/pull/10017#issuecomment-557070280
@dianfu Thanks for your review! I have addressed your comments. Please
WeiZhong94 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r349065035
##
File path:
flinkbot commented on issue #10279: [FLINK-14888][python] Move the Python
SqlDialect to module table
URL: https://github.com/apache/flink/pull/10279#issuecomment-557069220
## CI report:
* d2cf3979637d5cccb190c5ceff376aee262359ad : UNKNOWN
Bot commands
The
WeiZhong94 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r349063667
##
File path:
hailong wang created FLINK-14893:
Summary: Using Child ClassLoader to load class when Parent
ClassLoader couldn't load in ParentFirstPatterns
Key: FLINK-14893
URL:
flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support
for managing environment and dependencies of Python UDF in Flink Python API
URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394
## CI report:
*
flinkbot edited a comment on issue #10269: [FLINK-14876]Putting xercesImpl
related classes into alwaysParentFirstLoaderPatterns to avoid conflicts
URL: https://github.com/apache/flink/pull/10269#issuecomment-555964079
## CI report:
* caaddea342d2bc7d4483baae51525d903d5166d7 :
zhuzhurk commented on a change in pull request #10278: [FLINK-14735][scheduler]
Improve scheduling of all-to-all partitions with ALL input constraint for
legacy scheduler
URL: https://github.com/apache/flink/pull/10278#discussion_r349063148
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-14886.
--
Fix Version/s: (was: 1.9.2)
(was: 1.10.0)
Resolution: Not A Problem
WeiZhong94 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r349062753
##
File path:
flinkbot commented on issue #10280: [FLINK-14891][python] Set the default
chaining strategy to ALWAYS for Python operators
URL: https://github.com/apache/flink/pull/10280#issuecomment-557067427
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
StephanEwen commented on a change in pull request #10278:
[FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL
input constraint for legacy scheduler
URL: https://github.com/apache/flink/pull/10278#discussion_r349061322
##
File path:
dianfu opened a new pull request #10280: [FLINK-14891][python] Set the default
chaining strategy to ALWAYS for Python operators
URL: https://github.com/apache/flink/pull/10280
## What is the purpose of the change
*This pull request set the default chaining strategy to ALWAYS for
[
https://issues.apache.org/jira/browse/FLINK-14891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14891:
---
Labels: pull-request-available (was: )
> PythonScalarFunctionOperator should be chained
[
https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979239#comment-16979239
]
Congxian Qiu(klion26) commented on FLINK-14892:
---
[~sewen] as you're the owner of
StephanEwen commented on a change in pull request #10278:
[FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL
input constraint for legacy scheduler
URL: https://github.com/apache/flink/pull/10278#discussion_r349059986
##
File path:
WeiZhong94 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r349060205
##
File path:
Congxian Qiu(klion26) created FLINK-14892:
-
Summary: Add description for checkpoint directory layout
Key: FLINK-14892
URL: https://issues.apache.org/jira/browse/FLINK-14892
Project: Flink
Dian Fu created FLINK-14891:
---
Summary: PythonScalarFunctionOperator should be chained with
upstream operators by default
Key: FLINK-14891
URL: https://issues.apache.org/jira/browse/FLINK-14891
Project:
WeiZhong94 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r349058826
##
File path:
aljoscha commented on issue #10269: [FLINK-14876]Putting xercesImpl related
classes into alwaysParentFirstLoaderPatterns to avoid conflicts
URL: https://github.com/apache/flink/pull/10269#issuecomment-557064645
@flinkbot run travis
[
https://issues.apache.org/jira/browse/FLINK-14876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-14876:
Assignee: liupengcheng
> Putting xercesImpl related classes into
[
https://issues.apache.org/jira/browse/FLINK-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-14746.
Fix Version/s: 1.10.0
Assignee: David Moravek
Resolution: Fixed
Merged on
zhuzhurk commented on a change in pull request #10278: [FLINK-14735][scheduler]
Improve scheduling of all-to-all partitions with ALL input constraint for
legacy scheduler
URL: https://github.com/apache/flink/pull/10278#discussion_r349057067
##
File path:
zhuzhurk commented on a change in pull request #10278: [FLINK-14735][scheduler]
Improve scheduling of all-to-all partitions with ALL input constraint for
legacy scheduler
URL: https://github.com/apache/flink/pull/10278#discussion_r349040805
##
File path:
aljoscha merged pull request #10175: [FLINK-14746][web] Handle uncaught
exceptions in HistoryServerArchive…
URL: https://github.com/apache/flink/pull/10175
This is an automated message from the Apache Git Service.
To
aljoscha commented on issue #10175: [FLINK-14746][web] Handle uncaught
exceptions in HistoryServerArchive…
URL: https://github.com/apache/flink/pull/10175#issuecomment-557063871
Thanks for your work! I'm merging.
This is
aljoscha commented on a change in pull request #10175: [FLINK-14746][web]
Handle uncaught exceptions in HistoryServerArchive…
URL: https://github.com/apache/flink/pull/10175#discussion_r349057762
##
File path:
leonardBang commented on issue #10239: [Flink-11491][Test] Support all TPC-DS
queries
URL: https://github.com/apache/flink/pull/10239#issuecomment-557064038
@StephanEwen Thanks for your careful review, I learn so much and Will
address comments soon.
flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate
shared slot resources respecting the resources of all vertices in the group
URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330
## CI report:
* b62006e7cf875fa318b3ce57afb14b0b2679bcb5
leonardBang commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349057023
##
File path:
flinkbot edited a comment on issue #10221: [1.9][FLINK-14104][build] Add opt-in
jackson 2.10.1 profile
URL: https://github.com/apache/flink/pull/10221#issuecomment-554361057
## CI report:
* cfdc60b82dc0521d36f743bebb03427566cb45da : SUCCESS
leonardBang commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349055343
##
File path:
leonardBang commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349055286
##
File path:
leonardBang commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349054910
##
File path:
leonardBang commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349054809
##
File path: flink-end-to-end-tests/flink-tpcds-test/pom.xml
##
@@ -0,0 +1,84 @@
+
+
zentol commented on issue #10221: [1.9][FLINK-14104][build] Add opt-in jackson
2.10.1 profile
URL: https://github.com/apache/flink/pull/10221#issuecomment-557060301
@flinkbot run travis
This is an automated message from the
flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support
partition for temporary table
URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939
## CI report:
* 4937b8b139bab4957799947b841fb1ae3758ed48 : FAILURE
aljoscha commented on issue #10005: [FLINK-14533][flink-table-planner] Fix
LOWER/UPPER not being pushed down to TableSource
URL: https://github.com/apache/flink/pull/10005#issuecomment-557059308
@YuvalItzchakov Any news?
flinkbot edited a comment on issue #10278: [FLINK-14735][scheduler] Improve
scheduling of all-to-all partitions with ALL input constraint for legacy
scheduler
URL: https://github.com/apache/flink/pull/10278#issuecomment-557049375
## CI report:
*
flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support
for managing environment and dependencies of Python UDF in Flink Python API
URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394
## CI report:
*
flinkbot edited a comment on issue #10270: [FLINK-14672][sql-client] Make
Executor stateful in sql client
URL: https://github.com/apache/flink/pull/10270#issuecomment-555974946
## CI report:
* 4b5c6f4491d27b2ac16b571e3b92ce96c02c4a9a : SUCCESS
flinkbot commented on issue #10279: [FLINK-14888][python] Move the Python
SqlDialect to module table
URL: https://github.com/apache/flink/pull/10279#issuecomment-557058047
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
[
https://issues.apache.org/jira/browse/FLINK-14888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14888:
---
Labels: pull-request-available (was: )
> Move the Python SqlDialect to module table
>
Jun Qin created FLINK-14890:
---
Summary: TestHarness for KeyedBroadcastProcessFunction
Key: FLINK-14890
URL: https://issues.apache.org/jira/browse/FLINK-14890
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979222#comment-16979222
]
Chesnay Schepler commented on FLINK-13749:
--
[~aljoscha] This change implies that the client now
HuangXingBo opened a new pull request #10279: [FLINK-14888][python] Move the
Python SqlDialect to module table
URL: https://github.com/apache/flink/pull/10279
## What is the purpose of the change
*Currently SqlDialect is located in pyflink.common which is not correct as
it belongs
lamber-ken edited a comment on issue #10228: [FLINK-14816] Add thread dump
feature for taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557055299
> Okay, then let's drop the changes to files from the old UI.
But I don't think the changes will affect the
lamber-ken edited a comment on issue #10228: [FLINK-14816] Add thread dump
feature for taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557055299
> Okay, then let's drop the changes to files from the old UI.
But I don't think the changes will affect the
lamber-ken edited a comment on issue #10228: [FLINK-14816] Add thread dump
feature for taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557055299
> Okay, then let's drop the changes to files from the old UI.
But I don't think the changes will affect the
lamber-ken edited a comment on issue #10228: [FLINK-14816] Add thread dump
feature for taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557055299
> Okay, then let's drop the changes to files from the old UI.
But I don't think the changes will affect the
lamber-ken commented on issue #10228: [FLINK-14816] Add thread dump feature for
taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557055299
> Okay, then let's drop the changes to files from the old UI.
But I don't think the changes will affect the deletion of
[
https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979219#comment-16979219
]
Yingjie Cao commented on FLINK-14818:
-
I found there seems no very straightforward way to achieve
flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate
shared slot resources respecting the resources of all vertices in the group
URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330
## CI report:
* b62006e7cf875fa318b3ce57afb14b0b2679bcb5
flinkbot edited a comment on issue #10221: [1.9][FLINK-14104][build] Add opt-in
jackson 2.10.1 profile
URL: https://github.com/apache/flink/pull/10221#issuecomment-554361057
## CI report:
* cfdc60b82dc0521d36f743bebb03427566cb45da : SUCCESS
StephanEwen commented on issue #10228: [FLINK-14816] Add thread dump feature
for taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557052909
Okay, then let's drop the changes to files from the old UI.
lamber-ken edited a comment on issue #10228: [FLINK-14816] Add thread dump
feature for taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557052392
> We shouldn't be modifying the old UI. There's no reasonable way for us to
review this change.
> Given that no
lamber-ken commented on issue #10228: [FLINK-14816] Add thread dump feature for
taskmanager
URL: https://github.com/apache/flink/pull/10228#issuecomment-557052392
> We shouldn't be modifying the old UI. There's no reasonable way for us to
review this change.
> Given that no issues were
[
https://issues.apache.org/jira/browse/FLINK-14725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-14725:
-
Fix Version/s: (was: 1.10.0)
> Remove unused (anymore)
[
https://issues.apache.org/jira/browse/FLINK-14872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979191#comment-16979191
]
Yingjie Cao commented on FLINK-14872:
-
[~pnowojski] They are relevant and the causes are similar
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349034992
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349034936
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349034271
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349033738
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349041294
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349034789
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349040376
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349033380
##
File path:
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349032905
##
File path: flink-end-to-end-tests/flink-tpcds-test/pom.xml
##
@@ -0,0 +1,84 @@
+
+
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test]
Support all TPC-DS queries
URL: https://github.com/apache/flink/pull/10239#discussion_r349038631
##
File path:
401 - 500 of 635 matches
Mail list logo
