[GitHub] [flink-statefun-docker] tzulitai closed pull request #6: [FLINK-19107] Add checkpointing and recovery options to template flink-conf.yaml

2020-09-25 Thread GitBox
tzulitai closed pull request #6: URL: https://github.com/apache/flink-statefun-docker/pull/6 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

[GitHub] [flink-statefun-docker] tzulitai closed pull request #7: [FLINK-19019] [docker] Add common filesystem plugins to flink-statefun image

2020-09-25 Thread GitBox
tzulitai closed pull request #7: URL: https://github.com/apache/flink-statefun-docker/pull/7 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

[jira] [Assigned] (FLINK-19407) Translate "Elasticsearch Connector" page of "Connectors" into Chinese

2020-09-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19407: --- Assignee: weixubin > Translate "Elasticsearch Connector" page of "Connectors" into Chinese >

[GitHub] [flink-statefun-docker] tzulitai commented on pull request #7: [FLINK-19019] [docker] Add common filesystem plugins to flink-statefun image

2020-09-25 Thread GitBox
tzulitai commented on pull request #7: URL: https://github.com/apache/flink-statefun-docker/pull/7#issuecomment-698738681 Merging ... This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-statefun-docker] tzulitai commented on pull request #6: [FLINK-19107] Add checkpointing and recovery options to template flink-conf.yaml

2020-09-25 Thread GitBox
tzulitai commented on pull request #6: URL: https://github.com/apache/flink-statefun-docker/pull/6#issuecomment-698738603 Merging ... This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-19389) Error determining python major version to start fileserver during e-2-e tests

2020-09-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201929#comment-17201929 ] Yang Wang commented on FLINK-19389: --- Do you mean to start the E2E test in non-linux environment,

[jira] [Closed] (FLINK-19399) Add Python AsyncRequestReplyHandler docs

2020-09-25 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19399. --- Fix Version/s: statefun-2.2.0 Resolution: Fixed flink-statefun/master:

[GitHub] [flink] flinkbot edited a comment on pull request #13465: [FLINK-18906][task] Support checkpointing with multiple input operator chained with sources

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13465: URL: https://github.com/apache/flink/pull/13465#issuecomment-697465013 ## CI report: * 5799b14d314e5b58b2c46a56c3a6ca8132660303 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF

2020-09-25 Thread GitBox
dianfu commented on a change in pull request #13462: URL: https://github.com/apache/flink/pull/13462#discussion_r494763521 ## File path: flink-python/pyflink/common/state.py ## @@ -0,0 +1,65 @@ +

[GitHub] [flink-statefun] tzulitai closed pull request #162: [FLINK-19399][doc][py] Document AsyncRequestHandler

2020-09-25 Thread GitBox
tzulitai closed pull request #162: URL: https://github.com/apache/flink-statefun/pull/162 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

[jira] [Commented] (FLINK-17613) Run K8s related e2e tests with multiple K8s versions

2020-09-25 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201928#comment-17201928 ] Yang Wang commented on FLINK-17613: --- Make sense to me. [~rmetzger] Could you assign this ticket to

[jira] [Commented] (FLINK-19389) Error determining python major version to start fileserver during e-2-e tests

2020-09-25 Thread Di Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201935#comment-17201935 ] Di Xu commented on FLINK-19389: --- Not really, I think it affects both non-linux and linux environments b/c

[GitHub] [flink] HuangXingBo commented on a change in pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

2020-09-25 Thread GitBox
HuangXingBo commented on a change in pull request #13475: URL: https://github.com/apache/flink/pull/13475#discussion_r494767434 ## File path: flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx ## @@ -192,6 +194,108 @@ cdef class

[jira] [Commented] (FLINK-16866) Make job submission non-blocking

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201937#comment-17201937 ] Matthias commented on FLINK-16866: -- FYI: Just as a reminder - we forgot to regenerate the docs after

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 28d25983818d7805f6708b36125a65a493d03aa9 Azure:

[jira] [Created] (FLINK-19408) Update flink-statefun-docker release scripts for cross release Java 8 and 11

