[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/160752603) Azure: [FAILURE](https://de

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * 778239dfa00a84ab8457d49eedc759b601028676 Tr

[GitHub] [flink] dianfu commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dianfu commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616355772 It's a good idea to add description in the PR commit message and will do that. For this issue itself, I have already explained in the JIRA. Let me try to explain it in the PR again:

[GitHub] [flink] flinkbot commented on issue #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

flinkbot commented on issue #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-616355624 ## CI report: * 82b7e411419bbd8a1011bdc78e2a916dbc1256a7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] flinkbot edited a comment on issue #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on issue #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 2b64d49dac7f89d4abf600fda1d7beb5b34d3fc5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160982313) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11813: [FLINK-17249] Bump universal Kafka connector to Kafka 2.2.2

flinkbot edited a comment on issue #11813: URL: https://github.com/apache/flink/pull/11813#issuecomment-616239083 ## CI report: * 49a1530e3b0320a7053c977c2d36c1eed49245a2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160974132) Azure: [FAILURE](https://dev

[jira] [Assigned] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-16408: - Assignee: Till Rohrmann > Bind user code class loader to lifetime of a slot > -

[jira] [Commented] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-17189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087431#comment-17087431 ] Timo Walther commented on FLINK-17189: -- Hi [~lirui], yes, the {{TimestampKind}} i

[GitHub] [flink] dianfu edited a comment on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dianfu edited a comment on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616355772 It's a good idea to add description in the PR commit message and will do that. For this issue itself, I have already explained in the JIRA. Let me try to explain it in the PR aga

[jira] [Updated] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10

[ https://issues.apache.org/jira/browse/FLINK-16763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16763: --- Labels: pull-request-available (was: ) > Should not use BatchTableEnvironment for Python UD

[GitHub] [flink] hequn8128 opened a new pull request #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

hequn8128 opened a new pull request #11816: URL: https://github.com/apache/flink/pull/11816 ## What is the purpose of the change Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples since for flink-1.10, Python UDF is not supported in old planner unde

[GitHub] [flink] dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

dawidwys commented on a change in pull request #11692: URL: https://github.com/apache/flink/pull/11692#discussion_r411147490 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java ###

[GitHub] [flink] flinkbot commented on issue #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

flinkbot commented on issue #11816: URL: https://github.com/apache/flink/pull/11816#issuecomment-616359471 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 progress

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087435#comment-17087435 ] Wenlong Lyu commented on FLINK-17012: - hi, [~sewen] thanks for the explanation. but

[GitHub] [flink] twalthr commented on a change in pull request #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

twalthr commented on a change in pull request #11397: URL: https://github.com/apache/flink/pull/11397#discussion_r411152388 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -196,8 +196,12 @@ public void open() {

[GitHub] [flink] xintongsong commented on a change in pull request #11787: [FLINK-16746] Deprecate legacy heap memory option for JM and expose the new ones in docs

xintongsong commented on a change in pull request #11787: URL: https://github.com/apache/flink/pull/11787#discussion_r411148809 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -41,7 +41,7 @@ {:high-availability "zookeeper" :high-availability.

[GitHub] [flink] dawidwys commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

dawidwys commented on a change in pull request #11692: URL: https://github.com/apache/flink/pull/11692#discussion_r411153299 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/abilities/SupportsPartitioning.java ## @@ -0,0 +1,109 @

[GitHub] [flink] dawidwys commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616363030 I understood the underlying issue. I don't get though how this PR works around the issue. This is an automated messag

[GitHub] [flink] dawidwys edited a comment on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys edited a comment on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616363030 I understood the underlying issue. I don't get though how this PR works the issue around. This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/160752603) Azure: [FAILURE](https://de

[GitHub] [flink] dawidwys edited a comment on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys edited a comment on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616363030 I understood the underlying issue. I don't get though how this PR works the issue around. How do the adjustments make it less probable? ---

[GitHub] [flink] flinkbot commented on issue #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

flinkbot commented on issue #11816: URL: https://github.com/apache/flink/pull/11816#issuecomment-616363629 ## CI report: * 0ada8ce36bd618fa5e9c869ca6cf0e4c059dda92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[GitHub] [flink] flinkbot edited a comment on issue #11815: [FLINK-17253] Support viewfs for hadoop version < 2.7

flinkbot edited a comment on issue #11815: URL: https://github.com/apache/flink/pull/11815#issuecomment-616355624 ## CI report: * 82b7e411419bbd8a1011bdc78e2a916dbc1256a7 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/160984484) Azure: [PENDING](https://dev

[GitHub] [flink] KurtYoung commented on a change in pull request #11397: [FLINK-16217] [sql-client] catch all exceptions to avoid SQL client crashed

KurtYoung commented on a change in pull request #11397: URL: https://github.com/apache/flink/pull/11397#discussion_r411156938 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -196,8 +196,12 @@ public void open() {

[GitHub] [flink] twalthr commented on a change in pull request #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on a change in pull request #11692: URL: https://github.com/apache/flink/pull/11692#discussion_r411158004 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/source/abilities/PeriodicWatermarkAssignerProvider.java

[GitHub] [flink] GJL commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

GJL commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411148799 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategyTest.java ## @@ -0,0 +1,162 @@ +/* + *

[GitHub] [flink] hequn8128 commented on a change in pull request #11668: [FLINK-17013][python] Support Python UDTF in old planner under batch mode

hequn8128 commented on a change in pull request #11668: URL: https://github.com/apache/flink/pull/11668#discussion_r411152627 ## File path: flink-python/pyflink/table/tests/test_udtf.py ## @@ -41,44 +41,67 @@ def test_table_function(self): DataType

[jira] [Created] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

Xintong Song created FLINK-17257: Summary: AbstractYarnClusterTest does not compile with Hadoop 2.10 Key: FLINK-17257 URL: https://issues.apache.org/jira/browse/FLINK-17257 Project: Flink Iss

[jira] [Created] (FLINK-17258) Enable unaligned checkpoints in tests by default

Arvid Heise created FLINK-17258: --- Summary: Enable unaligned checkpoints in tests by default Key: FLINK-17258 URL: https://issues.apache.org/jira/browse/FLINK-17258 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-17259) Have scala 2.12 support

João Boto created FLINK-17259: - Summary: Have scala 2.12 support Key: FLINK-17259 URL: https://issues.apache.org/jira/browse/FLINK-17259 Project: Flink Issue Type: Improvement Component

[jira] [Assigned] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

[ https://issues.apache.org/jira/browse/FLINK-17257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17257: --- Assignee: Xintong Song > AbstractYarnClusterTest does not compile with Hadoop 2.10 > --

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087462#comment-17087462 ] Stephan Ewen commented on FLINK-17012: -- It is true that this needs a constructor wr

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * 778239dfa00a84ab8457d49eedc759b601028676 Tr

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087463#comment-17087463 ] Stephan Ewen commented on FLINK-17012: -- [~pnowojski] Given that you work on the Str

[GitHub] [flink] flinkbot edited a comment on issue #11785: [FLINK-17206][table] refactor function catalog to support delayed UDF initialization.

flinkbot edited a comment on issue #11785: URL: https://github.com/apache/flink/pull/11785#issuecomment-615087743 ## CI report: * 131d640159c9f367ef0d682b4616228d6bed939d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160979463) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11816: [FLINK-16763][python][doc] Replace BatchTableEnvironment with StreamTableEnvironment for Python UDF examples

flinkbot edited a comment on issue #11816: URL: https://github.com/apache/flink/pull/11816#issuecomment-616363629 ## CI report: * 0ada8ce36bd618fa5e9c869ca6cf0e4c059dda92 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/160986902) Bot commands

[GitHub] [flink] xintongsong opened a new pull request #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

xintongsong opened a new pull request #11817: URL: https://github.com/apache/flink/pull/11817 ## What is the purpose of the change In AbstractYarnClusterTest, we create ApplicationReport with the static method ApplicationReport.newInstance, which is annotated as private and unstable

[GitHub] [flink] xintongsong commented on issue #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

xintongsong commented on issue #11817: URL: https://github.com/apache/flink/pull/11817#issuecomment-616376921 cc @zhuzhurk This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10

[ https://issues.apache.org/jira/browse/FLINK-17257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17257: --- Labels: pull-request-available (was: ) > AbstractYarnClusterTest does not compile with Hado

[GitHub] [flink] zhuzhurk commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

zhuzhurk commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411170916 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategyTest.java ## @@ -0,0 +1,162 @@ +/

[GitHub] [flink] dawidwys commented on issue #11785: [FLINK-17206][table] refactor function catalog to support delayed UDF initialization.

dawidwys commented on issue #11785: URL: https://github.com/apache/flink/pull/11785#issuecomment-616377734 Hi @WeiZhong94 thank you for working on this. Personally I would choose a different approach in a couple of places. Let me describe how I see it. The ultimate goal is to have:

[jira] [Closed] (FLINK-13860) Flink Apache Kudu Connector

[ https://issues.apache.org/jira/browse/FLINK-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto closed FLINK-13860. - Resolution: Invalid > Flink Apache Kudu Connector > --- > > Key:

[GitHub] [flink] flinkbot commented on issue #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

flinkbot commented on issue #11817: URL: https://github.com/apache/flink/pull/11817#issuecomment-616377968 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 progress

[GitHub] [flink] zhuzhurk commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

zhuzhurk commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411171776 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingPipelinedRegion.java ## @@ -0,0 +1,61 @@ +/* + *

[GitHub] [flink] dawidwys removed a comment on issue #11785: [FLINK-17206][table] refactor function catalog to support delayed UDF initialization.

dawidwys removed a comment on issue #11785: URL: https://github.com/apache/flink/pull/11785#issuecomment-616377734 Hi @WeiZhong94 thank you for working on this. Personally I would choose a different approach in a couple of places. Let me describe how I see it. The ultimate goal is to

[jira] [Commented] (FLINK-11547) JsonMappingException in DynamoDBStreamsSchema

[ https://issues.apache.org/jira/browse/FLINK-11547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087466#comment-17087466 ] Jiawei Wu commented on FLINK-11547: --- +1 I have seen a similiar issue. The proposed fix

[jira] [Created] (FLINK-17260) StreamingKafkaITCase failure on Azure

Roman Khachatryan created FLINK-17260: - Summary: StreamingKafkaITCase failure on Azure Key: FLINK-17260 URL: https://issues.apache.org/jira/browse/FLINK-17260 Project: Flink Issue Type: B

[GitHub] [flink] zhuzhurk commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

zhuzhurk commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411173942 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingTopology.java ## @@ -78,6 +83,31 @@ public Testin

[GitHub] [flink] WeiZhong94 commented on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

WeiZhong94 commented on issue #11768: URL: https://github.com/apache/flink/pull/11768#issuecomment-616379782 @dianfu The documentation has been added in the latest commit, please take a look. This is an automated message fro

[jira] [Updated] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-17260: -- Description: [https://dev.azure.com/rmetzger/5bd3ef0a-4359-41af-abca-811b04098d2e/_api

[GitHub] [flink] rkhachatryan commented on issue #11754: [FLINK-17156][checkpointing] support cancellation of unaligned checkpoints

rkhachatryan commented on issue #11754: URL: https://github.com/apache/flink/pull/11754#issuecomment-616381588 > There is a test failure: https://dev.azure.com ... Created an issue for that https://issues.apache.org/jira/browse/FLINK-17260. Subsequent azure builds succeeded. ---

[jira] [Created] (FLINK-17261) Statefun docs broken

Chesnay Schepler created FLINK-17261: Summary: Statefun docs broken Key: FLINK-17261 URL: https://issues.apache.org/jira/browse/FLINK-17261 Project: Flink Issue Type: Bug Compon

[GitHub] [flink] zhuzhurk commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

zhuzhurk commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411177132 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingTopology.java ## @@ -78,6 +83,31 @@ public Testin

[jira] [Commented] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-17189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087472#comment-17087472 ] Rui Li commented on FLINK-17189: Hi [~twalthr], thanks for the explanations. Then I thin

[jira] [Created] (FLINK-17262) Statefun snapshot deployments broken

Chesnay Schepler created FLINK-17262: Summary: Statefun snapshot deployments broken Key: FLINK-17262 URL: https://issues.apache.org/jira/browse/FLINK-17262 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-17261) Statefun docs broken

[ https://issues.apache.org/jira/browse/FLINK-17261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17261: - Affects Version/s: (was: 2.1.0) (was: 2.0.0)

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

twalthr commented on a change in pull request #11568: URL: https://github.com/apache/flink/pull/11568#discussion_r411178550 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala ## @@ -484,6 +493,9 @@ o

[jira] [Updated] (FLINK-17262) Statefun snapshot deployments broken

[ https://issues.apache.org/jira/browse/FLINK-17262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17262: - Affects Version/s: (was: 2.1.0) (was: 2.0.0)

[GitHub] [flink] flinkbot edited a comment on issue #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on issue #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN * 2a47b5818c6bf072ab36f47130392f46a9bd4df8 Tr

[GitHub] [flink] flinkbot edited a comment on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

flinkbot edited a comment on issue #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * bd27b1b4dd97173d85bb0867f7c377ac4c638af5 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/156295604) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * 3ac7c714eacc6416b3dfbe163b4581d18e67de8d Travis: [FAILURE](https://travis-ci.com/github/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

flinkbot edited a comment on issue #11696: URL: https://github.com/apache/flink/pull/11696#issuecomment-611702183 ## CI report: * 10446262ad30a5f2a2a743065f1106d5242fead4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160726688) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

flinkbot edited a comment on issue #11768: URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552 ## CI report: * 01280e72a363ee72180dd385dc95e0013f60650f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160718616) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11784: [FLINK-17120][python] Add Cython support for operations

flinkbot edited a comment on issue #11784: URL: https://github.com/apache/flink/pull/11784#issuecomment-615011156 ## CI report: * 1ee639f83adcf607b722609782be88207de5fe49 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160666122) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot commented on issue #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

flinkbot commented on issue #11817: URL: https://github.com/apache/flink/pull/11817#issuecomment-616385883 ## CI report: * 19e4aa4ab7974adb5b771af4a9a51127c71e0bb4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run trav

[jira] [Commented] (FLINK-16478) add restApi to modify loglevel

[ https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087476#comment-17087476 ] xiaodao commented on FLINK-16478: - Hi [~felixzheng],[~fly_in_gis], i write a design doc,

[GitHub] [flink] dianfu commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dianfu commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616387332 There are two caches in RelDataTypeFactoryImpl: KEY2TYPE_CACHE and DATATYPE_CACHE. KEY2TYPE_CACHE caches the mapping of Key(consists of field names and field types, etc) to RelDataType

[jira] [Assigned] (FLINK-17261) Statefun docs broken

[ https://issues.apache.org/jira/browse/FLINK-17261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-17261: --- Assignee: Tzu-Li (Gordon) Tai > Statefun docs broken >

[jira] [Assigned] (FLINK-17261) Statefun docs broken

[ https://issues.apache.org/jira/browse/FLINK-17261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-17261: --- Assignee: (was: Tzu-Li (Gordon) Tai) > Statefun docs broken > -

[GitHub] [flink] zhuzhurk commented on a change in pull request #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

zhuzhurk commented on a change in pull request #11817: URL: https://github.com/apache/flink/pull/11817#discussion_r411183367 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/AbstractYarnClusterTest.java ## @@ -82,26 +83,21 @@ private ApplicationReport createApplica

[jira] [Commented] (FLINK-17261) Statefun docs broken

[ https://issues.apache.org/jira/browse/FLINK-17261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087478#comment-17087478 ] Tzu-Li (Gordon) Tai commented on FLINK-17261: - cc [~sjwiesman] seems to be c

[GitHub] [flink] zhuzhurk commented on a change in pull request #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

zhuzhurk commented on a change in pull request #11817: URL: https://github.com/apache/flink/pull/11817#discussion_r411183367 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/AbstractYarnClusterTest.java ## @@ -82,26 +83,21 @@ private ApplicationReport createApplica

[GitHub] [flink] twalthr commented on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

twalthr commented on issue #11692: URL: https://github.com/apache/flink/pull/11692#issuecomment-616388463 Thanks @dawidwys. I will merge this once the build is green. This is an automated message from the Apache Git Service.

[GitHub] [flink] becketqin commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

becketqin commented on a change in pull request #11554: URL: https://github.com/apache/flink/pull/11554#discussion_r410904702 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java ## @@ -0,0 +1,230 @@ +/* + Licensed to the

[GitHub] [flink] aljoscha commented on issue #11811: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

aljoscha commented on issue #11811: URL: https://github.com/apache/flink/pull/11811#issuecomment-616389339 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-17190) SQL client does not support views that reference a table from DDL

[ https://issues.apache.org/jira/browse/FLINK-17190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087479#comment-17087479 ] JinxinTang commented on FLINK-17190: Could you please provide version info and is it

[GitHub] [flink] rkhachatryan commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

rkhachatryan commented on issue #11802: URL: https://github.com/apache/flink/pull/11802#issuecomment-616389998 Thanks for testing it @KurtYoung! This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Assigned] (FLINK-17262) Statefun snapshot deployments broken

[ https://issues.apache.org/jira/browse/FLINK-17262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-17262: --- Assignee: Tzu-Li (Gordon) Tai > Statefun snapshot deployments broken >

[GitHub] [flink] rkhachatryan commented on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

rkhachatryan commented on issue #11802: URL: https://github.com/apache/flink/pull/11802#issuecomment-616391502 Azure failure is unrelated: https://issues.apache.org/jira/browse/FLINK-17205 Last push is a rebase onto the current master to get the fix.

[jira] [Assigned] (FLINK-17261) Statefun docs broken

[ https://issues.apache.org/jira/browse/FLINK-17261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-17261: --- Assignee: Tzu-Li (Gordon) Tai > Statefun docs broken >

[GitHub] [flink] twalthr commented on issue #11568: [FLINK-16779][table] Add RAW type support in DDL and functions

twalthr commented on issue #11568: URL: https://github.com/apache/flink/pull/11568#issuecomment-616393913 Having serde as part of a data type improves the usability a lot because we are hiding the complexity around this topic from users. A user must not care about serialization but can sim

[jira] [Commented] (FLINK-15331) Create a table from a changelog

[ https://issues.apache.org/jira/browse/FLINK-15331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087492#comment-17087492 ] Forward Xu commented on FLINK-15331: big +1, Thanks for firing this，[~twalthr] and [

[GitHub] [flink] alpinegizmo opened a new pull request #11818: [hotfix][docs] svg figure has overlapping text

alpinegizmo opened a new pull request #11818: URL: https://github.com/apache/flink/pull/11818 In this part of this svg figure, there's some misplaced text where it says "BucketingSink(path)": https://user-images.githubusercontent.com/43608/79730701-8054ed00-82f1-11ea-9d40-a7efff305ca

[GitHub] [flink] dawidwys commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dawidwys commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616394636 Thanks for the explanation @dianfu. Really helpful. Now I understand the change. Personally I don't have a better idea from the top of my head. Let's see what @danny0405 comes up with

[GitHub] [flink] dianfu commented on issue #11771: [FLINK-17135][python][tests] Fix the test testPandasFunctionMixedWithGeneralPythonFunction to make it more stable

dianfu commented on issue #11771: URL: https://github.com/apache/flink/pull/11771#issuecomment-616394631 May be we can revert the change of calcite-3149 in Flink? Does that makes sense for you? This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

flinkbot edited a comment on issue #11554: URL: https://github.com/apache/flink/pull/11554#issuecomment-605459909 ## CI report: * bd27b1b4dd97173d85bb0867f7c377ac4c638af5 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/156295604) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

flinkbot edited a comment on issue #11696: URL: https://github.com/apache/flink/pull/11696#issuecomment-611702183 ## CI report: * 10446262ad30a5f2a2a743065f1106d5242fead4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160726688) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11692: [FLINK-16992][table-common] Add all ability interfaces for table sources and sinks

flinkbot edited a comment on issue #11692: URL: https://github.com/apache/flink/pull/11692#issuecomment-611530487 ## CI report: * 4c854e0afe5cb934d919f37eb0891719063938ac Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/160752603) Azure: [FAILURE](https://de

[GitHub] [flink] flinkbot edited a comment on issue #11784: [FLINK-17120][python] Add Cython support for operations

flinkbot edited a comment on issue #11784: URL: https://github.com/apache/flink/pull/11784#issuecomment-615011156 ## CI report: * 1ee639f83adcf607b722609782be88207de5fe49 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160666122) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11768: [FLINK-16943][python] Support set the configuration option "pipeline.jars" in PyFlink.

flinkbot edited a comment on issue #11768: URL: https://github.com/apache/flink/pull/11768#issuecomment-614482552 ## CI report: * 01280e72a363ee72180dd385dc95e0013f60650f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160718616) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot edited a comment on issue #11727: URL: https://github.com/apache/flink/pull/11727#issuecomment-613273432 ## CI report: * fa5592cec0a6a5dcecc4f45c4bf72caf6e166eb4 UNKNOWN * 3ac7c714eacc6416b3dfbe163b4581d18e67de8d Travis: [FAILURE](https://travis-ci.com/github/flink-ci

[GitHub] [flink] flinkbot edited a comment on issue #11811: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

flinkbot edited a comment on issue #11811: URL: https://github.com/apache/flink/pull/11811#issuecomment-616107576 ## CI report: * 40bd2693a11d52097fd55b23173710f35965dcb7 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/160897124) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11802: [FLINK-17197][runtime] switch ContinuousFileReaderOperator state to FAILED on error

flinkbot edited a comment on issue #11802: URL: https://github.com/apache/flink/pull/11802#issuecomment-615431873 ## CI report: * 1f63e9f1b9f77c0b16ce16a743de535333ba7fff Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160783547) Azure: [FAILURE](https://dev

[GitHub] [flink] flinkbot edited a comment on issue #11817: [FLINK-17257][yarn][test] Fix AbstractYarnClusterTest not compiling with hadoop 2.10.

flinkbot edited a comment on issue #11817: URL: https://github.com/apache/flink/pull/11817#issuecomment-616385883 ## CI report: * 19e4aa4ab7974adb5b771af4a9a51127c71e0bb4 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/160993523) Azure: [PENDING](https://dev

[GitHub] [flink] flinkbot commented on issue #11818: [hotfix][docs] svg figure has overlapping text

flinkbot commented on issue #11818: URL: https://github.com/apache/flink/pull/11818#issuecomment-616396660 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 progress

[GitHub] [flink] KurtYoung commented on issue #10455: [FLINK-15089][connectors] Puslar catalog

KurtYoung commented on issue #10455: URL: https://github.com/apache/flink/pull/10455#issuecomment-616398922 Hi @yjshen , sorry for the late response on this. I think right now the community is busy with finishing 1.11 planned features thus don't have much capacity for reviewing this. I wou

[GitHub] [flink] wuchong commented on a change in pull request #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

wuchong commented on a change in pull request #11797: URL: https://github.com/apache/flink/pull/11797#discussion_r411198620 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowEmitStrategy.scala ## @@ -63,7 +63,7 @

[GitHub] [flink] GJL commented on a change in pull request #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

GJL commented on a change in pull request #11770: URL: https://github.com/apache/flink/pull/11770#discussion_r411198677 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedulingPipelinedRegion.java ## @@ -0,0 +1,61 @@ +/* + * Licen

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087501#comment-17087501 ] Chesnay Schepler commented on FLINK-16947: -- Maven 3.2.5 uses wagon-http 2.8 whi

[GitHub] [flink-statefun] tzulitai commented on issue #100: [FLINK-17060][docs] Replace "{flink}" with the Apache Flink trademark

tzulitai commented on issue #100: URL: https://github.com/apache/flink-statefun/pull/100#issuecomment-616400628 LGTM! Thanks for the fix @authuir. Merging this ... This is an automated message from the Apache Git Service.

  1   2   3   4   5   6   7   8   >