[GitHub] [flink] dawidwys merged pull request #13550: [FLINK-19474] Implement a state backend that holds a single key at a time

2020-10-12 Thread GitBox
dawidwys merged pull request #13550: URL: https://github.com/apache/flink/pull/13550 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-19474) Implement a state backend that holds a single key at a time

2020-10-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-19474. Resolution: Implemented Implemented in 1aea5f059cb1e0aee6168477391e6e17c9d23dc1 > Impleme

[GitHub] [flink] JingsongLi commented on a change in pull request #13479: [FLINK-19414][parquet] Introduce ParquetColumnarRowInputFormat

2020-10-12 Thread GitBox
JingsongLi commented on a change in pull request #13479: URL: https://github.com/apache/flink/pull/13479#discussion_r503081381 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetColumnarRowInputFormat.java ## @@ -0,0 +1,189 @@ +/* +

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

2020-10-12 Thread GitBox
JingsongLi commented on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-706923294 @lirui-apache Please take a look~ This is an automated message from the Apache Git Service. To respond to the

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

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 6fc43dcfa07a2f1488f33d54d26ed8c4bdeff2ef Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212180#comment-17212180 ] Till Rohrmann commented on FLINK-11105: --- Thanks [~fly_in_gis]. I will close this t

[jira] [Closed] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11105. - Resolution: Abandoned > Add a new implementation of the HighAvailabilityServices using etcd > --

[jira] [Assigned] (FLINK-11105) Add a new implementation of the HighAvailabilityServices using etcd

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11105: - Assignee: (was: MalcolmSanders) > Add a new implementation of the HighAvailabilityS

[jira] [Closed] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11807. - Resolution: Abandoned > Implement etcd based LeaderElectionService and LeaderRetrievalService >

[jira] [Assigned] (FLINK-11806) Import shaded jetcd

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11806: - Assignee: (was: MalcolmSanders) > Import shaded jetcd > --- > >

[jira] [Assigned] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11807: - Assignee: (was: MalcolmSanders) > Implement etcd based LeaderElectionService and Le

[jira] [Closed] (FLINK-11806) Import shaded jetcd

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11806. - Resolution: Abandoned > Import shaded jetcd > --- > > Key: FLINK

[jira] [Assigned] (FLINK-11808) Implement etcd based SharedCount or sequencer

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11808: - Assignee: (was: MalcolmSanders) > Implement etcd based SharedCount or sequencer > -

[jira] [Closed] (FLINK-11808) Implement etcd based SharedCount or sequencer

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11808. - Resolution: Abandoned > Implement etcd based SharedCount or sequencer >

[jira] [Assigned] (FLINK-11812) Composite etcd based HighAvailability components

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11812: - Assignee: (was: MalcolmSanders) > Composite etcd based HighAvailability components

[jira] [Closed] (FLINK-8304) Document Kubernetes and Flink HA setup

2020-10-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-8304. --- Resolution: Won't Fix Thanks for clarification [~fly_in_gis]. I'm gonna close this issue then. > Document Ku

[jira] [Assigned] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11810: - Assignee: (was: MalcolmSanders) > Implement etcd based CheckpointRecoveryFactory >

[jira] [Closed] (FLINK-11812) Composite etcd based HighAvailability components

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11812. - Resolution: Abandoned > Composite etcd based HighAvailability components > -

[jira] [Assigned] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11811: - Assignee: (was: MalcolmSanders) > Implement etcd based RunningJobsRegistry and Subm

[jira] [Closed] (FLINK-11809) Implement etcd based StateHandleStore

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11809. - Resolution: Abandoned > Implement etcd based StateHandleStore >

[jira] [Assigned] (FLINK-11809) Implement etcd based StateHandleStore

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11809: - Assignee: (was: MalcolmSanders) > Implement etcd based StateHandleStore > -

[jira] [Closed] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11811. - Resolution: Abandoned > Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore > --

[jira] [Closed] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11810. - Resolution: Abandoned > Implement etcd based CheckpointRecoveryFactory > ---

[jira] [Assigned] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs

2020-10-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-19513: Assignee: Kyle Zhang > Update docs/build_docs.sh to support the new parameters for regenerating t

[jira] [Commented] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs

2020-10-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212186#comment-17212186 ] Matthias commented on FLINK-19513: -- Thanks [~KyleZhang], feel free to open a PR. > Upd

[jira] [Commented] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-10-12 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212187#comment-17212187 ] Yun Gao commented on FLINK-18915: - Very thansk [~wei.wei] and [~lzljs3620320] for report

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

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 6fc43dcfa07a2f1488f33d54d26ed8c4bdeff2ef Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-10-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212194#comment-17212194 ] Jingsong Lee commented on FLINK-18915: -- I think yes, a UUID path can help. > FIXED