2020-09-25 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-19408: --- Summary: Update flink-statefun-docker release scripts for cross release Java 8 and 11 Key: FLINK-19408 URL: https://issues.apache.org/jira/browse/FLINK-19408

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
shuiqiangchen commented on a change in pull request #13327: URL: https://github.com/apache/flink/pull/13327#discussion_r494773417 ## File path: flink-python/pyflink/fn_execution/beam/beam_coders.py ## @@ -194,7 +194,7 @@ def _to_data_type(field_type):

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
shuiqiangchen commented on a change in pull request #13327: URL: https://github.com/apache/flink/pull/13327#discussion_r494773270 ## File path: flink-python/pyflink/fn_execution/coders.py ## @@ -467,8 +478,8 @@ def from_proto(field_type): if field_type_name ==

[GitHub] [flink] zentol merged pull request #13454: [FLINK-19304][coordination] Add FLIP-138 feature toggle

2020-09-25 Thread GitBox
zentol merged pull request #13454: URL: https://github.com/apache/flink/pull/13454 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-19304) Add feature toggle for declarative resource management

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19304. Resolution: Fixed master: 327b0242c2f4e6c4537a31a8e3a718df81791c87 > Add feature toggle

[jira] [Updated] (FLINK-19377) EventTimeWindowCheckpointingITCase setup can hide problems when changing parameters

2020-09-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19377: - Summary: EventTimeWindowCheckpointingITCase setup can hide problems when changing

[GitHub] [flink] flinkbot edited a comment on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937 ## CI report: * 2684468e6cc397456950f4fdada171cbbe6730a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 28d25983818d7805f6708b36125a65a493d03aa9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13465: [FLINK-18906][task] Support checkpointing with multiple input operator chained with sources

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13465: URL: https://github.com/apache/flink/pull/13465#issuecomment-697465013 ## CI report: * 5799b14d314e5b58b2c46a56c3a6ca8132660303 Azure:

[jira] [Updated] (FLINK-19408) Update flink-statefun-docker release scripts for cross release Java 8 and 11

2020-09-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19408: --- Labels: pull-request-available (was: ) > Update flink-statefun-docker release scripts for

[GitHub] [flink-statefun-docker] tzulitai opened a new pull request #8: [FLINK-19408] Update add-version.sh for cross-releasing Java 8 and 11

2020-09-25 Thread GitBox
tzulitai opened a new pull request #8: URL: https://github.com/apache/flink-statefun-docker/pull/8 Now when you execute `./add-version.sh -s -f `, two directories will be created: * `-java8` * `-java11` with each containing the Dockerfiles for the corresponding Java version.

[jira] [Updated] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-25 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-19409: Description: The comment for getValue is as following currently: {code:java} *    @Override  *    public Long

[GitHub] [flink] XComp commented on a change in pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

2020-09-25 Thread GitBox
XComp commented on a change in pull request #13458: URL: https://github.com/apache/flink/pull/13458#discussion_r494786048 ## File path: flink-runtime-web/src/test/resources/rest_api_v1.snapshot ## @@ -3082,4 +3098,4 @@ } } } ] -} +} Review comment: May

[GitHub] [flink] flinkbot edited a comment on pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13466: URL: https://github.com/apache/flink/pull/13466#issuecomment-697501001 ## CI report: * c855e4e249ddee6e2bdba3057182b40a16779e1e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * 469104d651f8f47e1dc76f0d317ea0477c1eef87 Azure:

[jira] [Commented] (FLINK-16866) Make job submission non-blocking

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201962#comment-17201962 ] Matthias commented on FLINK-16866: -- FLINK-19410 is created to fix the missing `enum` assertion. > Make

[jira] [Comment Edited] (FLINK-16866) Make job submission non-blocking

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201962#comment-17201962 ] Matthias edited comment on FLINK-16866 at 9/25/20, 7:19 AM: FLINK-19410 is

[jira] [Commented] (FLINK-19411) MultipleInputStreamTask fails with RuntimeException when its input contains union

2020-09-25 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201975#comment-17201975 ] Caizhi Weng commented on FLINK-19411: - cc [~pnowojski] > MultipleInputStreamTask fails with

[jira] [Updated] (FLINK-19413) Translate "FileSystem" page of "Table & SQL Connectors" into Chinese

2020-09-25 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng updated FLINK-19413: - Description: The page url is 

