[GitHub] [flink] carp84 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

carp84 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-608245577 @StephanEwen could you also take a look here? Thanks.

[jira] [Updated] (FLINK-16953) TableEnvHiveConnectorTest is unstable on travis.

[ https://issues.apache.org/jira/browse/FLINK-16953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-16953: - Description: [https://api.travis-ci.org/v3/job/670405441/log.txt] {code:java} [INFO] Running

[jira] [Created] (FLINK-16953) TableEnvHiveConnectorTest is unstable on travis.

Xintong Song created FLINK-16953: Summary: TableEnvHiveConnectorTest is unstable on travis. Key: FLINK-16953 URL: https://issues.apache.org/jira/browse/FLINK-16953 Project: Flink Issue Type:

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402719726 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402736479 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402718103 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402740615 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402745707 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402744613 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

xintongsong commented on a change in pull request #11615: [FLINK-16605] Add max limitation to the total number of slots URL: https://github.com/apache/flink/pull/11615#discussion_r402719311 ## File path:

[GitHub] [flink] leonardBang commented on a change in pull request #11574: [FLINK-16859][table-runtime] Introduce file system table factory

leonardBang commented on a change in pull request #11574: [FLINK-16859][table-runtime] Introduce file system table factory URL: https://github.com/apache/flink/pull/11574#discussion_r402748927 ## File path:

[GitHub] [flink] leonardBang commented on a change in pull request #11574: [FLINK-16859][table-runtime] Introduce file system table factory

leonardBang commented on a change in pull request #11574: [FLINK-16859][table-runtime] Introduce file system table factory URL: https://github.com/apache/flink/pull/11574#discussion_r402748612 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#discussion_r402749513 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#discussion_r402746198 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#discussion_r402747024 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#discussion_r402746856 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

JingsongLi commented on a change in pull request #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#discussion_r402746022 ## File path:

[jira] [Updated] (FLINK-16952) Parquet file system format support filter pushdown

[ https://issues.apache.org/jira/browse/FLINK-16952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16952: - Description: We can create the conversion between Flink Expression(NOTE: should be new

[jira] [Created] (FLINK-16952) Parquet file system format support filter pushdown

Jingsong Lee created FLINK-16952: Summary: Parquet file system format support filter pushdown Key: FLINK-16952 URL: https://issues.apache.org/jira/browse/FLINK-16952 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * b709e1952df66cba5a316f9a46902538bf8cf245 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#issuecomment-604493433 ## CI report: * 2670a045bd9c9c4c75e7a22bf188fc673c85a062 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * d8814c3aed36cea34b5069b2a270df8033d29956

[jira] [Updated] (FLINK-16887) Refactor retraction rules to support inferring ChangelogMode

[ https://issues.apache.org/jira/browse/FLINK-16887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16887: Description: Current retraction machanism only support 2 message kinds (+ and -). However, since

[GitHub] [flink] wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#discussion_r402739873 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#issuecomment-604493433 ## CI report: * 9e82da175780aa6a6ef19272a41c9a4796621e1a Travis:

[GitHub] [flink] wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#discussion_r402738678 ## File path:

[jira] [Commented] (FLINK-16794) ClassNotFoundException caused by ClassLoader.getSystemClassLoader using impertinently

[ https://issues.apache.org/jira/browse/FLINK-16794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074280#comment-17074280 ] victor.jiang commented on FLINK-16794: -- Hi Till Rohrmann, In our application scenario for

[GitHub] [flink] zhijiangW commented on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

zhijiangW commented on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#issuecomment-608230638 Thanks for the review @AHeise @rkhachatryan , and I have addressed all your comments.

[GitHub] [flink] flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#issuecomment-604493433 ## CI report: * 9e82da175780aa6a6ef19272a41c9a4796621e1a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * b709e1952df66cba5a316f9a46902538bf8cf245 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 5ad66720b750455263df2ccb345f46b298d62faa Travis:

[GitHub] [flink] docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#discussion_r402726288 ## File path:

[GitHub] [flink] docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#discussion_r402725215 ## File path:

[jira] [Resolved] (FLINK-16476) SelectivityEstimatorTest logs LinkageErrors

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16476. - Resolution: Fixed Fixed in mater (1.11.0) with 00526eba0f37f8869e62f41f43a40906e4169790 and

[GitHub] [flink] wuchong merged pull request #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest

wuchong merged pull request #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357 This is an automated message from

[GitHub] [flink] docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#discussion_r402722415 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 5ad66720b750455263df2ccb345f46b298d62faa Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * d20feb41f2e2940f6d6c8766586876addd3e2e92

[GitHub] [flink] flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#issuecomment-604493433 ## CI report: * d0d0b6fef21a118932e878255aa40f10f17fe753 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer

flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer URL: https://github.com/apache/flink/pull/11602#issuecomment-607241516 ## CI report: * 5dce0e57680a2e3b34f27ec2fac8ed7a59d00dbe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

flinkbot edited a comment on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619#issuecomment-607793023 ## CI report: * 68c82eef3469c403b1a0f8a64c13f04d989bf145 Travis:

[GitHub] [flink] docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#discussion_r402721904 ## File path:

[GitHub] [flink] docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#discussion_r402721935 ## File path:

[GitHub] [flink] wenlong88 commented on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

wenlong88 commented on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-608213838 @flinkbot run travis This is an automated message from the

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402721375 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402720894 ## File path:

[jira] [Commented] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074255#comment-17074255 ] YufeiLiu commented on FLINK-16938: -- It wasn't I want to use SqlTimestamp, because of blink-planner

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402719676 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402718999 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402719144 ## File path:

[jira] [Resolved] (FLINK-16885) SQL hive-connector wilcard excludes don't work on maven 3.1.X

[ https://issues.apache.org/jira/browse/FLINK-16885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16885. -- Resolution: Fixed master: 2b94ca60ca437df98d0efeb7b9a43ecdf216825b > SQL hive-connector

[GitHub] [flink] JingsongLi merged pull request #11620: [FLINK-16885][hive] Remove wilcard excludes that don't work on maven 3.1.X

JingsongLi merged pull request #11620: [FLINK-16885][hive] Remove wilcard excludes that don't work on maven 3.1.X URL: https://github.com/apache/flink/pull/11620 This is an automated message from the Apache Git Service. To

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402718422 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer

flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer URL: https://github.com/apache/flink/pull/11602#issuecomment-607241516 ## CI report: * 5dce0e57680a2e3b34f27ec2fac8ed7a59d00dbe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

flinkbot edited a comment on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619#issuecomment-607793023 ## CI report: * 68c82eef3469c403b1a0f8a64c13f04d989bf145 Travis:

[GitHub] [flink] JingsongLi commented on issue #11620: [FLINK-16885][hive] Remove wilcard excludes that don't work on maven 3.1.X

JingsongLi commented on issue #11620: [FLINK-16885][hive] Remove wilcard excludes that don't work on maven 3.1.X URL: https://github.com/apache/flink/pull/11620#issuecomment-608210790 Merged #11620 to master. Thanks @lirui-apache for the review.

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402718528 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint

flinkbot edited a comment on issue #11534: [FLINK-16537][network] Implement ResultPartition state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11534#issuecomment-604493433 ## CI report: * d0d0b6fef21a118932e878255aa40f10f17fe753 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * d20feb41f2e2940f6d6c8766586876addd3e2e92

[jira] [Commented] (FLINK-16949) Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

[ https://issues.apache.org/jira/browse/FLINK-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074248#comment-17074248 ] Jark Wu commented on FLINK-16949: - Thanks [~yunta], this approach sounds good to me. > Enhance

[jira] [Commented] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074243#comment-17074243 ] Jark Wu commented on FLINK-16938: - Regarding to the time attribute, yes, currently only TIMESTAMP(3) is

[GitHub] [flink] wangyang0918 commented on a change in pull request #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

wangyang0918 commented on a change in pull request #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619#discussion_r402715315 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -88,22 +86,43

[GitHub] [flink] xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

xintongsong commented on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-608203175 @azagrebin Thanks for the review. Comments addressed.

[GitHub] [flink] danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions

danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions URL: https://github.com/apache/flink/pull/11568#discussion_r402701406 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions

danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions URL: https://github.com/apache/flink/pull/11568#discussion_r402701101 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions

danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions URL: https://github.com/apache/flink/pull/11568#discussion_r402703105 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions

danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions URL: https://github.com/apache/flink/pull/11568#discussion_r402698067 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions

danny0405 commented on a change in pull request #11568: [FLINK-16779][table] Add RAW type support in DDL and functions URL: https://github.com/apache/flink/pull/11568#discussion_r402692226 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl

[GitHub] [flink] flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer

flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer URL: https://github.com/apache/flink/pull/11602#issuecomment-607241516 ## CI report: * 95f0deb44dfae1be800260732e47bf8ceaf9ef67 Travis:

[jira] [Created] (FLINK-16951) Integrate parquet to file system connector

Jingsong Lee created FLINK-16951: Summary: Integrate parquet to file system connector Key: FLINK-16951 URL: https://issues.apache.org/jira/browse/FLINK-16951 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074220#comment-17074220 ] Jark Wu edited comment on FLINK-16938 at 4/3/20, 2:34 AM: -- Hi [~liuyufei], I'm

[jira] [Commented] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074220#comment-17074220 ] Jark Wu commented on FLINK-16938: - Hi [~liuyufei], I'm interested why you want to use {{SqlTimestamp}} ?

[GitHub] [flink] flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer

flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer URL: https://github.com/apache/flink/pull/11602#issuecomment-607241516 ## CI report: * 95f0deb44dfae1be800260732e47bf8ceaf9ef67 Travis:

[GitHub] [flink] xintongsong commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

xintongsong commented on a change in pull request #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#discussion_r402691770 ## File path: flink-bash-java-utils/pom.xml

[GitHub] [flink] klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-608170820 Travis passed, Azure failed because of an irrelevant issue FLINK-16908

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074174#comment-17074174 ] Congxian Qiu(klion26) commented on FLINK-16908: --- another instance 

[GitHub] [flink] klion26 commented on issue #11614: [FLINK-16916][serialization] Fix the logic of NullableSerializer#copy

klion26 commented on issue #11614: [FLINK-16916][serialization] Fix the logic of NullableSerializer#copy URL: https://github.com/apache/flink/pull/11614#issuecomment-608168277 @aljoscha thanks for the review and merging.

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[jira] [Commented] (FLINK-16125) Make zookeeper.connect optional for Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-16125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074152#comment-17074152 ] Jiangjie Qin commented on FLINK-16125: -- Fixed on master: f93346c93c6a841cdce576d48a0b5ca8076cc195

[GitHub] [flink] becketqin commented on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation

becketqin commented on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation URL: https://github.com/apache/flink/pull/11425#issuecomment-608150214 @PatrickRen Thanks for the patch. LGTM. merged to master f93346c93c6a841cdce576d48a0b5ca8076cc195

[GitHub] [flink] becketqin closed pull request #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation

becketqin closed pull request #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation URL: https://github.com/apache/flink/pull/11425 This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-608048566 ## CI report: * 668797635ab529ea21ef234a1f99747cfb4d898a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-601593052 ## CI report: * 349f5d7bfd68016ba3595a17ff3a1533969581fb UNKNOWN *

[GitHub] [flink] TisonKun commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

TisonKun commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402631982 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402620783 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402618446 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402617148 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402616661 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

flinkbot edited a comment on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11473#issuecomment-602047938 ## CI report: * 93a7b2e30825316151be2f51c2126dc6b6051b66 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-608048566 ## CI report: * 668797635ab529ea21ef234a1f99747cfb4d898a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-607942457 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-601593052 ## CI report: * 349f5d7bfd68016ba3595a17ff3a1533969581fb UNKNOWN *

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402587643 ## File path:

[GitHub] [flink-statefun] sjwiesman commented on issue #94: [FLINK-16950][docs] Add Isolation level to

sjwiesman commented on issue #94: [FLINK-16950][docs] Add Isolation level to URL: https://github.com/apache/flink-statefun/pull/94#issuecomment-608081916 LGTM +1 This is an automated message from the Apache Git Service. To

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402588442 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

AHeise commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r402586336 ## File path:

[jira] [Commented] (FLINK-16666) Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074068#comment-17074068 ] Aljoscha Krettek commented on FLINK-1: -- I know that it can sometimes be annoying to come up

  1   2   3   4   5   6   7   8   >