[jira] [Commented] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-10-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212195#comment-17212195 ] Jingsong Lee commented on FLINK-18915: -- [~gaoyunhaii] Do you want to contribute thi

[jira] [Commented] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-10-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212197#comment-17212197 ] Jingsong Lee commented on FLINK-18915: -- CC: [~kkl0u] > FIXED_PATH(dummy Hadoop Pat

[jira] [Commented] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-10-12 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212198#comment-17212198 ] Yun Gao commented on FLINK-18915: - OK, no problem, I would open a PR for it. > FIXED_PA

[GitHub] [flink] WeiZhong94 commented on a change in pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-10-12 Thread GitBox
WeiZhong94 commented on a change in pull request #13507: URL: https://github.com/apache/flink/pull/13507#discussion_r503096233 ## File path: flink-python/pyflink/common/types.py ## @@ -37,7 +37,7 @@ def _create_row(fields, values, row_kind: RowKind = None): return row

[jira] [Assigned] (FLINK-18915) FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OOM

2020-10-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18915: Assignee: Yun Gao > FIXED_PATH(dummy Hadoop Path) with WriterImpl may cause ORC writer OO

[jira] [Assigned] (FLINK-19568) Offload creating TM launch contexts to the IO executor

2020-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19568: Assignee: Xintong Song > Offload creating TM launch contexts to the IO executor > ---

[GitHub] [flink] WeiZhong94 commented on pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-10-12 Thread GitBox
WeiZhong94 commented on pull request #13507: URL: https://github.com/apache/flink/pull/13507#issuecomment-706940408 @dianfu @twalthr Thanks for your comments. I have updated this PR. This is an automated message from the Apac

[GitHub] [flink] SteNicholas removed a comment on pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
SteNicholas removed a comment on pull request #13572: URL: https://github.com/apache/flink/pull/13572#issuecomment-706904807 > @shuiqiangchen Could you help to take a look at this PR? @dianfu @shuiqiangchen Wait for my changes. I would have a mirror change. -

[jira] [Commented] (FLINK-12110) Introduce API point for ShuffleEnvironment to get estimation of locally required memory