[jira] [Commented] (FLINK-19413) Translate "FileSystem" page of "Table & SQL Connectors" into Chinese

2020-09-25 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201984#comment-17201984 ] weizheng commented on FLINK-19413: -- Hi [~jark], Could you please assign it to me > Translate

[GitHub] [flink] echauchot commented on a change in pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-09-25 Thread GitBox
echauchot commented on a change in pull request #13040: URL: https://github.com/apache/flink/pull/13040#discussion_r494816021 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java ## @@ -283,6 +286,54 @@

[jira] [Updated] (FLINK-19411) MultipleInputStreamTask fails with RuntimeException when its input contains union

2020-09-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19411: --- Labels: pull-request-available (was: ) > MultipleInputStreamTask fails with

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * eab73c96345a18fb87286016aab4120d52e741fb Azure:

[GitHub] [flink] pnowojski opened a new pull request #13478: [FLINK-19411][task] Fix construction of MultipleInputStreamTask with union inputs

2020-09-25 Thread GitBox
pnowojski opened a new pull request #13478: URL: https://github.com/apache/flink/pull/13478 Previously number of input gates was assumed to be the same as number of logical inputs, which is not true in case of union inputs. This PR depends on

[GitHub] [flink] flinkbot edited a comment on pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13466: URL: https://github.com/apache/flink/pull/13466#issuecomment-697501001 ## CI report: * c855e4e249ddee6e2bdba3057182b40a16779e1e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13464: [FLINK-19307][coordination] Add ResourceTracker

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13464: URL: https://github.com/apache/flink/pull/13464#issuecomment-697462269 ## CI report: * f9cf786582a03b30617106c376cee2ce8e195f3a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13478: [FLINK-19411][task] Fix construction of MultipleInputStreamTask with union inputs

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13478: URL: https://github.com/apache/flink/pull/13478#issuecomment-698809939 ## CI report: * 0f0b85e13a86a7425a950b6819af09f20ccc1768 Azure:

[GitHub] [flink] dianfu closed pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
dianfu closed pull request #13327: URL: https://github.com/apache/flink/pull/13327 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] dianfu commented on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
dianfu commented on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-698819266 The test failure is not related to this PR. Merging... This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-19134) Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19134. --- Resolution: Fixed master: 8525c5ccf202ba6e9bb0d05b492d762b0228138c > Add BasicArrayTypeInfo and coder for

[jira] [Commented] (FLINK-9055) WebUI shows job as Running although not enough resources are available

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202049#comment-17202049 ] Matthias commented on FLINK-9055: - This issue was visited in the Backlog Grooming of the Engine Team on

[GitHub] [flink] flinkbot edited a comment on pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13466: URL: https://github.com/apache/flink/pull/13466#issuecomment-697501001 ## CI report: * e3728ea45538546b24d96081697a108eccab13cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13423: [FLINK-19269] Make the PushingAsyncDataInput.DataOutput aware of endOfInput

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13423: URL: https://github.com/apache/flink/pull/13423#issuecomment-694841940 ## CI report: * 0132280bc7d2a0b1147d75e9e63aa280880e5ff9 Azure:

[GitHub] [flink] twalthr opened a new pull request #13480: [FLINK-19341][table] Update all API related methods to FLIP-107

2020-09-25 Thread GitBox
twalthr opened a new pull request #13480: URL: https://github.com/apache/flink/pull/13480 ## What is the purpose of the change This updates all API related classes to support the concept of a metadata column. It considers all location until planner level. ## Brief change

[jira] [Commented] (FLINK-19382) Introducing ReplayableSourceStateBackend

2020-09-25 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201968#comment-17201968 ] Yun Tang commented on FLINK-19382: -- Thanks for bringing this discussion. If you ever read

[jira] [Updated] (FLINK-19410) RestAPIStabilityTest does not assert on enum changes

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19410: - Description: {{org.apache.flink.runtime.rest.compatibility.RestAPIStabilityTest}} does not assert on

[GitHub] [flink] dawidwys commented on a change in pull request #13443: [FLINK-19288] Make the InternalTimeServiceManager an interface

2020-09-25 Thread GitBox
dawidwys commented on a change in pull request #13443: URL: https://github.com/apache/flink/pull/13443#discussion_r494806615 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManagerImpl.java ## @@ -0,0 +1,272 @@ +/*

