GitHub user suez1224 reopened a pull request:
https://github.com/apache/flink/pull/6201
[FLINK-8866][Table API & SQL] Add support for unified table sink
instantiation
**(The sections below can be removed for hotfixes of typos)**
## What is the purpose of the ch
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/6201
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200806113
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/PhysicalTableSourceScan.scala
---
@@ -39,9 +39,12 @@ abstract class
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200806045
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/FileSystem.scala
---
@@ -27,6 +28,8 @@ class FileSystem extends
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200805902
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -56,23 +58,44 @@ public Environment
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200805881
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -56,23 +58,44 @@ public Environment
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r199951101
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/6201
@twalthr @fhueske sounds good to me. We can do that in a follow-up issue
for `from-source`, and we will not support `from-source` in this PR.
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/6201
@fhueske @twalthr thanks for the comments. In `from-source`, the only
system i know of is Kafka10 or Kafka11, which support writing record along with
timestamp. To support `from-source` in table
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r199066851
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/MemoryTableSourceSinkUtil.scala
---
@@ -0,0 +1,151
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r199066578
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java
---
@@ -321,6 +327,18 @@ public
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r199065915
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java
---
@@ -321,6 +327,18 @@ public
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/6201
@twalthr , for sink only table, I dont think the user need to define any
rowtimes on it, since it will never use as a source. For table as both source
and sink, when registering it as sink, I think
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198678147
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/connector/TableSinkFactoryServiceTest.scala
---
@@ -0,0 +1,84
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198677922
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198677762
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r198677754
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/connector/TableConnectorFactory.scala
---
@@ -16,21 +16,18
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/6201
[FLINK-8866][Table API & SQL] Add support for unified table sink
instantiation
**(The sections below can be removed for hotfixes of typos)**
## What is the purpose of the ch
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6121#discussion_r193637621
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/validation/ScalarFunctionsValidationTest.scala
---
@@ -98,16
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6082#discussion_r192955182
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java
---
@@ -73,9 +75,37 @@ private
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/6082
Thanks for the PR, @tragicjun. I will take a look in the next few days.
---
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/6100
[FLINK-9430][Table API & SQL] add cast rule in SQL to cast Object to other
assignable types
## What is the purpose of the change
Add cast rule in SQL to cast Object to o
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5306
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5306
@zentol , you are right, https://issues.apache.org/jira/browse/FLINK-8286
already did the removal.
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189167881
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189144224
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189144701
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189144263
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/util/ExplodeFunctionUtil.scala
---
@@ -18,74 +18,244
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5619#discussion_r189145367
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/AggregateITCase.scala
---
@@ -367,6 +367,36 @@ class
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r188786194
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSource.java
---
@@ -81,7
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6026#discussion_r188786307
--- Diff:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
@@ -110,6 +116,8 @@ private void
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5896
@aljoscha that's a very good catch. I added another commit to make sure the
call order is always correct
(https://github.com/apache/flink/pull/5896/commits/1298b04ea80b9160ac7e4ae8a171f80112a95945
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5901#discussion_r186298337
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -85,54 +88,75 @@ public void
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5896#discussion_r185606093
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunnerFactory.java
---
@@ -73,61 +105,68 @@ public static void main(String[] args
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5896#discussion_r185134529
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunnerFactory.java
---
@@ -73,61 +105,68 @@ public static void main(String[] args
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5896#discussion_r185135031
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunnerFactory.java
---
@@ -73,61 +105,68 @@ public static void main(String[] args
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5913#discussion_r184872369
--- Diff: docs/dev/table/sqlClient.md ---
@@ -0,0 +1,539 @@
+---
+title: "SQL Client"
+nav-parent_id: tableapi
+nav-pos: 100
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5940#discussion_r184866337
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonAggregate.scala
---
@@ -49,11 +49,16 @@ trait CommonAggregate
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5940#discussion_r184866214
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalAggregate.scala
---
@@ -82,7 +82,7 @@ private
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5901
[FLINK-9235][Security] Add integration tests for YARN kerberos integration.
## What is the purpose of the change
Add integration tests for YARN kerberos integration.
## Brief
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5896
[FLINK-8286][Security] Fix kerberos security configuration for
YarnTaskExecutor
## What is the purpose of the change
Fix broken YARN kerberos integration for flip-6
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5895
Fix kerberos security configuration for YarnTaskExecutor
## What is the purpose of the change
Fix broken YARN kerberos integration for flip-6.
## Brief change log
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5895
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5867#discussion_r182650740
--- Diff: flink-libraries/flink-sql-client/bin/sql-client.sh ---
@@ -44,20 +44,32 @@ bin=`dirname "$target"`
. "
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5867
Hi @twalthr ,
IMO, it's better to seperate the configuration of SQL client from the
configuration of the Flink job. From the user's perspective, many of them
probably do not need to know
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179686465
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r179686471
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75
GitHub user suez1224 reopened a pull request:
https://github.com/apache/flink/pull/5758
[FLINK-9059][Table API & SQL] add table type attribute; replace "sources"
with "tables" in environmâ¦
## What is the purpose of the change
Add support for unifi
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5758
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5688
Could you please rebase your pr to resolve conflict? Thanks.
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178330131
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/TableDescriptor.scala
---
@@ -0,0 +1,75
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178244750
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -102,10 +112,10 @@ public static
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5758#discussion_r178244473
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -29,38 +30,47
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5792
---
GitHub user suez1224 reopened a pull request:
https://github.com/apache/flink/pull/5792
[Flink-8563][Table API & SQL] add unittest for consecutive dot access of
composite array element in SQL
## What is the purpose of the change
add unittest for consecutive dot ac
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5792
retry build
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5791
Close and reopen to trigger travis.
SavepointITCase.testSavepointForJobWithIteration is unstable.
---
GitHub user suez1224 reopened a pull request:
https://github.com/apache/flink/pull/5791
[FLINK-8507][Table API & SQL] upgrade calcite dependency to 1.16
## What is the purpose of the change
Upgrade Flink table's Calcite dependency to 1.16.
## B
Github user suez1224 closed the pull request at:
https://github.com/apache/flink/pull/5791
---
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5794
[Flink-8509][Table API & SQL] Remove SqlGroupedWindowFunction copy from
flink
## What is the purpose of the change
Remove SqlGroupedWindowFunction copy from flink. This dep
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5793
[Flink-8508][Table API & SQL] Remove RexSimplify copy from flink
## What is the purpose of the change
Remove RexSimplify copy from flink. This depends on
https://github.com/ap
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5792
[Flink-8563][Table API & SQL] add unittest for consecutive dot access of
composite array element in SQL
## What is the purpose of the change
add unittest for consecutive dot ac
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5791
[FLINK-8507][Table API & SQL] upgrade calcite dependency to 1.16
## What is the purpose of the change
Upgrade Flink table's Calcite dependency to 1.16.
## Brief ch
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5758
[FLINK-9059][Table API & SQL] add table type attribute; replace "sources"
with "tables" in environmâ¦
## What is the purpose of the change
Add support for unifi
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5416
@tillrohrmann addressed your comments. PTAL.
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176231789
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -465,27 +514,23 @@ private static void start(YarnConfiguration conf
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176230467
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -106,8 +106,16 @@ public void testDetachedMode() throws
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176209369
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -105,7 +105,7 @@ public void testDetachedMode() throws
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176209223
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -515,28 +514,23 @@ private static void start(YarnConfiguration conf
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r176209172
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -465,27 +514,23 @@ private static void start(YarnConfiguration conf
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r175677410
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -105,7 +105,7 @@ public void testDetachedMode() throws
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5416
@tillrohrmann what signal should I wait for? I can address the flip6 mode
test in the end-to--end test JIRA
https://issues.apache.org/jira/browse/FLINK-8981. What do you think?
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r175672004
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -206,7 +209,7 @@ public void checkClusterEmpty() throws IOException
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5416
Also, I've disabled the test for flip6 mode in order to make the test pass.
Can you explain a bit on why this code block
(https://github.com/apache/flink/blob
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5416
Thanks a lot, @tillrohrmann, for looking into the PR. I've rebased and
addressed your comment. Please take another look.
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r175342198
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -379,6 +382,50 @@ public boolean accept(File dir, String name
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r175341644
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ---
@@ -206,7 +209,7 @@ public void checkClusterEmpty() throws IOException
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r175325407
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java
---
@@ -97,6 +98,15 @@ public static void
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5416#discussion_r175325243
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -105,7 +105,7 @@ public void testDetachedMode() throws
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r175183811
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala
---
@@ -103,6 +106,19
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r174962566
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/calcite/rel/rules/AggregateReduceFunctionsRule.java
---
@@ -0,0 +1,590
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5706#discussion_r174965171
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalWindowAggregate.scala
---
@@ -103,6 +106,19
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5638
The PR looks good. Could you please add documentation in
docs/dev/table/tableApi.md for both java and scala? Thanks.
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5272
Thanks a lot, @fhueske, I'll do that next time.
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5272
@fhueske can you help take another look? Thanks.
---
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168338536
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java
---
@@ -95,15
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168330940
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java
---
@@ -0,0
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168331011
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java
---
@@ -37,11
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168330917
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java
---
@@ -0,0
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168330890
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5272#discussion_r168330869
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5274
@tillrohrmann , can you help take another look?
---
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5472
[FLINK-7658][Table API & SQL] support Collect aggregate function in Table
API
## What is the purpose of the change
Add Collect aggregate function for Table API.
## B
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5172
It's already merged to master, and should be available in Flink 1.4.1.
On Wed, Feb 7, 2018 at 11:11 PM, toggm <notificati...@github.com> wrote:
> What happended with thi
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5416
[FLINK-8562] [Security] Fix YARNSessionFIFOSecuredITCase
## What is the purpose of the change
Fix YARNSessionFIFOSecuredITCase. It's currently broken.
## Brief change log
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5172
@tzulitai thanks a lot for the refactoring, the commit looks good to me.
---
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5367
@hequn8128 @twalthr could you please take another look? I've refactored the
code to reuse the generateFieldAccess() code, also added null test. Nested
tuple wont work now due to https
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5367#discussion_r165560261
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/CalcTest.scala
---
@@ -0,0 +1,47 @@
+/*
+ * Licensed
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5367#discussion_r165560235
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -984,6 +987,63 @@ object
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5367#discussion_r165527528
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -984,6 +987,63 @@ object
1 - 100 of 170 matches
Mail list logo