2020-10-12 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212207#comment-17212207 ] Matthias commented on FLINK-12110: -- Is this still a topic considering the resolution of

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

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 8b7772756eb215c09ef7a77bec62a2e258661454 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19484) Kubernetes pyflink application test failed with "error executing jsonpath "{range .items[*]}{.metadata.name}{\"\\n\"}{end}": Error executing template: not in rang"

2020-10-12 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212208#comment-17212208 ] Shuiqiang Chen commented on FLINK-19484: [~dian.fu] Thank you for reporting this

[GitHub] [flink] flinkbot edited a comment on pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13507: URL: https://github.com/apache/flink/pull/13507#issuecomment-700666447 ## CI report: * 4a0ccb37d548b600efc2d5eb5d2e786f11e6bfa2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-19539) JMXReporterFactoryTest fails on Azure

2020-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-19539: Assignee: Chesnay Schepler > JMXReporterFactoryTest fails on Azure >

[jira] [Updated] (FLINK-19468) Metrics return empty when data stream / operator name contains "+"

2020-10-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19468: --- Affects Version/s: (was: 2.0.0) > Metrics return empty when data stream / operator name

[jira] [Updated] (FLINK-19468) Metrics return empty when data stream / operator name contains "+"

2020-10-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19468: --- Component/s: Runtime / Metrics > Metrics return empty when data stream / operator name conta

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
shuiqiangchen commented on a change in pull request #13572: URL: https://github.com/apache/flink/pull/13572#discussion_r503108048 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -35,6 +35,8 @@ from pyflink.datastream.time_characteristic impo

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
shuiqiangchen commented on a change in pull request #13572: URL: https://github.com/apache/flink/pull/13572#discussion_r503108048 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -35,6 +35,8 @@ from pyflink.datastream.time_characteristic impo

[jira] [Created] (FLINK-19569) Upgrade ICU4J to 67.1+

2020-10-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-19569: Summary: Upgrade ICU4J to 67.1+ Key: FLINK-19569 URL: https://issues.apache.org/jira/browse/FLINK-19569 Project: Flink Issue Type: Improvement

[GitHub] [flink] SteNicholas commented on a change in pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
SteNicholas commented on a change in pull request #13572: URL: https://github.com/apache/flink/pull/13572#discussion_r503111486 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -35,6 +35,8 @@ from pyflink.datastream.time_characteristic import

[GitHub] [flink] HuangXingBo commented on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

2020-10-12 Thread GitBox
HuangXingBo commented on pull request #13520: URL: https://github.com/apache/flink/pull/13520#issuecomment-706957074 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] twalthr commented on pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-10-12 Thread GitBox
twalthr commented on pull request #13507: URL: https://github.com/apache/flink/pull/13507#issuecomment-706956988 Thanks for the update @WeiZhong94. My comment is addressed. I will leave the full review to somebody else. This

[jira] [Created] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

2020-10-12 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-19570: --- Summary: Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID Key: FLINK-19570 URL: https://issues.apache.org/jira/browse/FLINK-19570

[jira] [Updated] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

2020-10-12 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19570: Description: Since FLINK-17295, many tests encounters unexpected global failure due to registering duplic

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 8d6ca96817da4640dee68e9c81b7e612e63dfcd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13507: [FLINK-19231][python] Support ListState and ListView for Python UDAF.

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13507: URL: https://github.com/apache/flink/pull/13507#issuecomment-700666447 ## CI report: * 4a0ccb37d548b600efc2d5eb5d2e786f11e6bfa2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13520: URL: https://github.com/apache/flink/pull/13520#issuecomment-701257311 ## CI report: * 9a1e5ebd9eebb14725577dc02d0fdfe661608a33 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

2020-10-12 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212219#comment-17212219 ] Zhu Zhu commented on FLINK-19570: - cc [~karmagyz] [~trohrmann] [~mapohl] > Execution gr

[jira] [Updated] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

2020-10-12 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-19570: Description: Since FLINK-17295, many tests encounters unexpected global failure due to registering duplic

[GitHub] [flink] flinkbot edited a comment on pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13572: URL: https://github.com/apache/flink/pull/13572#issuecomment-706203264 ## CI report: * 2a573f226d23ae494719691d82a173fd562372de Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
shuiqiangchen commented on a change in pull request #13572: URL: https://github.com/apache/flink/pull/13572#discussion_r503118365 ## File path: flink-python/pyflink/datastream/stream_execution_environment.py ## @@ -711,6 +713,17 @@ def from_collection(self, collection: List[Any

[jira] [Commented] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs

2020-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1721#comment-1721 ] Chesnay Schepler commented on FLINK-19513: -- The regeneration is working with fo

[jira] [Closed] (FLINK-19539) JMXReporterFactoryTest fails on Azure

2020-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-19539. Resolution: Fixed master: eb7e46777a28865b68c6ff543a7350d17ad46e12 cf4328db168fe5488514efd

[GitHub] [flink] KyleZhang0536 opened a new pull request #13589: FLINK-19513 Update docs/build_docs.sh to support the new parameters f…

2020-10-12 Thread GitBox
KyleZhang0536 opened a new pull request #13589: URL: https://github.com/apache/flink/pull/13589 ## What is the purpose of the change Because watching is the default for serve since 2.4.0, we use `--force_polling` for regenerating the docs. ## Brief change log

[jira] [Updated] (FLINK-19513) Update docs/build_docs.sh to support the new parameters for regenerating the docs

2020-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19513: --- Labels: pull-request-available starter (was: starter) > Update docs/build_docs.sh to suppor

[GitHub] [flink] flinkbot commented on pull request #13589: [FLINK-19513][docs] Update docs/build_docs.sh to support the new parameters f…

2020-10-12 Thread GitBox
flinkbot commented on pull request #13589: URL: https://github.com/apache/flink/pull/13589#issuecomment-706965944 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

[GitHub] [flink] flinkbot edited a comment on pull request #13216: [FLINK-18999][table-planner-blink][hive] Temporary generic table does…

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13216: URL: https://github.com/apache/flink/pull/13216#issuecomment-678268420 ## CI report: * 8d6ca96817da4640dee68e9c81b7e612e63dfcd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 8b7772756eb215c09ef7a77bec62a2e258661454 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13520: [FLINK-19450][python][AZP] Optimize the Python CI Test

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13520: URL: https://github.com/apache/flink/pull/13520#issuecomment-701257311 ## CI report: * 9a1e5ebd9eebb14725577dc02d0fdfe661608a33 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13519: [FLINK-18850][Table SQL / Runtime]Add late records dropped metric for row time over windows

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13519: URL: https://github.com/apache/flink/pull/13519#issuecomment-701236311 ## CI report: * 2b1c9dcf9d5e3f27ad6635b58ccca2a6737b8b03 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13572: [FLINK-19416][python] Support Python datetime object in from_collection of Python DataStream

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13572: URL: https://github.com/apache/flink/pull/13572#issuecomment-706203264 ## CI report: * 2a573f226d23ae494719691d82a173fd562372de Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

2020-10-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212237#comment-17212237 ] Chesnay Schepler commented on FLINK-19570: -- [~zhuzh] Sounds good to me; I guess

[GitHub] [flink] flinkbot commented on pull request #13589: [FLINK-19513][docs] Update docs/build_docs.sh to support the new parameters f…

2020-10-12 Thread GitBox
flinkbot commented on pull request #13589: URL: https://github.com/apache/flink/pull/13589#issuecomment-706972177 ## CI report: * 7c3d1edbaa6c2fd237f5f11245414b709e598709 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-19571) Port Transformation translation logic to TransformationTranslator framework

2020-10-12 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19571: --- Summary: Port Transformation translation logic to TransformationTranslator framework (was:

[jira] [Created] (FLINK-19571) Port Transformation translation logic to StreamGraphTranslator framework

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19571: -- Summary: Port Transformation translation logic to StreamGraphTranslator framework Key: FLINK-19571 URL: https://issues.apache.org/jira/browse/FLINK-19571 Project:

[jira] [Updated] (FLINK-19571) Port Transformation translation logic to TransformationTranslator framework

2020-10-12 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19571: --- Description: Currently, the {{StreamGraphGenerator}} is responsible for: 1. traversing the g

[jira] [Created] (FLINK-19574) Create the SourceTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19574: -- Summary: Create the SourceTransformation translator Key: FLINK-19574 URL: https://issues.apache.org/jira/browse/FLINK-19574 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-19572) Create the TwoInputTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19572: -- Summary: Create the TwoInputTransformation translator Key: FLINK-19572 URL: https://issues.apache.org/jira/browse/FLINK-19572 Project: Flink Issue Type:

[jira] [Created] (FLINK-19573) Create the MultipleInputTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19573: -- Summary: Create the MultipleInputTransformation translator Key: FLINK-19573 URL: https://issues.apache.org/jira/browse/FLINK-19573 Project: Flink Issue T

[jira] [Created] (FLINK-19575) Create the LegacySourceTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19575: -- Summary: Create the LegacySourceTransformation translator Key: FLINK-19575 URL: https://issues.apache.org/jira/browse/FLINK-19575 Project: Flink Issue Ty

[jira] [Created] (FLINK-19576) Create the SinkTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19576: -- Summary: Create the SinkTransformation translator Key: FLINK-19576 URL: https://issues.apache.org/jira/browse/FLINK-19576 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-19578) Create the PartitionTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19578: -- Summary: Create the PartitionTransformation translator Key: FLINK-19578 URL: https://issues.apache.org/jira/browse/FLINK-19578 Project: Flink Issue Type:

[jira] [Created] (FLINK-19577) Create the UnionTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19577: -- Summary: Create the UnionTransformation translator Key: FLINK-19577 URL: https://issues.apache.org/jira/browse/FLINK-19577 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-19579) Create the SideOutputTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-19579: -- Summary: Create the SideOutputTransformation translator Key: FLINK-19579 URL: https://issues.apache.org/jira/browse/FLINK-19579 Project: Flink Issue Type

[jira] [Updated] (FLINK-19512) Introduce new Sink API interfaces

2020-10-12 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19512: - Summary: Introduce new Sink API interfaces (was: Introduce the new sink api) > Introdu

[jira] [Commented] (FLINK-19521) Support dynamic properties on DefaultCLI

2020-10-12 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212249#comment-17212249 ] Aljoscha Krettek commented on FLINK-19521: -- Yes, the "dynamic properties" imple

[GitHub] [flink] zhuzhurk opened a new pull request #13590: [FLINK-19570][tests] Avoid directly creating ExecutionJobVertex and ExecutionVertex via constructors in tests

2020-10-12 Thread GitBox
zhuzhurk opened a new pull request #13590: URL: https://github.com/apache/flink/pull/13590 ## What is the purpose of the change This PR is to fix the tests which encounters unexpected failures due to improperly creating ExecutionJobVertex and ExecutionVertex and registering duplicat

[jira] [Updated] (FLINK-19570) Execution graph related tests are possibly broken due to registering duplicated ExecutionAttemptID

2020-10-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19570: --- Labels: pull-request-available (was: ) > Execution graph related tests are possibly broken

[GitHub] [flink] flinkbot commented on pull request #13590: [FLINK-19570][tests] Avoid directly creating ExecutionJobVertex and ExecutionVertex via constructors in tests

2020-10-12 Thread GitBox
flinkbot commented on pull request #13590: URL: https://github.com/apache/flink/pull/13590#issuecomment-706988324 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

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

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13479: URL: https://github.com/apache/flink/pull/13479#issuecomment-698831350 ## CI report: * 8b7772756eb215c09ef7a77bec62a2e258661454 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] alpinegizmo commented on pull request #13546: [hotfix][docs] Adjust playground docs to Flink 1.11 output

2020-10-12 Thread GitBox
alpinegizmo commented on pull request #13546: URL: https://github.com/apache/flink/pull/13546#issuecomment-706989350 @afedulov Please create a JIRA ticket for updating the chinese docs. This is an automated message from the A

[GitHub] [flink] flinkbot edited a comment on pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13547: URL: https://github.com/apache/flink/pull/13547#issuecomment-704265372 ## CI report: * 268d260399e598943726839a254f004a61f5ba66 UNKNOWN * 54760df57f629890fd1de11b3f3cff80c2df74ba Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] dianfu commented on a change in pull request #13504: [FLINK-19404][python] Support Pandas Stream Over Window Aggregation

2020-10-12 Thread GitBox
dianfu commented on a change in pull request #13504: URL: https://github.com/apache/flink/pull/13504#discussion_r503085577 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/arrow/stream/StreamArrowPythonRowTimeRowsBoundedOverWindowAggre

[GitHub] [flink] flinkbot edited a comment on pull request #13576: [FLINK-19512] Introduce the new sink API

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13576: URL: https://github.com/apache/flink/pull/13576#issuecomment-706453519 ## CI report: * 8ffd7d8f19f7e60485e42e4692872c5775e5cb54 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zentol commented on a change in pull request #13553: [FLINK-19306][coordination] Add DeclarativeSlotManager

2020-10-12 Thread GitBox
zentol commented on a change in pull request #13553: URL: https://github.com/apache/flink/pull/13553#discussion_r503150537 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -861,6 +884,8 @@ protected void closeJobMana

[GitHub] [flink] flinkbot edited a comment on pull request #13589: [FLINK-19513][docs] Update docs/build_docs.sh to support the new parameters f…

2020-10-12 Thread GitBox
flinkbot edited a comment on pull request #13589: URL: https://github.com/apache/flink/pull/13589#issuecomment-706972177 ## CI report: * 7c3d1edbaa6c2fd237f5f11245414b709e598709 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong commented on a change in pull request #13577: [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL

2020-10-12 Thread GitBox
wuchong commented on a change in pull request #13577: URL: https://github.com/apache/flink/pull/13577#discussion_r503151143 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java ## @@ -994,7 +992,6 @@ public void testS

[GitHub] [flink] dianfu commented on a change in pull request #13504: [FLINK-19404][python] Support Pandas Stream Over Window Aggregation

2020-10-12 Thread GitBox
dianfu commented on a change in pull request #13504: URL: https://github.com/apache/flink/pull/13504#discussion_r503128744 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/arrow/stream/AbstractStreamArrowPythonRangeBoundedOverWindowAgg

[GitHub] [flink] alpinegizmo closed pull request #13546: [hotfix][docs] Adjust playground docs to Flink 1.11 output

2020-10-12 Thread GitBox
alpinegizmo closed pull request #13546: URL: https://github.com/apache/flink/pull/13546 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] dianfu commented on a change in pull request #13504: [FLINK-19404][python] Support Pandas Stream Over Window Aggregation

2020-10-12 Thread GitBox
dianfu commented on a change in pull request #13504: URL: https://github.com/apache/flink/pull/13504#discussion_r503147359 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecPythonOverAggregate.scala #

[GitHub] [flink] alpinegizmo commented on pull request #13546: [hotfix][docs] Adjust playground docs to Flink 1.11 output

2020-10-12 Thread GitBox
alpinegizmo commented on pull request #13546: URL: https://github.com/apache/flink/pull/13546#issuecomment-706990716 master closed via 35300ca63ed1bf4dcbd42c4e01b57d7cd4431888 release-1.11 closed via 6bd5734c888fb5b97d5d4e6027ff7b2620e8fc54 --

[jira] [Closed] (FLINK-11952) Introduce Plugin Architecture for loading FileSystems

2020-10-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-11952. - Fix Version/s: 1.9.0 Resolution: Done > Introduce Plugin Architecture for loading FileSys

[GitHub] [flink] dianfu commented on a change in pull request #13504: [FLINK-19404][python] Support Pandas Stream Over Window Aggregation

2020-10-12 Thread GitBox
dianfu commented on a change in pull request #13504: URL: https://github.com/apache/flink/pull/13504#discussion_r503147661 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecPythonOverAggregate.scala #

  1   2   3   4   5   6   >