[GitHub] [flink-statefun-docker] tzulitai opened a new pull request #10: [release] Add Dockerfiles for 2.2.0 release

2020-09-25 Thread GitBox
tzulitai opened a new pull request #10: URL: https://github.com/apache/flink-statefun-docker/pull/10 This is based on #8 which adds tooling functionality for cross-release for Java 8 and 11. The Dockerfiles added in this PR are generated from the updated add-version.sh script by

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * 469104d651f8f47e1dc76f0d317ea0477c1eef87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13322: [FLINK-17480][kubernetes] Support running PyFlink on Kubernetes.

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13322: URL: https://github.com/apache/flink/pull/13322#issuecomment-686859976 ## CI report: * eab73c96345a18fb87286016aab4120d52e741fb Azure:

[jira] [Closed] (FLINK-18906) Support checkpointing with multiple input operator chained with sources

2020-09-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18906. -- Resolution: Fixed Merged to master as 21a0ed8a05..f547f4c05e > Support checkpointing with

[GitHub] [flink] JingsongLi opened a new pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

2020-09-25 Thread GitBox
JingsongLi opened a new pull request #13479: URL: https://github.com/apache/flink/pull/13479 ## What is the purpose of the change Introduce `ParquetColumnarRowInputFormat` for filesystem connector. (Migrate Old interface to new/FLIP-27 source API) ## Brief change log

[jira] [Updated] (FLINK-19414) Introduce ParquetColumnarRowInputFormat

2020-09-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19414: --- Labels: pull-request-available (was: ) > Introduce ParquetColumnarRowInputFormat >

[jira] [Closed] (FLINK-7582) Rest client may buffer responses indefinitely under heavy laod

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7582. --- Resolution: Later So far this hasn't been a problem; let's revisit it once an issue is

[jira] [Closed] (FLINK-9732) Report more detailed error message on JobSubmissionFailure

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9732. --- Resolution: Won't Fix The job submission now triggers the asynchronous job master

[jira] [Updated] (FLINK-7753) HandlerUtils should close the channel on error responses

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7753: Affects Version/s: 1.10.0 > HandlerUtils should close the channel on error responses >

[jira] [Updated] (FLINK-7753) HandlerUtils should close the channel on error responses

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7753: Parent: (was: FLINK-7040) Issue Type: Bug (was: Sub-task) > HandlerUtils

[jira] [Updated] (FLINK-7753) HandlerUtils should close the channel on error responses

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7753: Component/s: (was: Runtime / Coordination) (was: Deployment /

[jira] [Created] (FLINK-19415) Move Hive document to "Table & SQL Connectors" from "Table API & SQL"

2020-09-25 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-19415: Summary: Move Hive document to "Table & SQL Connectors" from "Table API & SQL" Key: FLINK-19415 URL: https://issues.apache.org/jira/browse/FLINK-19415 Project: Flink

[jira] [Updated] (FLINK-19123) TestStreamEnvironment does not use shared MiniCluster for executeAsync()

2020-09-25 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19123: - Component/s: (was: Runtime / Coordination) > TestStreamEnvironment does not use

[jira] [Commented] (FLINK-12085) Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint'

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202048#comment-17202048 ] Matthias commented on FLINK-12085: -- [~jackyyin] Are you still working on this issue? If not, I'd

[GitHub] [flink] flinkbot edited a comment on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937 ## CI report: * 2684468e6cc397456950f4fdada171cbbe6730a9 Azure:

[GitHub] [flink-statefun-docker] tzulitai commented on pull request #9: [release] Add Dockerfiles for 2.2.0 release

2020-09-25 Thread GitBox
tzulitai commented on pull request #9: URL: https://github.com/apache/flink-statefun-docker/pull/9#issuecomment-698761826 FYI - the URLs were replaced with these to test these Dockerfiles with RC2: ``` ENV

[jira] [Created] (FLINK-19409) The comment for getValue has wrong code in class ListView

2020-09-25 Thread Liu (Jira)
Liu created FLINK-19409: --- Summary: The comment for getValue has wrong code in class ListView Key: FLINK-19409 URL: https://issues.apache.org/jira/browse/FLINK-19409 Project: Flink Issue Type:

[jira] [Created] (FLINK-19410) RestAPIStabilityTest does not assert on enum changes

2020-09-25 Thread Matthias (Jira)
Matthias created FLINK-19410: Summary: RestAPIStabilityTest does not assert on enum changes Key: FLINK-19410 URL: https://issues.apache.org/jira/browse/FLINK-19410 Project: Flink Issue Type: Bug

[GitHub] [flink-statefun-docker] tzulitai commented on a change in pull request #10: [release] Add Dockerfiles for 2.2.0 release

2020-09-25 Thread GitBox
tzulitai commented on a change in pull request #10: URL: https://github.com/apache/flink-statefun-docker/pull/10#discussion_r494808247 ## File path: 2.2.0-java11/Dockerfile ## @@ -0,0 +1,82 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +#

[jira] [Comment Edited] (FLINK-19400) Removed unused BufferPoolOwner

2020-09-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201983#comment-17201983 ] Nicholas Jiang edited comment on FLINK-19400 at 9/25/20, 8:04 AM: --

[jira] [Closed] (FLINK-19405) Translate "DataSet Connectors" page of "Connectors" into Chinese

2020-09-25 Thread weizheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weizheng closed FLINK-19405. Resolution: Abandoned > Translate "DataSet Connectors" page of "Connectors" into Chinese >

[GitHub] [flink] pnowojski commented on pull request #13465: [FLINK-18906][task] Support checkpointing with multiple input operator chained with sources

2020-09-25 Thread GitBox
pnowojski commented on pull request #13465: URL: https://github.com/apache/flink/pull/13465#issuecomment-698796760 Thanks for the review. Private azure build is green, merging. This is an automated message from the Apache

[GitHub] [flink] pnowojski merged pull request #13465: [FLINK-18906][task] Support checkpointing with multiple input operator chained with sources

2020-09-25 Thread GitBox
pnowojski merged pull request #13465: URL: https://github.com/apache/flink/pull/13465 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-19395) Replace SqlConversionException with either TableException or ValidationException

2020-09-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202000#comment-17202000 ] Timo Walther commented on FLINK-19395: -- Thanks [~ShawnHx]. I assigned you to this issue. Please

[GitHub] [flink] flinkbot edited a comment on pull request #13464: [FLINK-19307][coordination] Add ResourceTracker

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13464: URL: https://github.com/apache/flink/pull/13464#issuecomment-697462269 ## CI report: * f9cf786582a03b30617106c376cee2ce8e195f3a Azure:

[GitHub] [flink] flinkbot commented on pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

2020-09-25 Thread GitBox
flinkbot commented on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 9df0a7e3cff230a37dbd41f1edfb57ba9c060d0d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-19396) Fix properties type cast error

2020-09-25 Thread zhangmeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangmeng updated FLINK-19396: -- Description: Properties extends Hashtable ,The key and value of the Properties class support object

[jira] [Updated] (FLINK-19396) Fix properties type cast error

2020-09-25 Thread zhangmeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangmeng updated FLINK-19396: -- Description: Properties extends Hashtable ,The key and value of the Properties class support object

[jira] [Updated] (FLINK-10165) JarRunHandler/JarRunRequestBody should allow to pass program arguments as escaped json list

2020-09-25 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-10165: - Affects Version/s: 1.10.2 1.11.2 > JarRunHandler/JarRunRequestBody should allow

[jira] [Commented] (FLINK-18263) Allow external checkpoints to be persisted even when the job is in "Finished" state.

2020-09-25 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201960#comment-17201960 ] Yun Tang commented on FLINK-18263: -- If so, [~markcho] would you consider to continue modify your PR,

[GitHub] [flink] flinkbot edited a comment on pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13466: URL: https://github.com/apache/flink/pull/13466#issuecomment-697501001 ## CI report: * c855e4e249ddee6e2bdba3057182b40a16779e1e Azure:

[GitHub] [flink] dawidwys closed pull request #13443: [FLINK-19288] Make the InternalTimeServiceManager an interface

2020-09-25 Thread GitBox
dawidwys closed pull request #13443: URL: https://github.com/apache/flink/pull/13443 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] [Created] (FLINK-19412) Re-layer Python Operation Make it Possible to Provide only Python implementation

2020-09-25 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19412: Summary: Re-layer Python Operation Make it Possible to Provide only Python implementation Key: FLINK-19412 URL: https://issues.apache.org/jira/browse/FLINK-19412

[jira] [Commented] (FLINK-19400) Removed unused BufferPoolOwner

2020-09-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201983#comment-17201983 ] Nicholas Jiang commented on FLINK-19400: [~AHeise], I agree with you. IMO, BufferPoolOwner only

[GitHub] [flink] aljoscha commented on pull request #12157: [FLINK-17691][Connectors/Kafka] fix the bug FlinkKafkaProducer011 transactional.id too long when use Semantic.EXACTLY_ONCE mode

2020-09-25 Thread GitBox
aljoscha commented on pull request #12157: URL: https://github.com/apache/flink/pull/12157#issuecomment-698783730 I'm closing this as "Abandoned", since there is no more activity and the code base has moved on quite a bit. Please re-open this if you feel otherwise and work should

[jira] [Commented] (FLINK-19400) Removed unused BufferPoolOwner

2020-09-25 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201989#comment-17201989 ] Arvid Heise commented on FLINK-19400: - I think Zhijiang already gave green light. [~sewen],

[jira] [Updated] (FLINK-19411) MultipleInputStreamTask fails with RuntimeException when its input contains union

2020-09-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-19411: --- Priority: Critical (was: Major) > MultipleInputStreamTask fails with RuntimeException when

[GitHub] [flink] pnowojski commented on a change in pull request #13234: [FLINK-18905][task] Allow SourceOperator chaining with MultipleInputStreamTask

2020-09-25 Thread GitBox
pnowojski commented on a change in pull request #13234: URL: https://github.com/apache/flink/pull/13234#discussion_r494824026 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -53,42 +53,48 @@ public

[jira] [Assigned] (FLINK-19411) MultipleInputStreamTask fails with RuntimeException when its input contains union

2020-09-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-19411: -- Assignee: Piotr Nowojski > MultipleInputStreamTask fails with RuntimeException when

[GitHub] [flink] AHeise commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-09-25 Thread GitBox
AHeise commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r494830641 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReader.java ## @@ -0,0 +1,62 @@ +package

[GitHub] [flink] AHeise commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

2020-09-25 Thread GitBox
AHeise commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r494830641 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReader.java ## @@ -0,0 +1,62 @@ +package

[GitHub] [flink] flinkbot edited a comment on pull request #13466: [FLINK-18907][task] Add watermarks and metrics tests for MultipleSourceOperatorStreamTask

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13466: URL: https://github.com/apache/flink/pull/13466#issuecomment-697501001 ## CI report: * c855e4e249ddee6e2bdba3057182b40a16779e1e Azure:

[GitHub] [flink] flinkbot commented on pull request #13478: [FLINK-19411][task] Fix construction of MultipleInputStreamTask with union inputs

2020-09-25 Thread GitBox
flinkbot commented on pull request #13478: URL: https://github.com/apache/flink/pull/13478#issuecomment-698809939 ## CI report: * 0f0b85e13a86a7425a950b6819af09f20ccc1768 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] shuiqiangchen commented on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
shuiqiangchen commented on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-698818753 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #13327: [FLINK-19134][python] Add BasicArrayTypeInfo and coder for PrimitiveArrayTypeInfo for Python DataStream API.

2020-09-25 Thread GitBox
flinkbot edited a comment on pull request #13327: URL: https://github.com/apache/flink/pull/13327#issuecomment-687006937 ## CI report: * 2d5f8f486f57852dcb453bb60200c57e332df39a Azure:

[jira] [Commented] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger

2020-09-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202036#comment-17202036 ] Aljoscha Krettek commented on FLINK-5717: - The original PR seems to have been abandoned. I think

[jira] [Updated] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger

2020-09-25 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5717: Labels: easyfix starter (was: easyfix pull-request-available starter) > NPE on

[GitHub] [flink] aljoscha closed pull request #12754: [FLINK-5717][streaming] Fix NPE on SessionWindows with ContinuousProc…

2020-09-25 Thread GitBox
aljoscha closed pull request #12754: URL: https://github.com/apache/flink/pull/12754 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

  1   2   3   4   5   >